Package com.google.cloud.datastream.v1.stub

Class HttpJsonDatastreamStub

java.lang.Object

com.google.cloud.datastream.v1.stub.DatastreamStub

com.google.cloud.datastream.v1.stub.HttpJsonDatastreamStub

All Implemented Interfaces:

BackgroundResource, AutoCloseable

@Generated("by gapic-generator-java")
public class HttpJsonDatastreamStub
extends DatastreamStub

REST stub implementation for the Datastream service API.

This class is for advanced usage and reflects the underlying API directly.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	HttpJsonDatastreamStub(DatastreamStubSettings settings, ClientContext clientContext)	Constructs an instance of HttpJsonDatastreamStub, using the given settings.
protected	HttpJsonDatastreamStub(DatastreamStubSettings settings, ClientContext clientContext, HttpJsonStubCallableFactory callableFactory)	Constructs an instance of HttpJsonDatastreamStub, using the given settings.

Method Summary

Modifier and Type	Method	Description
boolean	awaitTermination(long duration, TimeUnit unit)
final void	close()
static final HttpJsonDatastreamStub	create(ClientContext clientContext)
static final HttpJsonDatastreamStub	create(ClientContext clientContext, HttpJsonStubCallableFactory callableFactory)
static final HttpJsonDatastreamStub	create(DatastreamStubSettings settings)
UnaryCallable<CreateConnectionProfileRequest,Operation>	createConnectionProfileCallable()
OperationCallable<CreateConnectionProfileRequest,ConnectionProfile,OperationMetadata>	createConnectionProfileOperationCallable()
UnaryCallable<CreatePrivateConnectionRequest,Operation>	createPrivateConnectionCallable()
OperationCallable<CreatePrivateConnectionRequest,PrivateConnection,OperationMetadata>	createPrivateConnectionOperationCallable()
UnaryCallable<CreateRouteRequest,Operation>	createRouteCallable()
OperationCallable<CreateRouteRequest,Route,OperationMetadata>	createRouteOperationCallable()
UnaryCallable<CreateStreamRequest,Operation>	createStreamCallable()
OperationCallable<CreateStreamRequest,Stream,OperationMetadata>	createStreamOperationCallable()
UnaryCallable<DeleteConnectionProfileRequest,Operation>	deleteConnectionProfileCallable()
OperationCallable<DeleteConnectionProfileRequest,com.google.protobuf.Empty,OperationMetadata>	deleteConnectionProfileOperationCallable()
UnaryCallable<DeletePrivateConnectionRequest,Operation>	deletePrivateConnectionCallable()
OperationCallable<DeletePrivateConnectionRequest,com.google.protobuf.Empty,OperationMetadata>	deletePrivateConnectionOperationCallable()
UnaryCallable<DeleteRouteRequest,Operation>	deleteRouteCallable()
OperationCallable<DeleteRouteRequest,com.google.protobuf.Empty,OperationMetadata>	deleteRouteOperationCallable()
UnaryCallable<DeleteStreamRequest,Operation>	deleteStreamCallable()
OperationCallable<DeleteStreamRequest,com.google.protobuf.Empty,OperationMetadata>	deleteStreamOperationCallable()
UnaryCallable<DiscoverConnectionProfileRequest,DiscoverConnectionProfileResponse>	discoverConnectionProfileCallable()
UnaryCallable<FetchStaticIpsRequest,FetchStaticIpsResponse>	fetchStaticIpsCallable()
UnaryCallable<FetchStaticIpsRequest,DatastreamClient.FetchStaticIpsPagedResponse>	fetchStaticIpsPagedCallable()
UnaryCallable<GetConnectionProfileRequest,ConnectionProfile>	getConnectionProfileCallable()
HttpJsonOperationsStub	getHttpJsonOperationsStub()
UnaryCallable<GetLocationRequest,Location>	getLocationCallable()
static List<ApiMethodDescriptor>	getMethodDescriptors()
UnaryCallable<GetPrivateConnectionRequest,PrivateConnection>	getPrivateConnectionCallable()
UnaryCallable<GetRouteRequest,Route>	getRouteCallable()
UnaryCallable<GetStreamRequest,Stream>	getStreamCallable()
UnaryCallable<GetStreamObjectRequest,StreamObject>	getStreamObjectCallable()
boolean	isShutdown()
boolean	isTerminated()
UnaryCallable<ListConnectionProfilesRequest,ListConnectionProfilesResponse>	listConnectionProfilesCallable()
UnaryCallable<ListConnectionProfilesRequest,DatastreamClient.ListConnectionProfilesPagedResponse>	listConnectionProfilesPagedCallable()
UnaryCallable<ListLocationsRequest,ListLocationsResponse>	listLocationsCallable()
UnaryCallable<ListLocationsRequest,DatastreamClient.ListLocationsPagedResponse>	listLocationsPagedCallable()
UnaryCallable<ListPrivateConnectionsRequest,ListPrivateConnectionsResponse>	listPrivateConnectionsCallable()
UnaryCallable<ListPrivateConnectionsRequest,DatastreamClient.ListPrivateConnectionsPagedResponse>	listPrivateConnectionsPagedCallable()
UnaryCallable<ListRoutesRequest,ListRoutesResponse>	listRoutesCallable()
UnaryCallable<ListRoutesRequest,DatastreamClient.ListRoutesPagedResponse>	listRoutesPagedCallable()
UnaryCallable<ListStreamObjectsRequest,ListStreamObjectsResponse>	listStreamObjectsCallable()
UnaryCallable<ListStreamObjectsRequest,DatastreamClient.ListStreamObjectsPagedResponse>	listStreamObjectsPagedCallable()
UnaryCallable<ListStreamsRequest,ListStreamsResponse>	listStreamsCallable()
UnaryCallable<ListStreamsRequest,DatastreamClient.ListStreamsPagedResponse>	listStreamsPagedCallable()
UnaryCallable<LookupStreamObjectRequest,StreamObject>	lookupStreamObjectCallable()
UnaryCallable<RunStreamRequest,Operation>	runStreamCallable()
OperationCallable<RunStreamRequest,Stream,OperationMetadata>	runStreamOperationCallable()
void	shutdown()
void	shutdownNow()
UnaryCallable<StartBackfillJobRequest,StartBackfillJobResponse>	startBackfillJobCallable()
UnaryCallable<StopBackfillJobRequest,StopBackfillJobResponse>	stopBackfillJobCallable()
UnaryCallable<UpdateConnectionProfileRequest,Operation>	updateConnectionProfileCallable()
OperationCallable<UpdateConnectionProfileRequest,ConnectionProfile,OperationMetadata>	updateConnectionProfileOperationCallable()
UnaryCallable<UpdateStreamRequest,Operation>	updateStreamCallable()
OperationCallable<UpdateStreamRequest,Stream,OperationMetadata>	updateStreamOperationCallable()

