Module io.axoniq.connector.axonserver
Package io.axoniq.axonserver.grpc.event.dcb

Class DcbEventStoreGrpc.DcbEventStoreFutureStub

  • Enclosing class:
    DcbEventStoreGrpc
    public static final class DcbEventStoreGrpc.DcbEventStoreFutureStub
extends io.grpc.stub.AbstractFutureStub<DcbEventStoreGrpc.DcbEventStoreFutureStub>
    A stub to allow clients to do ListenableFuture-style rpc calls to service DcbEventStore. 
     Service providing Event Store RPCs supporting DCB.

    • Method Detail

      • getHead

        public com.google.common.util.concurrent.ListenableFuture<GetHeadResponse> getHead​(GetHeadRequest request)
         Gets the current _head_ of the Event Store. The _head_ points to the sequence of the first event to be appended.

      • getTail

        public com.google.common.util.concurrent.ListenableFuture<GetTailResponse> getTail​(GetTailRequest request)
         Gets the current _tail_ of the Event Store. The _tail_ points to the sequence of the first event stored.

      • getSequenceAt

        public com.google.common.util.concurrent.ListenableFuture<GetSequenceAtResponse> getSequenceAt​(GetSequenceAtRequest request)
         Returns the lowest sequence of an event with a timestamp equal to or higher than the given timestamp. The HEAD is
returned if no events exist with a timestamp equal to or higher than the given timestamp.
N.B. Axon Server does not assign timestamps to events. The timestamps used for fulfilling this RPC are timestamps
provided by the client. It could happen that there are events after the returned sequence that have an earlier
timestamp. Axon Server does not reject appends if timestamps of events are not monotonically increasing.

      • addTags

        public com.google.common.util.concurrent.ListenableFuture<AddTagsResponse> addTags​(AddTagsRequest request)
         Assigns tags to the event identified by its sequence.

      • removeTags

        public com.google.common.util.concurrent.ListenableFuture<RemoveTagsResponse> removeTags​(RemoveTagsRequest request)
         Removes tags from the event identified by its sequence.

      • getTags

        public com.google.common.util.concurrent.ListenableFuture<GetTagsResponse> getTags​(GetTagsRequest request)
         Gets tags for the event identified by its sequence.