Module io.axoniq.connector.axonserver

Package io.axoniq.axonserver.grpc.event

Class EventStoreGrpc.EventStoreFutureStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractFutureStub<EventStoreGrpc.EventStoreFutureStub>

io.axoniq.axonserver.grpc.event.EventStoreGrpc.EventStoreFutureStub

Enclosing class:

EventStoreGrpc

public static final class EventStoreGrpc.EventStoreFutureStub
extends io.grpc.stub.AbstractFutureStub<EventStoreGrpc.EventStoreFutureStub>

A stub to allow clients to do ListenableFuture-style rpc calls to service EventStore.

 Service providing operations against the EventStore functionality of Axon Server 
 

Nested Class Summary

Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>

Method Summary

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

Methods inherited from class io.grpc.stub.AbstractFutureStub

newStub, newStub

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, 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.EventStoreFutureStub build(io.grpc.Channel channel,
                                                    io.grpc.CallOptions callOptions)

Specified by:

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

appendSnapshot

public com.google.common.util.concurrent.ListenableFuture<Confirmation> appendSnapshot(Event request)

 Accepts a Snapshot event returning a Confirmation when completed.
 

readHighestSequenceNr

public com.google.common.util.concurrent.ListenableFuture<ReadHighestSequenceNrResponse> readHighestSequenceNr(ReadHighestSequenceNrRequest request)

 Gets the highest sequence number for a specific aggregate.
 

getFirstToken

public com.google.common.util.concurrent.ListenableFuture<TrackingToken> getFirstToken(GetFirstTokenRequest request)

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

getLastToken

public com.google.common.util.concurrent.ListenableFuture<TrackingToken> getLastToken(GetLastTokenRequest request)

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

getTokenAt

public com.google.common.util.concurrent.ListenableFuture<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.