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, typing.Union[str, bytes]]] = () ) -> NoneStarts 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) -> strReturns 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) -> strReturns 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) -> strReturns 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) -> strReturns 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) -> strReturns 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 ) -> strReturns 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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperationUse 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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperationUse 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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperationUse 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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperationUse 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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperationUse 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, typing.Union[str, bytes]]] = () ) -> NoneDeletes 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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperationUse 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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperationUse 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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperationUse 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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.types.datastream.DiscoverConnectionProfileResponseUse 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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.services.datastream.pagers.FetchStaticIpsAsyncPagerThe 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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.types.datastream_resources.ConnectionProfileUse 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, typing.Union[str, bytes]]] = () ) -> google.cloud.location.locations_pb2.LocationGets 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, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.OperationGets 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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.types.datastream_resources.PrivateConnectionUse 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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.types.datastream_resources.RouteUse 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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.types.datastream_resources.StreamUse 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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.types.datastream_resources.StreamObjectUse 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, typing.Union[str, bytes]]] = () ) -> ( 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, typing.Union[str, bytes]]] = () ) -> google.cloud.location.locations_pb2.ListLocationsResponseLists 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, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.ListOperationsResponseLists 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, typing.Union[str, bytes]]] = () ) -> ( 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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.services.datastream.pagers.ListRoutesAsyncPagerUse 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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.services.datastream.pagers.ListStreamObjectsAsyncPagerUse 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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.services.datastream.pagers.ListStreamsAsyncPagerUse 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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.types.datastream_resources.StreamObjectUse 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) -> strReturns 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 ) -> strReturns 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) -> strReturns a fully-qualified route string.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.route_path
google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.run_stream
run_stream( request: typing.Optional[ typing.Union[google.cloud.datastream_v1.types.datastream.RunStreamRequest, 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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperationUse this method to start, resume or recover a stream with a non default CDC strategy.
See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.run_stream
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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.types.datastream.StartBackfillJobResponseUse 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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.types.datastream.StopBackfillJobResponseUse 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) -> strReturns 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) -> strReturns 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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperationUse 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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperationUse 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, typing.Union[str, bytes]]] = () ) -> NoneStarts 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) -> strReturns 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) -> strReturns 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) -> strReturns 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) -> strReturns 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) -> strReturns 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 ) -> strReturns 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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.OperationUse 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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.OperationUse 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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.OperationUse 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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.OperationUse 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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.OperationUse 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, typing.Union[str, bytes]]] = () ) -> NoneDeletes 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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.OperationUse 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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.OperationUse 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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.OperationUse 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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.types.datastream.DiscoverConnectionProfileResponseUse 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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.services.datastream.pagers.FetchStaticIpsPagerThe 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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.types.datastream_resources.ConnectionProfileUse 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, typing.Union[str, bytes]]] = () ) -> google.cloud.location.locations_pb2.LocationGets 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, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.OperationGets 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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.types.datastream_resources.PrivateConnectionUse 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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.types.datastream_resources.RouteUse 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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.types.datastream_resources.StreamUse 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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.types.datastream_resources.StreamObjectUse 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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.services.datastream.pagers.ListConnectionProfilesPagerUse 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, typing.Union[str, bytes]]] = () ) -> google.cloud.location.locations_pb2.ListLocationsResponseLists 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, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.ListOperationsResponseLists 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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.services.datastream.pagers.ListPrivateConnectionsPagerUse 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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.services.datastream.pagers.ListRoutesPagerUse 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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.services.datastream.pagers.ListStreamObjectsPagerUse 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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.services.datastream.pagers.ListStreamsPagerUse 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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.types.datastream_resources.StreamObjectUse 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) -> strReturns 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 ) -> strReturns 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) -> strReturns a fully-qualified route string.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.route_path
google.cloud.datastream_v1.services.datastream.DatastreamClient.run_stream
run_stream( request: typing.Optional[ typing.Union[google.cloud.datastream_v1.types.datastream.RunStreamRequest, 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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.OperationUse this method to start, resume or recover a stream with a non default CDC strategy.
See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.run_stream
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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.types.datastream.StartBackfillJobResponseUse 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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.types.datastream.StopBackfillJobResponseUse 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) -> strReturns 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) -> strReturns 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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.OperationUse 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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.OperationUse 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, typing.Union[str, bytes]]] = () )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, typing.Union[str, bytes]]] = () )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, typing.Union[str, bytes]]] = () )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, typing.Union[str, bytes]]] = () )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, typing.Union[str, bytes]]] = () )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, typing.Union[str, bytes]]] = () )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, typing.Union[str, bytes]]] = () )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, typing.Union[str, bytes]]] = () )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, typing.Union[str, bytes]]] = () )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, typing.Union[str, bytes]]] = () )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, typing.Union[str, bytes]]] = () )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, typing.Union[str, bytes]]] = () )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) -> strReturns a fully-qualified billing_account string.
google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.common_folder_path
common_folder_path(folder: str) -> strReturns 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) -> strReturns 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) -> strReturns 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) -> strReturns 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 ) -> strReturns 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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperationUse 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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperationUse 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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperationUse 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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperationUse 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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperationUse 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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperationUse 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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperationUse 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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperationUse 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, typing.Union[str, bytes]]] = () ) -> ( 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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperationUse 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, typing.Union[str, bytes]]] = () ) -> ( 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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1alpha1.types.datastream_resources.ConnectionProfileUse 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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1alpha1.types.datastream_resources.PrivateConnectionUse 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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1alpha1.types.datastream_resources.RouteUse 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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1alpha1.types.datastream_resources.StreamUse 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.datastream.transports.base.DatastreamTransport ]Returns an appropriate transport class.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.get_transport_class
google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.list_connection_profiles
list_connection_profiles( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.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, typing.Union[str, bytes]]] = () ) -> ( google.cloud.datastream_v1alpha1.services.datastream.pagers.ListConnectionProfilesAsyncPager )Use this method to list connection profiles created in a project and location.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.list_connection_profiles
google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.list_private_connections
list_private_connections( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.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, typing.Union[str, bytes]]] = () ) -> ( google.cloud.datastream_v1alpha1.services.datastream.pagers.ListPrivateConnectionsAsyncPager )Use this method to list private connectivity configurations in a project and location.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.list_private_connections
google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.list_routes
list_routes( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1alpha1.services.datastream.pagers.ListRoutesAsyncPagerUse this method to list routes created for a private connectivity in a project and location.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.list_routes
google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.list_streams
list_streams( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1alpha1.services.datastream.pagers.ListStreamsAsyncPagerUse this method to list streams in a project and location.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.list_streams
google.cloud.datastream_v1alpha1.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_v1alpha1.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_v1alpha1.services.datastream.DatastreamAsyncClient.parse_common_folder_path
google.cloud.datastream_v1alpha1.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.
google.cloud.datastream_v1alpha1.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.
google.cloud.datastream_v1alpha1.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_v1alpha1.services.datastream.DatastreamAsyncClient.parse_common_project_path
google.cloud.datastream_v1alpha1.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.
google.cloud.datastream_v1alpha1.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.
google.cloud.datastream_v1alpha1.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_v1alpha1.services.datastream.DatastreamAsyncClient.parse_route_path
google.cloud.datastream_v1alpha1.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_v1alpha1.services.datastream.DatastreamAsyncClient.parse_stream_path
google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.private_connection_path
private_connection_path( project: str, location: str, private_connection: str ) -> strReturns a fully-qualified private_connection string.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.private_connection_path
google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.route_path
route_path(project: str, location: str, private_connection: str, route: str) -> strReturns a fully-qualified route string.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.route_path
google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.stream_path
stream_path(project: str, location: str, stream: str) -> strReturns a fully-qualified stream string.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.stream_path
google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.update_connection_profile
update_connection_profile( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.UpdateConnectionProfileRequest, dict, ] ] = None, *, connection_profile: typing.Optional[ google.cloud.datastream_v1alpha1.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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperationUse this method to update the parameters of a connection profile.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.update_connection_profile
google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.update_stream
update_stream( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.UpdateStreamRequest, dict ] ] = None, *, stream: typing.Optional[ google.cloud.datastream_v1alpha1.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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperationUse this method to update the configuration of a stream.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.update_stream
google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient
DatastreamClient(*, 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]]] = 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_v1alpha1.services.datastream.DatastreamClient
google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.__exit__
__exit__(type, value, traceback)Releases underlying transport's resources.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.exit
google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.common_billing_account_path
common_billing_account_path(billing_account: str) -> strReturns a fully-qualified billing_account string.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.common_billing_account_path
google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.common_folder_path
common_folder_path(folder: str) -> strReturns a fully-qualified folder string.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.common_folder_path
google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.common_location_path
common_location_path(project: str, location: str) -> strReturns a fully-qualified location string.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.common_location_path
google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.common_organization_path
common_organization_path(organization: str) -> strReturns a fully-qualified organization string.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.common_organization_path
google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.common_project_path
common_project_path(project: str) -> strReturns a fully-qualified project string.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.common_project_path
google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.connection_profile_path
connection_profile_path( project: str, location: str, connection_profile: str ) -> strReturns a fully-qualified connection_profile string.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.connection_profile_path
google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.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.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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.OperationUse this method to create a connection profile in a project and location.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.create_connection_profile
google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.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.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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.OperationUse this method to create a private connectivity configuration.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.create_private_connection
google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.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.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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.OperationUse this method to create a route for a private connectivity in a project and location.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.create_route
google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.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.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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.OperationUse this method to create a stream.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.create_stream
google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.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.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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.OperationUse this method to delete a connection profile.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.delete_connection_profile
google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.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.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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.OperationUse this method to delete a private connectivity configuration.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.delete_private_connection
google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.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.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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.OperationUse this method to delete a route.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.delete_route
google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.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.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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.OperationUse this method to delete a stream.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.delete_stream
google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.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.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, typing.Union[str, bytes]]] = () ) -> ( google.cloud.datastream_v1alpha1.types.datastream.DiscoverConnectionProfileResponse )Use this method to discover a connection profile.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.discover_connection_profile
google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.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.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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.OperationUse this method to fetch any errors associated with a stream.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.fetch_errors
google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.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.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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1alpha1.services.datastream.pagers.FetchStaticIpsPagerThe FetchStaticIps API call exposes the static ips used by Datastream.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.fetch_static_ips
google.cloud.datastream_v1alpha1.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_v1alpha1.services.datastream.DatastreamClient.from_service_account_file
google.cloud.datastream_v1alpha1.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_v1alpha1.services.datastream.DatastreamClient.from_service_account_info
google.cloud.datastream_v1alpha1.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_v1alpha1.services.datastream.DatastreamClient.from_service_account_json
google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.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.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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1alpha1.types.datastream_resources.ConnectionProfileUse this method to get details about a connection profile.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.get_connection_profile
google.cloud.datastream_v1alpha1.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.
google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.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.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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1alpha1.types.datastream_resources.PrivateConnectionUse this method to get details about a private connectivity configuration.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.get_private_connection
google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.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.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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1alpha1.types.datastream_resources.RouteUse this method to get details about a route.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.get_route
google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.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.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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1alpha1.types.datastream_resources.StreamUse this method to get details about a stream.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.get_stream
google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.list_connection_profiles
list_connection_profiles( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.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, typing.Union[str, bytes]]] = () ) -> ( google.cloud.datastream_v1alpha1.services.datastream.pagers.ListConnectionProfilesPager )Use this method to list connection profiles created in a project and location.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.list_connection_profiles
google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.list_private_connections
list_private_connections( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.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, typing.Union[str, bytes]]] = () ) -> ( google.cloud.datastream_v1alpha1.services.datastream.pagers.ListPrivateConnectionsPager )Use this method to list private connectivity configurations in a project and location.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.list_private_connections
google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.list_routes
list_routes( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1alpha1.services.datastream.pagers.ListRoutesPagerUse this method to list routes created for a private connectivity in a project and location.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.list_routes
google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.list_streams
list_streams( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.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, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1alpha1.services.datastream.pagers.ListStreamsPagerUse this method to list streams in a project and location.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.list_streams
google.cloud.datastream_v1alpha1.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.
google.cloud.datastream_v1alpha1.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_v1alpha1.services.datastream.DatastreamClient.parse_common_folder_path
google.cloud.datastream_v1alpha1.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_v1alpha1.services.datastream.DatastreamClient.parse_common_location_path
google.cloud.datastream_v1alpha1.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_v1alpha1.services.datastream.DatastreamClient.parse_common_organization_path
google.cloud.datastream_v1alpha1.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_v1alpha1.services.datastream.DatastreamClient.parse_common_project_path
google.cloud.datastream_v1alpha1.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_v1alpha1.services.datastream.DatastreamClient.parse_connection_profile_path
google.cloud.datastream_v1alpha1.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_v1alpha1.services.datastream.DatastreamClient.parse_private_connection_path
google.cloud.datastream_v1alpha1.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_v1alpha1.services.datastream.DatastreamClient.parse_route_path
google.cloud.datastream_v1alpha1.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_v1alpha1.services.datastream.DatastreamClient.parse_stream_path
google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.private_connection_path
private_connection_path( project: str, location: str, private_connection: str ) -> strReturns a fully-qualified private_connection string.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.private_connection_path
google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.route_path
route_path(project: str, location: str, private_connection: str, route: str) -> strReturns a fully-qualified route string.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.route_path
google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.stream_path
stream_path(project: str, location: str, stream: str) -> strReturns a fully-qualified stream string.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.stream_path
google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.update_connection_profile
update_connection_profile( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.UpdateConnectionProfileRequest, dict, ] ] = None, *, connection_profile: typing.Optional[ google.cloud.datastream_v1alpha1.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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.OperationUse this method to update the parameters of a connection profile.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.update_connection_profile
google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.update_stream
update_stream( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.UpdateStreamRequest, dict ] ] = None, *, stream: typing.Optional[ google.cloud.datastream_v1alpha1.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, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.OperationUse this method to update the configuration of a stream.
See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.update_stream
google.cloud.datastream_v1alpha1.services.datastream.pagers.FetchStaticIpsAsyncPager
FetchStaticIpsAsyncPager( method: typing.Callable[ [...], typing.Awaitable[ google.cloud.datastream_v1alpha1.types.datastream.FetchStaticIpsResponse ], ], request: google.cloud.datastream_v1alpha1.types.datastream.FetchStaticIpsRequest, response: google.cloud.datastream_v1alpha1.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, typing.Union[str, bytes]]] = () )Instantiates the pager.
See more: google.cloud.datastream_v1alpha1.services.datastream.pagers.FetchStaticIpsAsyncPager
google.cloud.datastream_v1alpha1.services.datastream.pagers.FetchStaticIpsPager
FetchStaticIpsPager( method: typing.Callable[ [...], google.cloud.datastream_v1alpha1.types.datastream.FetchStaticIpsResponse ], request: google.cloud.datastream_v1alpha1.types.datastream.FetchStaticIpsRequest, response: google.cloud.datastream_v1alpha1.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, typing.Union[str, bytes]]] = () )Instantiate the pager.
See more: google.cloud.datastream_v1alpha1.services.datastream.pagers.FetchStaticIpsPager
google.cloud.datastream_v1alpha1.services.datastream.pagers.ListConnectionProfilesAsyncPager
ListConnectionProfilesAsyncPager( method: typing.Callable[ [...], typing.Awaitable[ google.cloud.datastream_v1alpha1.types.datastream.ListConnectionProfilesResponse ], ], request: google.cloud.datastream_v1alpha1.types.datastream.ListConnectionProfilesRequest, response: google.cloud.datastream_v1alpha1.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, typing.Union[str, bytes]]] = () )Instantiates the pager.
See more: google.cloud.datastream_v1alpha1.services.datastream.pagers.ListConnectionProfilesAsyncPager
google.cloud.datastream_v1alpha1.services.datastream.pagers.ListConnectionProfilesPager
ListConnectionProfilesPager( method: typing.Callable[ [...], google.cloud.datastream_v1alpha1.types.datastream.ListConnectionProfilesResponse, ], request: google.cloud.datastream_v1alpha1.types.datastream.ListConnectionProfilesRequest, response: google.cloud.datastream_v1alpha1.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, typing.Union[str, bytes]]] = () )Instantiate the pager.
See more: google.cloud.datastream_v1alpha1.services.datastream.pagers.ListConnectionProfilesPager
google.cloud.datastream_v1alpha1.services.datastream.pagers.ListPrivateConnectionsAsyncPager
ListPrivateConnectionsAsyncPager( method: typing.Callable[ [...], typing.Awaitable[ google.cloud.datastream_v1alpha1.types.datastream.ListPrivateConnectionsResponse ], ], request: google.cloud.datastream_v1alpha1.types.datastream.ListPrivateConnectionsRequest, response: google.cloud.datastream_v1alpha1.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, typing.Union[str, bytes]]] = () )Instantiates the pager.
See more: google.cloud.datastream_v1alpha1.services.datastream.pagers.ListPrivateConnectionsAsyncPager
google.cloud.datastream_v1alpha1.services.datastream.pagers.ListPrivateConnectionsPager
ListPrivateConnectionsPager( method: typing.Callable[ [...], google.cloud.datastream_v1alpha1.types.datastream.ListPrivateConnectionsResponse, ], request: google.cloud.datastream_v1alpha1.types.datastream.ListPrivateConnectionsRequest, response: google.cloud.datastream_v1alpha1.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, typing.Union[str, bytes]]] = () )Instantiate the pager.
See more: google.cloud.datastream_v1alpha1.services.datastream.pagers.ListPrivateConnectionsPager
google.cloud.datastream_v1alpha1.services.datastream.pagers.ListRoutesAsyncPager
ListRoutesAsyncPager( method: typing.Callable[ [...], typing.Awaitable[ google.cloud.datastream_v1alpha1.types.datastream.ListRoutesResponse ], ], request: google.cloud.datastream_v1alpha1.types.datastream.ListRoutesRequest, response: google.cloud.datastream_v1alpha1.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, typing.Union[str, bytes]]] = () )Instantiates the pager.
See more: google.cloud.datastream_v1alpha1.services.datastream.pagers.ListRoutesAsyncPager
google.cloud.datastream_v1alpha1.services.datastream.pagers.ListRoutesPager
ListRoutesPager( method: typing.Callable[ [...], google.cloud.datastream_v1alpha1.types.datastream.ListRoutesResponse ], request: google.cloud.datastream_v1alpha1.types.datastream.ListRoutesRequest, response: google.cloud.datastream_v1alpha1.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, typing.Union[str, bytes]]] = () )Instantiate the pager.
See more: google.cloud.datastream_v1alpha1.services.datastream.pagers.ListRoutesPager
google.cloud.datastream_v1alpha1.services.datastream.pagers.ListStreamsAsyncPager
ListStreamsAsyncPager( method: typing.Callable[ [...], typing.Awaitable[ google.cloud.datastream_v1alpha1.types.datastream.ListStreamsResponse ], ], request: google.cloud.datastream_v1alpha1.types.datastream.ListStreamsRequest, response: google.cloud.datastream_v1alpha1.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, typing.Union[str, bytes]]] = () )Instantiates the pager.
See more: google.cloud.datastream_v1alpha1.services.datastream.pagers.ListStreamsAsyncPager
google.cloud.datastream_v1alpha1.services.datastream.pagers.ListStreamsPager
ListStreamsPager( method: typing.Callable[ [...], google.cloud.datastream_v1alpha1.types.datastream.ListStreamsResponse ], request: google.cloud.datastream_v1alpha1.types.datastream.ListStreamsRequest, response: google.cloud.datastream_v1alpha1.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, typing.Union[str, bytes]]] = () )Instantiate the pager.
See more: google.cloud.datastream_v1alpha1.services.datastream.pagers.ListStreamsPager