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 TypeClassDescriptionclass
Supports regular, byte ordered, and atomic (memory ordered) access to an underlying buffer. -
Uses of AtomicBuffer in org.agrona.concurrent.broadcast
Fields in org.agrona.concurrent.broadcast declared as AtomicBufferModifier and TypeFieldDescriptionprivate final AtomicBuffer
BroadcastReceiver.buffer
private final AtomicBuffer
BroadcastTransmitter.buffer
Methods in org.agrona.concurrent.broadcast with parameters of type AtomicBufferModifier and TypeMethodDescriptionprivate static void
BroadcastTransmitter.insertPaddingRecord
(AtomicBuffer buffer, int recordOffset, int length) private void
BroadcastTransmitter.signalTailIntent
(AtomicBuffer buffer, long newTail) private boolean
BroadcastReceiver.validate
(long cursor, AtomicBuffer buffer, int capacity) 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
Fields in org.agrona.concurrent.errors declared as AtomicBufferMethods in org.agrona.concurrent.errors that return AtomicBufferMethods in org.agrona.concurrent.errors with parameters of type AtomicBufferModifier and TypeMethodDescriptionstatic boolean
ErrorLogReader.hasErrors
(AtomicBuffer buffer) Has the error buffer any recorded errors?static int
ErrorLogReader.read
(AtomicBuffer buffer, ErrorConsumer consumer) Read all the errors in a log since the creation of the log.static int
ErrorLogReader.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
Fields in org.agrona.concurrent.ringbuffer declared as AtomicBufferModifier and TypeFieldDescriptionprivate final AtomicBuffer
ManyToOneRingBuffer.buffer
private final AtomicBuffer
OneToOneRingBuffer.buffer
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.Methods in org.agrona.concurrent.ringbuffer with parameters of type AtomicBufferModifier and TypeMethodDescriptionprivate int
ManyToOneRingBuffer.claimCapacity
(AtomicBuffer buffer, int recordLength) private int
OneToOneRingBuffer.claimCapacity
(AtomicBuffer buffer, int recordLength) private static boolean
ManyToOneRingBuffer.scanBackToConfirmStillZeroed
(AtomicBuffer buffer, int from, int limit) private int
ManyToOneRingBuffer.verifyClaimedSpaceNotReleased
(AtomicBuffer buffer, int recordIndex) private int
OneToOneRingBuffer.verifyClaimedSpaceNotReleased
(AtomicBuffer buffer, int recordIndex) Constructors in org.agrona.concurrent.ringbuffer with parameters of type AtomicBufferModifierConstructorDescriptionManyToOneRingBuffer
(AtomicBuffer buffer) Construct a newRingBuffer
based on an underlyingAtomicBuffer
.OneToOneRingBuffer
(AtomicBuffer buffer) Construct a newRingBuffer
based on an underlyingAtomicBuffer
. -
Uses of AtomicBuffer in org.agrona.concurrent.status
Fields in org.agrona.concurrent.status declared as AtomicBufferModifier and TypeFieldDescriptionprotected final AtomicBuffer
CountersReader.metaDataBuffer
Meta-data buffer.protected final AtomicBuffer
CountersReader.valuesBuffer
Values 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.Methods in org.agrona.concurrent.status with parameters of type AtomicBufferModifier and TypeMethodDescriptionprivate String
CountersReader.labelValue
(AtomicBuffer metaDataBuffer, int recordOffset) 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.