Methods inherited from class com.google.cloud.datastream.v1.stub.DatastreamStub

getOperationsStub

Methods inherited from class java.lang.Object

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

Constructor Details

HttpJsonDatastreamStub

protected HttpJsonDatastreamStub(DatastreamStubSettings settings,
 ClientContext clientContext)
                          throws IOException

Constructs an instance of HttpJsonDatastreamStub, 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.

Throws:

IOException

HttpJsonDatastreamStub

protected HttpJsonDatastreamStub(DatastreamStubSettings settings,
 ClientContext clientContext,
 HttpJsonStubCallableFactory callableFactory)
                          throws IOException

Constructs an instance of HttpJsonDatastreamStub, 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.

Throws:

IOException

Method Details

create

public static final HttpJsonDatastreamStub create(DatastreamStubSettings settings)
                                           throws IOException

Throws:

IOException

create

public static final HttpJsonDatastreamStub create(ClientContext clientContext)
                                           throws IOException

Throws:

IOException

create

public static final HttpJsonDatastreamStub create(ClientContext clientContext,
 HttpJsonStubCallableFactory callableFactory)
                                           throws IOException

Throws:

IOException

getMethodDescriptors

@InternalApi
public static List<ApiMethodDescriptor> getMethodDescriptors()

getHttpJsonOperationsStub

public HttpJsonOperationsStub getHttpJsonOperationsStub()

Overrides:

getHttpJsonOperationsStub in class DatastreamStub

listConnectionProfilesCallable

public UnaryCallable<ListConnectionProfilesRequest,ListConnectionProfilesResponse> listConnectionProfilesCallable()

Overrides:

listConnectionProfilesCallable in class DatastreamStub

listConnectionProfilesPagedCallable

public UnaryCallable<ListConnectionProfilesRequest,DatastreamClient.ListConnectionProfilesPagedResponse> listConnectionProfilesPagedCallable()

Overrides:

listConnectionProfilesPagedCallable in class DatastreamStub

getConnectionProfileCallable

public UnaryCallable<GetConnectionProfileRequest,ConnectionProfile> getConnectionProfileCallable()

Overrides:

getConnectionProfileCallable in class DatastreamStub

createConnectionProfileCallable

public UnaryCallable<CreateConnectionProfileRequest,Operation> createConnectionProfileCallable()

Overrides:

createConnectionProfileCallable in class DatastreamStub

