Package s2.v1alpha

Class BasinServiceGrpc.BasinServiceBlockingStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractBlockingStub<BasinServiceGrpc.BasinServiceBlockingStub>

s2.v1alpha.BasinServiceGrpc.BasinServiceBlockingStub

Enclosing class:

BasinServiceGrpc

public static final class BasinServiceGrpc.BasinServiceBlockingStub
extends io.grpc.stub.AbstractBlockingStub<BasinServiceGrpc.BasinServiceBlockingStub>

A stub to allow clients to do limited synchronous 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 Type	Method	Description
protected BasinServiceGrpc.BasinServiceBlockingStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
CreateStreamResponse	createStream(CreateStreamRequest request)	Create a stream.
DeleteStreamResponse	deleteStream(DeleteStreamRequest request)	Delete a stream.
GetStreamConfigResponse	getStreamConfig(GetStreamConfigRequest request)	Get stream configuration.
ListStreamsResponse	listStreams(ListStreamsRequest request)	List streams.
ReconfigureStreamResponse	reconfigureStream(ReconfigureStreamRequest request)	Update stream configuration.

Methods inherited from class io.grpc.stub.AbstractBlockingStub

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 BasinServiceGrpc.BasinServiceBlockingStub build(io.grpc.Channel channel,
 io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<BasinServiceGrpc.BasinServiceBlockingStub>

listStreams

public ListStreamsResponse listStreams(ListStreamsRequest request)

 List streams.
 

createStream

public CreateStreamResponse createStream(CreateStreamRequest request)

 Create a stream.
 Provide a client request token with the `S2-Request-Token` header for idempotent retry behaviour.
 

deleteStream

public DeleteStreamResponse deleteStream(DeleteStreamRequest request)

 Delete a stream.
 Stream deletion is asynchronous, and may take a few minutes to complete.
 

getStreamConfig

public GetStreamConfigResponse getStreamConfig(GetStreamConfigRequest request)

 Get stream configuration.
 

reconfigureStream

public ReconfigureStreamResponse reconfigureStream(ReconfigureStreamRequest request)

 Update stream configuration.