io.axoniq.axonserver.grpc.event

Class EventStoreGrpc.EventStoreImplBase

java.lang.Object

io.axoniq.axonserver.grpc.event.EventStoreGrpc.EventStoreImplBase

All Implemented Interfaces:

io.grpc.BindableService

Enclosing class:

EventStoreGrpc

public abstract static class EventStoreGrpc.EventStoreImplBase
extends Object
implements io.grpc.BindableService

Constructor Summary

Constructors

Constructor and Description
EventStoreImplBase()

Method Summary

Modifier and Type	Method and Description
io.grpc.stub.StreamObserver<Event>	appendEvent(io.grpc.stub.StreamObserver<Confirmation> responseObserver) Accepts a stream of Events returning a Confirmation when completed.
void	appendSnapshot(Event request, io.grpc.stub.StreamObserver<Confirmation> responseObserver) Accepts a Snapshot event returning a Confirmation when completed.
io.grpc.ServerServiceDefinition	bindService()
void	getFirstToken(GetFirstTokenRequest request, io.grpc.stub.StreamObserver<TrackingToken> responseObserver) Retrieves the first token available in event store (typically 0).
void	getLastToken(GetLastTokenRequest request, io.grpc.stub.StreamObserver<TrackingToken> responseObserver) Retrieves the last committed token in event store.
void	getTokenAt(GetTokenAtRequest request, io.grpc.stub.StreamObserver<TrackingToken> responseObserver) Retrieves the token of the first token of an event from specified time in event store.
void	listAggregateEvents(GetAggregateEventsRequest request, io.grpc.stub.StreamObserver<Event> responseObserver) Retrieves the Events for a given aggregate.
void	listAggregateSnapshots(GetAggregateSnapshotsRequest request, io.grpc.stub.StreamObserver<Event> responseObserver) Retrieves the Snapshots for a given aggregate.
io.grpc.stub.StreamObserver<GetEventsRequest>	listEvents(io.grpc.stub.StreamObserver<EventWithToken> responseObserver) Retrieves the Events from a given tracking token.
io.grpc.stub.StreamObserver<QueryEventsRequest>	queryEvents(io.grpc.stub.StreamObserver<QueryEventsResponse> responseObserver) Performs a query on the event store, returns a stream of results.
void	readHighestSequenceNr(ReadHighestSequenceNrRequest request, io.grpc.stub.StreamObserver<ReadHighestSequenceNrResponse> responseObserver) Gets the highest sequence number for a specific aggregate.

Methods inherited from class java.lang.Object

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

Constructor Detail

EventStoreImplBase

public EventStoreImplBase()

Method Detail

appendEvent

public io.grpc.stub.StreamObserver<Event> appendEvent(io.grpc.stub.StreamObserver<Confirmation> responseObserver)

 Accepts a stream of Events returning a Confirmation when completed.
 

appendSnapshot

public void appendSnapshot(Event request,
                           io.grpc.stub.StreamObserver<Confirmation> responseObserver)

 Accepts a Snapshot event returning a Confirmation when completed.
 

listAggregateEvents

public void listAggregateEvents(GetAggregateEventsRequest request,
                                io.grpc.stub.StreamObserver<Event> responseObserver)

 Retrieves the Events for a given aggregate. Results are streamed rather than returned at once.
 

listAggregateSnapshots

public void listAggregateSnapshots(GetAggregateSnapshotsRequest request,
                                   io.grpc.stub.StreamObserver<Event> responseObserver)

 Retrieves the Snapshots for a given aggregate. Results are streamed rather than returned at once.
 

listEvents

public io.grpc.stub.StreamObserver<GetEventsRequest> listEvents(io.grpc.stub.StreamObserver<EventWithToken> responseObserver)

 Retrieves the Events from a given tracking token. Results are streamed rather than returned at once.
 

readHighestSequenceNr

public void readHighestSequenceNr(ReadHighestSequenceNrRequest request,
                                  io.grpc.stub.StreamObserver<ReadHighestSequenceNrResponse> responseObserver)

 Gets the highest sequence number for a specific aggregate.
 

queryEvents

public io.grpc.stub.StreamObserver<QueryEventsRequest> queryEvents(io.grpc.stub.StreamObserver<QueryEventsResponse> responseObserver)

 Performs a query on the event store, returns a stream of results. Input is a stream to allow flow control from the
 client
 

getFirstToken

public void getFirstToken(GetFirstTokenRequest request,
                          io.grpc.stub.StreamObserver<TrackingToken> responseObserver)

 Retrieves the first token available in event store (typically 0). Returns 0 when no events in store.
 

getLastToken

public void getLastToken(GetLastTokenRequest request,
                         io.grpc.stub.StreamObserver<TrackingToken> responseObserver)

 Retrieves the last committed token in event store. Returns -1 when no events in store.
 

getTokenAt

public void getTokenAt(GetTokenAtRequest request,
                       io.grpc.stub.StreamObserver<TrackingToken> responseObserver)

 Retrieves the token of the first token of an event from specified time in event store. Returns -1 when no events in store.
 

bindService

public final io.grpc.ServerServiceDefinition bindService()

Specified by:

bindService in interface io.grpc.BindableService