Uses of Class
io.fluxzero.common.api.SerializedMessage

Packages that use SerializedMessage

Package	Description
io.fluxzero.common.api
io.fluxzero.common.api.internal
io.fluxzero.common.api.publishing
io.fluxzero.common.api.tracking
io.fluxzero.common.serialization
io.fluxzero.common.tracking

Uses of SerializedMessage in io.fluxzero.common.api

Methods in io.fluxzero.common.api that return SerializedMessage

Modifier and Type	Method	Description
SerializedMessage	SerializedMessage.withData(@NonNull Data<byte[]> data)

Uses of SerializedMessage in io.fluxzero.common.api.internal

Methods in io.fluxzero.common.api.internal that return SerializedMessage

Modifier and Type	Method	Description
static SerializedMessage	BinaryWire.decodeEnvelope(byte[] bytes, int maximumValueSize)	Decodes exactly one native message envelope while retaining zero-copy payload and metadata views.
static SerializedMessage	BinaryWire.prepareEnvelope(SerializedMessage message)	Prepares a message once for reuse by an enclosing transport codec.
SerializedMessage	BinaryWire.Reader.readEnvelope()

Methods in io.fluxzero.common.api.internal that return types with arguments of type SerializedMessage

Modifier and Type	Method	Description
static List<SerializedMessage>	BinaryWire.decodeEnvelopes(byte[] bytes, int maximumValueSize)	Decodes a sequence while retaining zero-copy payload and metadata views.
static List<SerializedMessage>	BinaryWire.decodeEnvelopes(byte[] bytes, int offset, int length, int maximumValueSize)	Decodes a native-envelope sequence from a byte range.
static List<SerializedMessage>	BinaryWire.prepareEnvelopes(List<SerializedMessage> messages)	Prepares a message sequence, retaining the original list when every envelope is reusable.

Methods in io.fluxzero.common.api.internal with parameters of type SerializedMessage

Modifier and Type	Method	Description
static byte[]	BinaryWire.encodeEnvelope(SerializedMessage message)	Encodes one native message envelope.
static int	BinaryWire.envelopeSize(SerializedMessage message)	Returns the complete encoded size of one native message envelope.
static int	BinaryWire.nestedEnvelopeSize(SerializedMessage message)	Returns the size of a native envelope when embedded as one length-delimited wire value.
static SerializedMessage	BinaryWire.prepareEnvelope(SerializedMessage message)	Prepares a message once for reuse by an enclosing transport codec.
void	BinaryWire.Writer.writeEnvelope(SerializedMessage message)

Method parameters in io.fluxzero.common.api.internal with type arguments of type SerializedMessage

Modifier and Type	Method	Description
static byte[]	BinaryWire.encodeEnvelopes(List<SerializedMessage> messages)	Encodes a sequence of concatenated native message envelopes.
static List<SerializedMessage>	BinaryWire.prepareEnvelopes(List<SerializedMessage> messages)	Prepares a message sequence, retaining the original list when every envelope is reusable.

Uses of SerializedMessage in io.fluxzero.common.api.publishing

Constructor parameters in io.fluxzero.common.api.publishing with type arguments of type SerializedMessage

Modifier	Constructor	Description
	Append(long requestId, MessageType messageType, List<SerializedMessage> messages, Guarantee guarantee)	Restores an append request received through an optimized transport representation.
	Append(MessageType messageType, List<SerializedMessage> messages, Guarantee guarantee)

Uses of SerializedMessage in io.fluxzero.common.api.tracking

Methods in io.fluxzero.common.api.tracking with parameters of type SerializedMessage

Modifier and Type	Method	Description
boolean	Position.isNewMessage(SerializedMessage message)	Indicates whether the message index is newer than what is currently tracked for its segment.

Uses of SerializedMessage in io.fluxzero.common.serialization

Methods in io.fluxzero.common.serialization that return types with arguments of type SerializedMessage

Modifier and Type	Method	Description
static List<SerializedMessage>	SerializedMessagePackCodec.decode(byte[] bytes)	Decodes zero or more consecutive serialized messages.
static List<SerializedMessage>	SerializedMessagePackCodec.decode(byte[] bytes, int offset, int length)	Decodes consecutive serialized messages from a zero-copy byte range.

Uses of SerializedMessage in io.fluxzero.common.tracking

Subinterfaces with type arguments of type SerializedMessage in io.fluxzero.common.tracking

