Uses of Record Class
io.fluxzero.common.tracking.MessageStoreBatch

Packages that use MessageStoreBatch

Package	Description
io.fluxzero.common.tracking
io.fluxzero.sdk.scheduling.client
io.fluxzero.sdk.tracking.client
io.fluxzero.testserver.scheduling

Uses of MessageStoreBatch in io.fluxzero.common.tracking

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

Modifier and Type	Method	Description
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.

Uses of MessageStoreBatch in io.fluxzero.sdk.scheduling.client

Methods in io.fluxzero.sdk.scheduling.client that return MessageStoreBatch

Modifier and Type	Method	Description
MessageStoreBatch	InMemoryScheduleStore.scanBatch(Long minIndex, int maxSize, boolean inclusive, long maxBytes, Predicate<? super SerializedMessage> filter)

Uses of MessageStoreBatch in io.fluxzero.sdk.tracking.client

Methods in io.fluxzero.sdk.tracking.client that return MessageStoreBatch

Modifier and Type	Method	Description
MessageStoreBatch	InMemoryMessageStore.scanBatch(Long minIndex, int maxSize, boolean inclusive, long maxBytes, Predicate<? super SerializedMessage> filter)

Uses of MessageStoreBatch in io.fluxzero.testserver.scheduling

Methods in io.fluxzero.testserver.scheduling that return MessageStoreBatch

Modifier and Type	Method	Description
MessageStoreBatch	TestServerScheduleStore.scanBatch(Long minIndex, int maxSize, boolean inclusive, long maxBytes, Predicate<? super SerializedMessage> filter)