Package com.google.cloud.datastream.v1

Class DatastreamGrpc.DatastreamBlockingStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractBlockingStub<DatastreamGrpc.DatastreamBlockingStub>

com.google.cloud.datastream.v1.DatastreamGrpc.DatastreamBlockingStub

Enclosing class:

DatastreamGrpc

public static final class DatastreamGrpc.DatastreamBlockingStub
extends io.grpc.stub.AbstractBlockingStub<DatastreamGrpc.DatastreamBlockingStub>

A stub to allow clients to do limited synchronous rpc calls to service Datastream.

 Datastream service
 

Nested Class Summary

Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>

Method Summary

Modifier and Type	Method	Description
protected DatastreamGrpc.DatastreamBlockingStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
Operation	createConnectionProfile(CreateConnectionProfileRequest request)	Use this method to create a connection profile in a project and location.
Operation	createPrivateConnection(CreatePrivateConnectionRequest request)	Use this method to create a private connectivity configuration.
Operation	createRoute(CreateRouteRequest request)	Use this method to create a route for a private connectivity configuration in a project and location.
Operation	createStream(CreateStreamRequest request)	Use this method to create a stream.
Operation	deleteConnectionProfile(DeleteConnectionProfileRequest request)	Use this method to delete a connection profile.
Operation	deletePrivateConnection(DeletePrivateConnectionRequest request)	Use this method to delete a private connectivity configuration.
Operation	deleteRoute(DeleteRouteRequest request)	Use this method to delete a route.
Operation	deleteStream(DeleteStreamRequest request)	Use this method to delete a stream.
DiscoverConnectionProfileResponse	discoverConnectionProfile(DiscoverConnectionProfileRequest request)	Use this method to discover a connection profile.
FetchStaticIpsResponse	fetchStaticIps(FetchStaticIpsRequest request)	The FetchStaticIps API call exposes the static IP addresses used by Datastream.
ConnectionProfile	getConnectionProfile(GetConnectionProfileRequest request)	Use this method to get details about a connection profile.
PrivateConnection	getPrivateConnection(GetPrivateConnectionRequest request)	Use this method to get details about a private connectivity configuration.
Route	getRoute(GetRouteRequest request)	Use this method to get details about a route.
Stream	getStream(GetStreamRequest request)	Use this method to get details about a stream.
StreamObject	getStreamObject(GetStreamObjectRequest request)	Use this method to get details about a stream object.
ListConnectionProfilesResponse	listConnectionProfiles(ListConnectionProfilesRequest request)	Use this method to list connection profiles created in a project and location.
ListPrivateConnectionsResponse	listPrivateConnections(ListPrivateConnectionsRequest request)	Use this method to list private connectivity configurations in a project and location.
ListRoutesResponse	listRoutes(ListRoutesRequest request)	Use this method to list routes created for a private connectivity configuration in a project and location.
ListStreamObjectsResponse	listStreamObjects(ListStreamObjectsRequest request)	Use this method to list the objects of a specific stream.
ListStreamsResponse	listStreams(ListStreamsRequest request)	Use this method to list streams in a project and location.
StreamObject	lookupStreamObject(LookupStreamObjectRequest request)	Use this method to look up a stream object by its source object identifier.
Operation	runStream(RunStreamRequest request)	Use this method to start, resume or recover a stream with a non default CDC strategy.
StartBackfillJobResponse	startBackfillJob(StartBackfillJobRequest request)	Use this method to start a backfill job for the specified stream object.
StopBackfillJobResponse	stopBackfillJob(StopBackfillJobRequest request)	Use this method to stop a backfill job for the specified stream object.
Operation	updateConnectionProfile(UpdateConnectionProfileRequest request)	Use this method to update the parameters of a connection profile.
Operation	updateStream(UpdateStreamRequest request)	Use this method to update the configuration of a stream.

Methods inherited from class io.grpc.stub.AbstractBlockingStub

newStub, newStub

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady

Methods inherited from class java.lang.Object

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

Method Details

build