Modifier and Type	Interface	Description
interface	MessageStore	A low-level store for serialized messages.

Methods in io.fluxzero.common.tracking that return SerializedMessage

Modifier and Type	Method	Description
protected SerializedMessage	DefaultTrackingStrategy.ensureMessageSegment(SerializedMessage message)

Methods in io.fluxzero.common.tracking that return types with arguments of type SerializedMessage

Modifier and Type	Method	Description
protected List<SerializedMessage>	DefaultTrackingStrategy.filter(List<SerializedMessage> messages, int[] segmentRange, Position position, Tracker tracker)
protected Predicate<SerializedMessage>	DefaultTrackingStrategy.filterPredicate(int[] segmentRange, Position position, Tracker tracker)
protected List<SerializedMessage>	DefaultTrackingStrategy.getBatch(int[] segment, Position position, int batchSize)
default List<SerializedMessage>	MessageStore.getBatch(Long lastIndex, int maxSize)	Retrieves a batch of messages starting from the given lastIndex (exclusive).
List<SerializedMessage>	MessageStore.getBatch(Long minIndex, int maxSize, boolean inclusive)	Retrieves a batch of messages starting from the given minIndex.
default List<SerializedMessage>	MessageStore.getBatch(Long minIndex, int maxSize, boolean inclusive, long maxBytes)	Retrieves a batch of messages starting from the given minIndex, limiting both message count and complete serialized message bytes.
default List<SerializedMessage>	MessageStore.getBatch(Long lastIndex, int maxSize, long maxBytes)	Retrieves a batch of messages starting from the given lastIndex (exclusive), limiting both message count and complete serialized message bytes.
List<SerializedMessage>	MessageStoreBatch.messages()	Returns the value of the messages record component.

Methods in io.fluxzero.common.tracking with parameters of type SerializedMessage

Modifier and Type	Method	Description
default CompletableFuture<Void>	MessageStore.append(SerializedMessage... messages)	Appends the given messages to the store.
default boolean	Tracker.canHandle(SerializedMessage message, int[] segmentRange)	Checks if the given message can be handled by this tracker based on segment range and type filtering.
protected SerializedMessage	DefaultTrackingStrategy.ensureMessageSegment(SerializedMessage message)

Method parameters in io.fluxzero.common.tracking with type arguments of type SerializedMessage

Modifier and Type	Method	Description
CompletableFuture<Void>	MessageStore.append(List<SerializedMessage> messages)	Appends a list of messages to the store.
protected List<SerializedMessage>	DefaultTrackingStrategy.filter(List<SerializedMessage> messages, int[] segmentRange, Position position, Tracker tracker)
protected void	DefaultTrackingStrategy.onUpdate(List<SerializedMessage> messages)
static MessageStoreBatch	MessageStoreBatch.scan(Iterable<SerializedMessage> source, int maxSize, long maxBytes, Predicate<? super SerializedMessage> filter)	Scans source messages until the source count or accepted-message byte budget is exhausted.
static MessageStoreBatch	MessageStoreBatch.scan(Iterable<SerializedMessage> source, int maxSize, long maxBytes, Predicate<? super SerializedMessage> filter)	Scans source messages until the source count or accepted-message byte budget is exhausted.
protected MessageStoreBatch	DefaultTrackingStrategy.scanBatch(int[] segment, Position position, int batchSize, long maxBytes, Predicate<? super SerializedMessage> filter)
protected MessageStoreBatch	DefaultTrackingStrategy.scanBatch(int[] segment, Position position, int batchSize, long maxBytes, Predicate<? super SerializedMessage> filter, boolean includeDocumentTombstones)
default MessageStoreBatch	MessageStore.scanBatch(Long minIndex, int maxSize, boolean inclusive, long maxBytes, Predicate<? super SerializedMessage> filter)	Scans messages starting from the given minIndex, returning messages accepted by filter and metadata about the unfiltered source scan.
default MessageStoreBatch	MessageStore.scanBatch(Long minIndex, int maxSize, boolean inclusive, long maxBytes, Predicate<? super SerializedMessage> filter, boolean includeDocumentTombstones)	Scans messages with optional document tombstones.

Constructor parameters in io.fluxzero.common.tracking with type arguments of type SerializedMessage

Modifier	Constructor	Description
	MessageStoreBatch(List<SerializedMessage> messages, Long lastScannedIndex, int scannedSize, boolean byteLimited)	Creates an instance of a MessageStoreBatch record class.