io.spine.server.event

Interface EventStore

All Superinterfaces:

java.lang.AutoCloseable, Closeable

All Known Implementing Classes:

DefaultEventStore

public interface EventStore
extends Closeable

A store of all events in a Bounded Context.

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 interface io.spine.server.Closeable

checkOpen, isOpen

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

append

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

Appends the passed event to the history of events.

Parameters:

event - the record to append

appendAll

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

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.

Parameters:

events - the events to append

read

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.

Parameters:

request - the query with filtering parameters for the event history

responseObserver - observer for the resulting stream