protected DatastreamGrpc.DatastreamBlockingStub build(io.grpc.Channel channel,
 io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<DatastreamGrpc.DatastreamBlockingStub>

listConnectionProfiles

public ListConnectionProfilesResponse listConnectionProfiles(ListConnectionProfilesRequest request)

 Use this method to list connection profiles created in a project and
 location.
 

getConnectionProfile

public ConnectionProfile getConnectionProfile(GetConnectionProfileRequest request)

 Use this method to get details about a connection profile.
 

createConnectionProfile

public Operation createConnectionProfile(CreateConnectionProfileRequest request)

 Use this method to create a connection profile in a project and location.
 

updateConnectionProfile

public Operation updateConnectionProfile(UpdateConnectionProfileRequest request)

 Use this method to update the parameters of a connection profile.
 

deleteConnectionProfile

public Operation deleteConnectionProfile(DeleteConnectionProfileRequest request)

 Use this method to delete a connection profile.
 

discoverConnectionProfile

public DiscoverConnectionProfileResponse discoverConnectionProfile(DiscoverConnectionProfileRequest request)

 Use this method to discover a connection profile.
 The discover API call exposes the data objects and metadata belonging to
 the profile. Typically, a request returns children data objects of a
 parent data object that's optionally supplied in the request.
 

listStreams

public ListStreamsResponse listStreams(ListStreamsRequest request)

 Use this method to list streams in a project and location.
 

getStream

public Stream getStream(GetStreamRequest request)

 Use this method to get details about a stream.
 

createStream

public Operation createStream(CreateStreamRequest request)

 Use this method to create a stream.
 

updateStream

public Operation updateStream(UpdateStreamRequest request)

 Use this method to update the configuration of a stream.
 

deleteStream

public Operation deleteStream(DeleteStreamRequest request)

 Use this method to delete a stream.
 

runStream

public Operation runStream(RunStreamRequest request)

 Use this method to start, resume or recover a stream with a non default CDC
 strategy.
 

getStreamObject

public StreamObject getStreamObject(GetStreamObjectRequest request)

 Use this method to get details about a stream object.
 

lookupStreamObject

public StreamObject lookupStreamObject(LookupStreamObjectRequest request)

 Use this method to look up a stream object by its source object identifier.
 

listStreamObjects

public ListStreamObjectsResponse listStreamObjects(ListStreamObjectsRequest request)

 Use this method to list the objects of a specific stream.
 

startBackfillJob

public StartBackfillJobResponse startBackfillJob(StartBackfillJobRequest request)

 Use this method to start a backfill job for the specified stream object.
 

stopBackfillJob

public StopBackfillJobResponse stopBackfillJob(StopBackfillJobRequest request)

 Use this method to stop a backfill job for the specified stream object.
 

fetchStaticIps

public FetchStaticIpsResponse fetchStaticIps(FetchStaticIpsRequest request)

 The FetchStaticIps API call exposes the static IP addresses used by
 Datastream.
 

createPrivateConnection

public Operation createPrivateConnection(CreatePrivateConnectionRequest request)

 Use this method to create a private connectivity configuration.
 

getPrivateConnection

public PrivateConnection getPrivateConnection(GetPrivateConnectionRequest request)

 Use this method to get details about a private connectivity configuration.
 

listPrivateConnections

public ListPrivateConnectionsResponse listPrivateConnections(ListPrivateConnectionsRequest request)

 Use this method to list private connectivity configurations in a project
 and location.
 

deletePrivateConnection

public Operation deletePrivateConnection(DeletePrivateConnectionRequest request)

 Use this method to delete a private connectivity configuration.
 

createRoute

public Operation createRoute(CreateRouteRequest request)

 Use this method to create a route for a private connectivity configuration
 in a project and location.
 

getRoute

public Route getRoute(GetRouteRequest request)

 Use this method to get details about a route.
 

listRoutes

public ListRoutesResponse listRoutes(ListRoutesRequest request)

 Use this method to list routes created for a private connectivity
 configuration in a project and location.
 

deleteRoute

public Operation deleteRoute(DeleteRouteRequest request)

 Use this method to delete a route.