Package s2.v1alpha
Class BasinServiceGrpc.BasinServiceStub
java.lang.Object
io.grpc.stub.AbstractStub<S>
io.grpc.stub.AbstractAsyncStub<BasinServiceGrpc.BasinServiceStub>
s2.v1alpha.BasinServiceGrpc.BasinServiceStub
- Enclosing class:
- BasinServiceGrpc
public static final class BasinServiceGrpc.BasinServiceStub
extends io.grpc.stub.AbstractAsyncStub<BasinServiceGrpc.BasinServiceStub>
A stub to allow clients to do asynchronous rpc calls to service BasinService.
Operate on an S2 basin.
-
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 TypeMethodDescriptionprotected BasinServiceGrpc.BasinServiceStub
build
(io.grpc.Channel channel, io.grpc.CallOptions callOptions) void
createStream
(CreateStreamRequest request, io.grpc.stub.StreamObserver<CreateStreamResponse> responseObserver) Create a stream.void
deleteStream
(DeleteStreamRequest request, io.grpc.stub.StreamObserver<DeleteStreamResponse> responseObserver) Delete a stream.void
getStreamConfig
(GetStreamConfigRequest request, io.grpc.stub.StreamObserver<GetStreamConfigResponse> responseObserver) Get stream configuration.void
listStreams
(ListStreamsRequest request, io.grpc.stub.StreamObserver<ListStreamsResponse> responseObserver) List streams.void
reconfigureStream
(ReconfigureStreamRequest request, io.grpc.stub.StreamObserver<ReconfigureStreamResponse> responseObserver) Update stream configuration.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
-
Method Details
-
build
protected BasinServiceGrpc.BasinServiceStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) - Specified by:
build
in classio.grpc.stub.AbstractStub<BasinServiceGrpc.BasinServiceStub>
-
listStreams
public void listStreams(ListStreamsRequest request, io.grpc.stub.StreamObserver<ListStreamsResponse> responseObserver) List streams.
-
createStream
public void createStream(CreateStreamRequest request, io.grpc.stub.StreamObserver<CreateStreamResponse> responseObserver) Create a stream. Provide a client request token with the `S2-Request-Token` header for idempotent retry behaviour.
-
deleteStream
public void deleteStream(DeleteStreamRequest request, io.grpc.stub.StreamObserver<DeleteStreamResponse> responseObserver) Delete a stream. Stream deletion is asynchronous, and may take a few minutes to complete.
-
getStreamConfig
public void getStreamConfig(GetStreamConfigRequest request, io.grpc.stub.StreamObserver<GetStreamConfigResponse> responseObserver) Get stream configuration.
-
reconfigureStream
public void reconfigureStream(ReconfigureStreamRequest request, io.grpc.stub.StreamObserver<ReconfigureStreamResponse> responseObserver) Update stream configuration.
-