io.axoniq.axonserver.grpc.event

Class EventStoreGrpc.EventStoreBlockingStub

java.lang.Object

io.grpc.stub.AbstractStub<EventStoreGrpc.EventStoreBlockingStub>

io.axoniq.axonserver.grpc.event.EventStoreGrpc.EventStoreBlockingStub

Enclosing class:

EventStoreGrpc

public static final class EventStoreGrpc.EventStoreBlockingStub
extends io.grpc.stub.AbstractStub<EventStoreGrpc.EventStoreBlockingStub>

Method Summary

Modifier and Type	Method and Description
Confirmation	appendSnapshot(Event request) Accepts a Snapshot event returning a Confirmation when completed.
protected EventStoreGrpc.EventStoreBlockingStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
TrackingToken	getFirstToken(GetFirstTokenRequest request) Retrieves the first token available in event store (typically 0).
TrackingToken	getLastToken(GetLastTokenRequest request) Retrieves the last committed token in event store.
TrackingToken	getTokenAt(GetTokenAtRequest request) Retrieves the token of the first token of an event from specified time in event store.
Iterator<Event>	listAggregateEvents(GetAggregateEventsRequest request) Retrieves the Events for a given aggregate.
Iterator<Event>	listAggregateSnapshots(GetAggregateSnapshotsRequest request) Retrieves the Snapshots for a given aggregate.
ReadHighestSequenceNrResponse	readHighestSequenceNr(ReadHighestSequenceNrRequest request) Gets the highest sequence number for a specific aggregate.

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOption, withWaitForReady

Methods inherited from class java.lang.Object

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

Method Detail

build

protected EventStoreGrpc.EventStoreBlockingStub build(io.grpc.Channel channel,
                                                      io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<EventStoreGrpc.EventStoreBlockingStub>

appendSnapshot

public Confirmation appendSnapshot(Event request)

 Accepts a Snapshot event returning a Confirmation when completed.
 

listAggregateEvents

public Iterator<Event> listAggregateEvents(GetAggregateEventsRequest request)

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

listAggregateSnapshots

public Iterator<Event> listAggregateSnapshots(GetAggregateSnapshotsRequest request)

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

readHighestSequenceNr

public ReadHighestSequenceNrResponse readHighestSequenceNr(ReadHighestSequenceNrRequest request)

 Gets the highest sequence number for a specific aggregate.
 

getFirstToken

public TrackingToken getFirstToken(GetFirstTokenRequest request)

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

getLastToken

public TrackingToken getLastToken(GetLastTokenRequest request)

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

getTokenAt

public TrackingToken getTokenAt(GetTokenAtRequest request)

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