Interface StreamsGrpc.AsyncService
-
- All Known Implementing Classes:
StreamsGrpc.StreamsImplBase
- Enclosing class:
- StreamsGrpc
public static interface StreamsGrpc.AsyncService
-
-
Method Summary
All Methods Instance Methods Default Methods Modifier and Type Method Description default io.grpc.stub.StreamObserver<StreamsOuterClass.AppendReq>
append(io.grpc.stub.StreamObserver<StreamsOuterClass.AppendResp> responseObserver)
default io.grpc.stub.StreamObserver<StreamsOuterClass.BatchAppendReq>
batchAppend(io.grpc.stub.StreamObserver<StreamsOuterClass.BatchAppendResp> responseObserver)
default void
delete(StreamsOuterClass.DeleteReq request, io.grpc.stub.StreamObserver<StreamsOuterClass.DeleteResp> responseObserver)
default void
read(StreamsOuterClass.ReadReq request, io.grpc.stub.StreamObserver<StreamsOuterClass.ReadResp> responseObserver)
default void
tombstone(StreamsOuterClass.TombstoneReq request, io.grpc.stub.StreamObserver<StreamsOuterClass.TombstoneResp> responseObserver)
-
-
-
Method Detail
-
read
default void read(StreamsOuterClass.ReadReq request, io.grpc.stub.StreamObserver<StreamsOuterClass.ReadResp> responseObserver)
-
append
default io.grpc.stub.StreamObserver<StreamsOuterClass.AppendReq> append(io.grpc.stub.StreamObserver<StreamsOuterClass.AppendResp> responseObserver)
-
delete
default void delete(StreamsOuterClass.DeleteReq request, io.grpc.stub.StreamObserver<StreamsOuterClass.DeleteResp> responseObserver)
-
tombstone
default void tombstone(StreamsOuterClass.TombstoneReq request, io.grpc.stub.StreamObserver<StreamsOuterClass.TombstoneResp> responseObserver)
-
batchAppend
default io.grpc.stub.StreamObserver<StreamsOuterClass.BatchAppendReq> batchAppend(io.grpc.stub.StreamObserver<StreamsOuterClass.BatchAppendResp> responseObserver)
-
-