Package s2.client

Class BasinClient

java.lang.Object

s2.client.BaseClient

s2.client.BasinClient

All Implemented Interfaces:

AutoCloseable

Direct Known Subclasses:

StreamClient

public class BasinClient
extends BaseClient

Constructor Summary

Constructors

Constructor	Description
BasinClient(String basin, Config config, io.grpc.ManagedChannel channel, ScheduledExecutorService executor)
BasinClient(String basin, Config config, ScheduledExecutorService executor)

Method Summary

Modifier and Type	Method	Description
com.google.common.util.concurrent.ListenableFuture<StreamInfo>	createStream(CreateStreamRequest createStreamRequest)
com.google.common.util.concurrent.ListenableFuture<Void>	deleteStream(String streamName)
com.google.common.util.concurrent.ListenableFuture<StreamConfig>	getStreamConfig(String streamName)
com.google.common.util.concurrent.ListenableFuture<Paginated<StreamInfo>>	listStreams(ListStreamsRequest listStreamsRequest)
com.google.common.util.concurrent.ListenableFuture<StreamConfig>	reconfigureStream(ReconfigureStreamRequest reconfigureStreamRequest)
StreamClient	streamClient(String streamName)

Methods inherited from class s2.client.BaseClient

close

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

BasinClient

public BasinClient(String basin,
 Config config,
 ScheduledExecutorService executor)

BasinClient

public BasinClient(String basin,
 Config config,
 io.grpc.ManagedChannel channel,
 ScheduledExecutorService executor)

Method Details

listStreams

public com.google.common.util.concurrent.ListenableFuture<Paginated<StreamInfo>> listStreams(ListStreamsRequest listStreamsRequest)

createStream

public com.google.common.util.concurrent.ListenableFuture<StreamInfo> createStream(CreateStreamRequest createStreamRequest)

deleteStream

public com.google.common.util.concurrent.ListenableFuture<Void> deleteStream(String streamName)

getStreamConfig

public com.google.common.util.concurrent.ListenableFuture<StreamConfig> getStreamConfig(String streamName)

reconfigureStream

public com.google.common.util.concurrent.ListenableFuture<StreamConfig> reconfigureStream(ReconfigureStreamRequest reconfigureStreamRequest)

streamClient

public StreamClient streamClient(String streamName)