createConnectionProfileOperationCallable

public OperationCallable<CreateConnectionProfileRequest,ConnectionProfile,OperationMetadata> createConnectionProfileOperationCallable()

Overrides:

createConnectionProfileOperationCallable in class DatastreamStub

updateConnectionProfileCallable

public UnaryCallable<UpdateConnectionProfileRequest,Operation> updateConnectionProfileCallable()

Overrides:

updateConnectionProfileCallable in class DatastreamStub

updateConnectionProfileOperationCallable

public OperationCallable<UpdateConnectionProfileRequest,ConnectionProfile,OperationMetadata> updateConnectionProfileOperationCallable()

Overrides:

updateConnectionProfileOperationCallable in class DatastreamStub

deleteConnectionProfileCallable

public UnaryCallable<DeleteConnectionProfileRequest,Operation> deleteConnectionProfileCallable()

Overrides:

deleteConnectionProfileCallable in class DatastreamStub

deleteConnectionProfileOperationCallable

public OperationCallable<DeleteConnectionProfileRequest,com.google.protobuf.Empty,OperationMetadata> deleteConnectionProfileOperationCallable()

Overrides:

deleteConnectionProfileOperationCallable in class DatastreamStub

discoverConnectionProfileCallable

public UnaryCallable<DiscoverConnectionProfileRequest,DiscoverConnectionProfileResponse> discoverConnectionProfileCallable()

Overrides:

discoverConnectionProfileCallable in class DatastreamStub

listStreamsCallable

public UnaryCallable<ListStreamsRequest,ListStreamsResponse> listStreamsCallable()

Overrides:

listStreamsCallable in class DatastreamStub

listStreamsPagedCallable

public UnaryCallable<ListStreamsRequest,DatastreamClient.ListStreamsPagedResponse> listStreamsPagedCallable()

Overrides:

listStreamsPagedCallable in class DatastreamStub

getStreamCallable

public UnaryCallable<GetStreamRequest,Stream> getStreamCallable()

Overrides:

getStreamCallable in class DatastreamStub

createStreamCallable

public UnaryCallable<CreateStreamRequest,Operation> createStreamCallable()

Overrides:

createStreamCallable in class DatastreamStub

createStreamOperationCallable

public OperationCallable<CreateStreamRequest,Stream,OperationMetadata> createStreamOperationCallable()

Overrides:

createStreamOperationCallable in class DatastreamStub

updateStreamCallable

public UnaryCallable<UpdateStreamRequest,Operation> updateStreamCallable()

Overrides:

updateStreamCallable in class DatastreamStub

updateStreamOperationCallable

public OperationCallable<UpdateStreamRequest,Stream,OperationMetadata> updateStreamOperationCallable()

Overrides:

updateStreamOperationCallable in class DatastreamStub

deleteStreamCallable

public UnaryCallable<DeleteStreamRequest,Operation> deleteStreamCallable()

Overrides:

deleteStreamCallable in class DatastreamStub

deleteStreamOperationCallable

public OperationCallable<DeleteStreamRequest,com.google.protobuf.Empty,OperationMetadata> deleteStreamOperationCallable()

Overrides:

deleteStreamOperationCallable in class DatastreamStub

runStreamCallable

public UnaryCallable<RunStreamRequest,Operation> runStreamCallable()

Overrides:

runStreamCallable in class DatastreamStub

runStreamOperationCallable

public OperationCallable<RunStreamRequest,Stream,OperationMetadata> runStreamOperationCallable()

Overrides:

runStreamOperationCallable in class DatastreamStub

getStreamObjectCallable

public UnaryCallable<GetStreamObjectRequest,StreamObject> getStreamObjectCallable()

Overrides:

getStreamObjectCallable in class DatastreamStub

lookupStreamObjectCallable

public UnaryCallable<LookupStreamObjectRequest,StreamObject> lookupStreamObjectCallable()

Overrides:

lookupStreamObjectCallable in class DatastreamStub

listStreamObjectsCallable

public UnaryCallable<ListStreamObjectsRequest,ListStreamObjectsResponse> listStreamObjectsCallable()

Overrides:

listStreamObjectsCallable in class DatastreamStub

listStreamObjectsPagedCallable

public UnaryCallable<ListStreamObjectsRequest,DatastreamClient.ListStreamObjectsPagedResponse> listStreamObjectsPagedCallable()

Overrides:

listStreamObjectsPagedCallable in class DatastreamStub

startBackfillJobCallable

public UnaryCallable<StartBackfillJobRequest,StartBackfillJobResponse> startBackfillJobCallable()

Overrides:

startBackfillJobCallable in class DatastreamStub

stopBackfillJobCallable

