Summary of entries of Methods for datastream.
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient
DatastreamAsyncClient(*, credentials: typing.Optional[google.auth.credentials.Credentials] = None, transport: typing.Optional[typing.Union[str, google.cloud.datastream_v1.services.datastream.transports.base.DatastreamTransport, typing.Callable[[...], google.cloud.datastream_v1.services.datastream.transports.base.DatastreamTransport]]] = 'grpc_asyncio', client_options: typing.Optional[google.api_core.client_options.ClientOptions] = None, client_info: google.api_core.gapic_v1.client_info.ClientInfo =
Instantiates the datastream async client.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.cancel_operation
cancel_operation(
request: typing.Optional[
google.longrunning.operations_pb2.CancelOperationRequest
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> None
Starts asynchronous cancellation on a long-running operation.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.cancel_operation
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.common_billing_account_path
common_billing_account_path(billing_account: str) -> str
Returns a fully-qualified billing_account string.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.common_billing_account_path
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.common_folder_path
common_folder_path(folder: str) -> str
Returns a fully-qualified folder string.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.common_folder_path
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.common_location_path
common_location_path(project: str, location: str) -> str
Returns a fully-qualified location string.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.common_location_path
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.common_organization_path
common_organization_path(organization: str) -> str
Returns a fully-qualified organization string.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.common_organization_path
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.common_project_path
common_project_path(project: str) -> str
Returns a fully-qualified project string.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.common_project_path
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.connection_profile_path
connection_profile_path(
project: str, location: str, connection_profile: str
) -> str
Returns a fully-qualified connection_profile string.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.connection_profile_path
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.create_connection_profile
create_connection_profile(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.CreateConnectionProfileRequest,
dict,
]
] = None,
*,
parent: typing.Optional[str] = None,
connection_profile: typing.Optional[
google.cloud.datastream_v1.types.datastream_resources.ConnectionProfile
] = None,
connection_profile_id: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation_async.AsyncOperation
Use this method to create a connection profile in a project and location.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.create_connection_profile
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.create_private_connection
create_private_connection(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.CreatePrivateConnectionRequest,
dict,
]
] = None,
*,
parent: typing.Optional[str] = None,
private_connection: typing.Optional[
google.cloud.datastream_v1.types.datastream_resources.PrivateConnection
] = None,
private_connection_id: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation_async.AsyncOperation
Use this method to create a private connectivity configuration.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.create_private_connection
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.create_route
create_route(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.CreateRouteRequest, dict
]
] = None,
*,
parent: typing.Optional[str] = None,
route: typing.Optional[
google.cloud.datastream_v1.types.datastream_resources.Route
] = None,
route_id: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation_async.AsyncOperation
Use this method to create a route for a private connectivity configuration in a project and location.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.create_route
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.create_stream
create_stream(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.CreateStreamRequest, dict
]
] = None,
*,
parent: typing.Optional[str] = None,
stream: typing.Optional[
google.cloud.datastream_v1.types.datastream_resources.Stream
] = None,
stream_id: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation_async.AsyncOperation
Use this method to create a stream.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.create_stream
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.delete_connection_profile
delete_connection_profile(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.DeleteConnectionProfileRequest,
dict,
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation_async.AsyncOperation
Use this method to delete a connection profile.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.delete_connection_profile
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.delete_operation
delete_operation(
request: typing.Optional[
google.longrunning.operations_pb2.DeleteOperationRequest
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> None
Deletes a long-running operation.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.delete_operation
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.delete_private_connection
delete_private_connection(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.DeletePrivateConnectionRequest,
dict,
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation_async.AsyncOperation
Use this method to delete a private connectivity configuration.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.delete_private_connection
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.delete_route
delete_route(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.DeleteRouteRequest, dict
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation_async.AsyncOperation
Use this method to delete a route.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.delete_route
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.delete_stream
delete_stream(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.DeleteStreamRequest, dict
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation_async.AsyncOperation
Use this method to delete a stream.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.delete_stream
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.discover_connection_profile
discover_connection_profile(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.DiscoverConnectionProfileRequest,
dict,
]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.types.datastream.DiscoverConnectionProfileResponse
Use this method to discover a connection profile.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.discover_connection_profile
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.fetch_static_ips
fetch_static_ips(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.FetchStaticIpsRequest, dict
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.services.datastream.pagers.FetchStaticIpsAsyncPager
The FetchStaticIps API call exposes the static IP addresses used by Datastream.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.fetch_static_ips
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.from_service_account_file
from_service_account_file(filename: str, *args, **kwargs)
Creates an instance of this client using the provided credentials file.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.from_service_account_file
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.from_service_account_info
from_service_account_info(info: dict, *args, **kwargs)
Creates an instance of this client using the provided credentials info.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.from_service_account_info
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.from_service_account_json
from_service_account_json(filename: str, *args, **kwargs)
Creates an instance of this client using the provided credentials file.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.from_service_account_json
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_connection_profile
get_connection_profile(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.GetConnectionProfileRequest,
dict,
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.types.datastream_resources.ConnectionProfile
Use this method to get details about a connection profile.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_connection_profile
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_location
get_location(
request: typing.Optional[
google.cloud.location.locations_pb2.GetLocationRequest
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.location.locations_pb2.Location
Gets information about a location.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_location
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source(
client_options: typing.Optional[
google.api_core.client_options.ClientOptions
] = None,
)
Return the API endpoint and client cert source for mutual TLS.
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_operation
get_operation(
request: typing.Optional[
google.longrunning.operations_pb2.GetOperationRequest
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.longrunning.operations_pb2.Operation
Gets the latest state of a long-running operation.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_operation
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_private_connection
get_private_connection(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.GetPrivateConnectionRequest,
dict,
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.types.datastream_resources.PrivateConnection
Use this method to get details about a private connectivity configuration.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_private_connection
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_route
get_route(
request: typing.Optional[
typing.Union[google.cloud.datastream_v1.types.datastream.GetRouteRequest, dict]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.types.datastream_resources.Route
Use this method to get details about a route.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_route
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_stream
get_stream(
request: typing.Optional[
typing.Union[google.cloud.datastream_v1.types.datastream.GetStreamRequest, dict]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.types.datastream_resources.Stream
Use this method to get details about a stream.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_stream
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_stream_object
get_stream_object(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.GetStreamObjectRequest, dict
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.types.datastream_resources.StreamObject
Use this method to get details about a stream object.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_stream_object
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_transport_class
get_transport_class(
label: typing.Optional[str] = None,
) -> typing.Type[
google.cloud.datastream_v1.services.datastream.transports.base.DatastreamTransport
]
Returns an appropriate transport class.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_transport_class
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_connection_profiles
list_connection_profiles(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.ListConnectionProfilesRequest,
dict,
]
] = None,
*,
parent: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> (
google.cloud.datastream_v1.services.datastream.pagers.ListConnectionProfilesAsyncPager
)
Use this method to list connection profiles created in a project and location.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_connection_profiles
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_locations
list_locations(
request: typing.Optional[
google.cloud.location.locations_pb2.ListLocationsRequest
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.location.locations_pb2.ListLocationsResponse
Lists information about the supported locations for this service.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_locations
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_operations
list_operations(
request: typing.Optional[
google.longrunning.operations_pb2.ListOperationsRequest
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.longrunning.operations_pb2.ListOperationsResponse
Lists operations that match the specified filter in the request.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_operations
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_private_connections
list_private_connections(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.ListPrivateConnectionsRequest,
dict,
]
] = None,
*,
parent: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> (
google.cloud.datastream_v1.services.datastream.pagers.ListPrivateConnectionsAsyncPager
)
Use this method to list private connectivity configurations in a project and location.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_private_connections
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_routes
list_routes(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.ListRoutesRequest, dict
]
] = None,
*,
parent: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.services.datastream.pagers.ListRoutesAsyncPager
Use this method to list routes created for a private connectivity configuration in a project and location.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_routes
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_stream_objects
list_stream_objects(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.ListStreamObjectsRequest, dict
]
] = None,
*,
parent: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.services.datastream.pagers.ListStreamObjectsAsyncPager
Use this method to list the objects of a specific stream.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_stream_objects
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_streams
list_streams(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.ListStreamsRequest, dict
]
] = None,
*,
parent: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.services.datastream.pagers.ListStreamsAsyncPager
Use this method to list streams in a project and location.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_streams
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.lookup_stream_object
lookup_stream_object(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.LookupStreamObjectRequest, dict
]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.types.datastream_resources.StreamObject
Use this method to look up a stream object by its source object identifier.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.lookup_stream_object
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.networks_path
networks_path(project: str, network: str) -> str
Returns a fully-qualified networks string.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.networks_path
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_common_billing_account_path
parse_common_billing_account_path(path: str) -> typing.Dict[str, str]
Parse a billing_account path into its component segments.
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_common_folder_path
parse_common_folder_path(path: str) -> typing.Dict[str, str]
Parse a folder path into its component segments.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_common_folder_path
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_common_location_path
parse_common_location_path(path: str) -> typing.Dict[str, str]
Parse a location path into its component segments.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_common_location_path
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_common_organization_path
parse_common_organization_path(path: str) -> typing.Dict[str, str]
Parse a organization path into its component segments.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_common_organization_path
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_common_project_path
parse_common_project_path(path: str) -> typing.Dict[str, str]
Parse a project path into its component segments.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_common_project_path
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_connection_profile_path
parse_connection_profile_path(path: str) -> typing.Dict[str, str]
Parses a connection_profile path into its component segments.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_connection_profile_path
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_networks_path
parse_networks_path(path: str) -> typing.Dict[str, str]
Parses a networks path into its component segments.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_networks_path
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_private_connection_path
parse_private_connection_path(path: str) -> typing.Dict[str, str]
Parses a private_connection path into its component segments.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_private_connection_path
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_route_path
parse_route_path(path: str) -> typing.Dict[str, str]
Parses a route path into its component segments.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_route_path
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_stream_object_path
parse_stream_object_path(path: str) -> typing.Dict[str, str]
Parses a stream_object path into its component segments.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_stream_object_path
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_stream_path
parse_stream_path(path: str) -> typing.Dict[str, str]
Parses a stream path into its component segments.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_stream_path
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.private_connection_path
private_connection_path(
project: str, location: str, private_connection: str
) -> str
Returns a fully-qualified private_connection string.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.private_connection_path
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.route_path
route_path(project: str, location: str, private_connection: str, route: str) -> str
Returns a fully-qualified route string.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.route_path
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.start_backfill_job
start_backfill_job(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.StartBackfillJobRequest, dict
]
] = None,
*,
object_: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.types.datastream.StartBackfillJobResponse
Use this method to start a backfill job for the specified stream object.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.start_backfill_job
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.stop_backfill_job
stop_backfill_job(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.StopBackfillJobRequest, dict
]
] = None,
*,
object_: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.types.datastream.StopBackfillJobResponse
Use this method to stop a backfill job for the specified stream object.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.stop_backfill_job
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.stream_object_path
stream_object_path(project: str, location: str, stream: str, object: str) -> str
Returns a fully-qualified stream_object string.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.stream_object_path
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.stream_path
stream_path(project: str, location: str, stream: str) -> str
Returns a fully-qualified stream string.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.stream_path
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.update_connection_profile
update_connection_profile(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.UpdateConnectionProfileRequest,
dict,
]
] = None,
*,
connection_profile: typing.Optional[
google.cloud.datastream_v1.types.datastream_resources.ConnectionProfile
] = None,
update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation_async.AsyncOperation
Use this method to update the parameters of a connection profile.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.update_connection_profile
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.update_stream
update_stream(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.UpdateStreamRequest, dict
]
] = None,
*,
stream: typing.Optional[
google.cloud.datastream_v1.types.datastream_resources.Stream
] = None,
update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation_async.AsyncOperation
Use this method to update the configuration of a stream.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.update_stream
google.cloud.datastream_v1.services.datastream.DatastreamClient
DatastreamClient(*, credentials: typing.Optional[google.auth.credentials.Credentials] = None, transport: typing.Optional[typing.Union[str, google.cloud.datastream_v1.services.datastream.transports.base.DatastreamTransport, typing.Callable[[...], google.cloud.datastream_v1.services.datastream.transports.base.DatastreamTransport]]] = None, client_options: typing.Optional[typing.Union[google.api_core.client_options.ClientOptions, dict]] = None, client_info: google.api_core.gapic_v1.client_info.ClientInfo =
Instantiates the datastream client.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient
google.cloud.datastream_v1.services.datastream.DatastreamClient.__exit__
__exit__(type, value, traceback)
Releases underlying transport's resources.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.exit
google.cloud.datastream_v1.services.datastream.DatastreamClient.cancel_operation
cancel_operation(
request: typing.Optional[
google.longrunning.operations_pb2.CancelOperationRequest
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> None
Starts asynchronous cancellation on a long-running operation.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.cancel_operation
google.cloud.datastream_v1.services.datastream.DatastreamClient.common_billing_account_path
common_billing_account_path(billing_account: str) -> str
Returns a fully-qualified billing_account string.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.common_billing_account_path
google.cloud.datastream_v1.services.datastream.DatastreamClient.common_folder_path
common_folder_path(folder: str) -> str
Returns a fully-qualified folder string.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.common_folder_path
google.cloud.datastream_v1.services.datastream.DatastreamClient.common_location_path
common_location_path(project: str, location: str) -> str
Returns a fully-qualified location string.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.common_location_path
google.cloud.datastream_v1.services.datastream.DatastreamClient.common_organization_path
common_organization_path(organization: str) -> str
Returns a fully-qualified organization string.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.common_organization_path
google.cloud.datastream_v1.services.datastream.DatastreamClient.common_project_path
common_project_path(project: str) -> str
Returns a fully-qualified project string.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.common_project_path
google.cloud.datastream_v1.services.datastream.DatastreamClient.connection_profile_path
connection_profile_path(
project: str, location: str, connection_profile: str
) -> str
Returns a fully-qualified connection_profile string.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.connection_profile_path
google.cloud.datastream_v1.services.datastream.DatastreamClient.create_connection_profile
create_connection_profile(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.CreateConnectionProfileRequest,
dict,
]
] = None,
*,
parent: typing.Optional[str] = None,
connection_profile: typing.Optional[
google.cloud.datastream_v1.types.datastream_resources.ConnectionProfile
] = None,
connection_profile_id: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation.Operation
Use this method to create a connection profile in a project and location.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.create_connection_profile
google.cloud.datastream_v1.services.datastream.DatastreamClient.create_private_connection
create_private_connection(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.CreatePrivateConnectionRequest,
dict,
]
] = None,
*,
parent: typing.Optional[str] = None,
private_connection: typing.Optional[
google.cloud.datastream_v1.types.datastream_resources.PrivateConnection
] = None,
private_connection_id: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation.Operation
Use this method to create a private connectivity configuration.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.create_private_connection
google.cloud.datastream_v1.services.datastream.DatastreamClient.create_route
create_route(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.CreateRouteRequest, dict
]
] = None,
*,
parent: typing.Optional[str] = None,
route: typing.Optional[
google.cloud.datastream_v1.types.datastream_resources.Route
] = None,
route_id: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation.Operation
Use this method to create a route for a private connectivity configuration in a project and location.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.create_route
google.cloud.datastream_v1.services.datastream.DatastreamClient.create_stream
create_stream(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.CreateStreamRequest, dict
]
] = None,
*,
parent: typing.Optional[str] = None,
stream: typing.Optional[
google.cloud.datastream_v1.types.datastream_resources.Stream
] = None,
stream_id: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation.Operation
Use this method to create a stream.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.create_stream
google.cloud.datastream_v1.services.datastream.DatastreamClient.delete_connection_profile
delete_connection_profile(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.DeleteConnectionProfileRequest,
dict,
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation.Operation
Use this method to delete a connection profile.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.delete_connection_profile
google.cloud.datastream_v1.services.datastream.DatastreamClient.delete_operation
delete_operation(
request: typing.Optional[
google.longrunning.operations_pb2.DeleteOperationRequest
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> None
Deletes a long-running operation.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.delete_operation
google.cloud.datastream_v1.services.datastream.DatastreamClient.delete_private_connection
delete_private_connection(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.DeletePrivateConnectionRequest,
dict,
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation.Operation
Use this method to delete a private connectivity configuration.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.delete_private_connection
google.cloud.datastream_v1.services.datastream.DatastreamClient.delete_route
delete_route(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.DeleteRouteRequest, dict
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation.Operation
Use this method to delete a route.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.delete_route
google.cloud.datastream_v1.services.datastream.DatastreamClient.delete_stream
delete_stream(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.DeleteStreamRequest, dict
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation.Operation
Use this method to delete a stream.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.delete_stream
google.cloud.datastream_v1.services.datastream.DatastreamClient.discover_connection_profile
discover_connection_profile(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.DiscoverConnectionProfileRequest,
dict,
]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.types.datastream.DiscoverConnectionProfileResponse
Use this method to discover a connection profile.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.discover_connection_profile
google.cloud.datastream_v1.services.datastream.DatastreamClient.fetch_static_ips
fetch_static_ips(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.FetchStaticIpsRequest, dict
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.services.datastream.pagers.FetchStaticIpsPager
The FetchStaticIps API call exposes the static IP addresses used by Datastream.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.fetch_static_ips
google.cloud.datastream_v1.services.datastream.DatastreamClient.from_service_account_file
from_service_account_file(filename: str, *args, **kwargs)
Creates an instance of this client using the provided credentials file.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.from_service_account_file
google.cloud.datastream_v1.services.datastream.DatastreamClient.from_service_account_info
from_service_account_info(info: dict, *args, **kwargs)
Creates an instance of this client using the provided credentials info.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.from_service_account_info
google.cloud.datastream_v1.services.datastream.DatastreamClient.from_service_account_json
from_service_account_json(filename: str, *args, **kwargs)
Creates an instance of this client using the provided credentials file.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.from_service_account_json
google.cloud.datastream_v1.services.datastream.DatastreamClient.get_connection_profile
get_connection_profile(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.GetConnectionProfileRequest,
dict,
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.types.datastream_resources.ConnectionProfile
Use this method to get details about a connection profile.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.get_connection_profile
google.cloud.datastream_v1.services.datastream.DatastreamClient.get_location
get_location(
request: typing.Optional[
google.cloud.location.locations_pb2.GetLocationRequest
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.location.locations_pb2.Location
Gets information about a location.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.get_location
google.cloud.datastream_v1.services.datastream.DatastreamClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source(
client_options: typing.Optional[
google.api_core.client_options.ClientOptions
] = None,
)
Deprecated.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.get_mtls_endpoint_and_cert_source
google.cloud.datastream_v1.services.datastream.DatastreamClient.get_operation
get_operation(
request: typing.Optional[
google.longrunning.operations_pb2.GetOperationRequest
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.longrunning.operations_pb2.Operation
Gets the latest state of a long-running operation.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.get_operation
google.cloud.datastream_v1.services.datastream.DatastreamClient.get_private_connection
get_private_connection(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.GetPrivateConnectionRequest,
dict,
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.types.datastream_resources.PrivateConnection
Use this method to get details about a private connectivity configuration.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.get_private_connection
google.cloud.datastream_v1.services.datastream.DatastreamClient.get_route
get_route(
request: typing.Optional[
typing.Union[google.cloud.datastream_v1.types.datastream.GetRouteRequest, dict]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.types.datastream_resources.Route
Use this method to get details about a route.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.get_route
google.cloud.datastream_v1.services.datastream.DatastreamClient.get_stream
get_stream(
request: typing.Optional[
typing.Union[google.cloud.datastream_v1.types.datastream.GetStreamRequest, dict]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.types.datastream_resources.Stream
Use this method to get details about a stream.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.get_stream
google.cloud.datastream_v1.services.datastream.DatastreamClient.get_stream_object
get_stream_object(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.GetStreamObjectRequest, dict
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.types.datastream_resources.StreamObject
Use this method to get details about a stream object.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.get_stream_object
google.cloud.datastream_v1.services.datastream.DatastreamClient.list_connection_profiles
list_connection_profiles(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.ListConnectionProfilesRequest,
dict,
]
] = None,
*,
parent: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.services.datastream.pagers.ListConnectionProfilesPager
Use this method to list connection profiles created in a project and location.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.list_connection_profiles
google.cloud.datastream_v1.services.datastream.DatastreamClient.list_locations
list_locations(
request: typing.Optional[
google.cloud.location.locations_pb2.ListLocationsRequest
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.location.locations_pb2.ListLocationsResponse
Lists information about the supported locations for this service.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.list_locations
google.cloud.datastream_v1.services.datastream.DatastreamClient.list_operations
list_operations(
request: typing.Optional[
google.longrunning.operations_pb2.ListOperationsRequest
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.longrunning.operations_pb2.ListOperationsResponse
Lists operations that match the specified filter in the request.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.list_operations
google.cloud.datastream_v1.services.datastream.DatastreamClient.list_private_connections
list_private_connections(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.ListPrivateConnectionsRequest,
dict,
]
] = None,
*,
parent: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.services.datastream.pagers.ListPrivateConnectionsPager
Use this method to list private connectivity configurations in a project and location.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.list_private_connections
google.cloud.datastream_v1.services.datastream.DatastreamClient.list_routes
list_routes(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.ListRoutesRequest, dict
]
] = None,
*,
parent: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.services.datastream.pagers.ListRoutesPager
Use this method to list routes created for a private connectivity configuration in a project and location.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.list_routes
google.cloud.datastream_v1.services.datastream.DatastreamClient.list_stream_objects
list_stream_objects(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.ListStreamObjectsRequest, dict
]
] = None,
*,
parent: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.services.datastream.pagers.ListStreamObjectsPager
Use this method to list the objects of a specific stream.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.list_stream_objects
google.cloud.datastream_v1.services.datastream.DatastreamClient.list_streams
list_streams(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.ListStreamsRequest, dict
]
] = None,
*,
parent: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.services.datastream.pagers.ListStreamsPager
Use this method to list streams in a project and location.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.list_streams
google.cloud.datastream_v1.services.datastream.DatastreamClient.lookup_stream_object
lookup_stream_object(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.LookupStreamObjectRequest, dict
]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.types.datastream_resources.StreamObject
Use this method to look up a stream object by its source object identifier.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.lookup_stream_object
google.cloud.datastream_v1.services.datastream.DatastreamClient.networks_path
networks_path(project: str, network: str) -> str
Returns a fully-qualified networks string.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.networks_path
google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_common_billing_account_path
parse_common_billing_account_path(path: str) -> typing.Dict[str, str]
Parse a billing_account path into its component segments.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_common_billing_account_path
google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_common_folder_path
parse_common_folder_path(path: str) -> typing.Dict[str, str]
Parse a folder path into its component segments.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_common_folder_path
google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_common_location_path
parse_common_location_path(path: str) -> typing.Dict[str, str]
Parse a location path into its component segments.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_common_location_path
google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_common_organization_path
parse_common_organization_path(path: str) -> typing.Dict[str, str]
Parse a organization path into its component segments.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_common_organization_path
google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_common_project_path
parse_common_project_path(path: str) -> typing.Dict[str, str]
Parse a project path into its component segments.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_common_project_path
google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_connection_profile_path
parse_connection_profile_path(path: str) -> typing.Dict[str, str]
Parses a connection_profile path into its component segments.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_connection_profile_path
google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_networks_path
parse_networks_path(path: str) -> typing.Dict[str, str]
Parses a networks path into its component segments.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_networks_path
google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_private_connection_path
parse_private_connection_path(path: str) -> typing.Dict[str, str]
Parses a private_connection path into its component segments.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_private_connection_path
google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_route_path
parse_route_path(path: str) -> typing.Dict[str, str]
Parses a route path into its component segments.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_route_path
google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_stream_object_path
parse_stream_object_path(path: str) -> typing.Dict[str, str]
Parses a stream_object path into its component segments.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_stream_object_path
google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_stream_path
parse_stream_path(path: str) -> typing.Dict[str, str]
Parses a stream path into its component segments.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_stream_path
google.cloud.datastream_v1.services.datastream.DatastreamClient.private_connection_path
private_connection_path(
project: str, location: str, private_connection: str
) -> str
Returns a fully-qualified private_connection string.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.private_connection_path
google.cloud.datastream_v1.services.datastream.DatastreamClient.route_path
route_path(project: str, location: str, private_connection: str, route: str) -> str
Returns a fully-qualified route string.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.route_path
google.cloud.datastream_v1.services.datastream.DatastreamClient.start_backfill_job
start_backfill_job(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.StartBackfillJobRequest, dict
]
] = None,
*,
object_: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.types.datastream.StartBackfillJobResponse
Use this method to start a backfill job for the specified stream object.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.start_backfill_job
google.cloud.datastream_v1.services.datastream.DatastreamClient.stop_backfill_job
stop_backfill_job(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.StopBackfillJobRequest, dict
]
] = None,
*,
object_: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.types.datastream.StopBackfillJobResponse
Use this method to stop a backfill job for the specified stream object.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.stop_backfill_job
google.cloud.datastream_v1.services.datastream.DatastreamClient.stream_object_path
stream_object_path(project: str, location: str, stream: str, object: str) -> str
Returns a fully-qualified stream_object string.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.stream_object_path
google.cloud.datastream_v1.services.datastream.DatastreamClient.stream_path
stream_path(project: str, location: str, stream: str) -> str
Returns a fully-qualified stream string.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.stream_path
google.cloud.datastream_v1.services.datastream.DatastreamClient.update_connection_profile
update_connection_profile(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.UpdateConnectionProfileRequest,
dict,
]
] = None,
*,
connection_profile: typing.Optional[
google.cloud.datastream_v1.types.datastream_resources.ConnectionProfile
] = None,
update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation.Operation
Use this method to update the parameters of a connection profile.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.update_connection_profile
google.cloud.datastream_v1.services.datastream.DatastreamClient.update_stream
update_stream(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1.types.datastream.UpdateStreamRequest, dict
]
] = None,
*,
stream: typing.Optional[
google.cloud.datastream_v1.types.datastream_resources.Stream
] = None,
update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation.Operation
Use this method to update the configuration of a stream.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.update_stream
google.cloud.datastream_v1.services.datastream.pagers.FetchStaticIpsAsyncPager
FetchStaticIpsAsyncPager(
method: typing.Callable[
[...],
typing.Awaitable[
google.cloud.datastream_v1.types.datastream.FetchStaticIpsResponse
],
],
request: google.cloud.datastream_v1.types.datastream.FetchStaticIpsRequest,
response: google.cloud.datastream_v1.types.datastream.FetchStaticIpsResponse,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)
Instantiates the pager.
See more: google.cloud.datastream_v1.services.datastream.pagers.FetchStaticIpsAsyncPager
google.cloud.datastream_v1.services.datastream.pagers.FetchStaticIpsPager
FetchStaticIpsPager(
method: typing.Callable[
[...], google.cloud.datastream_v1.types.datastream.FetchStaticIpsResponse
],
request: google.cloud.datastream_v1.types.datastream.FetchStaticIpsRequest,
response: google.cloud.datastream_v1.types.datastream.FetchStaticIpsResponse,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)
Instantiate the pager.
See more: google.cloud.datastream_v1.services.datastream.pagers.FetchStaticIpsPager
google.cloud.datastream_v1.services.datastream.pagers.ListConnectionProfilesAsyncPager
ListConnectionProfilesAsyncPager(
method: typing.Callable[
[...],
typing.Awaitable[
google.cloud.datastream_v1.types.datastream.ListConnectionProfilesResponse
],
],
request: google.cloud.datastream_v1.types.datastream.ListConnectionProfilesRequest,
response: google.cloud.datastream_v1.types.datastream.ListConnectionProfilesResponse,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)
Instantiates the pager.
See more: google.cloud.datastream_v1.services.datastream.pagers.ListConnectionProfilesAsyncPager
google.cloud.datastream_v1.services.datastream.pagers.ListConnectionProfilesPager
ListConnectionProfilesPager(
method: typing.Callable[
[...],
google.cloud.datastream_v1.types.datastream.ListConnectionProfilesResponse,
],
request: google.cloud.datastream_v1.types.datastream.ListConnectionProfilesRequest,
response: google.cloud.datastream_v1.types.datastream.ListConnectionProfilesResponse,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)
Instantiate the pager.
See more: google.cloud.datastream_v1.services.datastream.pagers.ListConnectionProfilesPager
google.cloud.datastream_v1.services.datastream.pagers.ListPrivateConnectionsAsyncPager
ListPrivateConnectionsAsyncPager(
method: typing.Callable[
[...],
typing.Awaitable[
google.cloud.datastream_v1.types.datastream.ListPrivateConnectionsResponse
],
],
request: google.cloud.datastream_v1.types.datastream.ListPrivateConnectionsRequest,
response: google.cloud.datastream_v1.types.datastream.ListPrivateConnectionsResponse,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)
Instantiates the pager.
See more: google.cloud.datastream_v1.services.datastream.pagers.ListPrivateConnectionsAsyncPager
google.cloud.datastream_v1.services.datastream.pagers.ListPrivateConnectionsPager
ListPrivateConnectionsPager(
method: typing.Callable[
[...],
google.cloud.datastream_v1.types.datastream.ListPrivateConnectionsResponse,
],
request: google.cloud.datastream_v1.types.datastream.ListPrivateConnectionsRequest,
response: google.cloud.datastream_v1.types.datastream.ListPrivateConnectionsResponse,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)
Instantiate the pager.
See more: google.cloud.datastream_v1.services.datastream.pagers.ListPrivateConnectionsPager
google.cloud.datastream_v1.services.datastream.pagers.ListRoutesAsyncPager
ListRoutesAsyncPager(
method: typing.Callable[
[...],
typing.Awaitable[
google.cloud.datastream_v1.types.datastream.ListRoutesResponse
],
],
request: google.cloud.datastream_v1.types.datastream.ListRoutesRequest,
response: google.cloud.datastream_v1.types.datastream.ListRoutesResponse,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)
Instantiates the pager.
See more: google.cloud.datastream_v1.services.datastream.pagers.ListRoutesAsyncPager
google.cloud.datastream_v1.services.datastream.pagers.ListRoutesPager
ListRoutesPager(
method: typing.Callable[
[...], google.cloud.datastream_v1.types.datastream.ListRoutesResponse
],
request: google.cloud.datastream_v1.types.datastream.ListRoutesRequest,
response: google.cloud.datastream_v1.types.datastream.ListRoutesResponse,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)
Instantiate the pager.
See more: google.cloud.datastream_v1.services.datastream.pagers.ListRoutesPager
google.cloud.datastream_v1.services.datastream.pagers.ListStreamObjectsAsyncPager
ListStreamObjectsAsyncPager(
method: typing.Callable[
[...],
typing.Awaitable[
google.cloud.datastream_v1.types.datastream.ListStreamObjectsResponse
],
],
request: google.cloud.datastream_v1.types.datastream.ListStreamObjectsRequest,
response: google.cloud.datastream_v1.types.datastream.ListStreamObjectsResponse,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)
Instantiates the pager.
See more: google.cloud.datastream_v1.services.datastream.pagers.ListStreamObjectsAsyncPager
google.cloud.datastream_v1.services.datastream.pagers.ListStreamObjectsPager
ListStreamObjectsPager(
method: typing.Callable[
[...], google.cloud.datastream_v1.types.datastream.ListStreamObjectsResponse
],
request: google.cloud.datastream_v1.types.datastream.ListStreamObjectsRequest,
response: google.cloud.datastream_v1.types.datastream.ListStreamObjectsResponse,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)
Instantiate the pager.
See more: google.cloud.datastream_v1.services.datastream.pagers.ListStreamObjectsPager
google.cloud.datastream_v1.services.datastream.pagers.ListStreamsAsyncPager
ListStreamsAsyncPager(
method: typing.Callable[
[...],
typing.Awaitable[
google.cloud.datastream_v1.types.datastream.ListStreamsResponse
],
],
request: google.cloud.datastream_v1.types.datastream.ListStreamsRequest,
response: google.cloud.datastream_v1.types.datastream.ListStreamsResponse,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)
Instantiates the pager.
See more: google.cloud.datastream_v1.services.datastream.pagers.ListStreamsAsyncPager
google.cloud.datastream_v1.services.datastream.pagers.ListStreamsPager
ListStreamsPager(
method: typing.Callable[
[...], google.cloud.datastream_v1.types.datastream.ListStreamsResponse
],
request: google.cloud.datastream_v1.types.datastream.ListStreamsRequest,
response: google.cloud.datastream_v1.types.datastream.ListStreamsResponse,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary.Retry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)
Instantiate the pager.
See more: google.cloud.datastream_v1.services.datastream.pagers.ListStreamsPager
google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient
DatastreamAsyncClient(*, credentials: typing.Optional[google.auth.credentials.Credentials] = None, transport: typing.Optional[typing.Union[str, google.cloud.datastream_v1alpha1.services.datastream.transports.base.DatastreamTransport, typing.Callable[[...], google.cloud.datastream_v1alpha1.services.datastream.transports.base.DatastreamTransport]]] = 'grpc_asyncio', client_options: typing.Optional[google.api_core.client_options.ClientOptions] = None, client_info: google.api_core.gapic_v1.client_info.ClientInfo =
Instantiates the datastream async client.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient
google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.common_billing_account_path
common_billing_account_path(billing_account: str) -> str
Returns a fully-qualified billing_account string.
google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.common_folder_path
common_folder_path(folder: str) -> str
Returns a fully-qualified folder string.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.common_folder_path
google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.common_location_path
common_location_path(project: str, location: str) -> str
Returns a fully-qualified location string.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.common_location_path
google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.common_organization_path
common_organization_path(organization: str) -> str
Returns a fully-qualified organization string.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.common_organization_path
google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.common_project_path
common_project_path(project: str) -> str
Returns a fully-qualified project string.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.common_project_path
google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.connection_profile_path
connection_profile_path(
project: str, location: str, connection_profile: str
) -> str
Returns a fully-qualified connection_profile string.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.connection_profile_path
google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.create_connection_profile
create_connection_profile(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1alpha1.types.datastream.CreateConnectionProfileRequest,
dict,
]
] = None,
*,
parent: typing.Optional[str] = None,
connection_profile: typing.Optional[
google.cloud.datastream_v1alpha1.types.datastream_resources.ConnectionProfile
] = None,
connection_profile_id: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation_async.AsyncOperation
Use this method to create a connection profile in a project and location.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.create_connection_profile
google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.create_private_connection
create_private_connection(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1alpha1.types.datastream.CreatePrivateConnectionRequest,
dict,
]
] = None,
*,
parent: typing.Optional[str] = None,
private_connection: typing.Optional[
google.cloud.datastream_v1alpha1.types.datastream_resources.PrivateConnection
] = None,
private_connection_id: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation_async.AsyncOperation
Use this method to create a private connectivity configuration.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.create_private_connection
google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.create_route
create_route(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1alpha1.types.datastream.CreateRouteRequest, dict
]
] = None,
*,
parent: typing.Optional[str] = None,
route: typing.Optional[
google.cloud.datastream_v1alpha1.types.datastream_resources.Route
] = None,
route_id: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation_async.AsyncOperation
Use this method to create a route for a private connectivity in a project and location.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.create_route
google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.create_stream
create_stream(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1alpha1.types.datastream.CreateStreamRequest, dict
]
] = None,
*,
parent: typing.Optional[str] = None,
stream: typing.Optional[
google.cloud.datastream_v1alpha1.types.datastream_resources.Stream
] = None,
stream_id: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation_async.AsyncOperation
Use this method to create a stream.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.create_stream
google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.delete_connection_profile
delete_connection_profile(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1alpha1.types.datastream.DeleteConnectionProfileRequest,
dict,
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation_async.AsyncOperation
Use this method to delete a connection profile.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.delete_connection_profile
google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.delete_private_connection
delete_private_connection(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1alpha1.types.datastream.DeletePrivateConnectionRequest,
dict,
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation_async.AsyncOperation
Use this method to delete a private connectivity configuration.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.delete_private_connection
google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.delete_route
delete_route(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1alpha1.types.datastream.DeleteRouteRequest, dict
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation_async.AsyncOperation
Use this method to delete a route.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.delete_route
google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.delete_stream
delete_stream(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1alpha1.types.datastream.DeleteStreamRequest, dict
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation_async.AsyncOperation
Use this method to delete a stream.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.delete_stream
google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.discover_connection_profile
discover_connection_profile(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1alpha1.types.datastream.DiscoverConnectionProfileRequest,
dict,
]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> (
google.cloud.datastream_v1alpha1.types.datastream.DiscoverConnectionProfileResponse
)
Use this method to discover a connection profile.
google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.fetch_errors
fetch_errors(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1alpha1.types.datastream.FetchErrorsRequest, dict
]
] = None,
*,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation_async.AsyncOperation
Use this method to fetch any errors associated with a stream.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.fetch_errors
google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.fetch_static_ips
fetch_static_ips(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1alpha1.types.datastream.FetchStaticIpsRequest,
dict,
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> (
google.cloud.datastream_v1alpha1.services.datastream.pagers.FetchStaticIpsAsyncPager
)
The FetchStaticIps API call exposes the static ips used by Datastream.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.fetch_static_ips
google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.from_service_account_file
from_service_account_file(filename: str, *args, **kwargs)
Creates an instance of this client using the provided credentials file.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.from_service_account_file
google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.from_service_account_info
from_service_account_info(info: dict, *args, **kwargs)
Creates an instance of this client using the provided credentials info.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.from_service_account_info
google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.from_service_account_json
from_service_account_json(filename: str, *args, **kwargs)
Creates an instance of this client using the provided credentials file.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.from_service_account_json
google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.get_connection_profile
get_connection_profile(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1alpha1.types.datastream.GetConnectionProfileRequest,
dict,
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1alpha1.types.datastream_resources.ConnectionProfile
Use this method to get details about a connection profile.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.get_connection_profile
google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source(
client_options: typing.Optional[
google.api_core.client_options.ClientOptions
] = None,
)
Return the API endpoint and client cert source for mutual TLS.
google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.get_private_connection
get_private_connection(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1alpha1.types.datastream.GetPrivateConnectionRequest,
dict,
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1alpha1.types.datastream_resources.PrivateConnection
Use this method to get details about a private connectivity configuration.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.get_private_connection
google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.get_route
get_route(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1alpha1.types.datastream.GetRouteRequest, dict
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1alpha1.types.datastream_resources.Route
Use this method to get details about a route.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.get_route
google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.get_stream
get_stream(
request: typing.Optional[
typing.Union[
google.cloud.datastream_v1alpha1.types.datastream.GetStreamRequest, dict
]
] = None,
*,
name: typing.Optional[str] = None,
retry: typing.Optional[
typing.Union[
google.api_core.retry.retry_unary_async.AsyncRetry,
google.api_core.gapic_v1.method._MethodDefault,
]
] = _MethodDefault._DEFAULT_VALUE,
timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1alpha1.types.datastream_resources.Stream
Use this method to get details about a stream.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.get_stream
google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.get_transport_class
get_transport_class(
label: typing.Optional[str] = None,
) -> typing.Type[
google.cloud.datastream_v1alpha1.services