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

Interface DcbEventStoreGrpc.AsyncService

    • Method Detail

      • source

        default void source​(SourceEventsRequest request,
                    io.grpc.stub.StreamObserver<SourceEventsResponse> responseObserver)
         Provides a finite stream of events based on the passed SourceEventsRequest.

      • stream

        default void stream​(StreamEventsRequest request,
                    io.grpc.stub.StreamObserver<StreamEventsResponse> responseObserver)
         Provides an infinite stream of events based on the passed StreamEventsRequest.

      • getHead

        default void getHead​(GetHeadRequest request,
                     io.grpc.stub.StreamObserver<GetHeadResponse> responseObserver)
         Gets the current _head_ of the Event Store. The _head_ points to the sequence of the first event to be appended.

      • getTail

        default void getTail​(GetTailRequest request,
                     io.grpc.stub.StreamObserver<GetTailResponse> responseObserver)
         Gets the current _tail_ of the Event Store. The _tail_ points to the sequence of the first event stored.

      • getSequenceAt

        default void getSequenceAt​(GetSequenceAtRequest request,
                           io.grpc.stub.StreamObserver<GetSequenceAtResponse> responseObserver)
         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

        default void addTags​(AddTagsRequest request,
                     io.grpc.stub.StreamObserver<AddTagsResponse> responseObserver)
         Assigns tags to the event identified by its sequence.

      • removeTags

        default void removeTags​(RemoveTagsRequest request,
                        io.grpc.stub.StreamObserver<RemoveTagsResponse> responseObserver)
         Removes tags from the event identified by its sequence.

      • getTags

        default void getTags​(GetTagsRequest request,
                     io.grpc.stub.StreamObserver<GetTagsResponse> responseObserver)
         Gets tags for the event identified by its sequence.