Package Methods (1.9.5)

Version 1.9.5

• 1.11.0 (latest)
• 1.10.1
• 1.9.5
• 1.8.0
• 1.7.0
• 1.6.1
• 1.5.1
• 1.4.1
• 1.3.0
• 1.2.2
• 1.1.1
• 1.0.2
• 0.4.3
• 0.3.1
• 0.2.0
• 0.1.3

Summary of entries of Methods for datastream.

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient

DatastreamAsyncClient(*, credentials: typing.Optional[google.auth.credentials.Credentials] = None, transport: typing.Optional[typing.Union[str, google.cloud.datastream_v1.services.datastream.transports.base.DatastreamTransport, typing.Callable[[...], google.cloud.datastream_v1.services.datastream.transports.base.DatastreamTransport]]] = 'grpc_asyncio', client_options: typing.Optional[google.api_core.client_options.ClientOptions] = None, client_info: google.api_core.gapic_v1.client_info.ClientInfo = 

Instantiates the datastream async client.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.cancel_operation

cancel_operation(
    request: typing.Optional[
        google.longrunning.operations_pb2.CancelOperationRequest
    ] = None,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> None

Starts asynchronous cancellation on a long-running operation.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.cancel_operation

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.common_billing_account_path

common_billing_account_path(billing_account: str) -> str

Returns a fully-qualified billing_account string.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.common_billing_account_path

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.common_folder_path

common_folder_path(folder: str) -> str

Returns a fully-qualified folder string.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.common_folder_path

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.common_location_path

common_location_path(project: str, location: str) -> str

Returns a fully-qualified location string.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.common_location_path

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.common_organization_path

common_organization_path(organization: str) -> str

Returns a fully-qualified organization string.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.common_organization_path

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.common_project_path

common_project_path(project: str) -> str

Returns a fully-qualified project string.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.common_project_path

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.connection_profile_path

connection_profile_path(
    project: str, location: str, connection_profile: str
) -> str

Returns a fully-qualified connection_profile string.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.connection_profile_path

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.create_connection_profile

create_connection_profile(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.CreateConnectionProfileRequest,
            dict,
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    connection_profile: typing.Optional[
        google.cloud.datastream_v1.types.datastream_resources.ConnectionProfile
    ] = None,
    connection_profile_id: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation_async.AsyncOperation

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

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.create_connection_profile

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.create_private_connection

create_private_connection(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.CreatePrivateConnectionRequest,
            dict,
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    private_connection: typing.Optional[
        google.cloud.datastream_v1.types.datastream_resources.PrivateConnection
    ] = None,
    private_connection_id: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation_async.AsyncOperation

Use this method to create a private connectivity configuration.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.create_private_connection

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.create_route

create_route(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.CreateRouteRequest, dict
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    route: typing.Optional[
        google.cloud.datastream_v1.types.datastream_resources.Route
    ] = None,
    route_id: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation_async.AsyncOperation

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

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.create_route

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.create_stream

create_stream(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.CreateStreamRequest, dict
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    stream: typing.Optional[
        google.cloud.datastream_v1.types.datastream_resources.Stream
    ] = None,
    stream_id: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation_async.AsyncOperation

Use this method to create a stream.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.create_stream

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.delete_connection_profile

delete_connection_profile(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.DeleteConnectionProfileRequest,
            dict,
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation_async.AsyncOperation

Use this method to delete a connection profile.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.delete_connection_profile

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.delete_operation

delete_operation(
    request: typing.Optional[
        google.longrunning.operations_pb2.DeleteOperationRequest
    ] = None,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> None

Deletes a long-running operation.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.delete_operation

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.delete_private_connection

delete_private_connection(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.DeletePrivateConnectionRequest,
            dict,
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation_async.AsyncOperation

Use this method to delete a private connectivity configuration.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.delete_private_connection

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.delete_route

delete_route(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.DeleteRouteRequest, dict
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation_async.AsyncOperation

Use this method to delete a route.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.delete_route

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.delete_stream

delete_stream(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.DeleteStreamRequest, dict
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation_async.AsyncOperation

Use this method to delete a stream.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.delete_stream

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.discover_connection_profile

discover_connection_profile(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.DiscoverConnectionProfileRequest,
            dict,
        ]
    ] = None,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.types.datastream.DiscoverConnectionProfileResponse

Use this method to discover a connection profile.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.discover_connection_profile

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.fetch_static_ips

fetch_static_ips(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.FetchStaticIpsRequest, dict
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.services.datastream.pagers.FetchStaticIpsAsyncPager

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

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.fetch_static_ips

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.from_service_account_file

from_service_account_file(filename: str, *args, **kwargs)

Creates an instance of this client using the provided credentials file.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.from_service_account_file

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.from_service_account_info

from_service_account_info(info: dict, *args, **kwargs)

Creates an instance of this client using the provided credentials info.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.from_service_account_info

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.from_service_account_json

from_service_account_json(filename: str, *args, **kwargs)

Creates an instance of this client using the provided credentials file.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.from_service_account_json

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_connection_profile

get_connection_profile(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.GetConnectionProfileRequest,
            dict,
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.types.datastream_resources.ConnectionProfile

Use this method to get details about a connection profile.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_connection_profile

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_location

get_location(
    request: typing.Optional[
        google.cloud.location.locations_pb2.GetLocationRequest
    ] = None,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.location.locations_pb2.Location

Gets information about a location.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_location

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_mtls_endpoint_and_cert_source

get_mtls_endpoint_and_cert_source(
    client_options: typing.Optional[
        google.api_core.client_options.ClientOptions
    ] = None,
)

Return the API endpoint and client cert source for mutual TLS.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_mtls_endpoint_and_cert_source

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_operation

get_operation(
    request: typing.Optional[
        google.longrunning.operations_pb2.GetOperationRequest
    ] = None,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.longrunning.operations_pb2.Operation

Gets the latest state of a long-running operation.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_operation

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_private_connection

get_private_connection(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.GetPrivateConnectionRequest,
            dict,
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.types.datastream_resources.PrivateConnection

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

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_private_connection

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_route

get_route(
    request: typing.Optional[
        typing.Union[google.cloud.datastream_v1.types.datastream.GetRouteRequest, dict]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.types.datastream_resources.Route

Use this method to get details about a route.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_route

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_stream

get_stream(
    request: typing.Optional[
        typing.Union[google.cloud.datastream_v1.types.datastream.GetStreamRequest, dict]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.types.datastream_resources.Stream

Use this method to get details about a stream.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_stream

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_stream_object

get_stream_object(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.GetStreamObjectRequest, dict
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.types.datastream_resources.StreamObject

Use this method to get details about a stream object.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_stream_object

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_transport_class

get_transport_class() -> (
    typing.Type[
        google.cloud.datastream_v1.services.datastream.transports.base.DatastreamTransport
    ]
)

Returns an appropriate transport class.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_transport_class

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_connection_profiles

list_connection_profiles(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.ListConnectionProfilesRequest,
            dict,
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> (
    google.cloud.datastream_v1.services.datastream.pagers.ListConnectionProfilesAsyncPager
)

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

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_connection_profiles

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_locations

list_locations(
    request: typing.Optional[
        google.cloud.location.locations_pb2.ListLocationsRequest
    ] = None,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.location.locations_pb2.ListLocationsResponse

Lists information about the supported locations for this service.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_locations

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_operations

list_operations(
    request: typing.Optional[
        google.longrunning.operations_pb2.ListOperationsRequest
    ] = None,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.longrunning.operations_pb2.ListOperationsResponse

Lists operations that match the specified filter in the request.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_operations

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_private_connections

list_private_connections(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.ListPrivateConnectionsRequest,
            dict,
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> (
    google.cloud.datastream_v1.services.datastream.pagers.ListPrivateConnectionsAsyncPager
)

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

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_private_connections

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_routes

list_routes(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.ListRoutesRequest, dict
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.services.datastream.pagers.ListRoutesAsyncPager

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

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_routes

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_stream_objects

list_stream_objects(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.ListStreamObjectsRequest, dict
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.services.datastream.pagers.ListStreamObjectsAsyncPager

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

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_stream_objects

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_streams

list_streams(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.ListStreamsRequest, dict
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.services.datastream.pagers.ListStreamsAsyncPager

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

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_streams

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.lookup_stream_object

lookup_stream_object(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.LookupStreamObjectRequest, dict
        ]
    ] = None,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.types.datastream_resources.StreamObject

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

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.lookup_stream_object

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.networks_path

networks_path(project: str, network: str) -> str

Returns a fully-qualified networks string.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.networks_path

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_common_billing_account_path

parse_common_billing_account_path(path: str) -> typing.Dict[str, str]

Parse a billing_account path into its component segments.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_common_billing_account_path

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_common_folder_path

parse_common_folder_path(path: str) -> typing.Dict[str, str]

Parse a folder path into its component segments.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_common_folder_path

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_common_location_path

parse_common_location_path(path: str) -> typing.Dict[str, str]

Parse a location path into its component segments.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_common_location_path

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_common_organization_path

parse_common_organization_path(path: str) -> typing.Dict[str, str]

Parse a organization path into its component segments.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_common_organization_path

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_common_project_path

parse_common_project_path(path: str) -> typing.Dict[str, str]

Parse a project path into its component segments.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_common_project_path

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_connection_profile_path

parse_connection_profile_path(path: str) -> typing.Dict[str, str]

Parses a connection_profile path into its component segments.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_connection_profile_path

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_networks_path

parse_networks_path(path: str) -> typing.Dict[str, str]

Parses a networks path into its component segments.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_networks_path

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_private_connection_path

parse_private_connection_path(path: str) -> typing.Dict[str, str]

Parses a private_connection path into its component segments.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_private_connection_path

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_route_path

parse_route_path(path: str) -> typing.Dict[str, str]

Parses a route path into its component segments.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_route_path

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_stream_object_path

parse_stream_object_path(path: str) -> typing.Dict[str, str]

Parses a stream_object path into its component segments.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_stream_object_path

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_stream_path

parse_stream_path(path: str) -> typing.Dict[str, str]

Parses a stream path into its component segments.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_stream_path

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.private_connection_path

private_connection_path(
    project: str, location: str, private_connection: str
) -> str

Returns a fully-qualified private_connection string.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.private_connection_path

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.route_path

route_path(project: str, location: str, private_connection: str, route: str) -> str

Returns a fully-qualified route string.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.route_path

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.start_backfill_job

start_backfill_job(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.StartBackfillJobRequest, dict
        ]
    ] = None,
    *,
    object_: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.types.datastream.StartBackfillJobResponse

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

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.start_backfill_job

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.stop_backfill_job

stop_backfill_job(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.StopBackfillJobRequest, dict
        ]
    ] = None,
    *,
    object_: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.types.datastream.StopBackfillJobResponse

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

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.stop_backfill_job

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.stream_object_path

stream_object_path(project: str, location: str, stream: str, object: str) -> str

Returns a fully-qualified stream_object string.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.stream_object_path

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.stream_path

stream_path(project: str, location: str, stream: str) -> str

Returns a fully-qualified stream string.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.stream_path

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.update_connection_profile

update_connection_profile(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.UpdateConnectionProfileRequest,
            dict,
        ]
    ] = None,
    *,
    connection_profile: typing.Optional[
        google.cloud.datastream_v1.types.datastream_resources.ConnectionProfile
    ] = None,
    update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation_async.AsyncOperation

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

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.update_connection_profile

google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.update_stream

update_stream(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.UpdateStreamRequest, dict
        ]
    ] = None,
    *,
    stream: typing.Optional[
        google.cloud.datastream_v1.types.datastream_resources.Stream
    ] = None,
    update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation_async.AsyncOperation

Use this method to update the configuration of a stream.

See more: google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.update_stream

google.cloud.datastream_v1.services.datastream.DatastreamClient

DatastreamClient(*, credentials: typing.Optional[google.auth.credentials.Credentials] = None, transport: typing.Optional[typing.Union[str, google.cloud.datastream_v1.services.datastream.transports.base.DatastreamTransport, typing.Callable[[...], google.cloud.datastream_v1.services.datastream.transports.base.DatastreamTransport]]] = None, client_options: typing.Optional[typing.Union[google.api_core.client_options.ClientOptions, dict]] = None, client_info: google.api_core.gapic_v1.client_info.ClientInfo = 

Instantiates the datastream client.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient

google.cloud.datastream_v1.services.datastream.DatastreamClient.__exit__

__exit__(type, value, traceback)

Releases underlying transport's resources.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.exit

google.cloud.datastream_v1.services.datastream.DatastreamClient.cancel_operation

cancel_operation(
    request: typing.Optional[
        google.longrunning.operations_pb2.CancelOperationRequest
    ] = None,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> None

Starts asynchronous cancellation on a long-running operation.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.cancel_operation

google.cloud.datastream_v1.services.datastream.DatastreamClient.common_billing_account_path

common_billing_account_path(billing_account: str) -> str

Returns a fully-qualified billing_account string.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.common_billing_account_path

google.cloud.datastream_v1.services.datastream.DatastreamClient.common_folder_path

common_folder_path(folder: str) -> str

Returns a fully-qualified folder string.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.common_folder_path

google.cloud.datastream_v1.services.datastream.DatastreamClient.common_location_path

common_location_path(project: str, location: str) -> str

Returns a fully-qualified location string.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.common_location_path

google.cloud.datastream_v1.services.datastream.DatastreamClient.common_organization_path

common_organization_path(organization: str) -> str

Returns a fully-qualified organization string.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.common_organization_path

google.cloud.datastream_v1.services.datastream.DatastreamClient.common_project_path

common_project_path(project: str) -> str

Returns a fully-qualified project string.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.common_project_path

google.cloud.datastream_v1.services.datastream.DatastreamClient.connection_profile_path

connection_profile_path(
    project: str, location: str, connection_profile: str
) -> str

Returns a fully-qualified connection_profile string.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.connection_profile_path

google.cloud.datastream_v1.services.datastream.DatastreamClient.create_connection_profile

create_connection_profile(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.CreateConnectionProfileRequest,
            dict,
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    connection_profile: typing.Optional[
        google.cloud.datastream_v1.types.datastream_resources.ConnectionProfile
    ] = None,
    connection_profile_id: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation.Operation

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

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.create_connection_profile

google.cloud.datastream_v1.services.datastream.DatastreamClient.create_private_connection

create_private_connection(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.CreatePrivateConnectionRequest,
            dict,
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    private_connection: typing.Optional[
        google.cloud.datastream_v1.types.datastream_resources.PrivateConnection
    ] = None,
    private_connection_id: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation.Operation

Use this method to create a private connectivity configuration.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.create_private_connection

google.cloud.datastream_v1.services.datastream.DatastreamClient.create_route

create_route(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.CreateRouteRequest, dict
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    route: typing.Optional[
        google.cloud.datastream_v1.types.datastream_resources.Route
    ] = None,
    route_id: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation.Operation

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

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.create_route

google.cloud.datastream_v1.services.datastream.DatastreamClient.create_stream

create_stream(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.CreateStreamRequest, dict
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    stream: typing.Optional[
        google.cloud.datastream_v1.types.datastream_resources.Stream
    ] = None,
    stream_id: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation.Operation

Use this method to create a stream.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.create_stream

google.cloud.datastream_v1.services.datastream.DatastreamClient.delete_connection_profile

delete_connection_profile(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.DeleteConnectionProfileRequest,
            dict,
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation.Operation

Use this method to delete a connection profile.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.delete_connection_profile

google.cloud.datastream_v1.services.datastream.DatastreamClient.delete_operation

delete_operation(
    request: typing.Optional[
        google.longrunning.operations_pb2.DeleteOperationRequest
    ] = None,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> None

Deletes a long-running operation.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.delete_operation

google.cloud.datastream_v1.services.datastream.DatastreamClient.delete_private_connection

delete_private_connection(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.DeletePrivateConnectionRequest,
            dict,
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation.Operation

Use this method to delete a private connectivity configuration.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.delete_private_connection

google.cloud.datastream_v1.services.datastream.DatastreamClient.delete_route

delete_route(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.DeleteRouteRequest, dict
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation.Operation

Use this method to delete a route.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.delete_route

google.cloud.datastream_v1.services.datastream.DatastreamClient.delete_stream

delete_stream(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.DeleteStreamRequest, dict
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation.Operation

Use this method to delete a stream.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.delete_stream

google.cloud.datastream_v1.services.datastream.DatastreamClient.discover_connection_profile

discover_connection_profile(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.DiscoverConnectionProfileRequest,
            dict,
        ]
    ] = None,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.types.datastream.DiscoverConnectionProfileResponse

Use this method to discover a connection profile.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.discover_connection_profile

google.cloud.datastream_v1.services.datastream.DatastreamClient.fetch_static_ips

fetch_static_ips(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.FetchStaticIpsRequest, dict
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.services.datastream.pagers.FetchStaticIpsPager

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

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.fetch_static_ips

google.cloud.datastream_v1.services.datastream.DatastreamClient.from_service_account_file

from_service_account_file(filename: str, *args, **kwargs)

Creates an instance of this client using the provided credentials file.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.from_service_account_file

google.cloud.datastream_v1.services.datastream.DatastreamClient.from_service_account_info

from_service_account_info(info: dict, *args, **kwargs)

Creates an instance of this client using the provided credentials info.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.from_service_account_info

google.cloud.datastream_v1.services.datastream.DatastreamClient.from_service_account_json

from_service_account_json(filename: str, *args, **kwargs)

Creates an instance of this client using the provided credentials file.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.from_service_account_json

google.cloud.datastream_v1.services.datastream.DatastreamClient.get_connection_profile

get_connection_profile(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.GetConnectionProfileRequest,
            dict,
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.types.datastream_resources.ConnectionProfile

Use this method to get details about a connection profile.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.get_connection_profile

google.cloud.datastream_v1.services.datastream.DatastreamClient.get_location

get_location(
    request: typing.Optional[
        google.cloud.location.locations_pb2.GetLocationRequest
    ] = None,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.location.locations_pb2.Location

Gets information about a location.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.get_location

google.cloud.datastream_v1.services.datastream.DatastreamClient.get_mtls_endpoint_and_cert_source

get_mtls_endpoint_and_cert_source(
    client_options: typing.Optional[
        google.api_core.client_options.ClientOptions
    ] = None,
)

Deprecated.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.get_mtls_endpoint_and_cert_source

google.cloud.datastream_v1.services.datastream.DatastreamClient.get_operation

get_operation(
    request: typing.Optional[
        google.longrunning.operations_pb2.GetOperationRequest
    ] = None,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.longrunning.operations_pb2.Operation

Gets the latest state of a long-running operation.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.get_operation

google.cloud.datastream_v1.services.datastream.DatastreamClient.get_private_connection

get_private_connection(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.GetPrivateConnectionRequest,
            dict,
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.types.datastream_resources.PrivateConnection

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

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.get_private_connection

google.cloud.datastream_v1.services.datastream.DatastreamClient.get_route

get_route(
    request: typing.Optional[
        typing.Union[google.cloud.datastream_v1.types.datastream.GetRouteRequest, dict]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.types.datastream_resources.Route

Use this method to get details about a route.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.get_route

google.cloud.datastream_v1.services.datastream.DatastreamClient.get_stream

get_stream(
    request: typing.Optional[
        typing.Union[google.cloud.datastream_v1.types.datastream.GetStreamRequest, dict]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.types.datastream_resources.Stream

Use this method to get details about a stream.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.get_stream

google.cloud.datastream_v1.services.datastream.DatastreamClient.get_stream_object

get_stream_object(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.GetStreamObjectRequest, dict
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.types.datastream_resources.StreamObject

Use this method to get details about a stream object.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.get_stream_object

google.cloud.datastream_v1.services.datastream.DatastreamClient.list_connection_profiles

list_connection_profiles(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.ListConnectionProfilesRequest,
            dict,
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.services.datastream.pagers.ListConnectionProfilesPager

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

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.list_connection_profiles

google.cloud.datastream_v1.services.datastream.DatastreamClient.list_locations

list_locations(
    request: typing.Optional[
        google.cloud.location.locations_pb2.ListLocationsRequest
    ] = None,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.location.locations_pb2.ListLocationsResponse

Lists information about the supported locations for this service.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.list_locations

google.cloud.datastream_v1.services.datastream.DatastreamClient.list_operations

list_operations(
    request: typing.Optional[
        google.longrunning.operations_pb2.ListOperationsRequest
    ] = None,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.longrunning.operations_pb2.ListOperationsResponse

Lists operations that match the specified filter in the request.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.list_operations

google.cloud.datastream_v1.services.datastream.DatastreamClient.list_private_connections

list_private_connections(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.ListPrivateConnectionsRequest,
            dict,
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.services.datastream.pagers.ListPrivateConnectionsPager

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

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.list_private_connections

google.cloud.datastream_v1.services.datastream.DatastreamClient.list_routes

list_routes(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.ListRoutesRequest, dict
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.services.datastream.pagers.ListRoutesPager

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

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.list_routes

google.cloud.datastream_v1.services.datastream.DatastreamClient.list_stream_objects

list_stream_objects(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.ListStreamObjectsRequest, dict
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.services.datastream.pagers.ListStreamObjectsPager

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

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.list_stream_objects

google.cloud.datastream_v1.services.datastream.DatastreamClient.list_streams

list_streams(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.ListStreamsRequest, dict
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.services.datastream.pagers.ListStreamsPager

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

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.list_streams

google.cloud.datastream_v1.services.datastream.DatastreamClient.lookup_stream_object

lookup_stream_object(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.LookupStreamObjectRequest, dict
        ]
    ] = None,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.types.datastream_resources.StreamObject

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

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.lookup_stream_object

google.cloud.datastream_v1.services.datastream.DatastreamClient.networks_path

networks_path(project: str, network: str) -> str

Returns a fully-qualified networks string.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.networks_path

google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_common_billing_account_path

parse_common_billing_account_path(path: str) -> typing.Dict[str, str]

Parse a billing_account path into its component segments.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_common_billing_account_path

google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_common_folder_path

parse_common_folder_path(path: str) -> typing.Dict[str, str]

Parse a folder path into its component segments.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_common_folder_path

google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_common_location_path

parse_common_location_path(path: str) -> typing.Dict[str, str]

Parse a location path into its component segments.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_common_location_path

google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_common_organization_path

parse_common_organization_path(path: str) -> typing.Dict[str, str]

Parse a organization path into its component segments.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_common_organization_path

google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_common_project_path

parse_common_project_path(path: str) -> typing.Dict[str, str]

Parse a project path into its component segments.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_common_project_path

google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_connection_profile_path

parse_connection_profile_path(path: str) -> typing.Dict[str, str]

Parses a connection_profile path into its component segments.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_connection_profile_path

google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_networks_path

parse_networks_path(path: str) -> typing.Dict[str, str]

Parses a networks path into its component segments.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_networks_path

google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_private_connection_path

parse_private_connection_path(path: str) -> typing.Dict[str, str]

Parses a private_connection path into its component segments.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_private_connection_path

google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_route_path

parse_route_path(path: str) -> typing.Dict[str, str]

Parses a route path into its component segments.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_route_path

google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_stream_object_path

parse_stream_object_path(path: str) -> typing.Dict[str, str]

Parses a stream_object path into its component segments.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_stream_object_path

google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_stream_path

parse_stream_path(path: str) -> typing.Dict[str, str]

Parses a stream path into its component segments.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_stream_path

google.cloud.datastream_v1.services.datastream.DatastreamClient.private_connection_path

private_connection_path(
    project: str, location: str, private_connection: str
) -> str

Returns a fully-qualified private_connection string.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.private_connection_path

google.cloud.datastream_v1.services.datastream.DatastreamClient.route_path

route_path(project: str, location: str, private_connection: str, route: str) -> str

Returns a fully-qualified route string.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.route_path

google.cloud.datastream_v1.services.datastream.DatastreamClient.start_backfill_job

start_backfill_job(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.StartBackfillJobRequest, dict
        ]
    ] = None,
    *,
    object_: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.types.datastream.StartBackfillJobResponse

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

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.start_backfill_job

google.cloud.datastream_v1.services.datastream.DatastreamClient.stop_backfill_job

stop_backfill_job(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.StopBackfillJobRequest, dict
        ]
    ] = None,
    *,
    object_: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1.types.datastream.StopBackfillJobResponse

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

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.stop_backfill_job

google.cloud.datastream_v1.services.datastream.DatastreamClient.stream_object_path

stream_object_path(project: str, location: str, stream: str, object: str) -> str

Returns a fully-qualified stream_object string.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.stream_object_path

google.cloud.datastream_v1.services.datastream.DatastreamClient.stream_path

stream_path(project: str, location: str, stream: str) -> str

Returns a fully-qualified stream string.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.stream_path

google.cloud.datastream_v1.services.datastream.DatastreamClient.update_connection_profile

update_connection_profile(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.UpdateConnectionProfileRequest,
            dict,
        ]
    ] = None,
    *,
    connection_profile: typing.Optional[
        google.cloud.datastream_v1.types.datastream_resources.ConnectionProfile
    ] = None,
    update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation.Operation

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

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.update_connection_profile

google.cloud.datastream_v1.services.datastream.DatastreamClient.update_stream

update_stream(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1.types.datastream.UpdateStreamRequest, dict
        ]
    ] = None,
    *,
    stream: typing.Optional[
        google.cloud.datastream_v1.types.datastream_resources.Stream
    ] = None,
    update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation.Operation

Use this method to update the configuration of a stream.

See more: google.cloud.datastream_v1.services.datastream.DatastreamClient.update_stream

google.cloud.datastream_v1.services.datastream.pagers.FetchStaticIpsAsyncPager

FetchStaticIpsAsyncPager(
    method: typing.Callable[
        [...],
        typing.Awaitable[
            google.cloud.datastream_v1.types.datastream.FetchStaticIpsResponse
        ],
    ],
    request: google.cloud.datastream_v1.types.datastream.FetchStaticIpsRequest,
    response: google.cloud.datastream_v1.types.datastream.FetchStaticIpsResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)

Instantiates the pager.

See more: google.cloud.datastream_v1.services.datastream.pagers.FetchStaticIpsAsyncPager

google.cloud.datastream_v1.services.datastream.pagers.FetchStaticIpsPager

FetchStaticIpsPager(
    method: typing.Callable[
        [...], google.cloud.datastream_v1.types.datastream.FetchStaticIpsResponse
    ],
    request: google.cloud.datastream_v1.types.datastream.FetchStaticIpsRequest,
    response: google.cloud.datastream_v1.types.datastream.FetchStaticIpsResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)

Instantiate the pager.

See more: google.cloud.datastream_v1.services.datastream.pagers.FetchStaticIpsPager

google.cloud.datastream_v1.services.datastream.pagers.ListConnectionProfilesAsyncPager

ListConnectionProfilesAsyncPager(
    method: typing.Callable[
        [...],
        typing.Awaitable[
            google.cloud.datastream_v1.types.datastream.ListConnectionProfilesResponse
        ],
    ],
    request: google.cloud.datastream_v1.types.datastream.ListConnectionProfilesRequest,
    response: google.cloud.datastream_v1.types.datastream.ListConnectionProfilesResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)

Instantiates the pager.

See more: google.cloud.datastream_v1.services.datastream.pagers.ListConnectionProfilesAsyncPager

google.cloud.datastream_v1.services.datastream.pagers.ListConnectionProfilesPager

ListConnectionProfilesPager(
    method: typing.Callable[
        [...],
        google.cloud.datastream_v1.types.datastream.ListConnectionProfilesResponse,
    ],
    request: google.cloud.datastream_v1.types.datastream.ListConnectionProfilesRequest,
    response: google.cloud.datastream_v1.types.datastream.ListConnectionProfilesResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)

Instantiate the pager.

See more: google.cloud.datastream_v1.services.datastream.pagers.ListConnectionProfilesPager

google.cloud.datastream_v1.services.datastream.pagers.ListPrivateConnectionsAsyncPager

ListPrivateConnectionsAsyncPager(
    method: typing.Callable[
        [...],
        typing.Awaitable[
            google.cloud.datastream_v1.types.datastream.ListPrivateConnectionsResponse
        ],
    ],
    request: google.cloud.datastream_v1.types.datastream.ListPrivateConnectionsRequest,
    response: google.cloud.datastream_v1.types.datastream.ListPrivateConnectionsResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)

Instantiates the pager.

See more: google.cloud.datastream_v1.services.datastream.pagers.ListPrivateConnectionsAsyncPager

google.cloud.datastream_v1.services.datastream.pagers.ListPrivateConnectionsPager

ListPrivateConnectionsPager(
    method: typing.Callable[
        [...],
        google.cloud.datastream_v1.types.datastream.ListPrivateConnectionsResponse,
    ],
    request: google.cloud.datastream_v1.types.datastream.ListPrivateConnectionsRequest,
    response: google.cloud.datastream_v1.types.datastream.ListPrivateConnectionsResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)

Instantiate the pager.

See more: google.cloud.datastream_v1.services.datastream.pagers.ListPrivateConnectionsPager

google.cloud.datastream_v1.services.datastream.pagers.ListRoutesAsyncPager

ListRoutesAsyncPager(
    method: typing.Callable[
        [...],
        typing.Awaitable[
            google.cloud.datastream_v1.types.datastream.ListRoutesResponse
        ],
    ],
    request: google.cloud.datastream_v1.types.datastream.ListRoutesRequest,
    response: google.cloud.datastream_v1.types.datastream.ListRoutesResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)

Instantiates the pager.

See more: google.cloud.datastream_v1.services.datastream.pagers.ListRoutesAsyncPager

google.cloud.datastream_v1.services.datastream.pagers.ListRoutesPager

ListRoutesPager(
    method: typing.Callable[
        [...], google.cloud.datastream_v1.types.datastream.ListRoutesResponse
    ],
    request: google.cloud.datastream_v1.types.datastream.ListRoutesRequest,
    response: google.cloud.datastream_v1.types.datastream.ListRoutesResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)

Instantiate the pager.

See more: google.cloud.datastream_v1.services.datastream.pagers.ListRoutesPager

google.cloud.datastream_v1.services.datastream.pagers.ListStreamObjectsAsyncPager

ListStreamObjectsAsyncPager(
    method: typing.Callable[
        [...],
        typing.Awaitable[
            google.cloud.datastream_v1.types.datastream.ListStreamObjectsResponse
        ],
    ],
    request: google.cloud.datastream_v1.types.datastream.ListStreamObjectsRequest,
    response: google.cloud.datastream_v1.types.datastream.ListStreamObjectsResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)

Instantiates the pager.

See more: google.cloud.datastream_v1.services.datastream.pagers.ListStreamObjectsAsyncPager

google.cloud.datastream_v1.services.datastream.pagers.ListStreamObjectsPager

ListStreamObjectsPager(
    method: typing.Callable[
        [...], google.cloud.datastream_v1.types.datastream.ListStreamObjectsResponse
    ],
    request: google.cloud.datastream_v1.types.datastream.ListStreamObjectsRequest,
    response: google.cloud.datastream_v1.types.datastream.ListStreamObjectsResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)

Instantiate the pager.

See more: google.cloud.datastream_v1.services.datastream.pagers.ListStreamObjectsPager

google.cloud.datastream_v1.services.datastream.pagers.ListStreamsAsyncPager

ListStreamsAsyncPager(
    method: typing.Callable[
        [...],
        typing.Awaitable[
            google.cloud.datastream_v1.types.datastream.ListStreamsResponse
        ],
    ],
    request: google.cloud.datastream_v1.types.datastream.ListStreamsRequest,
    response: google.cloud.datastream_v1.types.datastream.ListStreamsResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)

Instantiates the pager.

See more: google.cloud.datastream_v1.services.datastream.pagers.ListStreamsAsyncPager

google.cloud.datastream_v1.services.datastream.pagers.ListStreamsPager

ListStreamsPager(
    method: typing.Callable[
        [...], google.cloud.datastream_v1.types.datastream.ListStreamsResponse
    ],
    request: google.cloud.datastream_v1.types.datastream.ListStreamsRequest,
    response: google.cloud.datastream_v1.types.datastream.ListStreamsResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
)

Instantiate the pager.

See more: google.cloud.datastream_v1.services.datastream.pagers.ListStreamsPager

google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient

DatastreamAsyncClient(*, credentials: typing.Optional[google.auth.credentials.Credentials] = None, transport: typing.Optional[typing.Union[str, google.cloud.datastream_v1alpha1.services.datastream.transports.base.DatastreamTransport, typing.Callable[[...], google.cloud.datastream_v1alpha1.services.datastream.transports.base.DatastreamTransport]]] = 'grpc_asyncio', client_options: typing.Optional[google.api_core.client_options.ClientOptions] = None, client_info: google.api_core.gapic_v1.client_info.ClientInfo = 

Instantiates the datastream async client.

See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient

google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.common_billing_account_path

common_billing_account_path(billing_account: str) -> str

Returns a fully-qualified billing_account string.

See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.common_billing_account_path

google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.common_folder_path

common_folder_path(folder: str) -> str

Returns a fully-qualified folder string.

See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.common_folder_path

google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.common_location_path

common_location_path(project: str, location: str) -> str

Returns a fully-qualified location string.

See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.common_location_path

google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.common_organization_path

common_organization_path(organization: str) -> str

Returns a fully-qualified organization string.

See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.common_organization_path

google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.common_project_path

common_project_path(project: str) -> str

Returns a fully-qualified project string.

See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.common_project_path

google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.connection_profile_path

connection_profile_path(
    project: str, location: str, connection_profile: str
) -> str

Returns a fully-qualified connection_profile string.

See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.connection_profile_path

google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.create_connection_profile

create_connection_profile(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1alpha1.types.datastream.CreateConnectionProfileRequest,
            dict,
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    connection_profile: typing.Optional[
        google.cloud.datastream_v1alpha1.types.datastream_resources.ConnectionProfile
    ] = None,
    connection_profile_id: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation_async.AsyncOperation

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

See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.create_connection_profile

google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.create_private_connection

create_private_connection(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1alpha1.types.datastream.CreatePrivateConnectionRequest,
            dict,
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    private_connection: typing.Optional[
        google.cloud.datastream_v1alpha1.types.datastream_resources.PrivateConnection
    ] = None,
    private_connection_id: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation_async.AsyncOperation

Use this method to create a private connectivity configuration.

See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.create_private_connection

google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.create_route

create_route(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1alpha1.types.datastream.CreateRouteRequest, dict
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    route: typing.Optional[
        google.cloud.datastream_v1alpha1.types.datastream_resources.Route
    ] = None,
    route_id: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation_async.AsyncOperation

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

See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.create_route

google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.create_stream

create_stream(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1alpha1.types.datastream.CreateStreamRequest, dict
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    stream: typing.Optional[
        google.cloud.datastream_v1alpha1.types.datastream_resources.Stream
    ] = None,
    stream_id: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation_async.AsyncOperation

Use this method to create a stream.

See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.create_stream

google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.delete_connection_profile

delete_connection_profile(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1alpha1.types.datastream.DeleteConnectionProfileRequest,
            dict,
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation_async.AsyncOperation

Use this method to delete a connection profile.

See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.delete_connection_profile

google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.delete_private_connection

delete_private_connection(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1alpha1.types.datastream.DeletePrivateConnectionRequest,
            dict,
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation_async.AsyncOperation

Use this method to delete a private connectivity configuration.

See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.delete_private_connection

google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.delete_route

delete_route(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1alpha1.types.datastream.DeleteRouteRequest, dict
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation_async.AsyncOperation

Use this method to delete a route.

See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.delete_route

google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.delete_stream

delete_stream(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1alpha1.types.datastream.DeleteStreamRequest, dict
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation_async.AsyncOperation

Use this method to delete a stream.

See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.delete_stream

google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.discover_connection_profile

discover_connection_profile(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1alpha1.types.datastream.DiscoverConnectionProfileRequest,
            dict,
        ]
    ] = None,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> (
    google.cloud.datastream_v1alpha1.types.datastream.DiscoverConnectionProfileResponse
)

Use this method to discover a connection profile.

See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.discover_connection_profile

google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.fetch_errors

fetch_errors(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1alpha1.types.datastream.FetchErrorsRequest, dict
        ]
    ] = None,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.api_core.operation_async.AsyncOperation

Use this method to fetch any errors associated with a stream.

See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.fetch_errors

google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.fetch_static_ips

fetch_static_ips(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1alpha1.types.datastream.FetchStaticIpsRequest,
            dict,
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> (
    google.cloud.datastream_v1alpha1.services.datastream.pagers.FetchStaticIpsAsyncPager
)

The FetchStaticIps API call exposes the static ips used by Datastream.

See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.fetch_static_ips

google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.from_service_account_file

from_service_account_file(filename: str, *args, **kwargs)

Creates an instance of this client using the provided credentials file.

See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.from_service_account_file

google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.from_service_account_info

from_service_account_info(info: dict, *args, **kwargs)

Creates an instance of this client using the provided credentials info.

See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.from_service_account_info

google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.from_service_account_json

from_service_account_json(filename: str, *args, **kwargs)

Creates an instance of this client using the provided credentials file.

See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.from_service_account_json

google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.get_connection_profile

get_connection_profile(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1alpha1.types.datastream.GetConnectionProfileRequest,
            dict,
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1alpha1.types.datastream_resources.ConnectionProfile

Use this method to get details about a connection profile.

See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.get_connection_profile

google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.get_mtls_endpoint_and_cert_source

get_mtls_endpoint_and_cert_source(
    client_options: typing.Optional[
        google.api_core.client_options.ClientOptions
    ] = None,
)

Return the API endpoint and client cert source for mutual TLS.

See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.get_mtls_endpoint_and_cert_source

google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.get_private_connection

get_private_connection(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1alpha1.types.datastream.GetPrivateConnectionRequest,
            dict,
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1alpha1.types.datastream_resources.PrivateConnection

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

See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.get_private_connection

google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.get_route

get_route(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1alpha1.types.datastream.GetRouteRequest, dict
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1alpha1.types.datastream_resources.Route

Use this method to get details about a route.

See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.get_route

google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.get_stream

get_stream(
    request: typing.Optional[
        typing.Union[
            google.cloud.datastream_v1alpha1.types.datastream.GetStreamRequest, dict
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, str]] = ()
) -> google.cloud.datastream_v1alpha1.types.datastream_resources.Stream

Use this method to get details about a stream.

See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.get_stream

google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.get_transport_class

get_transport_class() -> (
    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, str]] = ()
) -> (
    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, str]] = ()
) -> (
    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, str]] = ()
) -> google.cloud.datastream_v1alpha1.services.datastream.pagers.ListRoutesAsyncPager

Use 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, str]] = ()
) -> google.cloud.datastream_v1alpha1.services.datastream.pagers.ListStreamsAsyncPager

Use 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.

See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.parse_common_billing_account_path

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.

See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.parse_common_location_path

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.

See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.parse_common_organization_path

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.

See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.parse_connection_profile_path

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.

See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.parse_private_connection_path

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
) -> str

Returns 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) -> str

Returns 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) -> str

Returns 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, str]] = ()
) -> google.api_core.operation_async.AsyncOperation

Use 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, str]] = ()
) -> google.api_core.operation_async.AsyncOperation

Use 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) -> str

Returns 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) -> str

Returns 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) -> str

Returns 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) -> str

Returns 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) -> str

Returns 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
) -> str

Returns 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, str]] = ()
) -> google.api_core.operation.Operation

Use 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, str]] = ()
) -> google.api_core.operation.Operation

Use 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, str]] = ()
) -> google.api_core.operation.Operation

Use 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, str]] = ()
) -> google.api_core.operation.Operation

Use 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, str]] = ()
) -> google.api_core.operation.Operation

Use 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, str]] = ()
) -> google.api_core.operation.Operation

Use 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, str]] = ()
) -> google.api_core.operation.Operation

Use 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, str]] = ()
) -> google.api_core.operation.Operation

Use 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, str]] = ()
) -> (
    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, str]] = ()
) -> google.api_core.operation.Operation

Use 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, str]] = ()
) -> google.cloud.datastream_v1alpha1.services.datastream.pagers.FetchStaticIpsPager

