Class EventarcClient (1.13.2)

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import eventarc_v1

def sample_create_channel():
    # Create a client
    client = eventarc_v1.EventarcClient()

    # Initialize request argument(s)
    channel = eventarc_v1.Channel()
    channel.pubsub_topic = "pubsub_topic_value"
    channel.name = "name_value"

    request = eventarc_v1.CreateChannelRequest(
        parent="parent_value",
        channel=channel,
        channel_id="channel_id_value",
    )

    # Make the request
    operation = client.create_channel(request=request)

    print("Waiting for operation to complete...")

    response = operation.result()

    # Handle the response
    print(response)

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import eventarc_v1

def sample_create_channel_connection():
    # Create a client
    client = eventarc_v1.EventarcClient()

    # Initialize request argument(s)
    channel_connection = eventarc_v1.ChannelConnection()
    channel_connection.name = "name_value"
    channel_connection.channel = "channel_value"

    request = eventarc_v1.CreateChannelConnectionRequest(
        parent="parent_value",
        channel_connection=channel_connection,
        channel_connection_id="channel_connection_id_value",
    )

    # Make the request
    operation = client.create_channel_connection(request=request)

    print("Waiting for operation to complete...")

    response = operation.result()

    # Handle the response
    print(response)

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import eventarc_v1

def sample_create_enrollment():
    # Create a client
    client = eventarc_v1.EventarcClient()

    # Initialize request argument(s)
    enrollment = eventarc_v1.Enrollment()
    enrollment.cel_match = "cel_match_value"
    enrollment.message_bus = "message_bus_value"
    enrollment.destination = "destination_value"

    request = eventarc_v1.CreateEnrollmentRequest(
        parent="parent_value",
        enrollment=enrollment,
        enrollment_id="enrollment_id_value",
    )

    # Make the request
    operation = client.create_enrollment(request=request)

    print("Waiting for operation to complete...")

    response = operation.result()

    # Handle the response
    print(response)

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import eventarc_v1

def sample_create_google_api_source():
    # Create a client
    client = eventarc_v1.EventarcClient()

    # Initialize request argument(s)
    google_api_source = eventarc_v1.GoogleApiSource()
    google_api_source.destination = "destination_value"

    request = eventarc_v1.CreateGoogleApiSourceRequest(
        parent="parent_value",
        google_api_source=google_api_source,
        google_api_source_id="google_api_source_id_value",
    )

    # Make the request
    operation = client.create_google_api_source(request=request)

    print("Waiting for operation to complete...")

    response = operation.result()

    # Handle the response
    print(response)

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import eventarc_v1

def sample_create_message_bus():
    # Create a client
    client = eventarc_v1.EventarcClient()

    # Initialize request argument(s)
    request = eventarc_v1.CreateMessageBusRequest(
        parent="parent_value",
        message_bus_id="message_bus_id_value",
    )

    # Make the request
    operation = client.create_message_bus(request=request)

    print("Waiting for operation to complete...")

    response = operation.result()

    # Handle the response
    print(response)

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import eventarc_v1

def sample_create_pipeline():
    # Create a client
    client = eventarc_v1.EventarcClient()

    # Initialize request argument(s)
    pipeline = eventarc_v1.Pipeline()
    pipeline.destinations.http_endpoint.uri = "uri_value"

    request = eventarc_v1.CreatePipelineRequest(
        parent="parent_value",
        pipeline=pipeline,
        pipeline_id="pipeline_id_value",
    )

    # Make the request
    operation = client.create_pipeline(request=request)

    print("Waiting for operation to complete...")

    response = operation.result()

    # Handle the response
    print(response)

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import eventarc_v1

def sample_create_trigger():
    # Create a client
    client = eventarc_v1.EventarcClient()

    # Initialize request argument(s)
    trigger = eventarc_v1.Trigger()
    trigger.name = "name_value"
    trigger.event_filters.attribute = "attribute_value"
    trigger.event_filters.value = "value_value"
    trigger.destination.cloud_run.service = "service_value"
    trigger.destination.cloud_run.region = "region_value"

    request = eventarc_v1.CreateTriggerRequest(
        parent="parent_value",
        trigger=trigger,
        trigger_id="trigger_id_value",
    )

    # Make the request
    operation = client.create_trigger(request=request)

    print("Waiting for operation to complete...")

    response = operation.result()

    # Handle the response
    print(response)

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import eventarc_v1

