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.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected 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.AbstractStub
getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady
-
-
-
-
Method Detail
-
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.
-
-