Class CollectionMessageStore

java.lang.Object

io.fluxzero.sdk.persisting.search.client.CollectionMessageStore

All Implemented Interfaces:

Monitored<List<SerializedMessage>>, HasMessageStore, MessageStore, AutoCloseable

public class CollectionMessageStore
extends Object
implements MessageStore

A MessageStore implementation backed by a collection in an InMemorySearchStore. This class provides functionality for tracking updated documents in a specific collection.

Used to support HandleDocument from in-memory search stores.

Constructor Summary

Constructors

Constructor	Description
CollectionMessageStore()

Method Summary

Modifier and Type	Method	Description
CompletableFuture<Void>	append(List<SerializedMessage> messages)	Appends a list of messages to the store.
List<SerializedMessage>	getBatch(Long minIndex, int maxSize, boolean inclusive)	Retrieves a batch of messages starting from the given minIndex.
Registration	registerMonitor(Consumer<List<SerializedMessage>> monitor)	Registers a monitor that will be notified when an activity of type T occurs.
MessageStoreBatch	scanBatch(Long minIndex, int maxSize, boolean inclusive, long maxBytes, Predicate<? super SerializedMessage> filter, boolean includeDocumentTombstones)	Scans messages with optional document tombstones.
void	setRetentionTime(Duration retentionPeriod)	Sets the retention period for messages.
void	truncate()	Removes all messages from this store while keeping the logical log available for future appends.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface MessageStore

append, close, getBatch, getBatch, getBatch, getMessageStore, scanBatch, unwrap

Constructor Details

CollectionMessageStore

public CollectionMessageStore()

Method Details

getBatch

public List<SerializedMessage> getBatch(Long minIndex,
 int maxSize,
 boolean inclusive)

Description copied from interface: MessageStore

Retrieves a batch of messages starting from the given minIndex.

Specified by:

getBatch in interface MessageStore

Parameters:

minIndex - minimum message index to start from

maxSize - maximum number of messages to retrieve

inclusive - whether to include the message at minIndex

Returns:

a list of SerializedMessage instances

scanBatch

public MessageStoreBatch scanBatch(Long minIndex,
 int maxSize,
 boolean inclusive,
 long maxBytes,
 Predicate<? super SerializedMessage> filter,
 boolean includeDocumentTombstones)

Description copied from interface: MessageStore

Scans messages with optional document tombstones. Stores that do not maintain typed graph tombstones retain their ordinary scan behavior.

Specified by:

scanBatch in interface MessageStore

registerMonitor

public Registration registerMonitor(Consumer<List<SerializedMessage>> monitor)

Description copied from interface: Monitored

Registers a monitor that will be notified when an activity of type T occurs.

Specified by:

registerMonitor in interface Monitored<List<SerializedMessage>>

Parameters:

monitor - the callback to invoke with each observed value

Returns:

a Registration that can be used to cancel the monitoring

append

public CompletableFuture<Void> append(List<SerializedMessage> messages)

Description copied from interface: MessageStore

Appends a list of messages to the store.

Specified by:

append in interface MessageStore

Parameters:

messages - messages to append

Returns:

a CompletableFuture that completes when the messages have been successfully appended

setRetentionTime

public void setRetentionTime(Duration retentionPeriod)

Description copied from interface: MessageStore

Sets the retention period for messages. Messages older than this duration may be removed depending on the implementation.

Specified by:

setRetentionTime in interface MessageStore

Parameters:

retentionPeriod - duration to retain messages

truncate

public void truncate()

Description copied from interface: MessageStore

Removes all messages from this store while keeping the logical log available for future appends.

Specified by:

truncate in interface MessageStore