server/io.spine.server.aggregate/AggregateStorage

AggregateStorage

public abstract class AggregateStorage extends AbstractStorage<I, M, R> implements StorageWithLifecycleFlags<I, M, R>

An event-sourced storage of aggregate part events and snapshots.

Parameters

the type of IDs of aggregates managed by this storage

Constructors

AggregateStorage

protected void AggregateStorage(boolean multitenant)

Functions

checkNotClosed

protected void checkNotClosed()

Ensures the storage is not closed.

distinctAggregateIds

protected abstract Iterator distinctAggregateIds()

Obtains distinct aggregate IDs from the stored event records.

historyBackward

protected abstract Iterator<AggregateEventRecord> historyBackward(AggregateReadRequest request)

Creates iterator of aggregate event history with the reverse traversal.

index

public Iterator index()

Returns an iterator over identifiers of records in the storage.

read

public Optional<AggregateHistory> read(AggregateReadRequest request)

Forms and returns an AggregateHistory based on the aggregate history.

truncate

protected abstract void truncate(int snapshotIndex)

Drops all records which occur before the Nth snapshot for each entity.

protected abstract void truncate(int snapshotIndex, Timestamp date)

Drops all records older than date but not newer than the Nth snapshot for each entity.

truncateOlderThan

public void truncateOlderThan(int snapshotIndex)

Truncates the storage, dropping all records which occur before the Nth snapshot for each entity.

public void truncateOlderThan(int snapshotIndex, Timestamp date)

Truncates the storage, dropping all records older than date but not newer than the Nth snapshot.

write

public void write(I id, AggregateHistory events)

Writes events into the storage.

writeRecord

protected abstract void writeRecord(I id, AggregateEventRecord record)

Writes the passed record into the storage.

Inherited functions

checkNotClosed

protected void checkNotClosed(String message)

Ensures the storage is not closed.

public void close()

Closes the storage.

public abstract void close()

isClosed

public boolean isClosed()

Tests whether the storage is closed.

isMultitenant

public boolean isMultitenant()

Verifies whether the storage is multitenant.

isOpen

public boolean isOpen()

Tests whether the storage is open.

readLifecycleFlags

public abstract Optional<LifecycleFlags> readLifecycleFlags(I id)

Reads the lifecycle status for the entity with the passed ID.

writeLifecycleFlags

public abstract void writeLifecycleFlags(I id, LifecycleFlags flags)

Writes the lifecycle status for the entity with the passed ID.