Package Methods (1.14.0)

Summary of entries of Methods for eventarc.

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient

EventarcAsyncClient(*, credentials: typing.Optional[google.auth.credentials.Credentials] = None, transport: typing.Optional[typing.Union[str, google.cloud.eventarc_v1.services.eventarc.transports.base.EventarcTransport, typing.Callable[[...], google.cloud.eventarc_v1.services.eventarc.transports.base.EventarcTransport]]] = '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 eventarc async client.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.cancel_operation

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

Starts asynchronous cancellation on a long-running operation.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.cancel_operation

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.channel_connection_path

channel_connection_path(
    project: str, location: str, channel_connection: str
) -> str

Returns a fully-qualified channel_connection string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.channel_connection_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.channel_path

channel_path(project: str, location: str, channel: str) -> str

Returns a fully-qualified channel string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.channel_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.cloud_function_path

cloud_function_path(project: str, location: str, function: str) -> str

Returns a fully-qualified cloud_function string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.cloud_function_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.common_billing_account_path

common_billing_account_path(billing_account: str) -> str

Returns a fully-qualified billing_account string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.common_billing_account_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.common_folder_path

common_folder_path(folder: str) -> str

Returns a fully-qualified folder string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.common_folder_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.common_location_path

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

Returns a fully-qualified location string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.common_location_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.common_organization_path

common_organization_path(organization: str) -> str

Returns a fully-qualified organization string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.common_organization_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.common_project_path

common_project_path(project: str) -> str

Returns a fully-qualified project string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.common_project_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.create_channel

create_channel(
    request: typing.Optional[
        typing.Union[google.cloud.eventarc_v1.types.eventarc.CreateChannelRequest, dict]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    channel: typing.Optional[google.cloud.eventarc_v1.types.channel.Channel] = None,
    channel_id: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation_async.AsyncOperation

Create a new channel in a particular project and location.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.create_channel

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.create_channel_connection

create_channel_connection(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.CreateChannelConnectionRequest, dict
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    channel_connection: typing.Optional[
        google.cloud.eventarc_v1.types.channel_connection.ChannelConnection
    ] = None,
    channel_connection_id: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation_async.AsyncOperation

Create a new ChannelConnection in a particular project and location.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.create_channel_connection

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.create_enrollment

create_enrollment(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.CreateEnrollmentRequest, dict
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    enrollment: typing.Optional[
        google.cloud.eventarc_v1.types.enrollment.Enrollment
    ] = None,
    enrollment_id: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation_async.AsyncOperation

Create a new Enrollment in a particular project and location.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.create_enrollment

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.create_google_api_source

create_google_api_source(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.CreateGoogleApiSourceRequest, dict
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    google_api_source: typing.Optional[
        google.cloud.eventarc_v1.types.google_api_source.GoogleApiSource
    ] = None,
    google_api_source_id: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation_async.AsyncOperation

Create a new GoogleApiSource in a particular project and location.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.create_google_api_source

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.create_message_bus

create_message_bus(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.CreateMessageBusRequest, dict
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    message_bus: typing.Optional[
        google.cloud.eventarc_v1.types.message_bus.MessageBus
    ] = None,
    message_bus_id: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation_async.AsyncOperation

Create a new MessageBus in a particular project and location.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.create_message_bus

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.create_pipeline

create_pipeline(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.CreatePipelineRequest, dict
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    pipeline: typing.Optional[google.cloud.eventarc_v1.types.pipeline.Pipeline] = None,
    pipeline_id: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation_async.AsyncOperation

Create a new Pipeline in a particular project and location.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.create_pipeline

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.create_trigger

create_trigger(
    request: typing.Optional[
        typing.Union[google.cloud.eventarc_v1.types.eventarc.CreateTriggerRequest, dict]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    trigger: typing.Optional[google.cloud.eventarc_v1.types.trigger.Trigger] = None,
    trigger_id: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation_async.AsyncOperation

Create a new trigger in a particular project and location.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.create_trigger

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.crypto_key_path

crypto_key_path(project: str, location: str, key_ring: str, crypto_key: str) -> str

Returns a fully-qualified crypto_key string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.crypto_key_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.delete_channel

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

Delete a single channel.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.delete_channel

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.delete_channel_connection

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

Delete a single ChannelConnection.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.delete_channel_connection

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.delete_enrollment

delete_enrollment(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.DeleteEnrollmentRequest, dict
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    etag: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation_async.AsyncOperation

Delete a single Enrollment.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.delete_enrollment

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.delete_google_api_source

delete_google_api_source(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.DeleteGoogleApiSourceRequest, dict
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    etag: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation_async.AsyncOperation

Delete a single GoogleApiSource.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.delete_google_api_source

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.delete_message_bus

delete_message_bus(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.DeleteMessageBusRequest, dict
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    etag: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation_async.AsyncOperation

Delete a single message bus.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.delete_message_bus

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.delete_operation

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

Deletes a long-running operation.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.delete_operation

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.delete_pipeline

delete_pipeline(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.DeletePipelineRequest, dict
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    etag: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation_async.AsyncOperation

Delete a single pipeline.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.delete_pipeline

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.delete_trigger

delete_trigger(
    request: typing.Optional[
        typing.Union[google.cloud.eventarc_v1.types.eventarc.DeleteTriggerRequest, dict]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    allow_missing: typing.Optional[bool] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation_async.AsyncOperation

Delete a single trigger.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.delete_trigger

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.enrollment_path

enrollment_path(project: str, location: str, enrollment: str) -> str

Returns a fully-qualified enrollment string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.enrollment_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.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.eventarc_v1.services.eventarc.EventarcAsyncClient.from_service_account_file

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.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.eventarc_v1.services.eventarc.EventarcAsyncClient.from_service_account_info

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.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.eventarc_v1.services.eventarc.EventarcAsyncClient.from_service_account_json

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.get_channel

get_channel(
    request: typing.Optional[
        typing.Union[google.cloud.eventarc_v1.types.eventarc.GetChannelRequest, dict]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.eventarc_v1.types.channel.Channel

Get a single Channel.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.get_channel

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.get_channel_connection

get_channel_connection(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.GetChannelConnectionRequest, dict
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.eventarc_v1.types.channel_connection.ChannelConnection

Get a single ChannelConnection.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.get_channel_connection

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.get_enrollment

get_enrollment(
    request: typing.Optional[
        typing.Union[google.cloud.eventarc_v1.types.eventarc.GetEnrollmentRequest, dict]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.eventarc_v1.types.enrollment.Enrollment

Get a single Enrollment.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.get_enrollment

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.get_google_api_source

get_google_api_source(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.GetGoogleApiSourceRequest, dict
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.eventarc_v1.types.google_api_source.GoogleApiSource

Get a single GoogleApiSource.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.get_google_api_source

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.get_google_channel_config

get_google_channel_config(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.GetGoogleChannelConfigRequest, dict
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.eventarc_v1.types.google_channel_config.GoogleChannelConfig

Get a GoogleChannelConfig.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.get_google_channel_config

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.get_iam_policy

get_iam_policy(
    request: typing.Optional[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest] = None,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.Policy

Gets the IAM access control policy for a function.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.get_iam_policy

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.get_location

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

Gets information about a location.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.get_location

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.get_message_bus

get_message_bus(
    request: typing.Optional[
        typing.Union[google.cloud.eventarc_v1.types.eventarc.GetMessageBusRequest, dict]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.eventarc_v1.types.message_bus.MessageBus

Get a single MessageBus.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.get_message_bus

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.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.eventarc_v1.services.eventarc.EventarcAsyncClient.get_mtls_endpoint_and_cert_source

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.get_operation

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

Gets the latest state of a long-running operation.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.get_operation

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.get_pipeline

get_pipeline(
    request: typing.Optional[
        typing.Union[google.cloud.eventarc_v1.types.eventarc.GetPipelineRequest, dict]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.eventarc_v1.types.pipeline.Pipeline

Get a single Pipeline.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.get_pipeline

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.get_provider

get_provider(
    request: typing.Optional[
        typing.Union[google.cloud.eventarc_v1.types.eventarc.GetProviderRequest, dict]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.eventarc_v1.types.discovery.Provider

Get a single Provider.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.get_provider

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.get_transport_class

get_transport_class(
    label: typing.Optional[str] = None,
) -> typing.Type[
    google.cloud.eventarc_v1.services.eventarc.transports.base.EventarcTransport
]

Returns an appropriate transport class.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.get_transport_class

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.get_trigger

get_trigger(
    request: typing.Optional[
        typing.Union[google.cloud.eventarc_v1.types.eventarc.GetTriggerRequest, dict]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.eventarc_v1.types.trigger.Trigger

Get a single trigger.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.get_trigger

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.google_api_source_path

google_api_source_path(project: str, location: str, google_api_source: str) -> str

Returns a fully-qualified google_api_source string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.google_api_source_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.google_channel_config_path

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

Returns a fully-qualified google_channel_config string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.google_channel_config_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.list_channel_connections

list_channel_connections(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.ListChannelConnectionsRequest, dict
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.eventarc_v1.services.eventarc.pagers.ListChannelConnectionsAsyncPager

List channel connections.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.list_channel_connections

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.list_channels

list_channels(
    request: typing.Optional[
        typing.Union[google.cloud.eventarc_v1.types.eventarc.ListChannelsRequest, dict]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.eventarc_v1.services.eventarc.pagers.ListChannelsAsyncPager

List channels.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.list_channels

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.list_enrollments

list_enrollments(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.ListEnrollmentsRequest, dict
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.eventarc_v1.services.eventarc.pagers.ListEnrollmentsAsyncPager

List Enrollments.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.list_enrollments

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.list_google_api_sources

list_google_api_sources(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.ListGoogleApiSourcesRequest, dict
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.eventarc_v1.services.eventarc.pagers.ListGoogleApiSourcesAsyncPager

List GoogleApiSources.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.list_google_api_sources

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.list_locations

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

Lists information about the supported locations for this service.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.list_locations

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.list_message_bus_enrollments

list_message_bus_enrollments(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.ListMessageBusEnrollmentsRequest,
            dict,
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> (
    google.cloud.eventarc_v1.services.eventarc.pagers.ListMessageBusEnrollmentsAsyncPager
)

List message bus enrollments.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.list_message_bus_enrollments

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.list_message_buses

list_message_buses(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.ListMessageBusesRequest, dict
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.eventarc_v1.services.eventarc.pagers.ListMessageBusesAsyncPager

List message buses.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.list_message_buses

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.list_operations

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

Lists operations that match the specified filter in the request.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.list_operations

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.list_pipelines

list_pipelines(
    request: typing.Optional[
        typing.Union[google.cloud.eventarc_v1.types.eventarc.ListPipelinesRequest, dict]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.eventarc_v1.services.eventarc.pagers.ListPipelinesAsyncPager

List pipelines.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.list_pipelines

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.list_providers

list_providers(
    request: typing.Optional[
        typing.Union[google.cloud.eventarc_v1.types.eventarc.ListProvidersRequest, dict]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.eventarc_v1.services.eventarc.pagers.ListProvidersAsyncPager

List providers.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.list_providers

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.list_triggers

list_triggers(
    request: typing.Optional[
        typing.Union[google.cloud.eventarc_v1.types.eventarc.ListTriggersRequest, dict]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.eventarc_v1.services.eventarc.pagers.ListTriggersAsyncPager

List triggers.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.list_triggers

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.message_bus_path

message_bus_path(project: str, location: str, message_bus: str) -> str

Returns a fully-qualified message_bus string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.message_bus_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.network_attachment_path

network_attachment_path(project: str, region: str, networkattachment: str) -> str

Returns a fully-qualified network_attachment string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.network_attachment_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.parse_channel_connection_path

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

Parses a channel_connection path into its component segments.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.parse_channel_connection_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.parse_channel_path

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

Parses a channel path into its component segments.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.parse_channel_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.parse_cloud_function_path

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

Parses a cloud_function path into its component segments.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.parse_cloud_function_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.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.eventarc_v1.services.eventarc.EventarcAsyncClient.parse_common_billing_account_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.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.eventarc_v1.services.eventarc.EventarcAsyncClient.parse_common_folder_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.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.eventarc_v1.services.eventarc.EventarcAsyncClient.parse_common_location_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.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.eventarc_v1.services.eventarc.EventarcAsyncClient.parse_common_organization_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.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.eventarc_v1.services.eventarc.EventarcAsyncClient.parse_common_project_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.parse_crypto_key_path

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

Parses a crypto_key path into its component segments.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.parse_crypto_key_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.parse_enrollment_path

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

Parses a enrollment path into its component segments.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.parse_enrollment_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.parse_google_api_source_path

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

Parses a google_api_source path into its component segments.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.parse_google_api_source_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.parse_google_channel_config_path

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

Parses a google_channel_config path into its component segments.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.parse_google_channel_config_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.parse_message_bus_path

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

Parses a message_bus path into its component segments.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.parse_message_bus_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.parse_network_attachment_path

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

Parses a network_attachment path into its component segments.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.parse_network_attachment_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.parse_pipeline_path

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

Parses a pipeline path into its component segments.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.parse_pipeline_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.parse_provider_path

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

Parses a provider path into its component segments.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.parse_provider_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.parse_service_account_path

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

Parses a service_account path into its component segments.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.parse_service_account_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.parse_service_path

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

Parses a service path into its component segments.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.parse_service_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.parse_topic_path

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

Parses a topic path into its component segments.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.parse_topic_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.parse_trigger_path

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

Parses a trigger path into its component segments.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.parse_trigger_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.parse_workflow_path

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

Parses a workflow path into its component segments.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.parse_workflow_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.pipeline_path

pipeline_path(project: str, location: str, pipeline: str) -> str

Returns a fully-qualified pipeline string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.pipeline_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.provider_path

provider_path(project: str, location: str, provider: str) -> str

Returns a fully-qualified provider string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.provider_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.service_account_path

service_account_path(project: str, service_account: str) -> str

Returns a fully-qualified service_account string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.service_account_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.service_path

service_path() -> str

Returns a fully-qualified service string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.service_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.set_iam_policy

set_iam_policy(
    request: typing.Optional[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest] = None,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.Policy

Sets the IAM access control policy on the specified function.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.set_iam_policy

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.test_iam_permissions

test_iam_permissions(
    request: typing.Optional[
        google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest
    ] = None,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.iam_policy_pb2.TestIamPermissionsResponse

Tests the specified IAM permissions against the IAM access control policy for a function.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.test_iam_permissions

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.topic_path

topic_path(project: str, topic: str) -> str

Returns a fully-qualified topic string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.topic_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.trigger_path

trigger_path(project: str, location: str, trigger: str) -> str

Returns a fully-qualified trigger string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.trigger_path

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.update_channel

update_channel(
    request: typing.Optional[
        typing.Union[google.cloud.eventarc_v1.types.eventarc.UpdateChannelRequest, dict]
    ] = None,
    *,
    channel: typing.Optional[google.cloud.eventarc_v1.types.channel.Channel] = None,
    update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation_async.AsyncOperation

Update a single channel.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.update_channel

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.update_enrollment

update_enrollment(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.UpdateEnrollmentRequest, dict
        ]
    ] = None,
    *,
    enrollment: typing.Optional[
        google.cloud.eventarc_v1.types.enrollment.Enrollment
    ] = None,
    update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation_async.AsyncOperation

Update a single Enrollment.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.update_enrollment

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.update_google_api_source

update_google_api_source(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.UpdateGoogleApiSourceRequest, dict
        ]
    ] = None,
    *,
    google_api_source: typing.Optional[
        google.cloud.eventarc_v1.types.google_api_source.GoogleApiSource
    ] = None,
    update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation_async.AsyncOperation

Update a single GoogleApiSource.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.update_google_api_source

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.update_google_channel_config

update_google_channel_config(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.UpdateGoogleChannelConfigRequest,
            dict,
        ]
    ] = None,
    *,
    google_channel_config: typing.Optional[
        google.cloud.eventarc_v1.types.google_channel_config.GoogleChannelConfig
    ] = None,
    update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.eventarc_v1.types.google_channel_config.GoogleChannelConfig

Update a single GoogleChannelConfig.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.update_google_channel_config

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.update_message_bus

update_message_bus(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.UpdateMessageBusRequest, dict
        ]
    ] = None,
    *,
    message_bus: typing.Optional[
        google.cloud.eventarc_v1.types.message_bus.MessageBus
    ] = None,
    update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation_async.AsyncOperation

Update a single message bus.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.update_message_bus

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.update_pipeline

update_pipeline(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.UpdatePipelineRequest, dict
        ]
    ] = None,
    *,
    pipeline: typing.Optional[google.cloud.eventarc_v1.types.pipeline.Pipeline] = None,
    update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation_async.AsyncOperation

Update a single pipeline.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.update_pipeline

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.update_trigger

update_trigger(
    request: typing.Optional[
        typing.Union[google.cloud.eventarc_v1.types.eventarc.UpdateTriggerRequest, dict]
    ] = None,
    *,
    trigger: typing.Optional[google.cloud.eventarc_v1.types.trigger.Trigger] = None,
    update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None,
    allow_missing: typing.Optional[bool] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation_async.AsyncOperation

Update a single trigger.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.update_trigger

google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.workflow_path

workflow_path(project: str, location: str, workflow: str) -> str

Returns a fully-qualified workflow string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcAsyncClient.workflow_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient

EventarcClient(*, credentials: typing.Optional[google.auth.credentials.Credentials] = None, transport: typing.Optional[typing.Union[str, google.cloud.eventarc_v1.services.eventarc.transports.base.EventarcTransport, typing.Callable[[...], google.cloud.eventarc_v1.services.eventarc.transports.base.EventarcTransport]]] = 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 eventarc client.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient

google.cloud.eventarc_v1.services.eventarc.EventarcClient.exit

__exit__(type, value, traceback)

Releases underlying transport's resources.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.exit

google.cloud.eventarc_v1.services.eventarc.EventarcClient.cancel_operation

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

Starts asynchronous cancellation on a long-running operation.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.cancel_operation

google.cloud.eventarc_v1.services.eventarc.EventarcClient.channel_connection_path

channel_connection_path(
    project: str, location: str, channel_connection: str
) -> str

Returns a fully-qualified channel_connection string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.channel_connection_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.channel_path

channel_path(project: str, location: str, channel: str) -> str

Returns a fully-qualified channel string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.channel_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.cloud_function_path

cloud_function_path(project: str, location: str, function: str) -> str

Returns a fully-qualified cloud_function string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.cloud_function_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.common_billing_account_path

common_billing_account_path(billing_account: str) -> str

Returns a fully-qualified billing_account string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.common_billing_account_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.common_folder_path

common_folder_path(folder: str) -> str

Returns a fully-qualified folder string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.common_folder_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.common_location_path

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

Returns a fully-qualified location string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.common_location_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.common_organization_path

common_organization_path(organization: str) -> str

Returns a fully-qualified organization string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.common_organization_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.common_project_path

common_project_path(project: str) -> str

Returns a fully-qualified project string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.common_project_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.create_channel

create_channel(
    request: typing.Optional[
        typing.Union[google.cloud.eventarc_v1.types.eventarc.CreateChannelRequest, dict]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    channel: typing.Optional[google.cloud.eventarc_v1.types.channel.Channel] = None,
    channel_id: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation.Operation

Create a new channel in a particular project and location.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.create_channel

google.cloud.eventarc_v1.services.eventarc.EventarcClient.create_channel_connection

create_channel_connection(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.CreateChannelConnectionRequest, dict
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    channel_connection: typing.Optional[
        google.cloud.eventarc_v1.types.channel_connection.ChannelConnection
    ] = None,
    channel_connection_id: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation.Operation

Create a new ChannelConnection in a particular project and location.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.create_channel_connection

google.cloud.eventarc_v1.services.eventarc.EventarcClient.create_enrollment

create_enrollment(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.CreateEnrollmentRequest, dict
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    enrollment: typing.Optional[
        google.cloud.eventarc_v1.types.enrollment.Enrollment
    ] = None,
    enrollment_id: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation.Operation

Create a new Enrollment in a particular project and location.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.create_enrollment

google.cloud.eventarc_v1.services.eventarc.EventarcClient.create_google_api_source

create_google_api_source(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.CreateGoogleApiSourceRequest, dict
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    google_api_source: typing.Optional[
        google.cloud.eventarc_v1.types.google_api_source.GoogleApiSource
    ] = None,
    google_api_source_id: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation.Operation

Create a new GoogleApiSource in a particular project and location.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.create_google_api_source

google.cloud.eventarc_v1.services.eventarc.EventarcClient.create_message_bus

create_message_bus(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.CreateMessageBusRequest, dict
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    message_bus: typing.Optional[
        google.cloud.eventarc_v1.types.message_bus.MessageBus
    ] = None,
    message_bus_id: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation.Operation

Create a new MessageBus in a particular project and location.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.create_message_bus

google.cloud.eventarc_v1.services.eventarc.EventarcClient.create_pipeline

create_pipeline(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.CreatePipelineRequest, dict
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    pipeline: typing.Optional[google.cloud.eventarc_v1.types.pipeline.Pipeline] = None,
    pipeline_id: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation.Operation

Create a new Pipeline in a particular project and location.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.create_pipeline

google.cloud.eventarc_v1.services.eventarc.EventarcClient.create_trigger

create_trigger(
    request: typing.Optional[
        typing.Union[google.cloud.eventarc_v1.types.eventarc.CreateTriggerRequest, dict]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    trigger: typing.Optional[google.cloud.eventarc_v1.types.trigger.Trigger] = None,
    trigger_id: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation.Operation

Create a new trigger in a particular project and location.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.create_trigger

google.cloud.eventarc_v1.services.eventarc.EventarcClient.crypto_key_path

crypto_key_path(project: str, location: str, key_ring: str, crypto_key: str) -> str

Returns a fully-qualified crypto_key string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.crypto_key_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.delete_channel

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

Delete a single channel.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.delete_channel

google.cloud.eventarc_v1.services.eventarc.EventarcClient.delete_channel_connection

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

Delete a single ChannelConnection.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.delete_channel_connection

google.cloud.eventarc_v1.services.eventarc.EventarcClient.delete_enrollment

delete_enrollment(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.DeleteEnrollmentRequest, dict
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    etag: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation.Operation

Delete a single Enrollment.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.delete_enrollment

google.cloud.eventarc_v1.services.eventarc.EventarcClient.delete_google_api_source

delete_google_api_source(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.DeleteGoogleApiSourceRequest, dict
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    etag: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation.Operation

Delete a single GoogleApiSource.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.delete_google_api_source

google.cloud.eventarc_v1.services.eventarc.EventarcClient.delete_message_bus

delete_message_bus(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.DeleteMessageBusRequest, dict
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    etag: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation.Operation

Delete a single message bus.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.delete_message_bus

google.cloud.eventarc_v1.services.eventarc.EventarcClient.delete_operation

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

Deletes a long-running operation.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.delete_operation

google.cloud.eventarc_v1.services.eventarc.EventarcClient.delete_pipeline

delete_pipeline(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.DeletePipelineRequest, dict
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    etag: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation.Operation

Delete a single pipeline.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.delete_pipeline

google.cloud.eventarc_v1.services.eventarc.EventarcClient.delete_trigger

delete_trigger(
    request: typing.Optional[
        typing.Union[google.cloud.eventarc_v1.types.eventarc.DeleteTriggerRequest, dict]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    allow_missing: typing.Optional[bool] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation.Operation

Delete a single trigger.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.delete_trigger

google.cloud.eventarc_v1.services.eventarc.EventarcClient.enrollment_path

enrollment_path(project: str, location: str, enrollment: str) -> str

Returns a fully-qualified enrollment string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.enrollment_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.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.eventarc_v1.services.eventarc.EventarcClient.from_service_account_file

google.cloud.eventarc_v1.services.eventarc.EventarcClient.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.eventarc_v1.services.eventarc.EventarcClient.from_service_account_info

google.cloud.eventarc_v1.services.eventarc.EventarcClient.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.eventarc_v1.services.eventarc.EventarcClient.from_service_account_json

google.cloud.eventarc_v1.services.eventarc.EventarcClient.get_channel

get_channel(
    request: typing.Optional[
        typing.Union[google.cloud.eventarc_v1.types.eventarc.GetChannelRequest, dict]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.eventarc_v1.types.channel.Channel

Get a single Channel.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.get_channel

google.cloud.eventarc_v1.services.eventarc.EventarcClient.get_channel_connection

get_channel_connection(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.GetChannelConnectionRequest, dict
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.eventarc_v1.types.channel_connection.ChannelConnection

Get a single ChannelConnection.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.get_channel_connection

google.cloud.eventarc_v1.services.eventarc.EventarcClient.get_enrollment

get_enrollment(
    request: typing.Optional[
        typing.Union[google.cloud.eventarc_v1.types.eventarc.GetEnrollmentRequest, dict]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.eventarc_v1.types.enrollment.Enrollment

Get a single Enrollment.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.get_enrollment

google.cloud.eventarc_v1.services.eventarc.EventarcClient.get_google_api_source

get_google_api_source(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.GetGoogleApiSourceRequest, dict
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.eventarc_v1.types.google_api_source.GoogleApiSource

Get a single GoogleApiSource.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.get_google_api_source

google.cloud.eventarc_v1.services.eventarc.EventarcClient.get_google_channel_config

get_google_channel_config(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.GetGoogleChannelConfigRequest, dict
        ]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.eventarc_v1.types.google_channel_config.GoogleChannelConfig

Get a GoogleChannelConfig.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.get_google_channel_config

google.cloud.eventarc_v1.services.eventarc.EventarcClient.get_iam_policy

get_iam_policy(
    request: typing.Optional[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest] = None,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.Policy

Gets the IAM access control policy for a function.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.get_iam_policy

google.cloud.eventarc_v1.services.eventarc.EventarcClient.get_location

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

Gets information about a location.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.get_location

google.cloud.eventarc_v1.services.eventarc.EventarcClient.get_message_bus

get_message_bus(
    request: typing.Optional[
        typing.Union[google.cloud.eventarc_v1.types.eventarc.GetMessageBusRequest, dict]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.eventarc_v1.types.message_bus.MessageBus

Get a single MessageBus.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.get_message_bus

google.cloud.eventarc_v1.services.eventarc.EventarcClient.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.eventarc_v1.services.eventarc.EventarcClient.get_mtls_endpoint_and_cert_source

google.cloud.eventarc_v1.services.eventarc.EventarcClient.get_operation

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

Gets the latest state of a long-running operation.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.get_operation

google.cloud.eventarc_v1.services.eventarc.EventarcClient.get_pipeline

get_pipeline(
    request: typing.Optional[
        typing.Union[google.cloud.eventarc_v1.types.eventarc.GetPipelineRequest, dict]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.eventarc_v1.types.pipeline.Pipeline

Get a single Pipeline.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.get_pipeline

google.cloud.eventarc_v1.services.eventarc.EventarcClient.get_provider

get_provider(
    request: typing.Optional[
        typing.Union[google.cloud.eventarc_v1.types.eventarc.GetProviderRequest, dict]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.eventarc_v1.types.discovery.Provider

Get a single Provider.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.get_provider

google.cloud.eventarc_v1.services.eventarc.EventarcClient.get_trigger

get_trigger(
    request: typing.Optional[
        typing.Union[google.cloud.eventarc_v1.types.eventarc.GetTriggerRequest, dict]
    ] = None,
    *,
    name: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.eventarc_v1.types.trigger.Trigger

Get a single trigger.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.get_trigger

google.cloud.eventarc_v1.services.eventarc.EventarcClient.google_api_source_path

google_api_source_path(project: str, location: str, google_api_source: str) -> str

Returns a fully-qualified google_api_source string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.google_api_source_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.google_channel_config_path

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

Returns a fully-qualified google_channel_config string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.google_channel_config_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.list_channel_connections

list_channel_connections(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.ListChannelConnectionsRequest, dict
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.eventarc_v1.services.eventarc.pagers.ListChannelConnectionsPager

List channel connections.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.list_channel_connections

google.cloud.eventarc_v1.services.eventarc.EventarcClient.list_channels

list_channels(
    request: typing.Optional[
        typing.Union[google.cloud.eventarc_v1.types.eventarc.ListChannelsRequest, dict]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.eventarc_v1.services.eventarc.pagers.ListChannelsPager

List channels.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.list_channels

google.cloud.eventarc_v1.services.eventarc.EventarcClient.list_enrollments

list_enrollments(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.ListEnrollmentsRequest, dict
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.eventarc_v1.services.eventarc.pagers.ListEnrollmentsPager

List Enrollments.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.list_enrollments

google.cloud.eventarc_v1.services.eventarc.EventarcClient.list_google_api_sources

list_google_api_sources(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.ListGoogleApiSourcesRequest, dict
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.eventarc_v1.services.eventarc.pagers.ListGoogleApiSourcesPager

List GoogleApiSources.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.list_google_api_sources

google.cloud.eventarc_v1.services.eventarc.EventarcClient.list_locations

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

Lists information about the supported locations for this service.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.list_locations

google.cloud.eventarc_v1.services.eventarc.EventarcClient.list_message_bus_enrollments

list_message_bus_enrollments(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.ListMessageBusEnrollmentsRequest,
            dict,
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.eventarc_v1.services.eventarc.pagers.ListMessageBusEnrollmentsPager

List message bus enrollments.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.list_message_bus_enrollments

google.cloud.eventarc_v1.services.eventarc.EventarcClient.list_message_buses

list_message_buses(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.ListMessageBusesRequest, dict
        ]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.eventarc_v1.services.eventarc.pagers.ListMessageBusesPager

List message buses.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.list_message_buses

google.cloud.eventarc_v1.services.eventarc.EventarcClient.list_operations

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

Lists operations that match the specified filter in the request.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.list_operations

google.cloud.eventarc_v1.services.eventarc.EventarcClient.list_pipelines

list_pipelines(
    request: typing.Optional[
        typing.Union[google.cloud.eventarc_v1.types.eventarc.ListPipelinesRequest, dict]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.eventarc_v1.services.eventarc.pagers.ListPipelinesPager

List pipelines.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.list_pipelines

google.cloud.eventarc_v1.services.eventarc.EventarcClient.list_providers

list_providers(
    request: typing.Optional[
        typing.Union[google.cloud.eventarc_v1.types.eventarc.ListProvidersRequest, dict]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.eventarc_v1.services.eventarc.pagers.ListProvidersPager

List providers.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.list_providers

google.cloud.eventarc_v1.services.eventarc.EventarcClient.list_triggers

list_triggers(
    request: typing.Optional[
        typing.Union[google.cloud.eventarc_v1.types.eventarc.ListTriggersRequest, dict]
    ] = None,
    *,
    parent: typing.Optional[str] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.eventarc_v1.services.eventarc.pagers.ListTriggersPager

List triggers.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.list_triggers

google.cloud.eventarc_v1.services.eventarc.EventarcClient.message_bus_path

message_bus_path(project: str, location: str, message_bus: str) -> str

Returns a fully-qualified message_bus string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.message_bus_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.network_attachment_path

network_attachment_path(project: str, region: str, networkattachment: str) -> str

Returns a fully-qualified network_attachment string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.network_attachment_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.parse_channel_connection_path

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

Parses a channel_connection path into its component segments.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.parse_channel_connection_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.parse_channel_path

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

Parses a channel path into its component segments.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.parse_channel_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.parse_cloud_function_path

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

Parses a cloud_function path into its component segments.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.parse_cloud_function_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.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.eventarc_v1.services.eventarc.EventarcClient.parse_common_billing_account_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.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.eventarc_v1.services.eventarc.EventarcClient.parse_common_folder_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.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.eventarc_v1.services.eventarc.EventarcClient.parse_common_location_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.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.eventarc_v1.services.eventarc.EventarcClient.parse_common_organization_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.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.eventarc_v1.services.eventarc.EventarcClient.parse_common_project_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.parse_crypto_key_path

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

Parses a crypto_key path into its component segments.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.parse_crypto_key_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.parse_enrollment_path

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

Parses a enrollment path into its component segments.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.parse_enrollment_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.parse_google_api_source_path

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

Parses a google_api_source path into its component segments.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.parse_google_api_source_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.parse_google_channel_config_path

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

Parses a google_channel_config path into its component segments.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.parse_google_channel_config_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.parse_message_bus_path

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

Parses a message_bus path into its component segments.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.parse_message_bus_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.parse_network_attachment_path

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

Parses a network_attachment path into its component segments.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.parse_network_attachment_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.parse_pipeline_path

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

Parses a pipeline path into its component segments.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.parse_pipeline_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.parse_provider_path

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

Parses a provider path into its component segments.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.parse_provider_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.parse_service_account_path

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

Parses a service_account path into its component segments.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.parse_service_account_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.parse_service_path

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

Parses a service path into its component segments.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.parse_service_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.parse_topic_path

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

Parses a topic path into its component segments.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.parse_topic_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.parse_trigger_path

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

Parses a trigger path into its component segments.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.parse_trigger_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.parse_workflow_path

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

Parses a workflow path into its component segments.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.parse_workflow_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.pipeline_path

pipeline_path(project: str, location: str, pipeline: str) -> str

Returns a fully-qualified pipeline string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.pipeline_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.provider_path

provider_path(project: str, location: str, provider: str) -> str

Returns a fully-qualified provider string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.provider_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.service_account_path

service_account_path(project: str, service_account: str) -> str

Returns a fully-qualified service_account string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.service_account_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.service_path

service_path() -> str

Returns a fully-qualified service string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.service_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.set_iam_policy

set_iam_policy(
    request: typing.Optional[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest] = None,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.Policy

Sets the IAM access control policy on the specified function.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.set_iam_policy

google.cloud.eventarc_v1.services.eventarc.EventarcClient.test_iam_permissions

test_iam_permissions(
    request: typing.Optional[
        google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest
    ] = None,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.iam_policy_pb2.TestIamPermissionsResponse

Tests the specified IAM permissions against the IAM access control policy for a function.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.test_iam_permissions

google.cloud.eventarc_v1.services.eventarc.EventarcClient.topic_path

topic_path(project: str, topic: str) -> str

Returns a fully-qualified topic string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.topic_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.trigger_path

trigger_path(project: str, location: str, trigger: str) -> str

Returns a fully-qualified trigger string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.trigger_path

google.cloud.eventarc_v1.services.eventarc.EventarcClient.update_channel

update_channel(
    request: typing.Optional[
        typing.Union[google.cloud.eventarc_v1.types.eventarc.UpdateChannelRequest, dict]
    ] = None,
    *,
    channel: typing.Optional[google.cloud.eventarc_v1.types.channel.Channel] = None,
    update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation.Operation

Update a single channel.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.update_channel

google.cloud.eventarc_v1.services.eventarc.EventarcClient.update_enrollment

update_enrollment(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.UpdateEnrollmentRequest, dict
        ]
    ] = None,
    *,
    enrollment: typing.Optional[
        google.cloud.eventarc_v1.types.enrollment.Enrollment
    ] = None,
    update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation.Operation

Update a single Enrollment.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.update_enrollment

google.cloud.eventarc_v1.services.eventarc.EventarcClient.update_google_api_source

update_google_api_source(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.UpdateGoogleApiSourceRequest, dict
        ]
    ] = None,
    *,
    google_api_source: typing.Optional[
        google.cloud.eventarc_v1.types.google_api_source.GoogleApiSource
    ] = None,
    update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation.Operation

Update a single GoogleApiSource.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.update_google_api_source

google.cloud.eventarc_v1.services.eventarc.EventarcClient.update_google_channel_config

update_google_channel_config(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.UpdateGoogleChannelConfigRequest,
            dict,
        ]
    ] = None,
    *,
    google_channel_config: typing.Optional[
        google.cloud.eventarc_v1.types.google_channel_config.GoogleChannelConfig
    ] = None,
    update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.eventarc_v1.types.google_channel_config.GoogleChannelConfig

Update a single GoogleChannelConfig.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.update_google_channel_config

google.cloud.eventarc_v1.services.eventarc.EventarcClient.update_message_bus

update_message_bus(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.UpdateMessageBusRequest, dict
        ]
    ] = None,
    *,
    message_bus: typing.Optional[
        google.cloud.eventarc_v1.types.message_bus.MessageBus
    ] = None,
    update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation.Operation

Update a single message bus.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.update_message_bus

google.cloud.eventarc_v1.services.eventarc.EventarcClient.update_pipeline

update_pipeline(
    request: typing.Optional[
        typing.Union[
            google.cloud.eventarc_v1.types.eventarc.UpdatePipelineRequest, dict
        ]
    ] = None,
    *,
    pipeline: typing.Optional[google.cloud.eventarc_v1.types.pipeline.Pipeline] = None,
    update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation.Operation

Update a single pipeline.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.update_pipeline

google.cloud.eventarc_v1.services.eventarc.EventarcClient.update_trigger

update_trigger(
    request: typing.Optional[
        typing.Union[google.cloud.eventarc_v1.types.eventarc.UpdateTriggerRequest, dict]
    ] = None,
    *,
    trigger: typing.Optional[google.cloud.eventarc_v1.types.trigger.Trigger] = None,
    update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None,
    allow_missing: typing.Optional[bool] = None,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.api_core.operation.Operation

Update a single trigger.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.update_trigger

google.cloud.eventarc_v1.services.eventarc.EventarcClient.workflow_path

workflow_path(project: str, location: str, workflow: str) -> str

Returns a fully-qualified workflow string.

See more: google.cloud.eventarc_v1.services.eventarc.EventarcClient.workflow_path

google.cloud.eventarc_v1.services.eventarc.pagers.ListChannelConnectionsAsyncPager

ListChannelConnectionsAsyncPager(
    method: typing.Callable[
        [...],
        typing.Awaitable[
            google.cloud.eventarc_v1.types.eventarc.ListChannelConnectionsResponse
        ],
    ],
    request: google.cloud.eventarc_v1.types.eventarc.ListChannelConnectionsRequest,
    response: google.cloud.eventarc_v1.types.eventarc.ListChannelConnectionsResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

Instantiates the pager.

See more: google.cloud.eventarc_v1.services.eventarc.pagers.ListChannelConnectionsAsyncPager

google.cloud.eventarc_v1.services.eventarc.pagers.ListChannelConnectionsPager

ListChannelConnectionsPager(
    method: typing.Callable[
        [...], google.cloud.eventarc_v1.types.eventarc.ListChannelConnectionsResponse
    ],
    request: google.cloud.eventarc_v1.types.eventarc.ListChannelConnectionsRequest,
    response: google.cloud.eventarc_v1.types.eventarc.ListChannelConnectionsResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

Instantiate the pager.

See more: google.cloud.eventarc_v1.services.eventarc.pagers.ListChannelConnectionsPager

google.cloud.eventarc_v1.services.eventarc.pagers.ListChannelsAsyncPager

ListChannelsAsyncPager(
    method: typing.Callable[
        [...],
        typing.Awaitable[google.cloud.eventarc_v1.types.eventarc.ListChannelsResponse],
    ],
    request: google.cloud.eventarc_v1.types.eventarc.ListChannelsRequest,
    response: google.cloud.eventarc_v1.types.eventarc.ListChannelsResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

Instantiates the pager.

See more: google.cloud.eventarc_v1.services.eventarc.pagers.ListChannelsAsyncPager

google.cloud.eventarc_v1.services.eventarc.pagers.ListChannelsPager

ListChannelsPager(
    method: typing.Callable[
        [...], google.cloud.eventarc_v1.types.eventarc.ListChannelsResponse
    ],
    request: google.cloud.eventarc_v1.types.eventarc.ListChannelsRequest,
    response: google.cloud.eventarc_v1.types.eventarc.ListChannelsResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

Instantiate the pager.

See more: google.cloud.eventarc_v1.services.eventarc.pagers.ListChannelsPager

google.cloud.eventarc_v1.services.eventarc.pagers.ListEnrollmentsAsyncPager

ListEnrollmentsAsyncPager(
    method: typing.Callable[
        [...],
        typing.Awaitable[
            google.cloud.eventarc_v1.types.eventarc.ListEnrollmentsResponse
        ],
    ],
    request: google.cloud.eventarc_v1.types.eventarc.ListEnrollmentsRequest,
    response: google.cloud.eventarc_v1.types.eventarc.ListEnrollmentsResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

Instantiates the pager.

See more: google.cloud.eventarc_v1.services.eventarc.pagers.ListEnrollmentsAsyncPager

google.cloud.eventarc_v1.services.eventarc.pagers.ListEnrollmentsPager

ListEnrollmentsPager(
    method: typing.Callable[
        [...], google.cloud.eventarc_v1.types.eventarc.ListEnrollmentsResponse
    ],
    request: google.cloud.eventarc_v1.types.eventarc.ListEnrollmentsRequest,
    response: google.cloud.eventarc_v1.types.eventarc.ListEnrollmentsResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

Instantiate the pager.

See more: google.cloud.eventarc_v1.services.eventarc.pagers.ListEnrollmentsPager

google.cloud.eventarc_v1.services.eventarc.pagers.ListGoogleApiSourcesAsyncPager

ListGoogleApiSourcesAsyncPager(
    method: typing.Callable[
        [...],
        typing.Awaitable[
            google.cloud.eventarc_v1.types.eventarc.ListGoogleApiSourcesResponse
        ],
    ],
    request: google.cloud.eventarc_v1.types.eventarc.ListGoogleApiSourcesRequest,
    response: google.cloud.eventarc_v1.types.eventarc.ListGoogleApiSourcesResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

Instantiates the pager.

See more: google.cloud.eventarc_v1.services.eventarc.pagers.ListGoogleApiSourcesAsyncPager

google.cloud.eventarc_v1.services.eventarc.pagers.ListGoogleApiSourcesPager

ListGoogleApiSourcesPager(
    method: typing.Callable[
        [...], google.cloud.eventarc_v1.types.eventarc.ListGoogleApiSourcesResponse
    ],
    request: google.cloud.eventarc_v1.types.eventarc.ListGoogleApiSourcesRequest,
    response: google.cloud.eventarc_v1.types.eventarc.ListGoogleApiSourcesResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

Instantiate the pager.

See more: google.cloud.eventarc_v1.services.eventarc.pagers.ListGoogleApiSourcesPager

google.cloud.eventarc_v1.services.eventarc.pagers.ListMessageBusEnrollmentsAsyncPager

ListMessageBusEnrollmentsAsyncPager(
    method: typing.Callable[
        [...],
        typing.Awaitable[
            google.cloud.eventarc_v1.types.eventarc.ListMessageBusEnrollmentsResponse
        ],
    ],
    request: google.cloud.eventarc_v1.types.eventarc.ListMessageBusEnrollmentsRequest,
    response: google.cloud.eventarc_v1.types.eventarc.ListMessageBusEnrollmentsResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

Instantiates the pager.

See more: google.cloud.eventarc_v1.services.eventarc.pagers.ListMessageBusEnrollmentsAsyncPager

google.cloud.eventarc_v1.services.eventarc.pagers.ListMessageBusEnrollmentsPager

ListMessageBusEnrollmentsPager(
    method: typing.Callable[
        [...], google.cloud.eventarc_v1.types.eventarc.ListMessageBusEnrollmentsResponse
    ],
    request: google.cloud.eventarc_v1.types.eventarc.ListMessageBusEnrollmentsRequest,
    response: google.cloud.eventarc_v1.types.eventarc.ListMessageBusEnrollmentsResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

Instantiate the pager.

See more: google.cloud.eventarc_v1.services.eventarc.pagers.ListMessageBusEnrollmentsPager

google.cloud.eventarc_v1.services.eventarc.pagers.ListMessageBusesAsyncPager

ListMessageBusesAsyncPager(
    method: typing.Callable[
        [...],
        typing.Awaitable[
            google.cloud.eventarc_v1.types.eventarc.ListMessageBusesResponse
        ],
    ],
    request: google.cloud.eventarc_v1.types.eventarc.ListMessageBusesRequest,
    response: google.cloud.eventarc_v1.types.eventarc.ListMessageBusesResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

Instantiates the pager.

See more: google.cloud.eventarc_v1.services.eventarc.pagers.ListMessageBusesAsyncPager

google.cloud.eventarc_v1.services.eventarc.pagers.ListMessageBusesPager

ListMessageBusesPager(
    method: typing.Callable[
        [...], google.cloud.eventarc_v1.types.eventarc.ListMessageBusesResponse
    ],
    request: google.cloud.eventarc_v1.types.eventarc.ListMessageBusesRequest,
    response: google.cloud.eventarc_v1.types.eventarc.ListMessageBusesResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

Instantiate the pager.

See more: google.cloud.eventarc_v1.services.eventarc.pagers.ListMessageBusesPager

google.cloud.eventarc_v1.services.eventarc.pagers.ListPipelinesAsyncPager

ListPipelinesAsyncPager(
    method: typing.Callable[
        [...],
        typing.Awaitable[google.cloud.eventarc_v1.types.eventarc.ListPipelinesResponse],
    ],
    request: google.cloud.eventarc_v1.types.eventarc.ListPipelinesRequest,
    response: google.cloud.eventarc_v1.types.eventarc.ListPipelinesResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

Instantiates the pager.

See more: google.cloud.eventarc_v1.services.eventarc.pagers.ListPipelinesAsyncPager

google.cloud.eventarc_v1.services.eventarc.pagers.ListPipelinesPager

ListPipelinesPager(
    method: typing.Callable[
        [...], google.cloud.eventarc_v1.types.eventarc.ListPipelinesResponse
    ],
    request: google.cloud.eventarc_v1.types.eventarc.ListPipelinesRequest,
    response: google.cloud.eventarc_v1.types.eventarc.ListPipelinesResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

Instantiate the pager.

See more: google.cloud.eventarc_v1.services.eventarc.pagers.ListPipelinesPager

google.cloud.eventarc_v1.services.eventarc.pagers.ListProvidersAsyncPager

ListProvidersAsyncPager(
    method: typing.Callable[
        [...],
        typing.Awaitable[google.cloud.eventarc_v1.types.eventarc.ListProvidersResponse],
    ],
    request: google.cloud.eventarc_v1.types.eventarc.ListProvidersRequest,
    response: google.cloud.eventarc_v1.types.eventarc.ListProvidersResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

Instantiates the pager.

See more: google.cloud.eventarc_v1.services.eventarc.pagers.ListProvidersAsyncPager

google.cloud.eventarc_v1.services.eventarc.pagers.ListProvidersPager

ListProvidersPager(
    method: typing.Callable[
        [...], google.cloud.eventarc_v1.types.eventarc.ListProvidersResponse
    ],
    request: google.cloud.eventarc_v1.types.eventarc.ListProvidersRequest,
    response: google.cloud.eventarc_v1.types.eventarc.ListProvidersResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

Instantiate the pager.

See more: google.cloud.eventarc_v1.services.eventarc.pagers.ListProvidersPager

google.cloud.eventarc_v1.services.eventarc.pagers.ListTriggersAsyncPager

ListTriggersAsyncPager(
    method: typing.Callable[
        [...],
        typing.Awaitable[google.cloud.eventarc_v1.types.eventarc.ListTriggersResponse],
    ],
    request: google.cloud.eventarc_v1.types.eventarc.ListTriggersRequest,
    response: google.cloud.eventarc_v1.types.eventarc.ListTriggersResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary_async.AsyncRetry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

Instantiates the pager.

See more: google.cloud.eventarc_v1.services.eventarc.pagers.ListTriggersAsyncPager

google.cloud.eventarc_v1.services.eventarc.pagers.ListTriggersPager

ListTriggersPager(
    method: typing.Callable[
        [...], google.cloud.eventarc_v1.types.eventarc.ListTriggersResponse
    ],
    request: google.cloud.eventarc_v1.types.eventarc.ListTriggersRequest,
    response: google.cloud.eventarc_v1.types.eventarc.ListTriggersResponse,
    *,
    retry: typing.Optional[
        typing.Union[
            google.api_core.retry.retry_unary.Retry,
            google.api_core.gapic_v1.method._MethodDefault,
        ]
    ] = _MethodDefault._DEFAULT_VALUE,
    timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
    metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

Instantiate the pager.

See more: google.cloud.eventarc_v1.services.eventarc.pagers.ListTriggersPager