Package s2.v1alpha

Class StreamServiceGrpc.StreamServiceStub

java.lang.Object
io.grpc.stub.AbstractStub<S>
io.grpc.stub.AbstractAsyncStub<StreamServiceGrpc.StreamServiceStub>
s2.v1alpha.StreamServiceGrpc.StreamServiceStub
Enclosing class:
StreamServiceGrpc
public static final class StreamServiceGrpc.StreamServiceStub extends io.grpc.stub.AbstractAsyncStub<StreamServiceGrpc.StreamServiceStub>
A stub to allow clients to do asynchronous rpc calls to service StreamService. 
 Operate on an S2 stream.

  • Nested Class Summary

    Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

    io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    append(AppendRequest request, io.grpc.stub.StreamObserver<AppendResponse> responseObserver)
    Append a batch of records to a stream.
    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.
    protected StreamServiceGrpc.StreamServiceStub
    build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
     
    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.
    void
    read(ReadRequest request, io.grpc.stub.StreamObserver<ReadResponse> responseObserver)
    Retrieve a batch of records from a stream.
    void
    readSession(ReadSessionRequest request, io.grpc.stub.StreamObserver<ReadSessionResponse> responseObserver)
    Retrieve batches of records from a stream continuously.

    Methods inherited from class io.grpc.stub.AbstractAsyncStub

    newStub, newStub

    Methods inherited from class io.grpc.stub.AbstractStub

    getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Method Details

    • build

      protected StreamServiceGrpc.StreamServiceStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
      Specified by:
      build in class io.grpc.stub.AbstractStub<StreamServiceGrpc.StreamServiceStub>

    • checkTail

      public 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

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

    • appendSession

      public 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

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

    • readSession

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