public static final class EventStoreGrpc.EventStoreFutureStub extends io.grpc.stub.AbstractStub<EventStoreGrpc.EventStoreFutureStub>
Service providing operations against the EventStore functionality of Axon Server
Modifier and Type | Method and 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.
|
protected EventStoreGrpc.EventStoreFutureStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
build
in class io.grpc.stub.AbstractStub<EventStoreGrpc.EventStoreFutureStub>
public com.google.common.util.concurrent.ListenableFuture<Confirmation> appendSnapshot(Event request)
Accepts a Snapshot event returning a Confirmation when completed.
public com.google.common.util.concurrent.ListenableFuture<ReadHighestSequenceNrResponse> readHighestSequenceNr(ReadHighestSequenceNrRequest request)
Gets the highest sequence number for a specific aggregate.
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.
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.
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.
Copyright © 2010–2020. All rights reserved.