Interface DCBGrpc.AsyncService

All Known Implementing Classes:
DCBGrpc.DCBImplBase
Enclosing class:
DCBGrpc
public static interface DCBGrpc.AsyncService
Service providing Event Store RPCs supporting DCB.

  • Method Details

    • read

      default void read(Umadb.ReadRequest request, io.grpc.stub.StreamObserver<Umadb.ReadResponse> responseObserver)
      Provides a stream of batches of already-recorded events, up to a captured head position.

    • subscribe

      default void subscribe(Umadb.SubscribeRequest request, io.grpc.stub.StreamObserver<Umadb.SubscribeResponse> responseObserver)
      Provides a stream of batches of already-recorded events, then continues as new events are recorded.

    • append

      default void append(Umadb.AppendRequest request, io.grpc.stub.StreamObserver<Umadb.AppendResponse> responseObserver)
      Appends new events to the store.

    • head

      default void head(Umadb.HeadRequest request, io.grpc.stub.StreamObserver<Umadb.HeadResponse> responseObserver)
      Gets the position of the last recorded event in the store.

    • getTrackingInfo

      default void getTrackingInfo(Umadb.TrackingRequest request, io.grpc.stub.StreamObserver<Umadb.TrackingResponse> responseObserver)
      Gets the last record position for a named source.