io.spine.server.event.store

Class DefaultEventStore

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.core.EventId,io.spine.core.Event>

io.spine.server.event.store.DefaultEventStore

All Implemented Interfaces:

io.spine.logging.Logging, Closeable, EventStore, Storage<io.spine.core.EventId,io.spine.core.Event>, java.lang.AutoCloseable

public final class DefaultEventStore
extends MessageStorage<io.spine.core.EventId,io.spine.core.Event>
implements EventStore, io.spine.logging.Logging

Default implementation of EventStore.

Constructor Summary

Constructors

Constructor and Description
DefaultEventStore(ContextSpec context, StorageFactory factory) 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.
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.

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

write, write, writeBatch

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

close, delete, deleteAll, deleteRecord, index, index, isMultitenant, isOpen, queryForAll, read, read, readAll, 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

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(ContextSpec context,
                         StorageFactory factory)

Constructs new instance.

Method Detail

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