Package s2.v1alpha

Interface BasinServiceGrpc.AsyncService

All Known Implementing Classes:

BasinServiceGrpc.BasinServiceImplBase

Enclosing class:

BasinServiceGrpc

public static interface BasinServiceGrpc.AsyncService

 Operate on an S2 basin.
 

Method Summary

Modifier and Type	Method	Description
default void	createStream(CreateStreamRequest request, io.grpc.stub.StreamObserver<CreateStreamResponse> responseObserver)	Create a stream.
default void	deleteStream(DeleteStreamRequest request, io.grpc.stub.StreamObserver<DeleteStreamResponse> responseObserver)	Delete a stream.
default void	getStreamConfig(GetStreamConfigRequest request, io.grpc.stub.StreamObserver<GetStreamConfigResponse> responseObserver)	Get stream configuration.
default void	listStreams(ListStreamsRequest request, io.grpc.stub.StreamObserver<ListStreamsResponse> responseObserver)	List streams.
default void	reconfigureStream(ReconfigureStreamRequest request, io.grpc.stub.StreamObserver<ReconfigureStreamResponse> responseObserver)	Update stream configuration.

Method Detail

listStreams

default void listStreams(ListStreamsRequest request,
                         io.grpc.stub.StreamObserver<ListStreamsResponse> responseObserver)

 List streams.
 

createStream

default 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

default 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

default void getStreamConfig(GetStreamConfigRequest request,
                             io.grpc.stub.StreamObserver<GetStreamConfigResponse> responseObserver)

 Get stream configuration.
 

reconfigureStream

default void reconfigureStream(ReconfigureStreamRequest request,
                               io.grpc.stub.StreamObserver<ReconfigureStreamResponse> responseObserver)

 Update stream configuration.