Uses of Interface
org.agrona.concurrent.AtomicBuffer
Packages that use AtomicBuffer
Package
Description
Concurrent data structures and utilities that support both on and off Java heap usage.
Data structure for broadcasting messages from one source to many receivers via shared memory.
A logger which provides a summary of distinct stacktrace based errors with counts and times.
IPC ring buffers for messaging via shared memory.
Counters for indicating status and telemetry which can be put in shared memory for live inspection.
-
Uses of AtomicBuffer in org.agrona.concurrent
Classes in org.agrona.concurrent that implement AtomicBufferModifier and TypeClassDescriptionclassSupports regular, byte ordered, and atomic (memory ordered) access to an underlying buffer. -
Uses of AtomicBuffer in org.agrona.concurrent.broadcast
Constructors in org.agrona.concurrent.broadcast with parameters of type AtomicBufferModifierConstructorDescriptionBroadcastReceiver(AtomicBuffer buffer) Construct a new broadcast receiver based on an underlyingAtomicBuffer.BroadcastTransmitter(AtomicBuffer buffer) Construct a new broadcast transmitter based on an underlyingAtomicBuffer. -
Uses of AtomicBuffer in org.agrona.concurrent.errors
Methods in org.agrona.concurrent.errors that return AtomicBufferMethods in org.agrona.concurrent.errors with parameters of type AtomicBufferModifier and TypeMethodDescriptionstatic booleanErrorLogReader.hasErrors(AtomicBuffer buffer) Has the error buffer any recorded errors?static intErrorLogReader.read(AtomicBuffer buffer, ErrorConsumer consumer) Read all the errors in a log since the creation of the log.static intErrorLogReader.read(AtomicBuffer buffer, ErrorConsumer consumer, long sinceTimestamp) Read all the errors in a log since a given timestamp.Constructors in org.agrona.concurrent.errors with parameters of type AtomicBufferModifierConstructorDescriptionDistinctErrorLog(AtomicBuffer buffer, EpochClock clock) Create a new error log that will be written to a providedAtomicBuffer.DistinctErrorLog(AtomicBuffer buffer, EpochClock clock, Charset charset) Create a new error log that will be written to a providedAtomicBuffer. -
Uses of AtomicBuffer in org.agrona.concurrent.ringbuffer
Methods in org.agrona.concurrent.ringbuffer that return AtomicBufferModifier and TypeMethodDescriptionManyToOneRingBuffer.buffer()Get the underlying buffer used by the RingBuffer for storage.OneToOneRingBuffer.buffer()Get the underlying buffer used by the RingBuffer for storage.RingBuffer.buffer()Get the underlying buffer used by the RingBuffer for storage.Constructors in org.agrona.concurrent.ringbuffer with parameters of type AtomicBufferModifierConstructorDescriptionManyToOneRingBuffer(AtomicBuffer buffer) Construct a newRingBufferbased on an underlyingAtomicBuffer.OneToOneRingBuffer(AtomicBuffer buffer) Construct a newRingBufferbased on an underlyingAtomicBuffer. -
Uses of AtomicBuffer in org.agrona.concurrent.status
Fields in org.agrona.concurrent.status declared as AtomicBufferModifier and TypeFieldDescriptionprotected final AtomicBufferCountersReader.metaDataBufferMeta-data buffer.protected final AtomicBufferCountersReader.valuesBufferValues buffer.Methods in org.agrona.concurrent.status that return AtomicBufferModifier and TypeMethodDescriptionCountersReader.metaDataBuffer()Get the buffer containing the metadata for the counters.CountersReader.valuesBuffer()Get the buffer containing the values for the counters.Constructors in org.agrona.concurrent.status with parameters of type AtomicBufferModifierConstructorDescriptionAtomicCounter(AtomicBuffer buffer, int counterId) Map a counter over a buffer.AtomicCounter(AtomicBuffer buffer, int counterId, CountersManager countersManager) Map a counter over a buffer.ConcurrentCountersManager(AtomicBuffer metaDataBuffer, AtomicBuffer valuesBuffer) Construct a counter manager over buffers containing the values and associated metadata.ConcurrentCountersManager(AtomicBuffer metaDataBuffer, AtomicBuffer valuesBuffer, Charset labelCharset) Construct a counter manager over buffers containing the values and associated metadata.ConcurrentCountersManager(AtomicBuffer metaDataBuffer, AtomicBuffer valuesBuffer, Charset labelCharset, EpochClock epochClock, long freeToReuseTimeoutMs) Create a new counter manager over buffers containing the values and associated metadata.CountersManager(AtomicBuffer metaDataBuffer, AtomicBuffer valuesBuffer) Create a new counter manager over two buffers.CountersManager(AtomicBuffer metaDataBuffer, AtomicBuffer valuesBuffer, Charset labelCharset) Create a new counter manager over two buffers.CountersManager(AtomicBuffer metaDataBuffer, AtomicBuffer valuesBuffer, Charset labelCharset, EpochClock epochClock, long freeToReuseTimeoutMs) Create a new counter manager over two buffers.CountersReader(AtomicBuffer metaDataBuffer, AtomicBuffer valuesBuffer) Construct a reader over buffers containing the values and associated metadata.CountersReader(AtomicBuffer metaDataBuffer, AtomicBuffer valuesBuffer, Charset labelCharset) Construct a reader over buffers containing the values and associated metadata.UnsafeBufferStatusIndicator(AtomicBuffer buffer, int counterId) Map a status indicator over a buffer.