Package com.google.cloud.datastream.v1alpha1.stub

Class GrpcDatastreamStub

java.lang.Object

com.google.cloud.datastream.v1alpha1.stub.DatastreamStub

com.google.cloud.datastream.v1alpha1.stub.GrpcDatastreamStub

All Implemented Interfaces:

BackgroundResource, AutoCloseable

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

gRPC 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	GrpcDatastreamStub(DatastreamStubSettings settings, ClientContext clientContext)	Constructs an instance of GrpcDatastreamStub, using the given settings.
protected	GrpcDatastreamStub(DatastreamStubSettings settings, ClientContext clientContext, GrpcStubCallableFactory callableFactory)	Constructs an instance of GrpcDatastreamStub, using the given settings.

Method Summary

Modifier and Type	Method	Description
boolean	awaitTermination(long duration, TimeUnit unit)
final void	close()
static final GrpcDatastreamStub	create(ClientContext clientContext)
static final GrpcDatastreamStub	create(ClientContext clientContext, GrpcStubCallableFactory callableFactory)
static final GrpcDatastreamStub	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<FetchErrorsRequest,Operation>	fetchErrorsCallable()
OperationCallable<FetchErrorsRequest,FetchErrorsResponse,OperationMetadata>	fetchErrorsOperationCallable()
UnaryCallable<FetchStaticIpsRequest,FetchStaticIpsResponse>	fetchStaticIpsCallable()
UnaryCallable<FetchStaticIpsRequest,DatastreamClient.FetchStaticIpsPagedResponse>	fetchStaticIpsPagedCallable()
UnaryCallable<GetConnectionProfileRequest,ConnectionProfile>	getConnectionProfileCallable()
GrpcOperationsStub	getOperationsStub()
UnaryCallable<GetPrivateConnectionRequest,PrivateConnection>	getPrivateConnectionCallable()
UnaryCallable<GetRouteRequest,Route>	getRouteCallable()
UnaryCallable<GetStreamRequest,Stream>	getStreamCallable()
boolean	isShutdown()
boolean	isTerminated()
UnaryCallable<ListConnectionProfilesRequest,ListConnectionProfilesResponse>	listConnectionProfilesCallable()
UnaryCallable<ListConnectionProfilesRequest,DatastreamClient.ListConnectionProfilesPagedResponse>	listConnectionProfilesPagedCallable()
UnaryCallable<ListPrivateConnectionsRequest,ListPrivateConnectionsResponse>	listPrivateConnectionsCallable()
UnaryCallable<ListPrivateConnectionsRequest,DatastreamClient.ListPrivateConnectionsPagedResponse>	listPrivateConnectionsPagedCallable()
UnaryCallable<ListRoutesRequest,ListRoutesResponse>	listRoutesCallable()
UnaryCallable<ListRoutesRequest,DatastreamClient.ListRoutesPagedResponse>	listRoutesPagedCallable()
UnaryCallable<ListStreamsRequest,ListStreamsResponse>	listStreamsCallable()
UnaryCallable<ListStreamsRequest,DatastreamClient.ListStreamsPagedResponse>	listStreamsPagedCallable()
void	shutdown()
void	shutdownNow()
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.v1alpha1.stub.DatastreamStub

getHttpJsonOperationsStub

Methods inherited from class java.lang.Object

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

Constructor Details

GrpcDatastreamStub

protected GrpcDatastreamStub(DatastreamStubSettings settings,
 ClientContext clientContext)
                      throws IOException

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

GrpcDatastreamStub

protected GrpcDatastreamStub(DatastreamStubSettings settings,
 ClientContext clientContext,
 GrpcStubCallableFactory callableFactory)
                      throws IOException

Constructs an instance of GrpcDatastreamStub, 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 GrpcDatastreamStub create(DatastreamStubSettings settings)
                                       throws IOException

Throws:

IOException

create

public static final GrpcDatastreamStub create(ClientContext clientContext)
                                       throws IOException

Throws:

IOException

create

public static final GrpcDatastreamStub create(ClientContext clientContext,
 GrpcStubCallableFactory callableFactory)
                                       throws IOException

Throws:

IOException

getOperationsStub

public GrpcOperationsStub getOperationsStub()

Overrides:

getOperationsStub 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

fetchErrorsCallable

public UnaryCallable<FetchErrorsRequest,Operation> fetchErrorsCallable()

Overrides:

fetchErrorsCallable in class DatastreamStub

fetchErrorsOperationCallable

public OperationCallable<FetchErrorsRequest,FetchErrorsResponse,OperationMetadata> fetchErrorsOperationCallable()

Overrides:

fetchErrorsOperationCallable 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

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