Uses of Interface
org.agrona.MutableDirectBuffer
Packages that use MutableDirectBuffer
Package
Description
Data structures and utilities useful for building high-performance Java applications.
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.
Counters for indicating status and telemetry which can be put in shared memory for live inspection.
Bridging classes for allowing direct buffers implementations of
DirectBuffer
and
MutableDirectBuffer
to be used with Java IO streams.Common interfaces which can apply to SBE messages to support abstract usage.
-
Uses of MutableDirectBuffer in org.agrona
Classes in org.agrona that implement MutableDirectBufferModifier and TypeClassDescriptionclass
Common base class for implementingMutableDirectBuffer
interface.class
ExpandableMutableDirectBuffer
that is backed by an array.class
ExpandableMutableDirectBuffer
that is backed by a directByteBuffer
.Methods in org.agrona with parameters of type MutableDirectBufferModifier and TypeMethodDescriptionvoid
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.concurrentModifier and TypeInterfaceDescriptioninterface
Abstraction over a range of buffer types that allows type to be accessed with various memory ordering semantics.Classes in org.agrona.concurrent that implement MutableDirectBufferModifier and TypeClassDescriptionclass
Supports regular, byte ordered, and atomic (memory ordered) access to an underlying buffer.Methods in org.agrona.concurrent with parameters of type MutableDirectBufferModifier and TypeMethodDescriptionControlledMessageHandler.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 MutableDirectBufferModifier and TypeFieldDescriptionprivate final MutableDirectBuffer
CopyBroadcastReceiver.scratchBuffer
Methods in org.agrona.concurrent.broadcast that return MutableDirectBufferModifier and TypeMethodDescriptionBroadcastReceiver.buffer()
The underlying buffer containing the broadcast message stream.Constructors in org.agrona.concurrent.broadcast with parameters of type MutableDirectBufferModifierConstructorDescriptionCopyBroadcastReceiver
(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 MutableDirectBufferModifier and TypeMethodDescriptionint
ConcurrentCountersManager.allocate
(String label, int typeId, Consumer<MutableDirectBuffer> keyFunc) Allocate a new counter with a given label.int
CountersManager.allocate
(String label, int typeId, Consumer<MutableDirectBuffer> keyFunc) Allocate a new counter with a given label.CountersManager.newCounter
(String label, int typeId, Consumer<MutableDirectBuffer> keyFunc) Allocate a counter record and wrap it with a newAtomicCounter
for use.void
ConcurrentCountersManager.setCounterKey
(int counterId, 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, Consumer<MutableDirectBuffer> keyFunc) Set anAtomicCounter
key by on counter id, using a consumer callback to update the key metadata buffer.void
AtomicCounter.updateKey
(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 MutableDirectBufferModifier and TypeFieldDescriptionprivate MutableDirectBuffer
DirectBufferOutputStream.buffer
private MutableDirectBuffer
ExpandableDirectBufferOutputStream.buffer
Methods in org.agrona.io that return MutableDirectBufferModifier and TypeMethodDescriptionDirectBufferOutputStream.buffer()
The underlying buffer being wrapped.ExpandableDirectBufferOutputStream.buffer()
The underlying buffer being wrapped.Methods in org.agrona.io with parameters of type MutableDirectBufferModifier and TypeMethodDescriptionvoid
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 MutableDirectBufferModifierConstructorDescriptionConstructs output stream wrapping the given buffer.DirectBufferOutputStream
(MutableDirectBuffer buffer, int offset, int length) Constructs output stream wrapping the given buffer at an offset.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 MutableDirectBufferModifier and TypeMethodDescriptionEncoderFlyweight.buffer()
Buffer in which the flyweight is encoded.Methods in org.agrona.sbe with parameters of type MutableDirectBufferModifier and TypeMethodDescriptionEncoderFlyweight.wrap
(MutableDirectBuffer buffer, int offset) Wrap a buffer for encoding at a given offset.