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 AtomicBuffer
BroadcastReceiver. buffer
private 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 Constructor Description BroadcastReceiver(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 AtomicBuffer Modifier and Type Field Description private 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 Constructor Description DistinctErrorLog(AtomicBuffer buffer, EpochClock clock)
Create a new error log that will be written to a providedAtomicBuffer
.DistinctErrorLog(AtomicBuffer buffer, EpochClock clock, java.nio.charset.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 AtomicBuffer Modifier and Type Field Description private AtomicBuffer
ManyToOneRingBuffer. buffer
private 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 Constructor Description ManyToOneRingBuffer(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 AtomicBuffer Modifier and Type Field Description protected AtomicBuffer
CountersReader. metaDataBuffer
Meta-data buffer.protected 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 java.lang.String
CountersReader. labelValue(AtomicBuffer metaDataBuffer, int recordOffset)
Constructors in org.agrona.concurrent.status with parameters of type AtomicBuffer 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, java.nio.charset.Charset labelCharset)
Construct a counter manager over buffers containing the values and associated metadata.ConcurrentCountersManager(AtomicBuffer metaDataBuffer, AtomicBuffer valuesBuffer, java.nio.charset.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, java.nio.charset.Charset labelCharset)
Create a new counter manager over two buffers.CountersManager(AtomicBuffer metaDataBuffer, AtomicBuffer valuesBuffer, java.nio.charset.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, java.nio.charset.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.
-