The 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, str]] = ()
) -> google.cloud.datastream_v1alpha1.types.datastream_resources.ConnectionProfile

Use this method to get details about a connection profile.

See more: google.cloud.datastream_v1alpha1.services.datastream.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.

See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.get_mtls_endpoint_and_cert_source

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, str]] = ()
) -> google.cloud.datastream_v1alpha1.types.datastream_resources.PrivateConnection

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

See more: google.cloud.datastream_v1alpha1.services.datastream.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, str]] = ()
) -> google.cloud.datastream_v1alpha1.types.datastream_resources.Route

Use this method to get details about a route.

See more: google.cloud.datastream_v1alpha1.services.datastream.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, str]] = ()
) -> google.cloud.datastream_v1alpha1.types.datastream_resources.Stream

Use this method to get details about a stream.

See more: google.cloud.datastream_v1alpha1.services.datastream.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, str]] = ()
) -> (
    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, str]] = ()
) -> (
    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, str]] = ()
) -> google.cloud.datastream_v1alpha1.services.datastream.pagers.ListRoutesPager

Use 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, str]] = ()
) -> google.cloud.datastream_v1alpha1.services.datastream.pagers.ListStreamsPager

Use 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.

See more: google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.parse_common_billing_account_path

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
) -> str

Returns 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) -> str

Returns 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) -> str

Returns 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, str]] = ()
) -> google.api_core.operation.Operation

Use 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, str]] = ()
) -> google.api_core.operation.Operation

Use 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, str]] = ()
)

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, str]] = ()
)

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, str]] = ()
)

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, str]] = ()
)

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, str]] = ()
)

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, str]] = ()
)

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, str]] = ()
)

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, str]] = ()
)

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, str]] = ()
)

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, str]] = ()
)

Instantiate the pager.

See more: google.cloud.datastream_v1alpha1.services.datastream.pagers.ListStreamsPager