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

Packages that use MessageStoreBatch

Package	Description
io.fluxzero.common.tracking
io.fluxzero.sdk.persisting.search.client
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)
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.

Uses of MessageStoreBatch in io.fluxzero.sdk.persisting.search.client

Methods in io.fluxzero.sdk.persisting.search.client that return MessageStoreBatch

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

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)