Uses of Interface
org.agrona.MutableDirectBuffer
-
Packages that use MutableDirectBuffer Package Description org.agrona Data structures and utilities useful for building high-performance Java applications.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.status Counters for indicating status and telemetry which can be put in shared memory for live inspection.org.agrona.io Bridging classes for allowing direct buffers implementations ofDirectBuffer
andMutableDirectBuffer
to be used with Java IO streams.org.agrona.sbe Common interfaces which can apply to SBE messages to support abstract usage. -
-
Uses of MutableDirectBuffer in org.agrona
Classes in org.agrona that implement MutableDirectBuffer Modifier and Type Class Description class
AbstractMutableDirectBuffer
Common super class for implementingMutableDirectBuffer
interface.class
ExpandableArrayBuffer
ExpandableMutableDirectBuffer
that is backed by an array.class
ExpandableDirectByteBuffer
ExpandableMutableDirectBuffer
that is backed by a directByteBuffer
.Methods in org.agrona with parameters of type MutableDirectBuffer Modifier and Type Method Description void
AbstractMutableDirectBuffer. getBytes(int index, MutableDirectBuffer dstBuffer, int dstIndex, int length)
Get bytes from thisDirectBuffer
into the providedMutableDirectBuffer
at given indices.int
AsciiSequenceView. getBytes(MutableDirectBuffer dstBuffer, int dstOffset)
Copy the bytes from a view into a provided buffer.void
DirectBuffer. getBytes(int index, MutableDirectBuffer dstBuffer, int dstIndex, int length)
Get bytes from thisDirectBuffer
into the providedMutableDirectBuffer
at given indices.boolean
ExpandableRingBuffer.MessageConsumer. onMessage(MutableDirectBuffer buffer, int offset, int length, int headOffset)
Called for the processing of each message from a buffer in turn. -
Uses of MutableDirectBuffer in org.agrona.concurrent
Subinterfaces of MutableDirectBuffer in org.agrona.concurrent Modifier and Type Interface Description interface
AtomicBuffer
Abstraction over a range of buffer types that allows type to be accessed with memory ordering semantics.Classes in org.agrona.concurrent that implement MutableDirectBuffer Modifier and Type Class Description class
UnsafeBuffer
Supports regular, byte ordered, and atomic (memory ordered) access to an underlying buffer.Methods in org.agrona.concurrent with parameters of type MutableDirectBuffer Modifier and Type Method Description ControlledMessageHandler.Action
ControlledMessageHandler. onMessage(int msgTypeId, MutableDirectBuffer buffer, int index, int length)
Called for the processing of each message read from a buffer in turn.void
MessageHandler. onMessage(int msgTypeId, MutableDirectBuffer buffer, int index, int length)
Called for the processing of each message read from a buffer in turn. -
Uses of MutableDirectBuffer in org.agrona.concurrent.broadcast
Fields in org.agrona.concurrent.broadcast declared as MutableDirectBuffer Modifier and Type Field Description private MutableDirectBuffer
CopyBroadcastReceiver. scratchBuffer
Methods in org.agrona.concurrent.broadcast that return MutableDirectBuffer Modifier and Type Method Description MutableDirectBuffer
BroadcastReceiver. buffer()
The underlying buffer containing the broadcast message stream.Constructors in org.agrona.concurrent.broadcast with parameters of type MutableDirectBuffer Constructor Description CopyBroadcastReceiver(BroadcastReceiver receiver, MutableDirectBuffer scratchBuffer)
Wrap aBroadcastReceiver
to simplify the API for receiving messages. -
Uses of MutableDirectBuffer in org.agrona.concurrent.status
Method parameters in org.agrona.concurrent.status with type arguments of type MutableDirectBuffer Modifier and Type Method Description int
ConcurrentCountersManager. allocate(java.lang.String label, int typeId, java.util.function.Consumer<MutableDirectBuffer> keyFunc)
Allocate a new counter with a given label.int
CountersManager. allocate(java.lang.String label, int typeId, java.util.function.Consumer<MutableDirectBuffer> keyFunc)
Allocate a new counter with a given label.AtomicCounter
CountersManager. newCounter(java.lang.String label, int typeId, java.util.function.Consumer<MutableDirectBuffer> keyFunc)
Allocate a counter record and wrap it with a newAtomicCounter
for use.void
ConcurrentCountersManager. setCounterKey(int counterId, java.util.function.Consumer<MutableDirectBuffer> keyFunc)
Set anAtomicCounter
key by on counter id, using a consumer callback to update the key metadata buffer.void
CountersManager. setCounterKey(int counterId, java.util.function.Consumer<MutableDirectBuffer> keyFunc)
Set anAtomicCounter
key by on counter id, using a consumer callback to update the key metadata buffer.void
AtomicCounter. updateKey(java.util.function.Consumer<MutableDirectBuffer> keyFunc)
Update the key for a counter constructed with aCountersManager
. -
Uses of MutableDirectBuffer in org.agrona.io
Fields in org.agrona.io declared as MutableDirectBuffer Modifier and Type Field Description private MutableDirectBuffer
DirectBufferOutputStream. buffer
private MutableDirectBuffer
ExpandableDirectBufferOutputStream. buffer
Methods in org.agrona.io that return MutableDirectBuffer Modifier and Type Method Description MutableDirectBuffer
DirectBufferOutputStream. buffer()
The underlying buffer being wrapped.MutableDirectBuffer
ExpandableDirectBufferOutputStream. buffer()
The underlying buffer being wrapped.Methods in org.agrona.io with parameters of type MutableDirectBuffer Modifier and Type Method Description void
DirectBufferOutputStream. wrap(MutableDirectBuffer buffer)
Wrap the buffer.void
DirectBufferOutputStream. wrap(MutableDirectBuffer buffer, int offset, int length)
Wrap the buffer at an offset.void
ExpandableDirectBufferOutputStream. wrap(MutableDirectBuffer buffer)
Wrap a given buffer beginning with an offset of 0.void
ExpandableDirectBufferOutputStream. wrap(MutableDirectBuffer buffer, int offset)
Wrap a given buffer beginning at an offset.Constructors in org.agrona.io with parameters of type MutableDirectBuffer Constructor Description DirectBufferOutputStream(MutableDirectBuffer buffer)
Constructs output stream wrapping the given buffer.DirectBufferOutputStream(MutableDirectBuffer buffer, int offset, int length)
Constructs output stream wrapping the given buffer at an offset.ExpandableDirectBufferOutputStream(MutableDirectBuffer buffer)
Wrap givenMutableDirectBuffer
.ExpandableDirectBufferOutputStream(MutableDirectBuffer buffer, int offset)
Wrap givenMutableDirectBuffer
at a given offset. -
Uses of MutableDirectBuffer in org.agrona.sbe
Methods in org.agrona.sbe that return MutableDirectBuffer Modifier and Type Method Description MutableDirectBuffer
EncoderFlyweight. buffer()
Buffer in which the flyweight is encoded.Methods in org.agrona.sbe with parameters of type MutableDirectBuffer Modifier and Type Method Description EncoderFlyweight
EncoderFlyweight. wrap(MutableDirectBuffer buffer, int offset)
Wrap a buffer for encoding at a given offset.
-