Uses of Interface
org.agrona.concurrent.AtomicBuffer

Packages that use AtomicBuffer

Package	Description
org.agrona.concurrent	Concurrent data structures and utilities that support both on and off Java heap usage.
org.agrona.concurrent.broadcast	Data structure for broadcasting messages from one source to many receivers via shared memory.
org.agrona.concurrent.errors	A logger which provides a summary of distinct stacktrace based errors with counts and times.
org.agrona.concurrent.ringbuffer	IPC ring buffers for messaging via shared memory.
org.agrona.concurrent.status	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 AtomicBuffer

Modifier and Type	Class	Description
class	UnsafeBuffer	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 AtomicBuffer

Modifier and Type	Field	Description
private final AtomicBuffer	BroadcastReceiver.buffer
private final AtomicBuffer	BroadcastTransmitter.buffer

Methods in org.agrona.concurrent.broadcast with parameters of type AtomicBuffer

Modifier and Type	Method	Description
private 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 AtomicBuffer

Modifier	Constructor	Description
	BroadcastReceiver(AtomicBuffer buffer)	Construct a new broadcast receiver based on an underlying AtomicBuffer.
	BroadcastTransmitter(AtomicBuffer buffer)	Construct a new broadcast transmitter based on an underlying AtomicBuffer.

Uses of AtomicBuffer in org.agrona.concurrent.errors

Fields in org.agrona.concurrent.errors declared as AtomicBuffer

Modifier and Type	Field	Description
private final AtomicBuffer	DistinctErrorLog.buffer

Methods in org.agrona.concurrent.errors that return AtomicBuffer

Modifier and Type	Method	Description
AtomicBuffer	DistinctErrorLog.buffer()	Buffer the error log is written to.

Methods in org.agrona.concurrent.errors with parameters of type AtomicBuffer

Modifier and Type	Method	Description
static 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 AtomicBuffer

Modifier	Constructor	Description
	DistinctErrorLog(AtomicBuffer buffer, EpochClock clock)	Create a new error log that will be written to a provided AtomicBuffer.
	DistinctErrorLog(AtomicBuffer buffer, EpochClock clock, Charset charset)	Create a new error log that will be written to a provided AtomicBuffer.

Uses of AtomicBuffer in org.agrona.concurrent.ringbuffer

Fields in org.agrona.concurrent.ringbuffer declared as AtomicBuffer

Modifier and Type	Field	Description
private final AtomicBuffer	ManyToOneRingBuffer.buffer
private final AtomicBuffer	OneToOneRingBuffer.buffer

Methods in org.agrona.concurrent.ringbuffer that return AtomicBuffer

Modifier and Type	Method	Description
AtomicBuffer	ManyToOneRingBuffer.buffer()	Get the underlying buffer used by the RingBuffer for storage.
AtomicBuffer	OneToOneRingBuffer.buffer()	Get the underlying buffer used by the RingBuffer for storage.
AtomicBuffer	RingBuffer.buffer()	Get the underlying buffer used by the RingBuffer for storage.

Methods in org.agrona.concurrent.ringbuffer with parameters of type AtomicBuffer

Modifier and Type	Method	Description
private 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 AtomicBuffer

Modifier	Constructor	Description
	ManyToOneRingBuffer(AtomicBuffer buffer)	Construct a new RingBuffer based on an underlying AtomicBuffer.
	OneToOneRingBuffer(AtomicBuffer buffer)	Construct a new RingBuffer based on an underlying AtomicBuffer.

Uses of AtomicBuffer in org.agrona.concurrent.status

Fields in org.agrona.concurrent.status declared as AtomicBuffer

Modifier and Type	Field	Description
protected final AtomicBuffer	CountersReader.metaDataBuffer	Meta-data buffer.
protected final AtomicBuffer	CountersReader.valuesBuffer	Values buffer.

Methods in org.agrona.concurrent.status that return AtomicBuffer

Modifier and Type	Method	Description
AtomicBuffer	CountersReader.metaDataBuffer()	Get the buffer containing the metadata for the counters.
AtomicBuffer	CountersReader.valuesBuffer()	Get the buffer containing the values for the counters.

Methods in org.agrona.concurrent.status with parameters of type AtomicBuffer

Modifier and Type	Method	Description
private String	CountersReader.labelValue(AtomicBuffer metaDataBuffer, int recordOffset)

Constructors in org.agrona.concurrent.status with parameters of type AtomicBuffer

Modifier	Constructor	Description
	AtomicCounter(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.