public class HttpJsonStreamsServiceStub extends StreamsServiceStub
REST stub implementation for the StreamsService service API.
This class is for advanced usage and reflects the underlying API directly.
Static Methods
create(ClientContext clientContext)
public static final HttpJsonStreamsServiceStub create(ClientContext clientContext)
create(ClientContext clientContext, HttpJsonStubCallableFactory callableFactory)
public static final HttpJsonStreamsServiceStub create(ClientContext clientContext, HttpJsonStubCallableFactory callableFactory)
create(StreamsServiceStubSettings settings)
public static final HttpJsonStreamsServiceStub create(StreamsServiceStubSettings settings)
getMethodDescriptors()
public static List<ApiMethodDescriptor> getMethodDescriptors()
Constructors
HttpJsonStreamsServiceStub(StreamsServiceStubSettings settings, ClientContext clientContext)
protected HttpJsonStreamsServiceStub(StreamsServiceStubSettings settings, ClientContext clientContext)
Constructs an instance of HttpJsonStreamsServiceStub, using the given settings. This is
protected so that it is easy to make a subclass, but otherwise, the static factory methods
should be preferred.
HttpJsonStreamsServiceStub(StreamsServiceStubSettings settings, ClientContext clientContext, HttpJsonStubCallableFactory callableFactory)
protected HttpJsonStreamsServiceStub(StreamsServiceStubSettings settings, ClientContext clientContext, HttpJsonStubCallableFactory callableFactory)
Constructs an instance of HttpJsonStreamsServiceStub, using the given settings. This is
protected so that it is easy to make a subclass, but otherwise, the static factory methods
should be preferred.
Methods
awaitTermination(long duration, TimeUnit unit)
public boolean awaitTermination(long duration, TimeUnit unit)
close()
public final void close()
Overrides
createClusterCallable()
public UnaryCallable<CreateClusterRequest,Operation> createClusterCallable()
Overrides
createClusterOperationCallable()
public OperationCallable<CreateClusterRequest,Cluster,OperationMetadata> createClusterOperationCallable()
Overrides
createEventCallable()
public UnaryCallable<CreateEventRequest,Operation> createEventCallable()
Overrides
createEventOperationCallable()
public OperationCallable<CreateEventRequest,Event,OperationMetadata> createEventOperationCallable()
Overrides
createSeriesCallable()
public UnaryCallable<CreateSeriesRequest,Operation> createSeriesCallable()
Overrides
createSeriesOperationCallable()
public OperationCallable<CreateSeriesRequest,Series,OperationMetadata> createSeriesOperationCallable()
Overrides
createStreamCallable()
public UnaryCallable<CreateStreamRequest,Operation> createStreamCallable()
Overrides
createStreamOperationCallable()
public OperationCallable<CreateStreamRequest,Stream,OperationMetadata> createStreamOperationCallable()
Overrides
deleteClusterCallable()
public UnaryCallable<DeleteClusterRequest,Operation> deleteClusterCallable()
Overrides
deleteClusterOperationCallable()
public OperationCallable<DeleteClusterRequest,Empty,OperationMetadata> deleteClusterOperationCallable()
Overrides
deleteEventCallable()
public UnaryCallable<DeleteEventRequest,Operation> deleteEventCallable()
Overrides
deleteEventOperationCallable()
public OperationCallable<DeleteEventRequest,Empty,OperationMetadata> deleteEventOperationCallable()
Overrides
deleteSeriesCallable()
public UnaryCallable<DeleteSeriesRequest,Operation> deleteSeriesCallable()
Overrides
deleteSeriesOperationCallable()
public OperationCallable<DeleteSeriesRequest,Empty,OperationMetadata> deleteSeriesOperationCallable()
Overrides
deleteStreamCallable()
public UnaryCallable<DeleteStreamRequest,Operation> deleteStreamCallable()
Overrides
deleteStreamOperationCallable()
public OperationCallable<DeleteStreamRequest,Empty,OperationMetadata> deleteStreamOperationCallable()
Overrides
generateStreamHlsTokenCallable()
public UnaryCallable<GenerateStreamHlsTokenRequest,GenerateStreamHlsTokenResponse> generateStreamHlsTokenCallable()
Overrides
getClusterCallable()
public UnaryCallable<GetClusterRequest,Cluster> getClusterCallable()
Overrides
getEventCallable()
public UnaryCallable<GetEventRequest,Event> getEventCallable()
Overrides
getHttpJsonOperationsStub()
public HttpJsonOperationsStub getHttpJsonOperationsStub()
Overrides
getSeriesCallable()
public UnaryCallable<GetSeriesRequest,Series> getSeriesCallable()
Overrides
getStreamCallable()
public UnaryCallable<GetStreamRequest,Stream> getStreamCallable()
Overrides
getStreamThumbnailCallable()
public UnaryCallable<GetStreamThumbnailRequest,Operation> getStreamThumbnailCallable()
Overrides
getStreamThumbnailOperationCallable()
public OperationCallable<GetStreamThumbnailRequest,GetStreamThumbnailResponse,OperationMetadata> getStreamThumbnailOperationCallable()
Overrides
isShutdown()
public boolean isShutdown()
isTerminated()
public boolean isTerminated()
listClustersCallable()
public UnaryCallable<ListClustersRequest,ListClustersResponse> listClustersCallable()
Overrides
listClustersPagedCallable()
public UnaryCallable<ListClustersRequest,StreamsServiceClient.ListClustersPagedResponse> listClustersPagedCallable()
Overrides
listEventsCallable()
public UnaryCallable<ListEventsRequest,ListEventsResponse> listEventsCallable()
Overrides
listEventsPagedCallable()
public UnaryCallable<ListEventsRequest,StreamsServiceClient.ListEventsPagedResponse> listEventsPagedCallable()
Overrides
listSeriesCallable()
public UnaryCallable<ListSeriesRequest,ListSeriesResponse> listSeriesCallable()
Overrides
listSeriesPagedCallable()
public UnaryCallable<ListSeriesRequest,StreamsServiceClient.ListSeriesPagedResponse> listSeriesPagedCallable()
Overrides
listStreamsCallable()
public UnaryCallable<ListStreamsRequest,ListStreamsResponse> listStreamsCallable()
Overrides
listStreamsPagedCallable()
public UnaryCallable<ListStreamsRequest,StreamsServiceClient.ListStreamsPagedResponse> listStreamsPagedCallable()
Overrides
materializeChannelCallable()
public UnaryCallable<MaterializeChannelRequest,Operation> materializeChannelCallable()
Overrides
materializeChannelOperationCallable()
public OperationCallable<MaterializeChannelRequest,Channel,OperationMetadata> materializeChannelOperationCallable()
Overrides
shutdown()
shutdownNow()
public void shutdownNow()
updateClusterCallable()
public UnaryCallable<UpdateClusterRequest,Operation> updateClusterCallable()
Overrides
updateClusterOperationCallable()
public OperationCallable<UpdateClusterRequest,Cluster,OperationMetadata> updateClusterOperationCallable()
Overrides
updateEventCallable()
public UnaryCallable<UpdateEventRequest,Operation> updateEventCallable()
Overrides
updateEventOperationCallable()
public OperationCallable<UpdateEventRequest,Event,OperationMetadata> updateEventOperationCallable()
Overrides
updateSeriesCallable()
public UnaryCallable<UpdateSeriesRequest,Operation> updateSeriesCallable()
Overrides
updateSeriesOperationCallable()
public OperationCallable<UpdateSeriesRequest,Series,OperationMetadata> updateSeriesOperationCallable()
Overrides
updateStreamCallable()
public UnaryCallable<UpdateStreamRequest,Operation> updateStreamCallable()
Overrides
updateStreamOperationCallable()
public OperationCallable<UpdateStreamRequest,Stream,OperationMetadata> updateStreamOperationCallable()
Overrides