def sample_delete_channel():
    # Create a client
    client = eventarc_v1.EventarcClient()

    # Initialize request argument(s)
    request = eventarc_v1.DeleteChannelRequest(
        name="name_value",
    )

    # Make the request
    operation = client.delete_channel(request=request)

    print("Waiting for operation to complete...")

    response = operation.result()

    # Handle the response
    print(response)

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import eventarc_v1

def sample_delete_channel_connection():
    # Create a client
    client = eventarc_v1.EventarcClient()

    # Initialize request argument(s)
    request = eventarc_v1.DeleteChannelConnectionRequest(
        name="name_value",
    )

    # Make the request
    operation = client.delete_channel_connection(request=request)

    print("Waiting for operation to complete...")

    response = operation.result()

    # Handle the response
    print(response)

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import eventarc_v1

def sample_delete_enrollment():
    # Create a client
    client = eventarc_v1.EventarcClient()

    # Initialize request argument(s)
    request = eventarc_v1.DeleteEnrollmentRequest(
        name="name_value",
    )

    # Make the request
    operation = client.delete_enrollment(request=request)

    print("Waiting for operation to complete...")

    response = operation.result()

    # Handle the response
    print(response)

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import eventarc_v1

def sample_delete_google_api_source():
    # Create a client
    client = eventarc_v1.EventarcClient()

    # Initialize request argument(s)
    request = eventarc_v1.DeleteGoogleApiSourceRequest(
        name="name_value",
    )

    # Make the request
    operation = client.delete_google_api_source(request=request)

    print("Waiting for operation to complete...")

    response = operation.result()

    # Handle the response
    print(response)

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import eventarc_v1

def sample_delete_message_bus():
    # Create a client
    client = eventarc_v1.EventarcClient()

    # Initialize request argument(s)
    request = eventarc_v1.DeleteMessageBusRequest(
        name="name_value",
    )

    # Make the request
    operation = client.delete_message_bus(request=request)

    print("Waiting for operation to complete...")

    response = operation.result()

    # Handle the response
    print(response)

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import eventarc_v1

def sample_delete_pipeline():
    # Create a client
    client = eventarc_v1.EventarcClient()

    # Initialize request argument(s)
    request = eventarc_v1.DeletePipelineRequest(
        name="name_value",
    )

    # Make the request
    operation = client.delete_pipeline(request=request)

    print("Waiting for operation to complete...")

    response = operation.result()

    # Handle the response
    print(response)

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import eventarc_v1

def sample_delete_trigger():
    # Create a client
    client = eventarc_v1.EventarcClient()

    # Initialize request argument(s)
    request = eventarc_v1.DeleteTriggerRequest(
        name="name_value",
    )

    # Make the request
    operation = client.delete_trigger(request=request)

    print("Waiting for operation to complete...")

    response = operation.result()

    # Handle the response
    print(response)

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import eventarc_v1

def sample_get_channel():
    # Create a client
    client = eventarc_v1.EventarcClient()

    # Initialize request argument(s)
    request = eventarc_v1.GetChannelRequest(
        name="name_value",
    )

    # Make the request
    response = client.get_channel(request=request)

    # Handle the response
    print(response)

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import eventarc_v1

def sample_get_channel_connection():
    # Create a client
    client = eventarc_v1.EventarcClient()

    # Initialize request argument(s)
    request = eventarc_v1.GetChannelConnectionRequest(
        name="name_value",
    )

    # Make the request
    response = client.get_channel_connection(request=request)

    # Handle the response
    print(response)

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import eventarc_v1

def sample_get_enrollment():
    # Create a client
    client = eventarc_v1.EventarcClient()

    # Initialize request argument(s)
    request = eventarc_v1.GetEnrollmentRequest(
        name="name_value",
    )

    # Make the request
    response = client.get_enrollment(request=request)

    # Handle the response
    print(response)

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import eventarc_v1

