Package s2.v1alpha

Interface StreamServiceGrpc.AsyncService

All Known Implementing Classes:
StreamServiceGrpc.StreamServiceImplBase
Enclosing class:
StreamServiceGrpc
public static interface StreamServiceGrpc.AsyncService
 Operate on an S2 stream.

  • Method Details

    • 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.