public UnaryCallable<StopBackfillJobRequest,StopBackfillJobResponse> stopBackfillJobCallable()

Overrides:

stopBackfillJobCallable in class DatastreamStub

fetchStaticIpsCallable

public UnaryCallable<FetchStaticIpsRequest,FetchStaticIpsResponse> fetchStaticIpsCallable()

Overrides:

fetchStaticIpsCallable in class DatastreamStub

fetchStaticIpsPagedCallable

public UnaryCallable<FetchStaticIpsRequest,DatastreamClient.FetchStaticIpsPagedResponse> fetchStaticIpsPagedCallable()

Overrides:

fetchStaticIpsPagedCallable in class DatastreamStub

createPrivateConnectionCallable

public UnaryCallable<CreatePrivateConnectionRequest,Operation> createPrivateConnectionCallable()

Overrides:

createPrivateConnectionCallable in class DatastreamStub

createPrivateConnectionOperationCallable

public OperationCallable<CreatePrivateConnectionRequest,PrivateConnection,OperationMetadata> createPrivateConnectionOperationCallable()

Overrides:

createPrivateConnectionOperationCallable in class DatastreamStub

getPrivateConnectionCallable

public UnaryCallable<GetPrivateConnectionRequest,PrivateConnection> getPrivateConnectionCallable()

Overrides:

getPrivateConnectionCallable in class DatastreamStub

listPrivateConnectionsCallable

public UnaryCallable<ListPrivateConnectionsRequest,ListPrivateConnectionsResponse> listPrivateConnectionsCallable()

Overrides:

listPrivateConnectionsCallable in class DatastreamStub

listPrivateConnectionsPagedCallable

public UnaryCallable<ListPrivateConnectionsRequest,DatastreamClient.ListPrivateConnectionsPagedResponse> listPrivateConnectionsPagedCallable()

Overrides:

listPrivateConnectionsPagedCallable in class DatastreamStub

deletePrivateConnectionCallable

public UnaryCallable<DeletePrivateConnectionRequest,Operation> deletePrivateConnectionCallable()

Overrides:

deletePrivateConnectionCallable in class DatastreamStub

deletePrivateConnectionOperationCallable

public OperationCallable<DeletePrivateConnectionRequest,com.google.protobuf.Empty,OperationMetadata> deletePrivateConnectionOperationCallable()

Overrides:

deletePrivateConnectionOperationCallable in class DatastreamStub

createRouteCallable

public UnaryCallable<CreateRouteRequest,Operation> createRouteCallable()

Overrides:

createRouteCallable in class DatastreamStub

createRouteOperationCallable

public OperationCallable<CreateRouteRequest,Route,OperationMetadata> createRouteOperationCallable()

Overrides:

createRouteOperationCallable in class DatastreamStub

getRouteCallable

public UnaryCallable<GetRouteRequest,Route> getRouteCallable()

Overrides:

getRouteCallable in class DatastreamStub

listRoutesCallable

public UnaryCallable<ListRoutesRequest,ListRoutesResponse> listRoutesCallable()

Overrides:

listRoutesCallable in class DatastreamStub

listRoutesPagedCallable

public UnaryCallable<ListRoutesRequest,DatastreamClient.ListRoutesPagedResponse> listRoutesPagedCallable()

Overrides:

listRoutesPagedCallable in class DatastreamStub

deleteRouteCallable

public UnaryCallable<DeleteRouteRequest,Operation> deleteRouteCallable()

Overrides:

deleteRouteCallable in class DatastreamStub

deleteRouteOperationCallable

public OperationCallable<DeleteRouteRequest,com.google.protobuf.Empty,OperationMetadata> deleteRouteOperationCallable()

Overrides:

deleteRouteOperationCallable in class DatastreamStub

listLocationsCallable

public UnaryCallable<ListLocationsRequest,ListLocationsResponse> listLocationsCallable()

Overrides:

listLocationsCallable in class DatastreamStub

listLocationsPagedCallable

public UnaryCallable<ListLocationsRequest,DatastreamClient.ListLocationsPagedResponse> listLocationsPagedCallable()

Overrides:

listLocationsPagedCallable in class DatastreamStub

getLocationCallable

public UnaryCallable<GetLocationRequest,Location> getLocationCallable()

Overrides:

getLocationCallable in class DatastreamStub

close

public final void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in class DatastreamStub

shutdown

public void shutdown()

isShutdown

public boolean isShutdown()

isTerminated

public boolean isTerminated()

shutdownNow

public void shutdownNow()

awaitTermination

public boolean awaitTermination(long duration,
 TimeUnit unit)
                         throws InterruptedException

Throws:

InterruptedException