Package s2.v1alpha

Interface StreamServiceGrpc.AsyncService

    • Method Detail

      • checkTail

        default void checkTail​(CheckTailRequest request,
                       io.grpc.stub.StreamObserver<CheckTailResponse> responseObserver)
         Check the sequence number that will be assigned to the next record on a stream.

      • append

        default void append​(AppendRequest request,
                    io.grpc.stub.StreamObserver<AppendResponse> responseObserver)
         Append a batch of records to a stream.

      • appendSession

        default io.grpc.stub.StreamObserver<AppendSessionRequest> appendSession​(io.grpc.stub.StreamObserver<AppendSessionResponse> responseObserver)
         Append batches of records to a stream continuously, while guaranteeing pipelined requests are processed in order.
 If any request fails, the session is terminated.

      • read

        default void read​(ReadRequest request,
                  io.grpc.stub.StreamObserver<ReadResponse> responseObserver)
         Retrieve a batch of records from a stream.

      • readSession

        default void readSession​(ReadSessionRequest request,
                         io.grpc.stub.StreamObserver<ReadSessionResponse> responseObserver)
         Retrieve batches of records from a stream continuously.