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 TypeClassDescriptionclassCommon base class for implementingMutableDirectBufferinterface.classExpandableMutableDirectBufferthat is backed by an array.classExpandableMutableDirectBufferthat is backed by a directByteBuffer.Methods in org.agrona with parameters of type MutableDirectBufferModifier and TypeMethodDescriptionvoidAbstractMutableDirectBuffer.getBytes(int index, MutableDirectBuffer dstBuffer, int dstIndex, int length) Get bytes from thisDirectBufferinto the providedMutableDirectBufferat given indices.intAsciiSequenceView.getBytes(MutableDirectBuffer dstBuffer, int dstOffset) Copy the bytes from a view into a provided buffer.voidDirectBuffer.getBytes(int index, MutableDirectBuffer dstBuffer, int dstIndex, int length) Get bytes from thisDirectBufferinto the providedMutableDirectBufferat given indices.booleanExpandableRingBuffer.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 TypeInterfaceDescriptioninterfaceAbstraction 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 TypeClassDescriptionclassSupports 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.voidMessageHandler.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 MutableDirectBufferCopyBroadcastReceiver.scratchBufferMethods 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 aBroadcastReceiverto 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 TypeMethodDescriptionintConcurrentCountersManager.allocate(String label, int typeId, Consumer<MutableDirectBuffer> keyFunc) Allocate a new counter with a given label.intCountersManager.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 newAtomicCounterfor use.voidConcurrentCountersManager.setCounterKey(int counterId, Consumer<MutableDirectBuffer> keyFunc) Set anAtomicCounterkey by on counter id, using a consumer callback to update the key metadata buffer.voidCountersManager.setCounterKey(int counterId, Consumer<MutableDirectBuffer> keyFunc) Set anAtomicCounterkey by on counter id, using a consumer callback to update the key metadata buffer.voidAtomicCounter.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 MutableDirectBufferDirectBufferOutputStream.bufferprivate MutableDirectBufferExpandableDirectBufferOutputStream.bufferMethods 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 TypeMethodDescriptionvoidDirectBufferOutputStream.wrap(MutableDirectBuffer buffer) Wrap the buffer.voidDirectBufferOutputStream.wrap(MutableDirectBuffer buffer, int offset, int length) Wrap the buffer at an offset.voidExpandableDirectBufferOutputStream.wrap(MutableDirectBuffer buffer) Wrap a given buffer beginning with an offset of 0.voidExpandableDirectBufferOutputStream.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 givenMutableDirectBufferat 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.