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

Class EventStoreGrpc.EventStoreBlockingV2Stub

  • Enclosing class:
    EventStoreGrpc
    public static final class EventStoreGrpc.EventStoreBlockingV2Stub
extends io.grpc.stub.AbstractBlockingStub<EventStoreGrpc.EventStoreBlockingV2Stub>
    A stub to allow clients to do synchronous rpc calls to service EventStore. 
     Service providing operations against the EventStore functionality of Axon Server

    • Method Detail

      • appendEvent

        @ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918")
public io.grpc.stub.BlockingClientCall<Event,​ConfirmationWithConsistencyMarker> appendEvent()
         Accepts a stream of Events returning a Confirmation when completed.

      • appendSnapshot

        public Confirmation appendSnapshot​(Event request)
                            throws io.grpc.StatusException
         Accepts a Snapshot event returning a Confirmation when completed.
        Throws:
        io.grpc.StatusException

      • listAggregateEvents

        @ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918")
public io.grpc.stub.BlockingClientCall<?,​Event> listAggregateEvents​(GetAggregateEventsRequest request)
         Retrieves the Events for a given aggregate. Results are streamed rather than returned at once.

      • listAggregateSnapshots

        @ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918")
public io.grpc.stub.BlockingClientCall<?,​Event> listAggregateSnapshots​(GetAggregateSnapshotsRequest request)
         Retrieves the Snapshots for a given aggregate. Results are streamed rather than returned at once.

      • listEvents

        @ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918")
public io.grpc.stub.BlockingClientCall<GetEventsRequest,​EventWithToken> listEvents()
         Retrieves the Events from a given tracking token. However, if several GetEventsRequests are sent in the stream
only first one will create the tracker, others are used for increasing number of permits or blacklisting. Results
are streamed rather than returned at once.

      • queryEvents

        @ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918")
public io.grpc.stub.BlockingClientCall<QueryEventsRequest,​QueryEventsResponse> queryEvents()
         Performs a query on the event store, returns a stream of results. Input is a stream to allow flow control from the
 client

      • getFirstToken

        public TrackingToken getFirstToken​(GetFirstTokenRequest request)
                            throws io.grpc.StatusException
         Retrieves the first token available in event store (typically 0). Returns 0 when no events in store.
        Throws:
        io.grpc.StatusException

      • getLastToken

        public TrackingToken getLastToken​(GetLastTokenRequest request)
                           throws io.grpc.StatusException
         Retrieves the last committed token in event store. Returns -1 when no events in store.
        Throws:
        io.grpc.StatusException

      • getTokenAt

        public TrackingToken getTokenAt​(GetTokenAtRequest request)
                         throws io.grpc.StatusException
         Retrieves the token of the first token of an event from specified time in event store. Returns -1 when no events in store.
        Throws:
        io.grpc.StatusException