io.spine.server.aggregate

Class AggregateEventStorage

java.lang.Object

io.spine.server.storage.AbstractStorage<I,R>

io.spine.server.storage.RecordStorage<I,R>

io.spine.server.storage.RecordStorageDelegate<I,M>

io.spine.server.storage.MessageStorage<io.spine.server.aggregate.AggregateEventRecordId,io.spine.server.aggregate.AggregateEventRecord>

io.spine.server.aggregate.AggregateEventStorage

All Implemented Interfaces:

Storage<io.spine.server.aggregate.AggregateEventRecordId,io.spine.server.aggregate.AggregateEventRecord>, java.lang.AutoCloseable

public class AggregateEventStorage
extends MessageStorage<io.spine.server.aggregate.AggregateEventRecordId,io.spine.server.aggregate.AggregateEventRecord>

Storage of events for each Aggregate.

See Also:

AggregateStorage

Constructor Summary

Constructors

Constructor and Description
AggregateEventStorage(ContextSpec context, StorageFactory factory) Creates a new storage.

Method Summary

Modifier and Type	Method and Description
protected boolean	delete(io.spine.server.aggregate.AggregateEventRecordId id) Physically deletes the message record from the storage by the record identifier.
protected void	deleteAll(java.lang.Iterable<io.spine.server.aggregate.AggregateEventRecordId> ids) Deletes the batch of message records by their identifiers.
protected java.util.Iterator<io.spine.server.aggregate.AggregateEventRecord>	readAll(io.spine.query.RecordQuery<io.spine.server.aggregate.AggregateEventRecordId,io.spine.server.aggregate.AggregateEventRecord> query) Reads all message records according to the passed query.

Methods inherited from class io.spine.server.storage.MessageStorage

write, write, writeBatch

Methods inherited from class io.spine.server.storage.RecordStorageDelegate

close, deleteRecord, index, index, isMultitenant, isOpen, queryForAll, read, read, readAll, readAll, readAll, readAllRecords, toQuery, toQuery, toQuery, toQuery, write, writeAll, writeRecord

Methods inherited from class io.spine.server.storage.RecordStorage

queryBuilder

Methods inherited from class io.spine.server.storage.AbstractStorage

checkNotClosed, checkNotClosed, isClosed

Methods inherited from class java.lang.Object

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

Constructor Detail

AggregateEventStorage

public AggregateEventStorage(ContextSpec context,
                             StorageFactory factory)

Creates a new storage.

Uses the passed factory to create a RecordStorage delegate, and configures it with the columns stored for the AggregateEventRecord.

Parameters:

context - specification of the Bounded Context in scope of which the storage will be used

factory - the storage factory to use when creating a record storage delegate

Method Detail

readAll

protected java.util.Iterator<io.spine.server.aggregate.AggregateEventRecord> readAll(io.spine.query.RecordQuery<io.spine.server.aggregate.AggregateEventRecordId,io.spine.server.aggregate.AggregateEventRecord> query)

Reads all message records according to the passed query.

The default ResponseFormat is used.

Overrides to expose this method as a part of storage's package-level API.

Overrides:

readAll in class RecordStorageDelegate<io.spine.server.aggregate.AggregateEventRecordId,io.spine.server.aggregate.AggregateEventRecord>

Parameters:

query - the query to execute

Returns:

iterator over the matching records

delete

protected boolean delete(io.spine.server.aggregate.AggregateEventRecordId id)

Physically deletes the message record from the storage by the record identifier.

In case the record with the specified identifier is not found in the storage, this method does nothing and returns false.

Overrides to expose this method as a part of storage's package-level API.

Overrides:

delete in class RecordStorageDelegate<io.spine.server.aggregate.AggregateEventRecordId,io.spine.server.aggregate.AggregateEventRecord>

Parameters:

id - identifier of the record to delete

Returns:

true if the record was deleted, or false if the record with the specified identifier was not found

deleteAll

protected void deleteAll(java.lang.Iterable<io.spine.server.aggregate.AggregateEventRecordId> ids)

Deletes the batch of message records by their identifiers.

If for some provided identifiers there is no records in the storage, such identifiers are silently skipped.

Overrides to expose this method as a part of storage's package-level API.

Overrides:

deleteAll in class RecordStorageDelegate<io.spine.server.aggregate.AggregateEventRecordId,io.spine.server.aggregate.AggregateEventRecord>

Parameters:

ids - identifiers of the records to delete