public final class DefaultEventStore extends MessageStorage<io.spine.core.EventId,io.spine.core.Event> implements EventStore, io.spine.logging.Logging
|Constructor and Description|
Constructs new instance.
|Modifier and Type||Method and Description|
Appends the passed event to the history of events.
Appends the passed events to the history of events.
Creates the stream with events matching the passed query.
close, delete, deleteAll, deleteRecord, index, index, isMultitenant, isOpen, queryForAll, read, read, readAll, readAll, readAll, readAll, readAllRecords, toQuery, toQuery, toQuery, toQuery, write, writeAll, writeRecord
checkNotClosed, checkNotClosed, isClosed
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public void append(io.spine.core.Event event)
public void appendAll(java.lang.Iterable<io.spine.core.Event> events)
If the passed
Iterable is empty, no action is performed.
If the passed Events belong to the different
IllegalArgumentException is thrown.
public void read(io.spine.server.event.EventStreamQuery request, io.grpc.stub.StreamObserver<io.spine.core.Event> responseObserver)