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]]] = () ) -> NoneStarts 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 ) -> strReturns 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) -> strReturns 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) -> strReturns 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) -> strReturns 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) -> strReturns 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) -> strReturns 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) -> strReturns 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) -> strReturns 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.AsyncOperationCreate 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.AsyncOperationCreate 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.AsyncOperationCreate 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.AsyncOperationCreate 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.AsyncOperationCreate 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.AsyncOperationCreate 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.AsyncOperationCreate 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) -> strReturns 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.AsyncOperationDelete 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.AsyncOperationDelete 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.AsyncOperationDelete 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.AsyncOperationDelete 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.AsyncOperationDelete 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]]] = () ) -> NoneDeletes 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.AsyncOperationDelete 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.AsyncOperationDelete 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) -> strReturns 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.ChannelGet 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.ChannelConnectionGet 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.EnrollmentGet 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.GoogleApiSourceGet 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.GoogleChannelConfigGet 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.PolicyGets 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.LocationGets 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.MessageBusGet 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.OperationGets 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.PipelineGet 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.ProviderGet 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.TriggerGet 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) -> strReturns 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) -> strReturns 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.ListChannelConnectionsAsyncPagerList 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.ListChannelsAsyncPagerList 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.ListEnrollmentsAsyncPagerList 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.ListGoogleApiSourcesAsyncPagerList 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.ListLocationsResponseLists 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.ListMessageBusesAsyncPagerList 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.ListOperationsResponseLists 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.ListPipelinesAsyncPagerList 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.ListProvidersAsyncPagerList 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.ListTriggersAsyncPagerList 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) -> strReturns 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) -> strReturns 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) -> strReturns 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) -> strReturns 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) -> strReturns 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() -> strReturns 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.PolicySets 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.TestIamPermissionsResponseTests 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) -> strReturns 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) -> strReturns 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.AsyncOperationUpdate 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.AsyncOperationUpdate 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.AsyncOperationUpdate 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.GoogleChannelConfigUpdate 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.AsyncOperationUpdate 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.AsyncOperationUpdate 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.AsyncOperationUpdate 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) -> strReturns 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]]] = () ) -> NoneStarts 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 ) -> strReturns 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) -> strReturns 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) -> strReturns 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) -> strReturns 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) -> strReturns 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) -> strReturns 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) -> strReturns 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) -> strReturns 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.OperationCreate 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.OperationCreate 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.OperationCreate 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.OperationCreate 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.OperationCreate 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.OperationCreate 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.OperationCreate 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) -> strReturns 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.OperationDelete 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.OperationDelete 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.OperationDelete 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.OperationDelete 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.OperationDelete 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]]] = () ) -> NoneDeletes 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.OperationDelete 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.OperationDelete 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) -> strReturns 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.ChannelGet 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.ChannelConnectionGet 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.EnrollmentGet 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.GoogleApiSourceGet 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.GoogleChannelConfigGet 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.PolicyGets 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.LocationGets 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.MessageBusGet 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.OperationGets 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.PipelineGet 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.ProviderGet 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.TriggerGet 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) -> strReturns 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) -> strReturns 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.ListChannelConnectionsPagerList 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.ListChannelsPagerList 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.ListEnrollmentsPagerList 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.ListGoogleApiSourcesPagerList 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.ListLocationsResponseLists 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.ListMessageBusEnrollmentsPagerList 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.ListMessageBusesPagerList 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.ListOperationsResponseLists 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.ListPipelinesPagerList 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.ListProvidersPagerList 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.ListTriggersPagerList 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) -> strReturns 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) -> strReturns 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) -> strReturns 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) -> strReturns 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) -> strReturns 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() -> strReturns 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.PolicySets 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.TestIamPermissionsResponseTests 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) -> strReturns 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) -> strReturns 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.OperationUpdate 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.OperationUpdate 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.OperationUpdate 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.GoogleChannelConfigUpdate 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.OperationUpdate 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.OperationUpdate 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.OperationUpdate 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) -> strReturns 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