Uses of Record Class
io.fluxzero.common.tracking.MessageStoreBatch
Packages that use MessageStoreBatch
Package
Description
-
Uses of MessageStoreBatch in io.fluxzero.common.tracking
Methods in io.fluxzero.common.tracking that return MessageStoreBatchModifier and TypeMethodDescriptionstatic MessageStoreBatchMessageStoreBatch.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 MessageStoreBatchDefaultTrackingStrategy.scanBatch(int[] segment, Position position, int batchSize, long maxBytes, Predicate<? super SerializedMessage> filter) default MessageStoreBatchMessageStore.scanBatch(Long minIndex, int maxSize, boolean inclusive, long maxBytes, Predicate<? super SerializedMessage> filter) Scans messages starting from the givenminIndex, returning messages accepted byfilterand metadata about the unfiltered source scan. -
Uses of MessageStoreBatch in io.fluxzero.sdk.scheduling.client
Methods in io.fluxzero.sdk.scheduling.client that return MessageStoreBatchModifier and TypeMethodDescriptionInMemoryScheduleStore.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 MessageStoreBatchModifier and TypeMethodDescriptionInMemoryMessageStore.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 MessageStoreBatchModifier and TypeMethodDescriptionTestServerScheduleStore.scanBatch(Long minIndex, int maxSize, boolean inclusive, long maxBytes, Predicate<? super SerializedMessage> filter)