def sample_get_google_api_source():
    # Create a client
    client = eventarc_v1.EventarcClient()

    # Initialize request argument(s)
    request = eventarc_v1.GetGoogleApiSourceRequest(
        name="name_value",
    )

    # Make the request
    response = client.get_google_api_source(request=request)

    # Handle the response
    print(response)

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import eventarc_v1

def sample_get_google_channel_config():
    # Create a client
    client = eventarc_v1.EventarcClient()

    # Initialize request argument(s)
    request = eventarc_v1.GetGoogleChannelConfigRequest(
        name="name_value",
    )

    # Make the request
    response = client.get_google_channel_config(request=request)

    # Handle the response
    print(response)

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import eventarc_v1

def sample_get_message_bus():
    # Create a client
    client = eventarc_v1.EventarcClient()

    # Initialize request argument(s)
    request = eventarc_v1.GetMessageBusRequest(
        name="name_value",
    )

    # Make the request
    response = client.get_message_bus(request=request)

    # Handle the response
    print(response)

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import eventarc_v1

def sample_get_pipeline():
    # Create a client
    client = eventarc_v1.EventarcClient()

    # Initialize request argument(s)
    request = eventarc_v1.GetPipelineRequest(
        name="name_value",
    )

    # Make the request
    response = client.get_pipeline(request=request)

    # Handle the response
    print(response)

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import eventarc_v1

def sample_get_provider():
    # Create a client
    client = eventarc_v1.EventarcClient()

    # Initialize request argument(s)
    request = eventarc_v1.GetProviderRequest(
        name="name_value",
    )

    # Make the request
    response = client.get_provider(request=request)

    # Handle the response
    print(response)

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import eventarc_v1

def sample_get_trigger():
    # Create a client
    client = eventarc_v1.EventarcClient()

    # Initialize request argument(s)
    request = eventarc_v1.GetTriggerRequest(
        name="name_value",
    )

    # Make the request
    response = client.get_trigger(request=request)

    # Handle the response
    print(response)

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import eventarc_v1

def sample_list_channel_connections():
    # Create a client
    client = eventarc_v1.EventarcClient()

    # Initialize request argument(s)
    request = eventarc_v1.ListChannelConnectionsRequest(
        parent="parent_value",
    )

    # Make the request
    page_result = client.list_channel_connections(request=request)

    # Handle the response
    for response in page_result:
        print(response)

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import eventarc_v1

def sample_list_channels():
    # Create a client
    client = eventarc_v1.EventarcClient()

    # Initialize request argument(s)
    request = eventarc_v1.ListChannelsRequest(
        parent="parent_value",
    )

    # Make the request
    page_result = client.list_channels(request=request)

    # Handle the response
    for response in page_result:
        print(response)

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import eventarc_v1

def sample_list_enrollments():
    # Create a client
    client = eventarc_v1.EventarcClient()

    # Initialize request argument(s)
    request = eventarc_v1.ListEnrollmentsRequest(
        parent="parent_value",
    )

    # Make the request
    page_result = client.list_enrollments(request=request)

    # Handle the response
    for response in page_result:
        print(response)

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import eventarc_v1

def sample_list_google_api_sources():
    # Create a client
    client = eventarc_v1.EventarcClient()

    # Initialize request argument(s)
    request = eventarc_v1.ListGoogleApiSourcesRequest(
        parent="parent_value",
    )

    # Make the request
    page_result = client.list_google_api_sources(request=request)

    # Handle the response
    for response in page_result:
        print(response)

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import eventarc_v1

def sample_list_message_bus_enrollments():
    # Create a client
    client = eventarc_v1.EventarcClient()

    # Initialize request argument(s)
    request = eventarc_v1.ListMessageBusEnrollmentsRequest(
        parent="parent_value",
    )

    # Make the request
    page_result = client.list_message_bus_enrollments(request=request)

    # Handle the response
    for response in page_result:
        print(response)