io.spine.server.event.store

Class DefaultEventStore

java.lang.Object

io.spine.server.entity.Repository<I,E>

io.spine.server.entity.RecordBasedRepository<I,E,S>

io.spine.server.entity.DefaultRecordBasedRepository<io.spine.core.EventId,io.spine.server.event.store.EEntity,io.spine.core.Event>

io.spine.server.event.store.DefaultEventStore

All Implemented Interfaces:

io.spine.logging.Logging, Closeable, EventStore, java.lang.AutoCloseable

public final class DefaultEventStore
extends DefaultRecordBasedRepository<io.spine.core.EventId,io.spine.server.event.store.EEntity,io.spine.core.Event>
implements EventStore

Default implementation of EventStore.

Constructor Summary

Constructors

Constructor and Description
DefaultEventStore() Constructs new instance.

Method Summary

Modifier and Type	Method and Description
void	append(io.spine.core.Event event) Appends the passed event to the history of events.
void	appendAll(java.lang.Iterable<io.spine.core.Event> events) Appends the passed events to the history of events.
protected boolean	isTypeSupplier() Tells if this repository should be registered as a type supplier with a Stand of the BoundedContext to which this repository belongs.
void	read(io.spine.server.event.EventStreamQuery request, io.grpc.stub.StreamObserver<io.spine.core.Event> responseObserver) Creates the stream with events matching the passed query.
void	registerWith(BoundedContext context) Initializes the instance by registering itself with the passed BoundedContext.

Methods inherited from class io.spine.server.entity.DefaultRecordBasedRepository

entityFactory, storageConverter

Methods inherited from class io.spine.server.entity.RecordBasedRepository

applyMigration, applyMigration, create, createStorage, find, find, findActive, findOrCreate, iterator, loadAll, loadAll, recordStorage, store, store, toEntity

Methods inherited from class io.spine.server.entity.Repository

checkStorage, close, context, entityClass, entityStateType, eventFilter, hasContext, idClass, index, isOpen, isRegistered, onRegistered, open, storage, storageAssigned

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.spine.server.Closeable

checkOpen, isOpen

Methods inherited from interface java.lang.AutoCloseable

close

Methods inherited from interface io.spine.logging.Logging

_config, _debug, _error, _fine, _finer, _finest, _info, _severe, _trace, _warn, debugLevel, errorLevel, logger, loggerFor

Constructor Detail

DefaultEventStore

public DefaultEventStore()

Constructs new instance.

Method Detail

registerWith

public void registerWith(BoundedContext context)

Initializes the instance by registering itself with the passed BoundedContext.

Overrides:

registerWith in class DefaultRecordBasedRepository<io.spine.core.EventId,io.spine.server.event.store.EEntity,io.spine.core.Event>

Parameters:

context - the Bounded Context of this repository

Implementation Note:

Normally repositories are explicitly registered with a context during its creation. This method performs the registration with the context, so that normal repository flow is ensured. It avoids calling the super.init() since it assumes that the context is already assigned.

append

public void append(io.spine.core.Event event)

Description copied from interface: EventStore

Appends the passed event to the history of events.

Specified by:

append in interface EventStore

Parameters:

event - the record to append

appendAll

public void appendAll(java.lang.Iterable<io.spine.core.Event> events)

Description copied from interface: EventStore

Appends the passed events to the history of events.

If the passed Iterable is empty, no action is performed.

If the passed Events belong to the different tenants, an IllegalArgumentException is thrown.

Specified by:

appendAll in interface EventStore

Parameters:

events - the events to append

read

public void read(io.spine.server.event.EventStreamQuery request,
                 io.grpc.stub.StreamObserver<io.spine.core.Event> responseObserver)

Description copied from interface: EventStore

Creates the stream with events matching the passed query.

Specified by:

read in interface EventStore

Parameters:

request - the query with filtering parameters for the event history

responseObserver - observer for the resulting stream

isTypeSupplier

protected boolean isTypeSupplier()

Description copied from class: Repository

Tells if this repository should be registered as a type supplier with a Stand of the BoundedContext to which this repository belongs.

Normally repositories are type suppliers. Some types of internal repositories are not type suppliers because data of their entities should not be exposed. Those classes of repositories should overwrite this method returning false.

Overrides:

isTypeSupplier in class Repository<io.spine.core.EventId,io.spine.server.event.store.EEntity>

Returns:

true by default