public static final class EventStoreGrpc.EventStoreStub extends io.grpc.stub.AbstractStub<EventStoreGrpc.EventStoreStub>
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.
|
protected EventStoreGrpc.EventStoreStub |
build(io.grpc.Channel channel,
io.grpc.CallOptions callOptions) |
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.
|
protected EventStoreGrpc.EventStoreStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
build
in class io.grpc.stub.AbstractStub<EventStoreGrpc.EventStoreStub>
public io.grpc.stub.StreamObserver<Event> appendEvent(io.grpc.stub.StreamObserver<Confirmation> responseObserver)
Accepts a stream of Events returning a Confirmation when completed.
public void appendSnapshot(Event request, io.grpc.stub.StreamObserver<Confirmation> responseObserver)
Accepts a Snapshot event returning a Confirmation when completed.
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.
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.
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.
public void readHighestSequenceNr(ReadHighestSequenceNrRequest request, io.grpc.stub.StreamObserver<ReadHighestSequenceNrResponse> responseObserver)
Gets the highest sequence number for a specific aggregate.
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
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.
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.
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.
Copyright © 2010–2018. All rights reserved.