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

Packages that use SerializedMessage

Package	Description
io.fluxzero.common.api
io.fluxzero.common.api.tracking
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.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.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 serialized payload 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 serialized payload 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)
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.

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.