Class EventarcClient (1.76.0)

GitHub RepositoryProduct ReferenceREST DocumentationRPC Documentation

Service Description: Eventarc allows users to subscribe to various events that are provided by Google Cloud services and forward them to supported destinations.

This class provides the ability to make remote calls to the backing service through method calls that map to API methods. Sample code to get started:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   TriggerName name = TriggerName.of("[PROJECT]", "[LOCATION]", "[TRIGGER]");
   Trigger response = eventarcClient.getTrigger(name);
 }

Note: close() needs to be called on the EventarcClient object to clean up resources such as threads. In the example above, try-with-resources is used, which automatically calls close().

Methods
Method Description Method Variants

GetTrigger

Get a single trigger.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • getTrigger(GetTriggerRequest request)

"Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method.

  • getTrigger(TriggerName name)

  • getTrigger(String name)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • getTriggerCallable()

ListTriggers

List triggers.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • listTriggers(ListTriggersRequest request)

"Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method.

  • listTriggers(LocationName parent)

  • listTriggers(String parent)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • listTriggersPagedCallable()

  • listTriggersCallable()

CreateTrigger

Create a new trigger in a particular project and location.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • createTriggerAsync(CreateTriggerRequest request)

Methods that return long-running operations have "Async" method variants that return OperationFuture, which is used to track polling of the service.

  • createTriggerAsync(LocationName parent, Trigger trigger, String triggerId)

  • createTriggerAsync(String parent, Trigger trigger, String triggerId)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • createTriggerOperationCallable()

  • createTriggerCallable()

UpdateTrigger

Update a single trigger.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • updateTriggerAsync(UpdateTriggerRequest request)

Methods that return long-running operations have "Async" method variants that return OperationFuture, which is used to track polling of the service.

  • updateTriggerAsync(Trigger trigger, FieldMask updateMask, boolean allowMissing)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • updateTriggerOperationCallable()

  • updateTriggerCallable()

DeleteTrigger

Delete a single trigger.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • deleteTriggerAsync(DeleteTriggerRequest request)

Methods that return long-running operations have "Async" method variants that return OperationFuture, which is used to track polling of the service.

  • deleteTriggerAsync(TriggerName name, boolean allowMissing)

  • deleteTriggerAsync(String name, boolean allowMissing)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • deleteTriggerOperationCallable()

  • deleteTriggerCallable()

GetChannel

Get a single Channel.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • getChannel(GetChannelRequest request)

"Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method.

  • getChannel(ChannelName name)

  • getChannel(String name)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • getChannelCallable()

ListChannels

List channels.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • listChannels(ListChannelsRequest request)

"Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method.

  • listChannels(LocationName parent)

  • listChannels(String parent)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • listChannelsPagedCallable()

  • listChannelsCallable()

CreateChannel

Create a new channel in a particular project and location.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • createChannelAsync(CreateChannelRequest request)

Methods that return long-running operations have "Async" method variants that return OperationFuture, which is used to track polling of the service.

  • createChannelAsync(LocationName parent, Channel channel, String channelId)

  • createChannelAsync(String parent, Channel channel, String channelId)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • createChannelOperationCallable()

  • createChannelCallable()

UpdateChannel

Update a single channel.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • updateChannelAsync(UpdateChannelRequest request)

Methods that return long-running operations have "Async" method variants that return OperationFuture, which is used to track polling of the service.

  • updateChannelAsync(Channel channel, FieldMask updateMask)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • updateChannelOperationCallable()

  • updateChannelCallable()

DeleteChannel

Delete a single channel.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • deleteChannelAsync(DeleteChannelRequest request)

Methods that return long-running operations have "Async" method variants that return OperationFuture, which is used to track polling of the service.

  • deleteChannelAsync(ChannelName name)

  • deleteChannelAsync(String name)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • deleteChannelOperationCallable()

  • deleteChannelCallable()

GetProvider

Get a single Provider.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • getProvider(GetProviderRequest request)

"Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method.

  • getProvider(ProviderName name)

  • getProvider(String name)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • getProviderCallable()

ListProviders

List providers.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • listProviders(ListProvidersRequest request)

"Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method.

  • listProviders(LocationName parent)

  • listProviders(String parent)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • listProvidersPagedCallable()

  • listProvidersCallable()

GetChannelConnection

Get a single ChannelConnection.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • getChannelConnection(GetChannelConnectionRequest request)

"Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method.

  • getChannelConnection(ChannelConnectionName name)

  • getChannelConnection(String name)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • getChannelConnectionCallable()

ListChannelConnections

List channel connections.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • listChannelConnections(ListChannelConnectionsRequest request)

"Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method.

  • listChannelConnections(LocationName parent)

  • listChannelConnections(String parent)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • listChannelConnectionsPagedCallable()

  • listChannelConnectionsCallable()

CreateChannelConnection

Create a new ChannelConnection in a particular project and location.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • createChannelConnectionAsync(CreateChannelConnectionRequest request)

Methods that return long-running operations have "Async" method variants that return OperationFuture, which is used to track polling of the service.

  • createChannelConnectionAsync(LocationName parent, ChannelConnection channelConnection, String channelConnectionId)

  • createChannelConnectionAsync(String parent, ChannelConnection channelConnection, String channelConnectionId)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • createChannelConnectionOperationCallable()

  • createChannelConnectionCallable()

DeleteChannelConnection

Delete a single ChannelConnection.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • deleteChannelConnectionAsync(DeleteChannelConnectionRequest request)

Methods that return long-running operations have "Async" method variants that return OperationFuture, which is used to track polling of the service.

  • deleteChannelConnectionAsync(ChannelConnectionName name)

  • deleteChannelConnectionAsync(String name)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • deleteChannelConnectionOperationCallable()

  • deleteChannelConnectionCallable()

GetGoogleChannelConfig

Get a GoogleChannelConfig. The name of the GoogleChannelConfig in the response is ALWAYS coded with projectID.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • getGoogleChannelConfig(GetGoogleChannelConfigRequest request)

"Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method.

  • getGoogleChannelConfig(GoogleChannelConfigName name)

  • getGoogleChannelConfig(String name)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • getGoogleChannelConfigCallable()

UpdateGoogleChannelConfig

Update a single GoogleChannelConfig

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • updateGoogleChannelConfig(UpdateGoogleChannelConfigRequest request)

"Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method.

  • updateGoogleChannelConfig(GoogleChannelConfig googleChannelConfig, FieldMask updateMask)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • updateGoogleChannelConfigCallable()

GetMessageBus

Get a single MessageBus.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • getMessageBus(GetMessageBusRequest request)

"Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method.

  • getMessageBus(MessageBusName name)

  • getMessageBus(String name)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • getMessageBusCallable()

ListMessageBuses

List message buses.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • listMessageBuses(ListMessageBusesRequest request)

"Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method.

  • listMessageBuses(LocationName parent)

  • listMessageBuses(String parent)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • listMessageBusesPagedCallable()

  • listMessageBusesCallable()

ListMessageBusEnrollments

List message bus enrollments.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • listMessageBusEnrollments(ListMessageBusEnrollmentsRequest request)

"Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method.

  • listMessageBusEnrollments(MessageBusName parent)

  • listMessageBusEnrollments(String parent)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • listMessageBusEnrollmentsPagedCallable()

  • listMessageBusEnrollmentsCallable()

CreateMessageBus

Create a new MessageBus in a particular project and location.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • createMessageBusAsync(CreateMessageBusRequest request)

Methods that return long-running operations have "Async" method variants that return OperationFuture, which is used to track polling of the service.

  • createMessageBusAsync(LocationName parent, MessageBus messageBus, String messageBusId)

  • createMessageBusAsync(String parent, MessageBus messageBus, String messageBusId)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • createMessageBusOperationCallable()

  • createMessageBusCallable()

UpdateMessageBus

Update a single message bus.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • updateMessageBusAsync(UpdateMessageBusRequest request)

Methods that return long-running operations have "Async" method variants that return OperationFuture, which is used to track polling of the service.

  • updateMessageBusAsync(MessageBus messageBus, FieldMask updateMask)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • updateMessageBusOperationCallable()

  • updateMessageBusCallable()

DeleteMessageBus

Delete a single message bus.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • deleteMessageBusAsync(DeleteMessageBusRequest request)

Methods that return long-running operations have "Async" method variants that return OperationFuture, which is used to track polling of the service.

  • deleteMessageBusAsync(MessageBusName name, String etag)

  • deleteMessageBusAsync(String name, String etag)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • deleteMessageBusOperationCallable()

  • deleteMessageBusCallable()

GetEnrollment

Get a single Enrollment.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • getEnrollment(GetEnrollmentRequest request)

"Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method.

  • getEnrollment(EnrollmentName name)

  • getEnrollment(String name)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • getEnrollmentCallable()

ListEnrollments

List Enrollments.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • listEnrollments(ListEnrollmentsRequest request)

"Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method.

  • listEnrollments(LocationName parent)

  • listEnrollments(String parent)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • listEnrollmentsPagedCallable()

  • listEnrollmentsCallable()

CreateEnrollment

Create a new Enrollment in a particular project and location.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • createEnrollmentAsync(CreateEnrollmentRequest request)

Methods that return long-running operations have "Async" method variants that return OperationFuture, which is used to track polling of the service.

  • createEnrollmentAsync(LocationName parent, Enrollment enrollment, String enrollmentId)

  • createEnrollmentAsync(String parent, Enrollment enrollment, String enrollmentId)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • createEnrollmentOperationCallable()

  • createEnrollmentCallable()

UpdateEnrollment

Update a single Enrollment.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • updateEnrollmentAsync(UpdateEnrollmentRequest request)

Methods that return long-running operations have "Async" method variants that return OperationFuture, which is used to track polling of the service.

  • updateEnrollmentAsync(Enrollment enrollment, FieldMask updateMask)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • updateEnrollmentOperationCallable()

  • updateEnrollmentCallable()

DeleteEnrollment

Delete a single Enrollment.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • deleteEnrollmentAsync(DeleteEnrollmentRequest request)

Methods that return long-running operations have "Async" method variants that return OperationFuture, which is used to track polling of the service.

  • deleteEnrollmentAsync(EnrollmentName name, String etag)

  • deleteEnrollmentAsync(String name, String etag)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • deleteEnrollmentOperationCallable()

  • deleteEnrollmentCallable()

GetPipeline

Get a single Pipeline.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • getPipeline(GetPipelineRequest request)

"Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method.

  • getPipeline(PipelineName name)

  • getPipeline(String name)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • getPipelineCallable()

ListPipelines

List pipelines.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • listPipelines(ListPipelinesRequest request)

"Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method.

  • listPipelines(LocationName parent)

  • listPipelines(String parent)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • listPipelinesPagedCallable()

  • listPipelinesCallable()

CreatePipeline

Create a new Pipeline in a particular project and location.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • createPipelineAsync(CreatePipelineRequest request)

Methods that return long-running operations have "Async" method variants that return OperationFuture, which is used to track polling of the service.

  • createPipelineAsync(LocationName parent, Pipeline pipeline, String pipelineId)

  • createPipelineAsync(String parent, Pipeline pipeline, String pipelineId)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • createPipelineOperationCallable()

  • createPipelineCallable()

UpdatePipeline

Update a single pipeline.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • updatePipelineAsync(UpdatePipelineRequest request)

Methods that return long-running operations have "Async" method variants that return OperationFuture, which is used to track polling of the service.

  • updatePipelineAsync(Pipeline pipeline, FieldMask updateMask)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • updatePipelineOperationCallable()

  • updatePipelineCallable()

DeletePipeline

Delete a single pipeline.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • deletePipelineAsync(DeletePipelineRequest request)

Methods that return long-running operations have "Async" method variants that return OperationFuture, which is used to track polling of the service.

  • deletePipelineAsync(PipelineName name, String etag)

  • deletePipelineAsync(String name, String etag)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • deletePipelineOperationCallable()

  • deletePipelineCallable()

GetGoogleApiSource

Get a single GoogleApiSource.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • getGoogleApiSource(GetGoogleApiSourceRequest request)

"Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method.

  • getGoogleApiSource(GoogleApiSourceName name)

  • getGoogleApiSource(String name)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • getGoogleApiSourceCallable()

ListGoogleApiSources

List GoogleApiSources.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • listGoogleApiSources(ListGoogleApiSourcesRequest request)

"Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method.

  • listGoogleApiSources(LocationName parent)

  • listGoogleApiSources(String parent)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • listGoogleApiSourcesPagedCallable()

  • listGoogleApiSourcesCallable()

CreateGoogleApiSource

Create a new GoogleApiSource in a particular project and location.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • createGoogleApiSourceAsync(CreateGoogleApiSourceRequest request)

Methods that return long-running operations have "Async" method variants that return OperationFuture, which is used to track polling of the service.

  • createGoogleApiSourceAsync(LocationName parent, GoogleApiSource googleApiSource, String googleApiSourceId)

  • createGoogleApiSourceAsync(String parent, GoogleApiSource googleApiSource, String googleApiSourceId)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • createGoogleApiSourceOperationCallable()

  • createGoogleApiSourceCallable()

UpdateGoogleApiSource

Update a single GoogleApiSource.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • updateGoogleApiSourceAsync(UpdateGoogleApiSourceRequest request)

Methods that return long-running operations have "Async" method variants that return OperationFuture, which is used to track polling of the service.

  • updateGoogleApiSourceAsync(GoogleApiSource googleApiSource, FieldMask updateMask)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • updateGoogleApiSourceOperationCallable()

  • updateGoogleApiSourceCallable()

DeleteGoogleApiSource

Delete a single GoogleApiSource.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • deleteGoogleApiSourceAsync(DeleteGoogleApiSourceRequest request)

Methods that return long-running operations have "Async" method variants that return OperationFuture, which is used to track polling of the service.

  • deleteGoogleApiSourceAsync(GoogleApiSourceName name, String etag)

  • deleteGoogleApiSourceAsync(String name, String etag)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • deleteGoogleApiSourceOperationCallable()

  • deleteGoogleApiSourceCallable()

ListLocations

Lists information about the supported locations for this service.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • listLocations(ListLocationsRequest request)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • listLocationsPagedCallable()

  • listLocationsCallable()

GetLocation

Gets information about a location.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • getLocation(GetLocationRequest request)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • getLocationCallable()

SetIamPolicy

Sets the access control policy on the specified resource. Replacesany existing policy.

Can return NOT_FOUND, INVALID_ARGUMENT, and PERMISSION_DENIEDerrors.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • setIamPolicy(SetIamPolicyRequest request)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • setIamPolicyCallable()

GetIamPolicy

Gets the access control policy for a resource. Returns an empty policyif the resource exists and does not have a policy set.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • getIamPolicy(GetIamPolicyRequest request)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • getIamPolicyCallable()

TestIamPermissions

Returns permissions that a caller has on the specified resource. If theresource does not exist, this will return an empty set ofpermissions, not a NOT_FOUND error.

Note: This operation is designed to be used for buildingpermission-aware UIs and command-line tools, not for authorizationchecking. This operation may "fail open" without warning.

Request object method variants only take one parameter, a request object, which must be constructed before the call.

  • testIamPermissions(TestIamPermissionsRequest request)

Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.

  • testIamPermissionsCallable()

See the individual methods for example code.

Many parameters require resource names to be formatted in a particular way. To assist with these names, this class includes a format method for each type of name, and additionally a parse method to extract the individual identifiers contained within names that are returned.

This class can be customized by passing in a custom instance of EventarcSettings to create(). For example:

To customize credentials:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 EventarcSettings eventarcSettings =
     EventarcSettings.newBuilder()
         .setCredentialsProvider(FixedCredentialsProvider.create(myCredentials))
         .build();
 EventarcClient eventarcClient = EventarcClient.create(eventarcSettings);

To customize the endpoint:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 EventarcSettings eventarcSettings =
     EventarcSettings.newBuilder().setEndpoint(myEndpoint).build();
 EventarcClient eventarcClient = EventarcClient.create(eventarcSettings);

To use REST (HTTP1.1/JSON) transport (instead of gRPC) for sending and receiving requests over the wire:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 EventarcSettings eventarcSettings = EventarcSettings.newHttpJsonBuilder().build();
 EventarcClient eventarcClient = EventarcClient.create(eventarcSettings);

Please refer to the GitHub repository's samples for more quickstart code snippets.

Inheritance

java.lang.Object > EventarcClient

Static Methods

create()

public static final EventarcClient create()

Constructs an instance of EventarcClient with default settings.

Returns
Type Description
EventarcClient
Exceptions
Type Description
IOException

create(EventarcSettings settings)

public static final EventarcClient create(EventarcSettings settings)

Constructs an instance of EventarcClient, using the given settings. The channels are created based on the settings passed in, or defaults for any settings that are not set.

Parameter
Name Description
settings EventarcSettings
Returns
Type Description
EventarcClient
Exceptions
Type Description
IOException

create(EventarcStub stub)

public static final EventarcClient create(EventarcStub stub)

Constructs an instance of EventarcClient, using the given stub for making calls. This is for advanced usage - prefer using create(EventarcSettings).

Parameter
Name Description
stub EventarcStub
Returns
Type Description
EventarcClient

Constructors

EventarcClient(EventarcSettings settings)

protected EventarcClient(EventarcSettings settings)

Constructs an instance of EventarcClient, using the given settings. This is protected so that it is easy to make a subclass, but otherwise, the static factory methods should be preferred.

Parameter
Name Description
settings EventarcSettings

EventarcClient(EventarcStub stub)

protected EventarcClient(EventarcStub stub)
Parameter
Name Description
stub EventarcStub

Methods

awaitTermination(long duration, TimeUnit unit)

public boolean awaitTermination(long duration, TimeUnit unit)
Parameters
Name Description
duration long
unit TimeUnit
Returns
Type Description
boolean
Exceptions
Type Description
InterruptedException

close()

public final void close()

createChannelAsync(CreateChannelRequest request)

public final OperationFuture<Channel,OperationMetadata> createChannelAsync(CreateChannelRequest request)

Create a new channel in a particular project and location.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   CreateChannelRequest request =
       CreateChannelRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setChannel(Channel.newBuilder().build())
           .setChannelId("channelId1461735806")
           .setValidateOnly(true)
           .build();
   Channel response = eventarcClient.createChannelAsync(request).get();
 }
Parameter
Name Description
request CreateChannelRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
OperationFuture<Channel,OperationMetadata>

createChannelAsync(LocationName parent, Channel channel, String channelId)

public final OperationFuture<Channel,OperationMetadata> createChannelAsync(LocationName parent, Channel channel, String channelId)

Create a new channel in a particular project and location.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
   Channel channel = Channel.newBuilder().build();
   String channelId = "channelId1461735806";
   Channel response = eventarcClient.createChannelAsync(parent, channel, channelId).get();
 }
Parameters
Name Description
parent LocationName

Required. The parent collection in which to add this channel.
channel Channel

Required. The channel to create.
channelId String

Required. The user-provided ID to be assigned to the channel.
Returns
Type Description
OperationFuture<Channel,OperationMetadata>

createChannelAsync(String parent, Channel channel, String channelId)

public final OperationFuture<Channel,OperationMetadata> createChannelAsync(String parent, Channel channel, String channelId)

Create a new channel in a particular project and location.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
   Channel channel = Channel.newBuilder().build();
   String channelId = "channelId1461735806";
   Channel response = eventarcClient.createChannelAsync(parent, channel, channelId).get();
 }
Parameters
Name Description
parent String

Required. The parent collection in which to add this channel.
channel Channel

Required. The channel to create.
channelId String

Required. The user-provided ID to be assigned to the channel.
Returns
Type Description
OperationFuture<Channel,OperationMetadata>

createChannelCallable()

public final UnaryCallable<CreateChannelRequest,Operation> createChannelCallable()

Create a new channel in a particular project and location.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   CreateChannelRequest request =
       CreateChannelRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setChannel(Channel.newBuilder().build())
           .setChannelId("channelId1461735806")
           .setValidateOnly(true)
           .build();
   ApiFuture<Operation> future = eventarcClient.createChannelCallable().futureCall(request);
   // Do something.
   Operation response = future.get();
 }
Returns
Type Description
UnaryCallable<CreateChannelRequest,Operation>

createChannelConnectionAsync(CreateChannelConnectionRequest request)

public final OperationFuture<ChannelConnection,OperationMetadata> createChannelConnectionAsync(CreateChannelConnectionRequest request)

Create a new ChannelConnection in a particular project and location.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   CreateChannelConnectionRequest request =
       CreateChannelConnectionRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setChannelConnection(ChannelConnection.newBuilder().build())
           .setChannelConnectionId("channelConnectionId-1246974660")
           .build();
   ChannelConnection response = eventarcClient.createChannelConnectionAsync(request).get();
 }
Parameter
Name Description
request CreateChannelConnectionRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
OperationFuture<ChannelConnection,OperationMetadata>

createChannelConnectionAsync(LocationName parent, ChannelConnection channelConnection, String channelConnectionId)

public final OperationFuture<ChannelConnection,OperationMetadata> createChannelConnectionAsync(LocationName parent, ChannelConnection channelConnection, String channelConnectionId)

Create a new ChannelConnection in a particular project and location.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
   ChannelConnection channelConnection = ChannelConnection.newBuilder().build();
   String channelConnectionId = "channelConnectionId-1246974660";
   ChannelConnection response =
       eventarcClient
           .createChannelConnectionAsync(parent, channelConnection, channelConnectionId)
           .get();
 }
Parameters
Name Description
parent LocationName

Required. The parent collection in which to add this channel connection.
channelConnection ChannelConnection

Required. Channel connection to create.
channelConnectionId String

Required. The user-provided ID to be assigned to the channel connection.
Returns
Type Description
OperationFuture<ChannelConnection,OperationMetadata>

createChannelConnectionAsync(String parent, ChannelConnection channelConnection, String channelConnectionId)

public final OperationFuture<ChannelConnection,OperationMetadata> createChannelConnectionAsync(String parent, ChannelConnection channelConnection, String channelConnectionId)

Create a new ChannelConnection in a particular project and location.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
   ChannelConnection channelConnection = ChannelConnection.newBuilder().build();
   String channelConnectionId = "channelConnectionId-1246974660";
   ChannelConnection response =
       eventarcClient
           .createChannelConnectionAsync(parent, channelConnection, channelConnectionId)
           .get();
 }
Parameters
Name Description
parent String

Required. The parent collection in which to add this channel connection.
channelConnection ChannelConnection

Required. Channel connection to create.
channelConnectionId String

Required. The user-provided ID to be assigned to the channel connection.
Returns
Type Description
OperationFuture<ChannelConnection,OperationMetadata>

createChannelConnectionCallable()

public final UnaryCallable<CreateChannelConnectionRequest,Operation> createChannelConnectionCallable()

Create a new ChannelConnection in a particular project and location.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   CreateChannelConnectionRequest request =
       CreateChannelConnectionRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setChannelConnection(ChannelConnection.newBuilder().build())
           .setChannelConnectionId("channelConnectionId-1246974660")
           .build();
   ApiFuture<Operation> future =
       eventarcClient.createChannelConnectionCallable().futureCall(request);
   // Do something.
   Operation response = future.get();
 }
Returns
Type Description
UnaryCallable<CreateChannelConnectionRequest,Operation>

createChannelConnectionOperationCallable()

public final OperationCallable<CreateChannelConnectionRequest,ChannelConnection,OperationMetadata> createChannelConnectionOperationCallable()

Create a new ChannelConnection in a particular project and location.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   CreateChannelConnectionRequest request =
       CreateChannelConnectionRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setChannelConnection(ChannelConnection.newBuilder().build())
           .setChannelConnectionId("channelConnectionId-1246974660")
           .build();
   OperationFuture<ChannelConnection, OperationMetadata> future =
       eventarcClient.createChannelConnectionOperationCallable().futureCall(request);
   // Do something.
   ChannelConnection response = future.get();
 }
Returns
Type Description
OperationCallable<CreateChannelConnectionRequest,ChannelConnection,OperationMetadata>

createChannelOperationCallable()

public final OperationCallable<CreateChannelRequest,Channel,OperationMetadata> createChannelOperationCallable()

Create a new channel in a particular project and location.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   CreateChannelRequest request =
       CreateChannelRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setChannel(Channel.newBuilder().build())
           .setChannelId("channelId1461735806")
           .setValidateOnly(true)
           .build();
   OperationFuture<Channel, OperationMetadata> future =
       eventarcClient.createChannelOperationCallable().futureCall(request);
   // Do something.
   Channel response = future.get();
 }
Returns
Type Description
OperationCallable<CreateChannelRequest,Channel,OperationMetadata>

createEnrollmentAsync(CreateEnrollmentRequest request)

public final OperationFuture<Enrollment,OperationMetadata> createEnrollmentAsync(CreateEnrollmentRequest request)

Create a new Enrollment in a particular project and location.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   CreateEnrollmentRequest request =
       CreateEnrollmentRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setEnrollment(Enrollment.newBuilder().build())
           .setEnrollmentId("enrollmentId-107037889")
           .setValidateOnly(true)
           .build();
   Enrollment response = eventarcClient.createEnrollmentAsync(request).get();
 }
Parameter
Name Description
request CreateEnrollmentRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
OperationFuture<Enrollment,OperationMetadata>

createEnrollmentAsync(LocationName parent, Enrollment enrollment, String enrollmentId)

public final OperationFuture<Enrollment,OperationMetadata> createEnrollmentAsync(LocationName parent, Enrollment enrollment, String enrollmentId)

Create a new Enrollment in a particular project and location.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
   Enrollment enrollment = Enrollment.newBuilder().build();
   String enrollmentId = "enrollmentId-107037889";
   Enrollment response =
       eventarcClient.createEnrollmentAsync(parent, enrollment, enrollmentId).get();
 }
Parameters
Name Description
parent LocationName

Required. The parent collection in which to add this enrollment.
enrollment Enrollment

Required. The enrollment to create.
enrollmentId String

Required. The user-provided ID to be assigned to the Enrollment. It should match the format ^a-z?$.
Returns
Type Description
OperationFuture<Enrollment,OperationMetadata>

createEnrollmentAsync(String parent, Enrollment enrollment, String enrollmentId)

public final OperationFuture<Enrollment,OperationMetadata> createEnrollmentAsync(String parent, Enrollment enrollment, String enrollmentId)

Create a new Enrollment in a particular project and location.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
   Enrollment enrollment = Enrollment.newBuilder().build();
   String enrollmentId = "enrollmentId-107037889";
   Enrollment response =
       eventarcClient.createEnrollmentAsync(parent, enrollment, enrollmentId).get();
 }
Parameters
Name Description
parent String

Required. The parent collection in which to add this enrollment.
enrollment Enrollment

Required. The enrollment to create.
enrollmentId String

Required. The user-provided ID to be assigned to the Enrollment. It should match the format ^a-z?$.
Returns
Type Description
OperationFuture<Enrollment,OperationMetadata>

createEnrollmentCallable()

public final UnaryCallable<CreateEnrollmentRequest,Operation> createEnrollmentCallable()

Create a new Enrollment in a particular project and location.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   CreateEnrollmentRequest request =
       CreateEnrollmentRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setEnrollment(Enrollment.newBuilder().build())
           .setEnrollmentId("enrollmentId-107037889")
           .setValidateOnly(true)
           .build();
   ApiFuture<Operation> future = eventarcClient.createEnrollmentCallable().futureCall(request);
   // Do something.
   Operation response = future.get();
 }
Returns
Type Description
UnaryCallable<CreateEnrollmentRequest,Operation>

createEnrollmentOperationCallable()

public final OperationCallable<CreateEnrollmentRequest,Enrollment,OperationMetadata> createEnrollmentOperationCallable()

Create a new Enrollment in a particular project and location.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   CreateEnrollmentRequest request =
       CreateEnrollmentRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setEnrollment(Enrollment.newBuilder().build())
           .setEnrollmentId("enrollmentId-107037889")
           .setValidateOnly(true)
           .build();
   OperationFuture<Enrollment, OperationMetadata> future =
       eventarcClient.createEnrollmentOperationCallable().futureCall(request);
   // Do something.
   Enrollment response = future.get();
 }
Returns
Type Description
OperationCallable<CreateEnrollmentRequest,Enrollment,OperationMetadata>

createGoogleApiSourceAsync(CreateGoogleApiSourceRequest request)

public final OperationFuture<GoogleApiSource,OperationMetadata> createGoogleApiSourceAsync(CreateGoogleApiSourceRequest request)

Create a new GoogleApiSource in a particular project and location.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   CreateGoogleApiSourceRequest request =
       CreateGoogleApiSourceRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setGoogleApiSource(GoogleApiSource.newBuilder().build())
           .setGoogleApiSourceId("googleApiSourceId-1417062697")
           .setValidateOnly(true)
           .build();
   GoogleApiSource response = eventarcClient.createGoogleApiSourceAsync(request).get();
 }
Parameter
Name Description
request CreateGoogleApiSourceRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
OperationFuture<GoogleApiSource,OperationMetadata>

createGoogleApiSourceAsync(LocationName parent, GoogleApiSource googleApiSource, String googleApiSourceId)

public final OperationFuture<GoogleApiSource,OperationMetadata> createGoogleApiSourceAsync(LocationName parent, GoogleApiSource googleApiSource, String googleApiSourceId)

Create a new GoogleApiSource in a particular project and location.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
   GoogleApiSource googleApiSource = GoogleApiSource.newBuilder().build();
   String googleApiSourceId = "googleApiSourceId-1417062697";
   GoogleApiSource response =
       eventarcClient
           .createGoogleApiSourceAsync(parent, googleApiSource, googleApiSourceId)
           .get();
 }
Parameters
Name Description
parent LocationName

Required. The parent collection in which to add this google api source.
googleApiSource GoogleApiSource

Required. The google api source to create.
googleApiSourceId String

Required. The user-provided ID to be assigned to the GoogleApiSource. It should match the format ^a-z?$.
Returns
Type Description
OperationFuture<GoogleApiSource,OperationMetadata>

createGoogleApiSourceAsync(String parent, GoogleApiSource googleApiSource, String googleApiSourceId)

public final OperationFuture<GoogleApiSource,OperationMetadata> createGoogleApiSourceAsync(String parent, GoogleApiSource googleApiSource, String googleApiSourceId)

Create a new GoogleApiSource in a particular project and location.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
   GoogleApiSource googleApiSource = GoogleApiSource.newBuilder().build();
   String googleApiSourceId = "googleApiSourceId-1417062697";
   GoogleApiSource response =
       eventarcClient
           .createGoogleApiSourceAsync(parent, googleApiSource, googleApiSourceId)
           .get();
 }
Parameters
Name Description
parent String

Required. The parent collection in which to add this google api source.
googleApiSource GoogleApiSource

Required. The google api source to create.
googleApiSourceId String

Required. The user-provided ID to be assigned to the GoogleApiSource. It should match the format ^a-z?$.
Returns
Type Description
OperationFuture<GoogleApiSource,OperationMetadata>

createGoogleApiSourceCallable()

public final UnaryCallable<CreateGoogleApiSourceRequest,Operation> createGoogleApiSourceCallable()

Create a new GoogleApiSource in a particular project and location.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   CreateGoogleApiSourceRequest request =
       CreateGoogleApiSourceRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setGoogleApiSource(GoogleApiSource.newBuilder().build())
           .setGoogleApiSourceId("googleApiSourceId-1417062697")
           .setValidateOnly(true)
           .build();
   ApiFuture<Operation> future =
       eventarcClient.createGoogleApiSourceCallable().futureCall(request);
   // Do something.
   Operation response = future.get();
 }
Returns
Type Description
UnaryCallable<CreateGoogleApiSourceRequest,Operation>

createGoogleApiSourceOperationCallable()

public final OperationCallable<CreateGoogleApiSourceRequest,GoogleApiSource,OperationMetadata> createGoogleApiSourceOperationCallable()

Create a new GoogleApiSource in a particular project and location.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   CreateGoogleApiSourceRequest request =
       CreateGoogleApiSourceRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setGoogleApiSource(GoogleApiSource.newBuilder().build())
           .setGoogleApiSourceId("googleApiSourceId-1417062697")
           .setValidateOnly(true)
           .build();
   OperationFuture<GoogleApiSource, OperationMetadata> future =
       eventarcClient.createGoogleApiSourceOperationCallable().futureCall(request);
   // Do something.
   GoogleApiSource response = future.get();
 }
Returns
Type Description
OperationCallable<CreateGoogleApiSourceRequest,GoogleApiSource,OperationMetadata>

createMessageBusAsync(CreateMessageBusRequest request)

public final OperationFuture<MessageBus,OperationMetadata> createMessageBusAsync(CreateMessageBusRequest request)

Create a new MessageBus in a particular project and location.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   CreateMessageBusRequest request =
       CreateMessageBusRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setMessageBus(MessageBus.newBuilder().build())
           .setMessageBusId("messageBusId-1312824332")
           .setValidateOnly(true)
           .build();
   MessageBus response = eventarcClient.createMessageBusAsync(request).get();
 }
Parameter
Name Description
request CreateMessageBusRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
OperationFuture<MessageBus,OperationMetadata>

createMessageBusAsync(LocationName parent, MessageBus messageBus, String messageBusId)

public final OperationFuture<MessageBus,OperationMetadata> createMessageBusAsync(LocationName parent, MessageBus messageBus, String messageBusId)

Create a new MessageBus in a particular project and location.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
   MessageBus messageBus = MessageBus.newBuilder().build();
   String messageBusId = "messageBusId-1312824332";
   MessageBus response =
       eventarcClient.createMessageBusAsync(parent, messageBus, messageBusId).get();
 }
Parameters
Name Description
parent LocationName

Required. The parent collection in which to add this message bus.
messageBus MessageBus

Required. The message bus to create.
messageBusId String

Required. The user-provided ID to be assigned to the MessageBus. It should match the format ^a-z?$.
Returns
Type Description
OperationFuture<MessageBus,OperationMetadata>

createMessageBusAsync(String parent, MessageBus messageBus, String messageBusId)

public final OperationFuture<MessageBus,OperationMetadata> createMessageBusAsync(String parent, MessageBus messageBus, String messageBusId)

Create a new MessageBus in a particular project and location.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
   MessageBus messageBus = MessageBus.newBuilder().build();
   String messageBusId = "messageBusId-1312824332";
   MessageBus response =
       eventarcClient.createMessageBusAsync(parent, messageBus, messageBusId).get();
 }
Parameters
Name Description
parent String

Required. The parent collection in which to add this message bus.
messageBus MessageBus

Required. The message bus to create.
messageBusId String

Required. The user-provided ID to be assigned to the MessageBus. It should match the format ^a-z?$.
Returns
Type Description
OperationFuture<MessageBus,OperationMetadata>

createMessageBusCallable()

public final UnaryCallable<CreateMessageBusRequest,Operation> createMessageBusCallable()

Create a new MessageBus in a particular project and location.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   CreateMessageBusRequest request =
       CreateMessageBusRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setMessageBus(MessageBus.newBuilder().build())
           .setMessageBusId("messageBusId-1312824332")
           .setValidateOnly(true)
           .build();
   ApiFuture<Operation> future = eventarcClient.createMessageBusCallable().futureCall(request);
   // Do something.
   Operation response = future.get();
 }
Returns
Type Description
UnaryCallable<CreateMessageBusRequest,Operation>

createMessageBusOperationCallable()

public final OperationCallable<CreateMessageBusRequest,MessageBus,OperationMetadata> createMessageBusOperationCallable()

Create a new MessageBus in a particular project and location.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   CreateMessageBusRequest request =
       CreateMessageBusRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setMessageBus(MessageBus.newBuilder().build())
           .setMessageBusId("messageBusId-1312824332")
           .setValidateOnly(true)
           .build();
   OperationFuture<MessageBus, OperationMetadata> future =
       eventarcClient.createMessageBusOperationCallable().futureCall(request);
   // Do something.
   MessageBus response = future.get();
 }
Returns
Type Description
OperationCallable<CreateMessageBusRequest,MessageBus,OperationMetadata>

createPipelineAsync(CreatePipelineRequest request)

public final OperationFuture<Pipeline,OperationMetadata> createPipelineAsync(CreatePipelineRequest request)

Create a new Pipeline in a particular project and location.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   CreatePipelineRequest request =
       CreatePipelineRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setPipeline(Pipeline.newBuilder().build())
           .setPipelineId("pipelineId-1076718755")
           .setValidateOnly(true)
           .build();
   Pipeline response = eventarcClient.createPipelineAsync(request).get();
 }
Parameter
Name Description
request CreatePipelineRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
OperationFuture<Pipeline,OperationMetadata>

createPipelineAsync(LocationName parent, Pipeline pipeline, String pipelineId)

public final OperationFuture<Pipeline,OperationMetadata> createPipelineAsync(LocationName parent, Pipeline pipeline, String pipelineId)

Create a new Pipeline in a particular project and location.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
   Pipeline pipeline = Pipeline.newBuilder().build();
   String pipelineId = "pipelineId-1076718755";
   Pipeline response = eventarcClient.createPipelineAsync(parent, pipeline, pipelineId).get();
 }
Parameters
Name Description
parent LocationName

Required. The parent collection in which to add this pipeline.
pipeline Pipeline

Required. The pipeline to create.
pipelineId String

Required. The user-provided ID to be assigned to the Pipeline. It should match the format ^a-z?$.
Returns
Type Description
OperationFuture<Pipeline,OperationMetadata>

createPipelineAsync(String parent, Pipeline pipeline, String pipelineId)

public final OperationFuture<Pipeline,OperationMetadata> createPipelineAsync(String parent, Pipeline pipeline, String pipelineId)

Create a new Pipeline in a particular project and location.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
   Pipeline pipeline = Pipeline.newBuilder().build();
   String pipelineId = "pipelineId-1076718755";
   Pipeline response = eventarcClient.createPipelineAsync(parent, pipeline, pipelineId).get();
 }
Parameters
Name Description
parent String

Required. The parent collection in which to add this pipeline.
pipeline Pipeline

Required. The pipeline to create.
pipelineId String

Required. The user-provided ID to be assigned to the Pipeline. It should match the format ^a-z?$.
Returns
Type Description
OperationFuture<Pipeline,OperationMetadata>

createPipelineCallable()

public final UnaryCallable<CreatePipelineRequest,Operation> createPipelineCallable()

Create a new Pipeline in a particular project and location.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   CreatePipelineRequest request =
       CreatePipelineRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setPipeline(Pipeline.newBuilder().build())
           .setPipelineId("pipelineId-1076718755")
           .setValidateOnly(true)
           .build();
   ApiFuture<Operation> future = eventarcClient.createPipelineCallable().futureCall(request);
   // Do something.
   Operation response = future.get();
 }
Returns
Type Description
UnaryCallable<CreatePipelineRequest,Operation>

createPipelineOperationCallable()

public final OperationCallable<CreatePipelineRequest,Pipeline,OperationMetadata> createPipelineOperationCallable()

Create a new Pipeline in a particular project and location.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   CreatePipelineRequest request =
       CreatePipelineRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setPipeline(Pipeline.newBuilder().build())
           .setPipelineId("pipelineId-1076718755")
           .setValidateOnly(true)
           .build();
   OperationFuture<Pipeline, OperationMetadata> future =
       eventarcClient.createPipelineOperationCallable().futureCall(request);
   // Do something.
   Pipeline response = future.get();
 }
Returns
Type Description
OperationCallable<CreatePipelineRequest,Pipeline,OperationMetadata>

createTriggerAsync(CreateTriggerRequest request)

public final OperationFuture<Trigger,OperationMetadata> createTriggerAsync(CreateTriggerRequest request)

Create a new trigger in a particular project and location.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   CreateTriggerRequest request =
       CreateTriggerRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setTrigger(Trigger.newBuilder().build())
           .setTriggerId("triggerId-648752909")
           .setValidateOnly(true)
           .build();
   Trigger response = eventarcClient.createTriggerAsync(request).get();
 }
Parameter
Name Description
request CreateTriggerRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
OperationFuture<Trigger,OperationMetadata>

createTriggerAsync(LocationName parent, Trigger trigger, String triggerId)

public final OperationFuture<Trigger,OperationMetadata> createTriggerAsync(LocationName parent, Trigger trigger, String triggerId)

Create a new trigger in a particular project and location.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
   Trigger trigger = Trigger.newBuilder().build();
   String triggerId = "triggerId-648752909";
   Trigger response = eventarcClient.createTriggerAsync(parent, trigger, triggerId).get();
 }
Parameters
Name Description
parent LocationName

Required. The parent collection in which to add this trigger.
trigger Trigger

Required. The trigger to create.
triggerId String

Required. The user-provided ID to be assigned to the trigger.
Returns
Type Description
OperationFuture<Trigger,OperationMetadata>

createTriggerAsync(String parent, Trigger trigger, String triggerId)

public final OperationFuture<Trigger,OperationMetadata> createTriggerAsync(String parent, Trigger trigger, String triggerId)

Create a new trigger in a particular project and location.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
   Trigger trigger = Trigger.newBuilder().build();
   String triggerId = "triggerId-648752909";
   Trigger response = eventarcClient.createTriggerAsync(parent, trigger, triggerId).get();
 }
Parameters
Name Description
parent String

Required. The parent collection in which to add this trigger.
trigger Trigger

Required. The trigger to create.
triggerId String

Required. The user-provided ID to be assigned to the trigger.
Returns
Type Description
OperationFuture<Trigger,OperationMetadata>

createTriggerCallable()

public final UnaryCallable<CreateTriggerRequest,Operation> createTriggerCallable()

Create a new trigger in a particular project and location.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   CreateTriggerRequest request =
       CreateTriggerRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setTrigger(Trigger.newBuilder().build())
           .setTriggerId("triggerId-648752909")
           .setValidateOnly(true)
           .build();
   ApiFuture<Operation> future = eventarcClient.createTriggerCallable().futureCall(request);
   // Do something.
   Operation response = future.get();
 }
Returns
Type Description
UnaryCallable<CreateTriggerRequest,Operation>

createTriggerOperationCallable()

public final OperationCallable<CreateTriggerRequest,Trigger,OperationMetadata> createTriggerOperationCallable()

Create a new trigger in a particular project and location.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   CreateTriggerRequest request =
       CreateTriggerRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setTrigger(Trigger.newBuilder().build())
           .setTriggerId("triggerId-648752909")
           .setValidateOnly(true)
           .build();
   OperationFuture<Trigger, OperationMetadata> future =
       eventarcClient.createTriggerOperationCallable().futureCall(request);
   // Do something.
   Trigger response = future.get();
 }
Returns
Type Description
OperationCallable<CreateTriggerRequest,Trigger,OperationMetadata>

deleteChannelAsync(ChannelName name)

public final OperationFuture<Channel,OperationMetadata> deleteChannelAsync(ChannelName name)

Delete a single channel.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   ChannelName name = ChannelName.of("[PROJECT]", "[LOCATION]", "[CHANNEL]");
   Channel response = eventarcClient.deleteChannelAsync(name).get();
 }
Parameter
Name Description
name ChannelName

Required. The name of the channel to be deleted.
Returns
Type Description
OperationFuture<Channel,OperationMetadata>

deleteChannelAsync(DeleteChannelRequest request)

public final OperationFuture<Channel,OperationMetadata> deleteChannelAsync(DeleteChannelRequest request)

Delete a single channel.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   DeleteChannelRequest request =
       DeleteChannelRequest.newBuilder()
           .setName(ChannelName.of("[PROJECT]", "[LOCATION]", "[CHANNEL]").toString())
           .setValidateOnly(true)
           .build();
   Channel response = eventarcClient.deleteChannelAsync(request).get();
 }
Parameter
Name Description
request DeleteChannelRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
OperationFuture<Channel,OperationMetadata>

deleteChannelAsync(String name)

public final OperationFuture<Channel,OperationMetadata> deleteChannelAsync(String name)

Delete a single channel.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   String name = ChannelName.of("[PROJECT]", "[LOCATION]", "[CHANNEL]").toString();
   Channel response = eventarcClient.deleteChannelAsync(name).get();
 }
Parameter
Name Description
name String

Required. The name of the channel to be deleted.
Returns
Type Description
OperationFuture<Channel,OperationMetadata>

deleteChannelCallable()

public final UnaryCallable<DeleteChannelRequest,Operation> deleteChannelCallable()

Delete a single channel.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   DeleteChannelRequest request =
       DeleteChannelRequest.newBuilder()
           .setName(ChannelName.of("[PROJECT]", "[LOCATION]", "[CHANNEL]").toString())
           .setValidateOnly(true)
           .build();
   ApiFuture<Operation> future = eventarcClient.deleteChannelCallable().futureCall(request);
   // Do something.
   Operation response = future.get();
 }
Returns
Type Description
UnaryCallable<DeleteChannelRequest,Operation>

deleteChannelConnectionAsync(ChannelConnectionName name)

public final OperationFuture<ChannelConnection,OperationMetadata> deleteChannelConnectionAsync(ChannelConnectionName name)

Delete a single ChannelConnection.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   ChannelConnectionName name =
       ChannelConnectionName.of("[PROJECT]", "[LOCATION]", "[CHANNEL_CONNECTION]");
   ChannelConnection response = eventarcClient.deleteChannelConnectionAsync(name).get();
 }
Parameter
Name Description
name ChannelConnectionName

Required. The name of the channel connection to delete.
Returns
Type Description
OperationFuture<ChannelConnection,OperationMetadata>

deleteChannelConnectionAsync(DeleteChannelConnectionRequest request)

public final OperationFuture<ChannelConnection,OperationMetadata> deleteChannelConnectionAsync(DeleteChannelConnectionRequest request)

Delete a single ChannelConnection.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   DeleteChannelConnectionRequest request =
       DeleteChannelConnectionRequest.newBuilder()
           .setName(
               ChannelConnectionName.of("[PROJECT]", "[LOCATION]", "[CHANNEL_CONNECTION]")
                   .toString())
           .build();
   ChannelConnection response = eventarcClient.deleteChannelConnectionAsync(request).get();
 }
Parameter
Name Description
request DeleteChannelConnectionRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
OperationFuture<ChannelConnection,OperationMetadata>

deleteChannelConnectionAsync(String name)

public final OperationFuture<ChannelConnection,OperationMetadata> deleteChannelConnectionAsync(String name)

Delete a single ChannelConnection.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   String name =
       ChannelConnectionName.of("[PROJECT]", "[LOCATION]", "[CHANNEL_CONNECTION]").toString();
   ChannelConnection response = eventarcClient.deleteChannelConnectionAsync(name).get();
 }
Parameter
Name Description
name String

Required. The name of the channel connection to delete.
Returns
Type Description
OperationFuture<ChannelConnection,OperationMetadata>

deleteChannelConnectionCallable()

public final UnaryCallable<DeleteChannelConnectionRequest,Operation> deleteChannelConnectionCallable()

Delete a single ChannelConnection.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   DeleteChannelConnectionRequest request =
       DeleteChannelConnectionRequest.newBuilder()
           .setName(
               ChannelConnectionName.of("[PROJECT]", "[LOCATION]", "[CHANNEL_CONNECTION]")
                   .toString())
           .build();
   ApiFuture<Operation> future =
       eventarcClient.deleteChannelConnectionCallable().futureCall(request);
   // Do something.
   Operation response = future.get();
 }
Returns
Type Description
UnaryCallable<DeleteChannelConnectionRequest,Operation>

deleteChannelConnectionOperationCallable()

public final OperationCallable<DeleteChannelConnectionRequest,ChannelConnection,OperationMetadata> deleteChannelConnectionOperationCallable()

Delete a single ChannelConnection.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   DeleteChannelConnectionRequest request =
       DeleteChannelConnectionRequest.newBuilder()
           .setName(
               ChannelConnectionName.of("[PROJECT]", "[LOCATION]", "[CHANNEL_CONNECTION]")
                   .toString())
           .build();
   OperationFuture<ChannelConnection, OperationMetadata> future =
       eventarcClient.deleteChannelConnectionOperationCallable().futureCall(request);
   // Do something.
   ChannelConnection response = future.get();
 }
Returns
Type Description
OperationCallable<DeleteChannelConnectionRequest,ChannelConnection,OperationMetadata>

deleteChannelOperationCallable()

public final OperationCallable<DeleteChannelRequest,Channel,OperationMetadata> deleteChannelOperationCallable()

Delete a single channel.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   DeleteChannelRequest request =
       DeleteChannelRequest.newBuilder()
           .setName(ChannelName.of("[PROJECT]", "[LOCATION]", "[CHANNEL]").toString())
           .setValidateOnly(true)
           .build();
   OperationFuture<Channel, OperationMetadata> future =
       eventarcClient.deleteChannelOperationCallable().futureCall(request);
   // Do something.
   Channel response = future.get();
 }
Returns
Type Description
OperationCallable<DeleteChannelRequest,Channel,OperationMetadata>

deleteEnrollmentAsync(DeleteEnrollmentRequest request)

public final OperationFuture<Enrollment,OperationMetadata> deleteEnrollmentAsync(DeleteEnrollmentRequest request)

Delete a single Enrollment.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   DeleteEnrollmentRequest request =
       DeleteEnrollmentRequest.newBuilder()
           .setName(EnrollmentName.of("[PROJECT]", "[LOCATION]", "[ENROLLMENT]").toString())
           .setEtag("etag3123477")
           .setAllowMissing(true)
           .setValidateOnly(true)
           .build();
   Enrollment response = eventarcClient.deleteEnrollmentAsync(request).get();
 }
Parameter
Name Description
request DeleteEnrollmentRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
OperationFuture<Enrollment,OperationMetadata>

deleteEnrollmentAsync(EnrollmentName name, String etag)

public final OperationFuture<Enrollment,OperationMetadata> deleteEnrollmentAsync(EnrollmentName name, String etag)

Delete a single Enrollment.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   EnrollmentName name = EnrollmentName.of("[PROJECT]", "[LOCATION]", "[ENROLLMENT]");
   String etag = "etag3123477";
   Enrollment response = eventarcClient.deleteEnrollmentAsync(name, etag).get();
 }
Parameters
Name Description
name EnrollmentName

Required. The name of the Enrollment to be deleted.
etag String

Optional. If provided, the Enrollment will only be deleted if the etag matches the current etag on the resource.
Returns
Type Description
OperationFuture<Enrollment,OperationMetadata>

deleteEnrollmentAsync(String name, String etag)

public final OperationFuture<Enrollment,OperationMetadata> deleteEnrollmentAsync(String name, String etag)

Delete a single Enrollment.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   String name = EnrollmentName.of("[PROJECT]", "[LOCATION]", "[ENROLLMENT]").toString();
   String etag = "etag3123477";
   Enrollment response = eventarcClient.deleteEnrollmentAsync(name, etag).get();
 }
Parameters
Name Description
name String

Required. The name of the Enrollment to be deleted.
etag String

Optional. If provided, the Enrollment will only be deleted if the etag matches the current etag on the resource.
Returns
Type Description
OperationFuture<Enrollment,OperationMetadata>

deleteEnrollmentCallable()

public final UnaryCallable<DeleteEnrollmentRequest,Operation> deleteEnrollmentCallable()

Delete a single Enrollment.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   DeleteEnrollmentRequest request =
       DeleteEnrollmentRequest.newBuilder()
           .setName(EnrollmentName.of("[PROJECT]", "[LOCATION]", "[ENROLLMENT]").toString())
           .setEtag("etag3123477")
           .setAllowMissing(true)
           .setValidateOnly(true)
           .build();
   ApiFuture<Operation> future = eventarcClient.deleteEnrollmentCallable().futureCall(request);
   // Do something.
   Operation response = future.get();
 }
Returns
Type Description
UnaryCallable<DeleteEnrollmentRequest,Operation>

deleteEnrollmentOperationCallable()

public final OperationCallable<DeleteEnrollmentRequest,Enrollment,OperationMetadata> deleteEnrollmentOperationCallable()

Delete a single Enrollment.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   DeleteEnrollmentRequest request =
       DeleteEnrollmentRequest.newBuilder()
           .setName(EnrollmentName.of("[PROJECT]", "[LOCATION]", "[ENROLLMENT]").toString())
           .setEtag("etag3123477")
           .setAllowMissing(true)
           .setValidateOnly(true)
           .build();
   OperationFuture<Enrollment, OperationMetadata> future =
       eventarcClient.deleteEnrollmentOperationCallable().futureCall(request);
   // Do something.
   Enrollment response = future.get();
 }
Returns
Type Description
OperationCallable<DeleteEnrollmentRequest,Enrollment,OperationMetadata>

deleteGoogleApiSourceAsync(DeleteGoogleApiSourceRequest request)

public final OperationFuture<GoogleApiSource,OperationMetadata> deleteGoogleApiSourceAsync(DeleteGoogleApiSourceRequest request)

Delete a single GoogleApiSource.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   DeleteGoogleApiSourceRequest request =
       DeleteGoogleApiSourceRequest.newBuilder()
           .setName(
               GoogleApiSourceName.of("[PROJECT]", "[LOCATION]", "[GOOGLE_API_SOURCE]")
                   .toString())
           .setEtag("etag3123477")
           .setAllowMissing(true)
           .setValidateOnly(true)
           .build();
   GoogleApiSource response = eventarcClient.deleteGoogleApiSourceAsync(request).get();
 }
Parameter
Name Description
request DeleteGoogleApiSourceRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
OperationFuture<GoogleApiSource,OperationMetadata>

deleteGoogleApiSourceAsync(GoogleApiSourceName name, String etag)

public final OperationFuture<GoogleApiSource,OperationMetadata> deleteGoogleApiSourceAsync(GoogleApiSourceName name, String etag)

Delete a single GoogleApiSource.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   GoogleApiSourceName name =
       GoogleApiSourceName.of("[PROJECT]", "[LOCATION]", "[GOOGLE_API_SOURCE]");
   String etag = "etag3123477";
   GoogleApiSource response = eventarcClient.deleteGoogleApiSourceAsync(name, etag).get();
 }
Parameters
Name Description
name GoogleApiSourceName

Required. The name of the GoogleApiSource to be deleted.
etag String

Optional. If provided, the MessageBus will only be deleted if the etag matches the current etag on the resource.
Returns
Type Description
OperationFuture<GoogleApiSource,OperationMetadata>

deleteGoogleApiSourceAsync(String name, String etag)

public final OperationFuture<GoogleApiSource,OperationMetadata> deleteGoogleApiSourceAsync(String name, String etag)

Delete a single GoogleApiSource.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   String name =
       GoogleApiSourceName.of("[PROJECT]", "[LOCATION]", "[GOOGLE_API_SOURCE]").toString();
   String etag = "etag3123477";
   GoogleApiSource response = eventarcClient.deleteGoogleApiSourceAsync(name, etag).get();
 }
Parameters
Name Description
name String

Required. The name of the GoogleApiSource to be deleted.
etag String

Optional. If provided, the MessageBus will only be deleted if the etag matches the current etag on the resource.
Returns
Type Description
OperationFuture<GoogleApiSource,OperationMetadata>

deleteGoogleApiSourceCallable()

public final UnaryCallable<DeleteGoogleApiSourceRequest,Operation> deleteGoogleApiSourceCallable()

Delete a single GoogleApiSource.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   DeleteGoogleApiSourceRequest request =
       DeleteGoogleApiSourceRequest.newBuilder()
           .setName(
               GoogleApiSourceName.of("[PROJECT]", "[LOCATION]", "[GOOGLE_API_SOURCE]")
                   .toString())
           .setEtag("etag3123477")
           .setAllowMissing(true)
           .setValidateOnly(true)
           .build();
   ApiFuture<Operation> future =
       eventarcClient.deleteGoogleApiSourceCallable().futureCall(request);
   // Do something.
   Operation response = future.get();
 }
Returns
Type Description
UnaryCallable<DeleteGoogleApiSourceRequest,Operation>

deleteGoogleApiSourceOperationCallable()

public final OperationCallable<DeleteGoogleApiSourceRequest,GoogleApiSource,OperationMetadata> deleteGoogleApiSourceOperationCallable()

Delete a single GoogleApiSource.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   DeleteGoogleApiSourceRequest request =
       DeleteGoogleApiSourceRequest.newBuilder()
           .setName(
               GoogleApiSourceName.of("[PROJECT]", "[LOCATION]", "[GOOGLE_API_SOURCE]")
                   .toString())
           .setEtag("etag3123477")
           .setAllowMissing(true)
           .setValidateOnly(true)
           .build();
   OperationFuture<GoogleApiSource, OperationMetadata> future =
       eventarcClient.deleteGoogleApiSourceOperationCallable().futureCall(request);
   // Do something.
   GoogleApiSource response = future.get();
 }
Returns
Type Description
OperationCallable<DeleteGoogleApiSourceRequest,GoogleApiSource,OperationMetadata>

deleteMessageBusAsync(DeleteMessageBusRequest request)

public final OperationFuture<MessageBus,OperationMetadata> deleteMessageBusAsync(DeleteMessageBusRequest request)

Delete a single message bus.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   DeleteMessageBusRequest request =
       DeleteMessageBusRequest.newBuilder()
           .setName(MessageBusName.of("[PROJECT]", "[LOCATION]", "[MESSAGE_BUS]").toString())
           .setEtag("etag3123477")
           .setAllowMissing(true)
           .setValidateOnly(true)
           .build();
   MessageBus response = eventarcClient.deleteMessageBusAsync(request).get();
 }
Parameter
Name Description
request DeleteMessageBusRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
OperationFuture<MessageBus,OperationMetadata>

deleteMessageBusAsync(MessageBusName name, String etag)

public final OperationFuture<MessageBus,OperationMetadata> deleteMessageBusAsync(MessageBusName name, String etag)

Delete a single message bus.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   MessageBusName name = MessageBusName.of("[PROJECT]", "[LOCATION]", "[MESSAGE_BUS]");
   String etag = "etag3123477";
   MessageBus response = eventarcClient.deleteMessageBusAsync(name, etag).get();
 }
Parameters
Name Description
name MessageBusName

Required. The name of the MessageBus to be deleted.
etag String

Optional. If provided, the MessageBus will only be deleted if the etag matches the current etag on the resource.
Returns
Type Description
OperationFuture<MessageBus,OperationMetadata>

deleteMessageBusAsync(String name, String etag)

public final OperationFuture<MessageBus,OperationMetadata> deleteMessageBusAsync(String name, String etag)

Delete a single message bus.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   String name = MessageBusName.of("[PROJECT]", "[LOCATION]", "[MESSAGE_BUS]").toString();
   String etag = "etag3123477";
   MessageBus response = eventarcClient.deleteMessageBusAsync(name, etag).get();
 }
Parameters
Name Description
name String

Required. The name of the MessageBus to be deleted.
etag String

Optional. If provided, the MessageBus will only be deleted if the etag matches the current etag on the resource.
Returns
Type Description
OperationFuture<MessageBus,OperationMetadata>

deleteMessageBusCallable()

public final UnaryCallable<DeleteMessageBusRequest,Operation> deleteMessageBusCallable()

Delete a single message bus.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   DeleteMessageBusRequest request =
       DeleteMessageBusRequest.newBuilder()
           .setName(MessageBusName.of("[PROJECT]", "[LOCATION]", "[MESSAGE_BUS]").toString())
           .setEtag("etag3123477")
           .setAllowMissing(true)
           .setValidateOnly(true)
           .build();
   ApiFuture<Operation> future = eventarcClient.deleteMessageBusCallable().futureCall(request);
   // Do something.
   Operation response = future.get();
 }
Returns
Type Description
UnaryCallable<DeleteMessageBusRequest,Operation>

deleteMessageBusOperationCallable()

public final OperationCallable<DeleteMessageBusRequest,MessageBus,OperationMetadata> deleteMessageBusOperationCallable()

Delete a single message bus.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   DeleteMessageBusRequest request =
       DeleteMessageBusRequest.newBuilder()
           .setName(MessageBusName.of("[PROJECT]", "[LOCATION]", "[MESSAGE_BUS]").toString())
           .setEtag("etag3123477")
           .setAllowMissing(true)
           .setValidateOnly(true)
           .build();
   OperationFuture<MessageBus, OperationMetadata> future =
       eventarcClient.deleteMessageBusOperationCallable().futureCall(request);
   // Do something.
   MessageBus response = future.get();
 }
Returns
Type Description
OperationCallable<DeleteMessageBusRequest,MessageBus,OperationMetadata>

deletePipelineAsync(DeletePipelineRequest request)

public final OperationFuture<Pipeline,OperationMetadata> deletePipelineAsync(DeletePipelineRequest request)

Delete a single pipeline.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   DeletePipelineRequest request =
       DeletePipelineRequest.newBuilder()
           .setName(PipelineName.of("[PROJECT]", "[LOCATION]", "[PIPELINE]").toString())
           .setEtag("etag3123477")
           .setAllowMissing(true)
           .setValidateOnly(true)
           .build();
   Pipeline response = eventarcClient.deletePipelineAsync(request).get();
 }
Parameter
Name Description
request DeletePipelineRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
OperationFuture<Pipeline,OperationMetadata>

deletePipelineAsync(PipelineName name, String etag)

public final OperationFuture<Pipeline,OperationMetadata> deletePipelineAsync(PipelineName name, String etag)

Delete a single pipeline.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   PipelineName name = PipelineName.of("[PROJECT]", "[LOCATION]", "[PIPELINE]");
   String etag = "etag3123477";
   Pipeline response = eventarcClient.deletePipelineAsync(name, etag).get();
 }
Parameters
Name Description
name PipelineName

Required. The name of the Pipeline to be deleted.
etag String

Optional. If provided, the Pipeline will only be deleted if the etag matches the current etag on the resource.
Returns
Type Description
OperationFuture<Pipeline,OperationMetadata>

deletePipelineAsync(String name, String etag)

public final OperationFuture<Pipeline,OperationMetadata> deletePipelineAsync(String name, String etag)

Delete a single pipeline.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   String name = PipelineName.of("[PROJECT]", "[LOCATION]", "[PIPELINE]").toString();
   String etag = "etag3123477";
   Pipeline response = eventarcClient.deletePipelineAsync(name, etag).get();
 }
Parameters
Name Description
name String

Required. The name of the Pipeline to be deleted.
etag String

Optional. If provided, the Pipeline will only be deleted if the etag matches the current etag on the resource.
Returns
Type Description
OperationFuture<Pipeline,OperationMetadata>

deletePipelineCallable()

public final UnaryCallable<DeletePipelineRequest,Operation> deletePipelineCallable()

Delete a single pipeline.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   DeletePipelineRequest request =
       DeletePipelineRequest.newBuilder()
           .setName(PipelineName.of("[PROJECT]", "[LOCATION]", "[PIPELINE]").toString())
           .setEtag("etag3123477")
           .setAllowMissing(true)
           .setValidateOnly(true)
           .build();
   ApiFuture<Operation> future = eventarcClient.deletePipelineCallable().futureCall(request);
   // Do something.
   Operation response = future.get();
 }
Returns
Type Description
UnaryCallable<DeletePipelineRequest,Operation>

deletePipelineOperationCallable()

public final OperationCallable<DeletePipelineRequest,Pipeline,OperationMetadata> deletePipelineOperationCallable()

Delete a single pipeline.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   DeletePipelineRequest request =
       DeletePipelineRequest.newBuilder()
           .setName(PipelineName.of("[PROJECT]", "[LOCATION]", "[PIPELINE]").toString())
           .setEtag("etag3123477")
           .setAllowMissing(true)
           .setValidateOnly(true)
           .build();
   OperationFuture<Pipeline, OperationMetadata> future =
       eventarcClient.deletePipelineOperationCallable().futureCall(request);
   // Do something.
   Pipeline response = future.get();
 }
Returns
Type Description
OperationCallable<DeletePipelineRequest,Pipeline,OperationMetadata>

deleteTriggerAsync(DeleteTriggerRequest request)

public final OperationFuture<Trigger,OperationMetadata> deleteTriggerAsync(DeleteTriggerRequest request)

Delete a single trigger.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   DeleteTriggerRequest request =
       DeleteTriggerRequest.newBuilder()
           .setName(TriggerName.of("[PROJECT]", "[LOCATION]", "[TRIGGER]").toString())
           .setEtag("etag3123477")
           .setAllowMissing(true)
           .setValidateOnly(true)
           .build();
   Trigger response = eventarcClient.deleteTriggerAsync(request).get();
 }
Parameter
Name Description
request DeleteTriggerRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
OperationFuture<Trigger,OperationMetadata>

deleteTriggerAsync(TriggerName name, boolean allowMissing)

public final OperationFuture<Trigger,OperationMetadata> deleteTriggerAsync(TriggerName name, boolean allowMissing)

Delete a single trigger.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   TriggerName name = TriggerName.of("[PROJECT]", "[LOCATION]", "[TRIGGER]");
   boolean allowMissing = true;
   Trigger response = eventarcClient.deleteTriggerAsync(name, allowMissing).get();
 }
Parameters
Name Description
name TriggerName

Required. The name of the trigger to be deleted.
allowMissing boolean

If set to true, and the trigger is not found, the request will succeed but no action will be taken on the server.
Returns
Type Description
OperationFuture<Trigger,OperationMetadata>

deleteTriggerAsync(String name, boolean allowMissing)

public final OperationFuture<Trigger,OperationMetadata> deleteTriggerAsync(String name, boolean allowMissing)

Delete a single trigger.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   String name = TriggerName.of("[PROJECT]", "[LOCATION]", "[TRIGGER]").toString();
   boolean allowMissing = true;
   Trigger response = eventarcClient.deleteTriggerAsync(name, allowMissing).get();
 }
Parameters
Name Description
name String

Required. The name of the trigger to be deleted.
allowMissing boolean

If set to true, and the trigger is not found, the request will succeed but no action will be taken on the server.
Returns
Type Description
OperationFuture<Trigger,OperationMetadata>

deleteTriggerCallable()

public final UnaryCallable<DeleteTriggerRequest,Operation> deleteTriggerCallable()

Delete a single trigger.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   DeleteTriggerRequest request =
       DeleteTriggerRequest.newBuilder()
           .setName(TriggerName.of("[PROJECT]", "[LOCATION]", "[TRIGGER]").toString())
           .setEtag("etag3123477")
           .setAllowMissing(true)
           .setValidateOnly(true)
           .build();
   ApiFuture<Operation> future = eventarcClient.deleteTriggerCallable().futureCall(request);
   // Do something.
   Operation response = future.get();
 }
Returns
Type Description
UnaryCallable<DeleteTriggerRequest,Operation>

deleteTriggerOperationCallable()

public final OperationCallable<DeleteTriggerRequest,Trigger,OperationMetadata> deleteTriggerOperationCallable()

Delete a single trigger.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   DeleteTriggerRequest request =
       DeleteTriggerRequest.newBuilder()
           .setName(TriggerName.of("[PROJECT]", "[LOCATION]", "[TRIGGER]").toString())
           .setEtag("etag3123477")
           .setAllowMissing(true)
           .setValidateOnly(true)
           .build();
   OperationFuture<Trigger, OperationMetadata> future =
       eventarcClient.deleteTriggerOperationCallable().futureCall(request);
   // Do something.
   Trigger response = future.get();
 }
Returns
Type Description
OperationCallable<DeleteTriggerRequest,Trigger,OperationMetadata>

getChannel(ChannelName name)

public final Channel getChannel(ChannelName name)

Get a single Channel.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   ChannelName name = ChannelName.of("[PROJECT]", "[LOCATION]", "[CHANNEL]");
   Channel response = eventarcClient.getChannel(name);
 }
Parameter
Name Description
name ChannelName

Required. The name of the channel to get.
Returns
Type Description
Channel

getChannel(GetChannelRequest request)

public final Channel getChannel(GetChannelRequest request)

Get a single Channel.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   GetChannelRequest request =
       GetChannelRequest.newBuilder()
           .setName(ChannelName.of("[PROJECT]", "[LOCATION]", "[CHANNEL]").toString())
           .build();
   Channel response = eventarcClient.getChannel(request);
 }
Parameter
Name Description
request GetChannelRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
Channel

getChannel(String name)

public final Channel getChannel(String name)

Get a single Channel.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   String name = ChannelName.of("[PROJECT]", "[LOCATION]", "[CHANNEL]").toString();
   Channel response = eventarcClient.getChannel(name);
 }
Parameter
Name Description
name String

Required. The name of the channel to get.
Returns
Type Description
Channel

getChannelCallable()

public final UnaryCallable<GetChannelRequest,Channel> getChannelCallable()

Get a single Channel.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   GetChannelRequest request =
       GetChannelRequest.newBuilder()
           .setName(ChannelName.of("[PROJECT]", "[LOCATION]", "[CHANNEL]").toString())
           .build();
   ApiFuture<Channel> future = eventarcClient.getChannelCallable().futureCall(request);
   // Do something.
   Channel response = future.get();
 }
Returns
Type Description
UnaryCallable<GetChannelRequest,Channel>

getChannelConnection(ChannelConnectionName name)

public final ChannelConnection getChannelConnection(ChannelConnectionName name)

Get a single ChannelConnection.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   ChannelConnectionName name =
       ChannelConnectionName.of("[PROJECT]", "[LOCATION]", "[CHANNEL_CONNECTION]");
   ChannelConnection response = eventarcClient.getChannelConnection(name);
 }
Parameter
Name Description
name ChannelConnectionName

Required. The name of the channel connection to get.
Returns
Type Description
ChannelConnection

getChannelConnection(GetChannelConnectionRequest request)

public final ChannelConnection getChannelConnection(GetChannelConnectionRequest request)

Get a single ChannelConnection.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   GetChannelConnectionRequest request =
       GetChannelConnectionRequest.newBuilder()
           .setName(
               ChannelConnectionName.of("[PROJECT]", "[LOCATION]", "[CHANNEL_CONNECTION]")
                   .toString())
           .build();
   ChannelConnection response = eventarcClient.getChannelConnection(request);
 }
Parameter
Name Description
request GetChannelConnectionRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
ChannelConnection

getChannelConnection(String name)

public final ChannelConnection getChannelConnection(String name)

Get a single ChannelConnection.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   String name =
       ChannelConnectionName.of("[PROJECT]", "[LOCATION]", "[CHANNEL_CONNECTION]").toString();
   ChannelConnection response = eventarcClient.getChannelConnection(name);
 }
Parameter
Name Description
name String

Required. The name of the channel connection to get.
Returns
Type Description
ChannelConnection

getChannelConnectionCallable()

public final UnaryCallable<GetChannelConnectionRequest,ChannelConnection> getChannelConnectionCallable()

Get a single ChannelConnection.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   GetChannelConnectionRequest request =
       GetChannelConnectionRequest.newBuilder()
           .setName(
               ChannelConnectionName.of("[PROJECT]", "[LOCATION]", "[CHANNEL_CONNECTION]")
                   .toString())
           .build();
   ApiFuture<ChannelConnection> future =
       eventarcClient.getChannelConnectionCallable().futureCall(request);
   // Do something.
   ChannelConnection response = future.get();
 }
Returns
Type Description
UnaryCallable<GetChannelConnectionRequest,ChannelConnection>

getEnrollment(EnrollmentName name)

public final Enrollment getEnrollment(EnrollmentName name)

Get a single Enrollment.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   EnrollmentName name = EnrollmentName.of("[PROJECT]", "[LOCATION]", "[ENROLLMENT]");
   Enrollment response = eventarcClient.getEnrollment(name);
 }
Parameter
Name Description
name EnrollmentName

Required. The name of the Enrollment to get.
Returns
Type Description
Enrollment

getEnrollment(GetEnrollmentRequest request)

public final Enrollment getEnrollment(GetEnrollmentRequest request)

Get a single Enrollment.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   GetEnrollmentRequest request =
       GetEnrollmentRequest.newBuilder()
           .setName(EnrollmentName.of("[PROJECT]", "[LOCATION]", "[ENROLLMENT]").toString())
           .build();
   Enrollment response = eventarcClient.getEnrollment(request);
 }
Parameter
Name Description
request GetEnrollmentRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
Enrollment

getEnrollment(String name)

public final Enrollment getEnrollment(String name)

Get a single Enrollment.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   String name = EnrollmentName.of("[PROJECT]", "[LOCATION]", "[ENROLLMENT]").toString();
   Enrollment response = eventarcClient.getEnrollment(name);
 }
Parameter
Name Description
name String

Required. The name of the Enrollment to get.
Returns
Type Description
Enrollment

getEnrollmentCallable()

public final UnaryCallable<GetEnrollmentRequest,Enrollment> getEnrollmentCallable()

Get a single Enrollment.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   GetEnrollmentRequest request =
       GetEnrollmentRequest.newBuilder()
           .setName(EnrollmentName.of("[PROJECT]", "[LOCATION]", "[ENROLLMENT]").toString())
           .build();
   ApiFuture<Enrollment> future = eventarcClient.getEnrollmentCallable().futureCall(request);
   // Do something.
   Enrollment response = future.get();
 }
Returns
Type Description
UnaryCallable<GetEnrollmentRequest,Enrollment>

getGoogleApiSource(GetGoogleApiSourceRequest request)

public final GoogleApiSource getGoogleApiSource(GetGoogleApiSourceRequest request)

Get a single GoogleApiSource.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   GetGoogleApiSourceRequest request =
       GetGoogleApiSourceRequest.newBuilder()
           .setName(
               GoogleApiSourceName.of("[PROJECT]", "[LOCATION]", "[GOOGLE_API_SOURCE]")
                   .toString())
           .build();
   GoogleApiSource response = eventarcClient.getGoogleApiSource(request);
 }
Parameter
Name Description
request GetGoogleApiSourceRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
GoogleApiSource

getGoogleApiSource(GoogleApiSourceName name)

public final GoogleApiSource getGoogleApiSource(GoogleApiSourceName name)

Get a single GoogleApiSource.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   GoogleApiSourceName name =
       GoogleApiSourceName.of("[PROJECT]", "[LOCATION]", "[GOOGLE_API_SOURCE]");
   GoogleApiSource response = eventarcClient.getGoogleApiSource(name);
 }
Parameter
Name Description
name GoogleApiSourceName

Required. The name of the google api source to get.
Returns
Type Description
GoogleApiSource

getGoogleApiSource(String name)

public final GoogleApiSource getGoogleApiSource(String name)

Get a single GoogleApiSource.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   String name =
       GoogleApiSourceName.of("[PROJECT]", "[LOCATION]", "[GOOGLE_API_SOURCE]").toString();
   GoogleApiSource response = eventarcClient.getGoogleApiSource(name);
 }
Parameter
Name Description
name String

Required. The name of the google api source to get.
Returns
Type Description
GoogleApiSource

getGoogleApiSourceCallable()

public final UnaryCallable<GetGoogleApiSourceRequest,GoogleApiSource> getGoogleApiSourceCallable()

Get a single GoogleApiSource.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   GetGoogleApiSourceRequest request =
       GetGoogleApiSourceRequest.newBuilder()
           .setName(
               GoogleApiSourceName.of("[PROJECT]", "[LOCATION]", "[GOOGLE_API_SOURCE]")
                   .toString())
           .build();
   ApiFuture<GoogleApiSource> future =
       eventarcClient.getGoogleApiSourceCallable().futureCall(request);
   // Do something.
   GoogleApiSource response = future.get();
 }
Returns
Type Description
UnaryCallable<GetGoogleApiSourceRequest,GoogleApiSource>

getGoogleChannelConfig(GetGoogleChannelConfigRequest request)

public final GoogleChannelConfig getGoogleChannelConfig(GetGoogleChannelConfigRequest request)

Get a GoogleChannelConfig. The name of the GoogleChannelConfig in the response is ALWAYS coded with projectID.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   GetGoogleChannelConfigRequest request =
       GetGoogleChannelConfigRequest.newBuilder()
           .setName(GoogleChannelConfigName.of("[PROJECT]", "[LOCATION]").toString())
           .build();
   GoogleChannelConfig response = eventarcClient.getGoogleChannelConfig(request);
 }
Parameter
Name Description
request GetGoogleChannelConfigRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
GoogleChannelConfig

getGoogleChannelConfig(GoogleChannelConfigName name)

public final GoogleChannelConfig getGoogleChannelConfig(GoogleChannelConfigName name)

Get a GoogleChannelConfig. The name of the GoogleChannelConfig in the response is ALWAYS coded with projectID.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   GoogleChannelConfigName name = GoogleChannelConfigName.of("[PROJECT]", "[LOCATION]");
   GoogleChannelConfig response = eventarcClient.getGoogleChannelConfig(name);
 }
Parameter
Name Description
name GoogleChannelConfigName

Required. The name of the config to get.
Returns
Type Description
GoogleChannelConfig

getGoogleChannelConfig(String name)

public final GoogleChannelConfig getGoogleChannelConfig(String name)

Get a GoogleChannelConfig. The name of the GoogleChannelConfig in the response is ALWAYS coded with projectID.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   String name = GoogleChannelConfigName.of("[PROJECT]", "[LOCATION]").toString();
   GoogleChannelConfig response = eventarcClient.getGoogleChannelConfig(name);
 }
Parameter
Name Description
name String

Required. The name of the config to get.
Returns
Type Description
GoogleChannelConfig

getGoogleChannelConfigCallable()

public final UnaryCallable<GetGoogleChannelConfigRequest,GoogleChannelConfig> getGoogleChannelConfigCallable()

Get a GoogleChannelConfig. The name of the GoogleChannelConfig in the response is ALWAYS coded with projectID.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   GetGoogleChannelConfigRequest request =
       GetGoogleChannelConfigRequest.newBuilder()
           .setName(GoogleChannelConfigName.of("[PROJECT]", "[LOCATION]").toString())
           .build();
   ApiFuture<GoogleChannelConfig> future =
       eventarcClient.getGoogleChannelConfigCallable().futureCall(request);
   // Do something.
   GoogleChannelConfig response = future.get();
 }
Returns
Type Description
UnaryCallable<GetGoogleChannelConfigRequest,GoogleChannelConfig>

getHttpJsonOperationsClient()

public final OperationsClient getHttpJsonOperationsClient()

Returns the OperationsClient that can be used to query the status of a long-running operation returned by another API method call.

Returns
Type Description
OperationsClient

getIamPolicy(GetIamPolicyRequest request)

public final Policy getIamPolicy(GetIamPolicyRequest request)

Gets the access control policy for a resource. Returns an empty policyif the resource exists and does not have a policy set.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   GetIamPolicyRequest request =
       GetIamPolicyRequest.newBuilder()
           .setResource(ChannelName.of("[PROJECT]", "[LOCATION]", "[CHANNEL]").toString())
           .setOptions(GetPolicyOptions.newBuilder().build())
           .build();
   Policy response = eventarcClient.getIamPolicy(request);
 }
Parameter
Name Description
request com.google.iam.v1.GetIamPolicyRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
com.google.iam.v1.Policy

getIamPolicyCallable()

public final UnaryCallable<GetIamPolicyRequest,Policy> getIamPolicyCallable()

Gets the access control policy for a resource. Returns an empty policyif the resource exists and does not have a policy set.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   GetIamPolicyRequest request =
       GetIamPolicyRequest.newBuilder()
           .setResource(ChannelName.of("[PROJECT]", "[LOCATION]", "[CHANNEL]").toString())
           .setOptions(GetPolicyOptions.newBuilder().build())
           .build();
   ApiFuture<Policy> future = eventarcClient.getIamPolicyCallable().futureCall(request);
   // Do something.
   Policy response = future.get();
 }
Returns
Type Description
UnaryCallable<com.google.iam.v1.GetIamPolicyRequest,com.google.iam.v1.Policy>

getLocation(GetLocationRequest request)

public final Location getLocation(GetLocationRequest request)

Gets information about a location.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   GetLocationRequest request = GetLocationRequest.newBuilder().setName("name3373707").build();
   Location response = eventarcClient.getLocation(request);
 }
Parameter
Name Description
request com.google.cloud.location.GetLocationRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
com.google.cloud.location.Location

getLocationCallable()

public final UnaryCallable<GetLocationRequest,Location> getLocationCallable()

Gets information about a location.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   GetLocationRequest request = GetLocationRequest.newBuilder().setName("name3373707").build();
   ApiFuture<Location> future = eventarcClient.getLocationCallable().futureCall(request);
   // Do something.
   Location response = future.get();
 }
Returns
Type Description
UnaryCallable<com.google.cloud.location.GetLocationRequest,com.google.cloud.location.Location>

getMessageBus(GetMessageBusRequest request)

public final MessageBus getMessageBus(GetMessageBusRequest request)

Get a single MessageBus.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   GetMessageBusRequest request =
       GetMessageBusRequest.newBuilder()
           .setName(MessageBusName.of("[PROJECT]", "[LOCATION]", "[MESSAGE_BUS]").toString())
           .build();
   MessageBus response = eventarcClient.getMessageBus(request);
 }
Parameter
Name Description
request GetMessageBusRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
MessageBus

getMessageBus(MessageBusName name)

public final MessageBus getMessageBus(MessageBusName name)

Get a single MessageBus.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   MessageBusName name = MessageBusName.of("[PROJECT]", "[LOCATION]", "[MESSAGE_BUS]");
   MessageBus response = eventarcClient.getMessageBus(name);
 }
Parameter
Name Description
name MessageBusName

Required. The name of the message bus to get.
Returns
Type Description
MessageBus

getMessageBus(String name)

public final MessageBus getMessageBus(String name)

Get a single MessageBus.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   String name = MessageBusName.of("[PROJECT]", "[LOCATION]", "[MESSAGE_BUS]").toString();
   MessageBus response = eventarcClient.getMessageBus(name);
 }
Parameter
Name Description
name String

Required. The name of the message bus to get.
Returns
Type Description
MessageBus

getMessageBusCallable()

public final UnaryCallable<GetMessageBusRequest,MessageBus> getMessageBusCallable()

Get a single MessageBus.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   GetMessageBusRequest request =
       GetMessageBusRequest.newBuilder()
           .setName(MessageBusName.of("[PROJECT]", "[LOCATION]", "[MESSAGE_BUS]").toString())
           .build();
   ApiFuture<MessageBus> future = eventarcClient.getMessageBusCallable().futureCall(request);
   // Do something.
   MessageBus response = future.get();
 }
Returns
Type Description
UnaryCallable<GetMessageBusRequest,MessageBus>

getOperationsClient()

public final OperationsClient getOperationsClient()

Returns the OperationsClient that can be used to query the status of a long-running operation returned by another API method call.

Returns
Type Description
OperationsClient

getPipeline(GetPipelineRequest request)

public final Pipeline getPipeline(GetPipelineRequest request)

Get a single Pipeline.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   GetPipelineRequest request =
       GetPipelineRequest.newBuilder()
           .setName(PipelineName.of("[PROJECT]", "[LOCATION]", "[PIPELINE]").toString())
           .build();
   Pipeline response = eventarcClient.getPipeline(request);
 }
Parameter
Name Description
request GetPipelineRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
Pipeline

getPipeline(PipelineName name)

public final Pipeline getPipeline(PipelineName name)

Get a single Pipeline.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   PipelineName name = PipelineName.of("[PROJECT]", "[LOCATION]", "[PIPELINE]");
   Pipeline response = eventarcClient.getPipeline(name);
 }
Parameter
Name Description
name PipelineName

Required. The name of the pipeline to get.
Returns
Type Description
Pipeline

getPipeline(String name)

public final Pipeline getPipeline(String name)

Get a single Pipeline.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   String name = PipelineName.of("[PROJECT]", "[LOCATION]", "[PIPELINE]").toString();
   Pipeline response = eventarcClient.getPipeline(name);
 }
Parameter
Name Description
name String

Required. The name of the pipeline to get.
Returns
Type Description
Pipeline

getPipelineCallable()

public final UnaryCallable<GetPipelineRequest,Pipeline> getPipelineCallable()

Get a single Pipeline.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   GetPipelineRequest request =
       GetPipelineRequest.newBuilder()
           .setName(PipelineName.of("[PROJECT]", "[LOCATION]", "[PIPELINE]").toString())
           .build();
   ApiFuture<Pipeline> future = eventarcClient.getPipelineCallable().futureCall(request);
   // Do something.
   Pipeline response = future.get();
 }
Returns
Type Description
UnaryCallable<GetPipelineRequest,Pipeline>

getProvider(GetProviderRequest request)

public final Provider getProvider(GetProviderRequest request)

Get a single Provider.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   GetProviderRequest request =
       GetProviderRequest.newBuilder()
           .setName(ProviderName.of("[PROJECT]", "[LOCATION]", "[PROVIDER]").toString())
           .build();
   Provider response = eventarcClient.getProvider(request);
 }
Parameter
Name Description
request GetProviderRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
Provider

getProvider(ProviderName name)

public final Provider getProvider(ProviderName name)

Get a single Provider.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   ProviderName name = ProviderName.of("[PROJECT]", "[LOCATION]", "[PROVIDER]");
   Provider response = eventarcClient.getProvider(name);
 }
Parameter
Name Description
name ProviderName

Required. The name of the provider to get.
Returns
Type Description
Provider

getProvider(String name)

public final Provider getProvider(String name)

Get a single Provider.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   String name = ProviderName.of("[PROJECT]", "[LOCATION]", "[PROVIDER]").toString();
   Provider response = eventarcClient.getProvider(name);
 }
Parameter
Name Description
name String

Required. The name of the provider to get.
Returns
Type Description
Provider

getProviderCallable()

public final UnaryCallable<GetProviderRequest,Provider> getProviderCallable()

Get a single Provider.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   GetProviderRequest request =
       GetProviderRequest.newBuilder()
           .setName(ProviderName.of("[PROJECT]", "[LOCATION]", "[PROVIDER]").toString())
           .build();
   ApiFuture<Provider> future = eventarcClient.getProviderCallable().futureCall(request);
   // Do something.
   Provider response = future.get();
 }
Returns
Type Description
UnaryCallable<GetProviderRequest,Provider>

getSettings()

public final EventarcSettings getSettings()
Returns
Type Description
EventarcSettings

getStub()

public EventarcStub getStub()
Returns
Type Description
EventarcStub

getTrigger(GetTriggerRequest request)

public final Trigger getTrigger(GetTriggerRequest request)

Get a single trigger.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   GetTriggerRequest request =
       GetTriggerRequest.newBuilder()
           .setName(TriggerName.of("[PROJECT]", "[LOCATION]", "[TRIGGER]").toString())
           .build();
   Trigger response = eventarcClient.getTrigger(request);
 }
Parameter
Name Description
request GetTriggerRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
Trigger

getTrigger(TriggerName name)

public final Trigger getTrigger(TriggerName name)

Get a single trigger.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   TriggerName name = TriggerName.of("[PROJECT]", "[LOCATION]", "[TRIGGER]");
   Trigger response = eventarcClient.getTrigger(name);
 }
Parameter
Name Description
name TriggerName

Required. The name of the trigger to get.
Returns
Type Description
Trigger

getTrigger(String name)

public final Trigger getTrigger(String name)

Get a single trigger.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   String name = TriggerName.of("[PROJECT]", "[LOCATION]", "[TRIGGER]").toString();
   Trigger response = eventarcClient.getTrigger(name);
 }
Parameter
Name Description
name String

Required. The name of the trigger to get.
Returns
Type Description
Trigger

getTriggerCallable()

public final UnaryCallable<GetTriggerRequest,Trigger> getTriggerCallable()

Get a single trigger.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   GetTriggerRequest request =
       GetTriggerRequest.newBuilder()
           .setName(TriggerName.of("[PROJECT]", "[LOCATION]", "[TRIGGER]").toString())
           .build();
   ApiFuture<Trigger> future = eventarcClient.getTriggerCallable().futureCall(request);
   // Do something.
   Trigger response = future.get();
 }
Returns
Type Description
UnaryCallable<GetTriggerRequest,Trigger>

isShutdown()

public boolean isShutdown()
Returns
Type Description
boolean

isTerminated()

public boolean isTerminated()
Returns
Type Description
boolean

listChannelConnections(ListChannelConnectionsRequest request)

public final EventarcClient.ListChannelConnectionsPagedResponse listChannelConnections(ListChannelConnectionsRequest request)

List channel connections.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   ListChannelConnectionsRequest request =
       ListChannelConnectionsRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .build();
   for (ChannelConnection element :
       eventarcClient.listChannelConnections(request).iterateAll()) {
     // doThingsWith(element);
   }
 }
Parameter
Name Description
request ListChannelConnectionsRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
EventarcClient.ListChannelConnectionsPagedResponse

listChannelConnections(LocationName parent)

public final EventarcClient.ListChannelConnectionsPagedResponse listChannelConnections(LocationName parent)

List channel connections.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
   for (ChannelConnection element : eventarcClient.listChannelConnections(parent).iterateAll()) {
     // doThingsWith(element);
   }
 }
Parameter
Name Description
parent LocationName

Required. The parent collection from which to list channel connections.
Returns
Type Description
EventarcClient.ListChannelConnectionsPagedResponse

listChannelConnections(String parent)

public final EventarcClient.ListChannelConnectionsPagedResponse listChannelConnections(String parent)

List channel connections.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
   for (ChannelConnection element : eventarcClient.listChannelConnections(parent).iterateAll()) {
     // doThingsWith(element);
   }
 }
Parameter
Name Description
parent String

Required. The parent collection from which to list channel connections.
Returns
Type Description
EventarcClient.ListChannelConnectionsPagedResponse

listChannelConnectionsCallable()

public final UnaryCallable<ListChannelConnectionsRequest,ListChannelConnectionsResponse> listChannelConnectionsCallable()

List channel connections.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   ListChannelConnectionsRequest request =
       ListChannelConnectionsRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .build();
   while (true) {
     ListChannelConnectionsResponse response =
         eventarcClient.listChannelConnectionsCallable().call(request);
     for (ChannelConnection element : response.getChannelConnectionsList()) {
       // doThingsWith(element);
     }
     String nextPageToken = response.getNextPageToken();
     if (!Strings.isNullOrEmpty(nextPageToken)) {
       request = request.toBuilder().setPageToken(nextPageToken).build();
     } else {
       break;
     }
   }
 }
Returns
Type Description
UnaryCallable<ListChannelConnectionsRequest,ListChannelConnectionsResponse>

listChannelConnectionsPagedCallable()

public final UnaryCallable<ListChannelConnectionsRequest,EventarcClient.ListChannelConnectionsPagedResponse> listChannelConnectionsPagedCallable()

List channel connections.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   ListChannelConnectionsRequest request =
       ListChannelConnectionsRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .build();
   ApiFuture<ChannelConnection> future =
       eventarcClient.listChannelConnectionsPagedCallable().futureCall(request);
   // Do something.
   for (ChannelConnection element : future.get().iterateAll()) {
     // doThingsWith(element);
   }
 }
Returns
Type Description
UnaryCallable<ListChannelConnectionsRequest,ListChannelConnectionsPagedResponse>

listChannels(ListChannelsRequest request)

public final EventarcClient.ListChannelsPagedResponse listChannels(ListChannelsRequest request)

List channels.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   ListChannelsRequest request =
       ListChannelsRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .setOrderBy("orderBy-1207110587")
           .build();
   for (Channel element : eventarcClient.listChannels(request).iterateAll()) {
     // doThingsWith(element);
   }
 }
Parameter
Name Description
request ListChannelsRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
EventarcClient.ListChannelsPagedResponse

listChannels(LocationName parent)

public final EventarcClient.ListChannelsPagedResponse listChannels(LocationName parent)

List channels.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
   for (Channel element : eventarcClient.listChannels(parent).iterateAll()) {
     // doThingsWith(element);
   }
 }
Parameter
Name Description
parent LocationName

Required. The parent collection to list channels on.
Returns
Type Description
EventarcClient.ListChannelsPagedResponse

listChannels(String parent)

public final EventarcClient.ListChannelsPagedResponse listChannels(String parent)

List channels.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
   for (Channel element : eventarcClient.listChannels(parent).iterateAll()) {
     // doThingsWith(element);
   }
 }
Parameter
Name Description
parent String

Required. The parent collection to list channels on.
Returns
Type Description
EventarcClient.ListChannelsPagedResponse

listChannelsCallable()

public final UnaryCallable<ListChannelsRequest,ListChannelsResponse> listChannelsCallable()

List channels.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   ListChannelsRequest request =
       ListChannelsRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .setOrderBy("orderBy-1207110587")
           .build();
   while (true) {
     ListChannelsResponse response = eventarcClient.listChannelsCallable().call(request);
     for (Channel element : response.getChannelsList()) {
       // doThingsWith(element);
     }
     String nextPageToken = response.getNextPageToken();
     if (!Strings.isNullOrEmpty(nextPageToken)) {
       request = request.toBuilder().setPageToken(nextPageToken).build();
     } else {
       break;
     }
   }
 }
Returns
Type Description
UnaryCallable<ListChannelsRequest,ListChannelsResponse>

listChannelsPagedCallable()

public final UnaryCallable<ListChannelsRequest,EventarcClient.ListChannelsPagedResponse> listChannelsPagedCallable()

List channels.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   ListChannelsRequest request =
       ListChannelsRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .setOrderBy("orderBy-1207110587")
           .build();
   ApiFuture<Channel> future = eventarcClient.listChannelsPagedCallable().futureCall(request);
   // Do something.
   for (Channel element : future.get().iterateAll()) {
     // doThingsWith(element);
   }
 }
Returns
Type Description
UnaryCallable<ListChannelsRequest,ListChannelsPagedResponse>

listEnrollments(ListEnrollmentsRequest request)

public final EventarcClient.ListEnrollmentsPagedResponse listEnrollments(ListEnrollmentsRequest request)

List Enrollments.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   ListEnrollmentsRequest request =
       ListEnrollmentsRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .setOrderBy("orderBy-1207110587")
           .setFilter("filter-1274492040")
           .build();
   for (Enrollment element : eventarcClient.listEnrollments(request).iterateAll()) {
     // doThingsWith(element);
   }
 }
Parameter
Name Description
request ListEnrollmentsRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
EventarcClient.ListEnrollmentsPagedResponse

listEnrollments(LocationName parent)

public final EventarcClient.ListEnrollmentsPagedResponse listEnrollments(LocationName parent)

List Enrollments.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
   for (Enrollment element : eventarcClient.listEnrollments(parent).iterateAll()) {
     // doThingsWith(element);
   }
 }
Parameter
Name Description
parent LocationName

Required. The parent collection to list triggers on.
Returns
Type Description
EventarcClient.ListEnrollmentsPagedResponse

listEnrollments(String parent)

public final EventarcClient.ListEnrollmentsPagedResponse listEnrollments(String parent)

List Enrollments.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
   for (Enrollment element : eventarcClient.listEnrollments(parent).iterateAll()) {
     // doThingsWith(element);
   }
 }
Parameter
Name Description
parent String

Required. The parent collection to list triggers on.
Returns
Type Description
EventarcClient.ListEnrollmentsPagedResponse

listEnrollmentsCallable()

public final UnaryCallable<ListEnrollmentsRequest,ListEnrollmentsResponse> listEnrollmentsCallable()

List Enrollments.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   ListEnrollmentsRequest request =
       ListEnrollmentsRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .setOrderBy("orderBy-1207110587")
           .setFilter("filter-1274492040")
           .build();
   while (true) {
     ListEnrollmentsResponse response = eventarcClient.listEnrollmentsCallable().call(request);
     for (Enrollment element : response.getEnrollmentsList()) {
       // doThingsWith(element);
     }
     String nextPageToken = response.getNextPageToken();
     if (!Strings.isNullOrEmpty(nextPageToken)) {
       request = request.toBuilder().setPageToken(nextPageToken).build();
     } else {
       break;
     }
   }
 }
Returns
Type Description
UnaryCallable<ListEnrollmentsRequest,ListEnrollmentsResponse>

listEnrollmentsPagedCallable()

public final UnaryCallable<ListEnrollmentsRequest,EventarcClient.ListEnrollmentsPagedResponse> listEnrollmentsPagedCallable()

List Enrollments.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   ListEnrollmentsRequest request =
       ListEnrollmentsRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .setOrderBy("orderBy-1207110587")
           .setFilter("filter-1274492040")
           .build();
   ApiFuture<Enrollment> future =
       eventarcClient.listEnrollmentsPagedCallable().futureCall(request);
   // Do something.
   for (Enrollment element : future.get().iterateAll()) {
     // doThingsWith(element);
   }
 }
Returns
Type Description
UnaryCallable<ListEnrollmentsRequest,ListEnrollmentsPagedResponse>

listGoogleApiSources(ListGoogleApiSourcesRequest request)

public final EventarcClient.ListGoogleApiSourcesPagedResponse listGoogleApiSources(ListGoogleApiSourcesRequest request)

List GoogleApiSources.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   ListGoogleApiSourcesRequest request =
       ListGoogleApiSourcesRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .setOrderBy("orderBy-1207110587")
           .setFilter("filter-1274492040")
           .build();
   for (GoogleApiSource element : eventarcClient.listGoogleApiSources(request).iterateAll()) {
     // doThingsWith(element);
   }
 }
Parameter
Name Description
request ListGoogleApiSourcesRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
EventarcClient.ListGoogleApiSourcesPagedResponse

listGoogleApiSources(LocationName parent)

public final EventarcClient.ListGoogleApiSourcesPagedResponse listGoogleApiSources(LocationName parent)

List GoogleApiSources.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
   for (GoogleApiSource element : eventarcClient.listGoogleApiSources(parent).iterateAll()) {
     // doThingsWith(element);
   }
 }
Parameter
Name Description
parent LocationName

Required. The parent collection to list GoogleApiSources on.
Returns
Type Description
EventarcClient.ListGoogleApiSourcesPagedResponse

listGoogleApiSources(String parent)

public final EventarcClient.ListGoogleApiSourcesPagedResponse listGoogleApiSources(String parent)

List GoogleApiSources.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
   for (GoogleApiSource element : eventarcClient.listGoogleApiSources(parent).iterateAll()) {
     // doThingsWith(element);
   }
 }
Parameter
Name Description
parent String

Required. The parent collection to list GoogleApiSources on.
Returns
Type Description
EventarcClient.ListGoogleApiSourcesPagedResponse

listGoogleApiSourcesCallable()

public final UnaryCallable<ListGoogleApiSourcesRequest,ListGoogleApiSourcesResponse> listGoogleApiSourcesCallable()

List GoogleApiSources.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   ListGoogleApiSourcesRequest request =
       ListGoogleApiSourcesRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .setOrderBy("orderBy-1207110587")
           .setFilter("filter-1274492040")
           .build();
   while (true) {
     ListGoogleApiSourcesResponse response =
         eventarcClient.listGoogleApiSourcesCallable().call(request);
     for (GoogleApiSource element : response.getGoogleApiSourcesList()) {
       // doThingsWith(element);
     }
     String nextPageToken = response.getNextPageToken();
     if (!Strings.isNullOrEmpty(nextPageToken)) {
       request = request.toBuilder().setPageToken(nextPageToken).build();
     } else {
       break;
     }
   }
 }
Returns
Type Description
UnaryCallable<ListGoogleApiSourcesRequest,ListGoogleApiSourcesResponse>

listGoogleApiSourcesPagedCallable()

public final UnaryCallable<ListGoogleApiSourcesRequest,EventarcClient.ListGoogleApiSourcesPagedResponse> listGoogleApiSourcesPagedCallable()

List GoogleApiSources.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   ListGoogleApiSourcesRequest request =
       ListGoogleApiSourcesRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .setOrderBy("orderBy-1207110587")
           .setFilter("filter-1274492040")
           .build();
   ApiFuture<GoogleApiSource> future =
       eventarcClient.listGoogleApiSourcesPagedCallable().futureCall(request);
   // Do something.
   for (GoogleApiSource element : future.get().iterateAll()) {
     // doThingsWith(element);
   }
 }
Returns
Type Description
UnaryCallable<ListGoogleApiSourcesRequest,ListGoogleApiSourcesPagedResponse>

listLocations(ListLocationsRequest request)

public final EventarcClient.ListLocationsPagedResponse listLocations(ListLocationsRequest request)

Lists information about the supported locations for this service.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   ListLocationsRequest request =
       ListLocationsRequest.newBuilder()
           .setName("name3373707")
           .setFilter("filter-1274492040")
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .build();
   for (Location element : eventarcClient.listLocations(request).iterateAll()) {
     // doThingsWith(element);
   }
 }
Parameter
Name Description
request com.google.cloud.location.ListLocationsRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
EventarcClient.ListLocationsPagedResponse

listLocationsCallable()

public final UnaryCallable<ListLocationsRequest,ListLocationsResponse> listLocationsCallable()

Lists information about the supported locations for this service.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   ListLocationsRequest request =
       ListLocationsRequest.newBuilder()
           .setName("name3373707")
           .setFilter("filter-1274492040")
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .build();
   while (true) {
     ListLocationsResponse response = eventarcClient.listLocationsCallable().call(request);
     for (Location element : response.getLocationsList()) {
       // doThingsWith(element);
     }
     String nextPageToken = response.getNextPageToken();
     if (!Strings.isNullOrEmpty(nextPageToken)) {
       request = request.toBuilder().setPageToken(nextPageToken).build();
     } else {
       break;
     }
   }
 }
Returns
Type Description
UnaryCallable<com.google.cloud.location.ListLocationsRequest,com.google.cloud.location.ListLocationsResponse>

listLocationsPagedCallable()

public final UnaryCallable<ListLocationsRequest,EventarcClient.ListLocationsPagedResponse> listLocationsPagedCallable()

Lists information about the supported locations for this service.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   ListLocationsRequest request =
       ListLocationsRequest.newBuilder()
           .setName("name3373707")
           .setFilter("filter-1274492040")
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .build();
   ApiFuture<Location> future = eventarcClient.listLocationsPagedCallable().futureCall(request);
   // Do something.
   for (Location element : future.get().iterateAll()) {
     // doThingsWith(element);
   }
 }
Returns
Type Description
UnaryCallable<com.google.cloud.location.ListLocationsRequest,ListLocationsPagedResponse>

listMessageBusEnrollments(ListMessageBusEnrollmentsRequest request)

public final EventarcClient.ListMessageBusEnrollmentsPagedResponse listMessageBusEnrollments(ListMessageBusEnrollmentsRequest request)

List message bus enrollments.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   ListMessageBusEnrollmentsRequest request =
       ListMessageBusEnrollmentsRequest.newBuilder()
           .setParent(MessageBusName.of("[PROJECT]", "[LOCATION]", "[MESSAGE_BUS]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .build();
   for (String element : eventarcClient.listMessageBusEnrollments(request).iterateAll()) {
     // doThingsWith(element);
   }
 }
Parameter
Name Description
request ListMessageBusEnrollmentsRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
EventarcClient.ListMessageBusEnrollmentsPagedResponse

listMessageBusEnrollments(MessageBusName parent)

public final EventarcClient.ListMessageBusEnrollmentsPagedResponse listMessageBusEnrollments(MessageBusName parent)

List message bus enrollments.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   MessageBusName parent = MessageBusName.of("[PROJECT]", "[LOCATION]", "[MESSAGE_BUS]");
   for (String element : eventarcClient.listMessageBusEnrollments(parent).iterateAll()) {
     // doThingsWith(element);
   }
 }
Parameter
Name Description
parent MessageBusName

Required. The parent message bus to list enrollments on.
Returns
Type Description
EventarcClient.ListMessageBusEnrollmentsPagedResponse

listMessageBusEnrollments(String parent)

public final EventarcClient.ListMessageBusEnrollmentsPagedResponse listMessageBusEnrollments(String parent)

List message bus enrollments.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   String parent = MessageBusName.of("[PROJECT]", "[LOCATION]", "[MESSAGE_BUS]").toString();
   for (String element : eventarcClient.listMessageBusEnrollments(parent).iterateAll()) {
     // doThingsWith(element);
   }
 }
Parameter
Name Description
parent String

Required. The parent message bus to list enrollments on.
Returns
Type Description
EventarcClient.ListMessageBusEnrollmentsPagedResponse

listMessageBusEnrollmentsCallable()

public final UnaryCallable<ListMessageBusEnrollmentsRequest,ListMessageBusEnrollmentsResponse> listMessageBusEnrollmentsCallable()

List message bus enrollments.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   ListMessageBusEnrollmentsRequest request =
       ListMessageBusEnrollmentsRequest.newBuilder()
           .setParent(MessageBusName.of("[PROJECT]", "[LOCATION]", "[MESSAGE_BUS]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .build();
   while (true) {
     ListMessageBusEnrollmentsResponse response =
         eventarcClient.listMessageBusEnrollmentsCallable().call(request);
     for (String element : response.getEnrollmentsList()) {
       // doThingsWith(element);
     }
     String nextPageToken = response.getNextPageToken();
     if (!Strings.isNullOrEmpty(nextPageToken)) {
       request = request.toBuilder().setPageToken(nextPageToken).build();
     } else {
       break;
     }
   }
 }
Returns
Type Description
UnaryCallable<ListMessageBusEnrollmentsRequest,ListMessageBusEnrollmentsResponse>

listMessageBusEnrollmentsPagedCallable()

public final UnaryCallable<ListMessageBusEnrollmentsRequest,EventarcClient.ListMessageBusEnrollmentsPagedResponse> listMessageBusEnrollmentsPagedCallable()

List message bus enrollments.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   ListMessageBusEnrollmentsRequest request =
       ListMessageBusEnrollmentsRequest.newBuilder()
           .setParent(MessageBusName.of("[PROJECT]", "[LOCATION]", "[MESSAGE_BUS]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .build();
   ApiFuture<String> future =
       eventarcClient.listMessageBusEnrollmentsPagedCallable().futureCall(request);
   // Do something.
   for (String element : future.get().iterateAll()) {
     // doThingsWith(element);
   }
 }
Returns
Type Description
UnaryCallable<ListMessageBusEnrollmentsRequest,ListMessageBusEnrollmentsPagedResponse>

listMessageBuses(ListMessageBusesRequest request)

public final EventarcClient.ListMessageBusesPagedResponse listMessageBuses(ListMessageBusesRequest request)

List message buses.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   ListMessageBusesRequest request =
       ListMessageBusesRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .setOrderBy("orderBy-1207110587")
           .setFilter("filter-1274492040")
           .build();
   for (MessageBus element : eventarcClient.listMessageBuses(request).iterateAll()) {
     // doThingsWith(element);
   }
 }
Parameter
Name Description
request ListMessageBusesRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
EventarcClient.ListMessageBusesPagedResponse

listMessageBuses(LocationName parent)

public final EventarcClient.ListMessageBusesPagedResponse listMessageBuses(LocationName parent)

List message buses.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
   for (MessageBus element : eventarcClient.listMessageBuses(parent).iterateAll()) {
     // doThingsWith(element);
   }
 }
Parameter
Name Description
parent LocationName

Required. The parent collection to list message buses on.
Returns
Type Description
EventarcClient.ListMessageBusesPagedResponse

listMessageBuses(String parent)

public final EventarcClient.ListMessageBusesPagedResponse listMessageBuses(String parent)

List message buses.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
   for (MessageBus element : eventarcClient.listMessageBuses(parent).iterateAll()) {
     // doThingsWith(element);
   }
 }
Parameter
Name Description
parent String

Required. The parent collection to list message buses on.
Returns
Type Description
EventarcClient.ListMessageBusesPagedResponse

listMessageBusesCallable()

public final UnaryCallable<ListMessageBusesRequest,ListMessageBusesResponse> listMessageBusesCallable()

List message buses.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   ListMessageBusesRequest request =
       ListMessageBusesRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .setOrderBy("orderBy-1207110587")
           .setFilter("filter-1274492040")
           .build();
   while (true) {
     ListMessageBusesResponse response = eventarcClient.listMessageBusesCallable().call(request);
     for (MessageBus element : response.getMessageBusesList()) {
       // doThingsWith(element);
     }
     String nextPageToken = response.getNextPageToken();
     if (!Strings.isNullOrEmpty(nextPageToken)) {
       request = request.toBuilder().setPageToken(nextPageToken).build();
     } else {
       break;
     }
   }
 }
Returns
Type Description
UnaryCallable<ListMessageBusesRequest,ListMessageBusesResponse>

listMessageBusesPagedCallable()

public final UnaryCallable<ListMessageBusesRequest,EventarcClient.ListMessageBusesPagedResponse> listMessageBusesPagedCallable()

List message buses.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   ListMessageBusesRequest request =
       ListMessageBusesRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .setOrderBy("orderBy-1207110587")
           .setFilter("filter-1274492040")
           .build();
   ApiFuture<MessageBus> future =
       eventarcClient.listMessageBusesPagedCallable().futureCall(request);
   // Do something.
   for (MessageBus element : future.get().iterateAll()) {
     // doThingsWith(element);
   }
 }
Returns
Type Description
UnaryCallable<ListMessageBusesRequest,ListMessageBusesPagedResponse>

listPipelines(ListPipelinesRequest request)

public final EventarcClient.ListPipelinesPagedResponse listPipelines(ListPipelinesRequest request)

List pipelines.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   ListPipelinesRequest request =
       ListPipelinesRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .setOrderBy("orderBy-1207110587")
           .setFilter("filter-1274492040")
           .build();
   for (Pipeline element : eventarcClient.listPipelines(request).iterateAll()) {
     // doThingsWith(element);
   }
 }
Parameter
Name Description
request ListPipelinesRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
EventarcClient.ListPipelinesPagedResponse

listPipelines(LocationName parent)

public final EventarcClient.ListPipelinesPagedResponse listPipelines(LocationName parent)

List pipelines.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
   for (Pipeline element : eventarcClient.listPipelines(parent).iterateAll()) {
     // doThingsWith(element);
   }
 }
Parameter
Name Description
parent LocationName

Required. The parent collection to list pipelines on.
Returns
Type Description
EventarcClient.ListPipelinesPagedResponse

listPipelines(String parent)

public final EventarcClient.ListPipelinesPagedResponse listPipelines(String parent)

List pipelines.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
   for (Pipeline element : eventarcClient.listPipelines(parent).iterateAll()) {
     // doThingsWith(element);
   }
 }
Parameter
Name Description
parent String

Required. The parent collection to list pipelines on.
Returns
Type Description
EventarcClient.ListPipelinesPagedResponse

listPipelinesCallable()

public final UnaryCallable<ListPipelinesRequest,ListPipelinesResponse> listPipelinesCallable()

List pipelines.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   ListPipelinesRequest request =
       ListPipelinesRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .setOrderBy("orderBy-1207110587")
           .setFilter("filter-1274492040")
           .build();
   while (true) {
     ListPipelinesResponse response = eventarcClient.listPipelinesCallable().call(request);
     for (Pipeline element : response.getPipelinesList()) {
       // doThingsWith(element);
     }
     String nextPageToken = response.getNextPageToken();
     if (!Strings.isNullOrEmpty(nextPageToken)) {
       request = request.toBuilder().setPageToken(nextPageToken).build();
     } else {
       break;
     }
   }
 }
Returns
Type Description
UnaryCallable<ListPipelinesRequest,ListPipelinesResponse>

listPipelinesPagedCallable()

public final UnaryCallable<ListPipelinesRequest,EventarcClient.ListPipelinesPagedResponse> listPipelinesPagedCallable()

List pipelines.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   ListPipelinesRequest request =
       ListPipelinesRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .setOrderBy("orderBy-1207110587")
           .setFilter("filter-1274492040")
           .build();
   ApiFuture<Pipeline> future = eventarcClient.listPipelinesPagedCallable().futureCall(request);
   // Do something.
   for (Pipeline element : future.get().iterateAll()) {
     // doThingsWith(element);
   }
 }
Returns
Type Description
UnaryCallable<ListPipelinesRequest,ListPipelinesPagedResponse>

listProviders(ListProvidersRequest request)

public final EventarcClient.ListProvidersPagedResponse listProviders(ListProvidersRequest request)

List providers.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   ListProvidersRequest request =
       ListProvidersRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .setOrderBy("orderBy-1207110587")
           .setFilter("filter-1274492040")
           .build();
   for (Provider element : eventarcClient.listProviders(request).iterateAll()) {
     // doThingsWith(element);
   }
 }
Parameter
Name Description
request ListProvidersRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
EventarcClient.ListProvidersPagedResponse

listProviders(LocationName parent)

public final EventarcClient.ListProvidersPagedResponse listProviders(LocationName parent)

List providers.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
   for (Provider element : eventarcClient.listProviders(parent).iterateAll()) {
     // doThingsWith(element);
   }
 }
Parameter
Name Description
parent LocationName

Required. The parent of the provider to get.
Returns
Type Description
EventarcClient.ListProvidersPagedResponse

listProviders(String parent)

public final EventarcClient.ListProvidersPagedResponse listProviders(String parent)

List providers.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
   for (Provider element : eventarcClient.listProviders(parent).iterateAll()) {
     // doThingsWith(element);
   }
 }
Parameter
Name Description
parent String

Required. The parent of the provider to get.
Returns
Type Description
EventarcClient.ListProvidersPagedResponse

listProvidersCallable()

public final UnaryCallable<ListProvidersRequest,ListProvidersResponse> listProvidersCallable()

List providers.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   ListProvidersRequest request =
       ListProvidersRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .setOrderBy("orderBy-1207110587")
           .setFilter("filter-1274492040")
           .build();
   while (true) {
     ListProvidersResponse response = eventarcClient.listProvidersCallable().call(request);
     for (Provider element : response.getProvidersList()) {
       // doThingsWith(element);
     }
     String nextPageToken = response.getNextPageToken();
     if (!Strings.isNullOrEmpty(nextPageToken)) {
       request = request.toBuilder().setPageToken(nextPageToken).build();
     } else {
       break;
     }
   }
 }
Returns
Type Description
UnaryCallable<ListProvidersRequest,ListProvidersResponse>

listProvidersPagedCallable()

public final UnaryCallable<ListProvidersRequest,EventarcClient.ListProvidersPagedResponse> listProvidersPagedCallable()

List providers.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   ListProvidersRequest request =
       ListProvidersRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .setOrderBy("orderBy-1207110587")
           .setFilter("filter-1274492040")
           .build();
   ApiFuture<Provider> future = eventarcClient.listProvidersPagedCallable().futureCall(request);
   // Do something.
   for (Provider element : future.get().iterateAll()) {
     // doThingsWith(element);
   }
 }
Returns
Type Description
UnaryCallable<ListProvidersRequest,ListProvidersPagedResponse>

listTriggers(ListTriggersRequest request)

public final EventarcClient.ListTriggersPagedResponse listTriggers(ListTriggersRequest request)

List triggers.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   ListTriggersRequest request =
       ListTriggersRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .setOrderBy("orderBy-1207110587")
           .setFilter("filter-1274492040")
           .build();
   for (Trigger element : eventarcClient.listTriggers(request).iterateAll()) {
     // doThingsWith(element);
   }
 }
Parameter
Name Description
request ListTriggersRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
EventarcClient.ListTriggersPagedResponse

listTriggers(LocationName parent)

public final EventarcClient.ListTriggersPagedResponse listTriggers(LocationName parent)

List triggers.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
   for (Trigger element : eventarcClient.listTriggers(parent).iterateAll()) {
     // doThingsWith(element);
   }
 }
Parameter
Name Description
parent LocationName

Required. The parent collection to list triggers on.
Returns
Type Description
EventarcClient.ListTriggersPagedResponse

listTriggers(String parent)

public final EventarcClient.ListTriggersPagedResponse listTriggers(String parent)

List triggers.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
   for (Trigger element : eventarcClient.listTriggers(parent).iterateAll()) {
     // doThingsWith(element);
   }
 }
Parameter
Name Description
parent String

Required. The parent collection to list triggers on.
Returns
Type Description
EventarcClient.ListTriggersPagedResponse

listTriggersCallable()

public final UnaryCallable<ListTriggersRequest,ListTriggersResponse> listTriggersCallable()

List triggers.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   ListTriggersRequest request =
       ListTriggersRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .setOrderBy("orderBy-1207110587")
           .setFilter("filter-1274492040")
           .build();
   while (true) {
     ListTriggersResponse response = eventarcClient.listTriggersCallable().call(request);
     for (Trigger element : response.getTriggersList()) {
       // doThingsWith(element);
     }
     String nextPageToken = response.getNextPageToken();
     if (!Strings.isNullOrEmpty(nextPageToken)) {
       request = request.toBuilder().setPageToken(nextPageToken).build();
     } else {
       break;
     }
   }
 }
Returns
Type Description
UnaryCallable<ListTriggersRequest,ListTriggersResponse>

listTriggersPagedCallable()

public final UnaryCallable<ListTriggersRequest,EventarcClient.ListTriggersPagedResponse> listTriggersPagedCallable()

List triggers.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   ListTriggersRequest request =
       ListTriggersRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .setOrderBy("orderBy-1207110587")
           .setFilter("filter-1274492040")
           .build();
   ApiFuture<Trigger> future = eventarcClient.listTriggersPagedCallable().futureCall(request);
   // Do something.
   for (Trigger element : future.get().iterateAll()) {
     // doThingsWith(element);
   }
 }
Returns
Type Description
UnaryCallable<ListTriggersRequest,ListTriggersPagedResponse>

setIamPolicy(SetIamPolicyRequest request)

public final Policy setIamPolicy(SetIamPolicyRequest request)

Sets the access control policy on the specified resource. Replacesany existing policy.

Can return NOT_FOUND, INVALID_ARGUMENT, and PERMISSION_DENIEDerrors.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   SetIamPolicyRequest request =
       SetIamPolicyRequest.newBuilder()
           .setResource(ChannelName.of("[PROJECT]", "[LOCATION]", "[CHANNEL]").toString())
           .setPolicy(Policy.newBuilder().build())
           .setUpdateMask(FieldMask.newBuilder().build())
           .build();
   Policy response = eventarcClient.setIamPolicy(request);
 }
Parameter
Name Description
request com.google.iam.v1.SetIamPolicyRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
com.google.iam.v1.Policy

setIamPolicyCallable()

public final UnaryCallable<SetIamPolicyRequest,Policy> setIamPolicyCallable()

Sets the access control policy on the specified resource. Replacesany existing policy.

Can return NOT_FOUND, INVALID_ARGUMENT, and PERMISSION_DENIEDerrors.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   SetIamPolicyRequest request =
       SetIamPolicyRequest.newBuilder()
           .setResource(ChannelName.of("[PROJECT]", "[LOCATION]", "[CHANNEL]").toString())
           .setPolicy(Policy.newBuilder().build())
           .setUpdateMask(FieldMask.newBuilder().build())
           .build();
   ApiFuture<Policy> future = eventarcClient.setIamPolicyCallable().futureCall(request);
   // Do something.
   Policy response = future.get();
 }
Returns
Type Description
UnaryCallable<com.google.iam.v1.SetIamPolicyRequest,com.google.iam.v1.Policy>

shutdown()

public void shutdown()

shutdownNow()

public void shutdownNow()

testIamPermissions(TestIamPermissionsRequest request)

public final TestIamPermissionsResponse testIamPermissions(TestIamPermissionsRequest request)

Returns permissions that a caller has on the specified resource. If theresource does not exist, this will return an empty set ofpermissions, not a NOT_FOUND error.

Note: This operation is designed to be used for buildingpermission-aware UIs and command-line tools, not for authorizationchecking. This operation may "fail open" without warning.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   TestIamPermissionsRequest request =
       TestIamPermissionsRequest.newBuilder()
           .setResource(ChannelName.of("[PROJECT]", "[LOCATION]", "[CHANNEL]").toString())
           .addAllPermissions(new ArrayList<String>())
           .build();
   TestIamPermissionsResponse response = eventarcClient.testIamPermissions(request);
 }
Parameter
Name Description
request com.google.iam.v1.TestIamPermissionsRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
com.google.iam.v1.TestIamPermissionsResponse

testIamPermissionsCallable()

public final UnaryCallable<TestIamPermissionsRequest,TestIamPermissionsResponse> testIamPermissionsCallable()

Returns permissions that a caller has on the specified resource. If theresource does not exist, this will return an empty set ofpermissions, not a NOT_FOUND error.

Note: This operation is designed to be used for buildingpermission-aware UIs and command-line tools, not for authorizationchecking. This operation may "fail open" without warning.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   TestIamPermissionsRequest request =
       TestIamPermissionsRequest.newBuilder()
           .setResource(ChannelName.of("[PROJECT]", "[LOCATION]", "[CHANNEL]").toString())
           .addAllPermissions(new ArrayList<String>())
           .build();
   ApiFuture<TestIamPermissionsResponse> future =
       eventarcClient.testIamPermissionsCallable().futureCall(request);
   // Do something.
   TestIamPermissionsResponse response = future.get();
 }
Returns
Type Description
UnaryCallable<com.google.iam.v1.TestIamPermissionsRequest,com.google.iam.v1.TestIamPermissionsResponse>

updateChannelAsync(Channel channel, FieldMask updateMask)

public final OperationFuture<Channel,OperationMetadata> updateChannelAsync(Channel channel, FieldMask updateMask)

Update a single channel.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   Channel channel = Channel.newBuilder().build();
   FieldMask updateMask = FieldMask.newBuilder().build();
   Channel response = eventarcClient.updateChannelAsync(channel, updateMask).get();
 }
Parameters
Name Description
channel Channel

The channel to be updated.
updateMask FieldMask

The fields to be updated; only fields explicitly provided are updated. If no field mask is provided, all provided fields in the request are updated. To update all fields, provide a field mask of "*".
Returns
Type Description
OperationFuture<Channel,OperationMetadata>

updateChannelAsync(UpdateChannelRequest request)

public final OperationFuture<Channel,OperationMetadata> updateChannelAsync(UpdateChannelRequest request)

Update a single channel.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   UpdateChannelRequest request =
       UpdateChannelRequest.newBuilder()
           .setChannel(Channel.newBuilder().build())
           .setUpdateMask(FieldMask.newBuilder().build())
           .setValidateOnly(true)
           .build();
   Channel response = eventarcClient.updateChannelAsync(request).get();
 }
Parameter
Name Description
request UpdateChannelRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
OperationFuture<Channel,OperationMetadata>

updateChannelCallable()

public final UnaryCallable<UpdateChannelRequest,Operation> updateChannelCallable()

Update a single channel.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   UpdateChannelRequest request =
       UpdateChannelRequest.newBuilder()
           .setChannel(Channel.newBuilder().build())
           .setUpdateMask(FieldMask.newBuilder().build())
           .setValidateOnly(true)
           .build();
   ApiFuture<Operation> future = eventarcClient.updateChannelCallable().futureCall(request);
   // Do something.
   Operation response = future.get();
 }
Returns
Type Description
UnaryCallable<UpdateChannelRequest,Operation>

updateChannelOperationCallable()

public final OperationCallable<UpdateChannelRequest,Channel,OperationMetadata> updateChannelOperationCallable()

Update a single channel.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   UpdateChannelRequest request =
       UpdateChannelRequest.newBuilder()
           .setChannel(Channel.newBuilder().build())
           .setUpdateMask(FieldMask.newBuilder().build())
           .setValidateOnly(true)
           .build();
   OperationFuture<Channel, OperationMetadata> future =
       eventarcClient.updateChannelOperationCallable().futureCall(request);
   // Do something.
   Channel response = future.get();
 }
Returns
Type Description
OperationCallable<UpdateChannelRequest,Channel,OperationMetadata>

updateEnrollmentAsync(Enrollment enrollment, FieldMask updateMask)

public final OperationFuture<Enrollment,OperationMetadata> updateEnrollmentAsync(Enrollment enrollment, FieldMask updateMask)

Update a single Enrollment.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   Enrollment enrollment = Enrollment.newBuilder().build();
   FieldMask updateMask = FieldMask.newBuilder().build();
   Enrollment response = eventarcClient.updateEnrollmentAsync(enrollment, updateMask).get();
 }
Parameters
Name Description
enrollment Enrollment

Required. The Enrollment to be updated.
updateMask FieldMask

Optional. The fields to be updated; only fields explicitly provided are updated. If no field mask is provided, all provided fields in the request are updated. To update all fields, provide a field mask of "*".
Returns
Type Description
OperationFuture<Enrollment,OperationMetadata>

updateEnrollmentAsync(UpdateEnrollmentRequest request)

public final OperationFuture<Enrollment,OperationMetadata> updateEnrollmentAsync(UpdateEnrollmentRequest request)

Update a single Enrollment.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   UpdateEnrollmentRequest request =
       UpdateEnrollmentRequest.newBuilder()
           .setEnrollment(Enrollment.newBuilder().build())
           .setUpdateMask(FieldMask.newBuilder().build())
           .setAllowMissing(true)
           .setValidateOnly(true)
           .build();
   Enrollment response = eventarcClient.updateEnrollmentAsync(request).get();
 }
Parameter
Name Description
request UpdateEnrollmentRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
OperationFuture<Enrollment,OperationMetadata>

updateEnrollmentCallable()

public final UnaryCallable<UpdateEnrollmentRequest,Operation> updateEnrollmentCallable()

Update a single Enrollment.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   UpdateEnrollmentRequest request =
       UpdateEnrollmentRequest.newBuilder()
           .setEnrollment(Enrollment.newBuilder().build())
           .setUpdateMask(FieldMask.newBuilder().build())
           .setAllowMissing(true)
           .setValidateOnly(true)
           .build();
   ApiFuture<Operation> future = eventarcClient.updateEnrollmentCallable().futureCall(request);
   // Do something.
   Operation response = future.get();
 }
Returns
Type Description
UnaryCallable<UpdateEnrollmentRequest,Operation>

updateEnrollmentOperationCallable()

public final OperationCallable<UpdateEnrollmentRequest,Enrollment,OperationMetadata> updateEnrollmentOperationCallable()

Update a single Enrollment.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   UpdateEnrollmentRequest request =
       UpdateEnrollmentRequest.newBuilder()
           .setEnrollment(Enrollment.newBuilder().build())
           .setUpdateMask(FieldMask.newBuilder().build())
           .setAllowMissing(true)
           .setValidateOnly(true)
           .build();
   OperationFuture<Enrollment, OperationMetadata> future =
       eventarcClient.updateEnrollmentOperationCallable().futureCall(request);
   // Do something.
   Enrollment response = future.get();
 }
Returns
Type Description
OperationCallable<UpdateEnrollmentRequest,Enrollment,OperationMetadata>

updateGoogleApiSourceAsync(GoogleApiSource googleApiSource, FieldMask updateMask)

public final OperationFuture<GoogleApiSource,OperationMetadata> updateGoogleApiSourceAsync(GoogleApiSource googleApiSource, FieldMask updateMask)

Update a single GoogleApiSource.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   GoogleApiSource googleApiSource = GoogleApiSource.newBuilder().build();
   FieldMask updateMask = FieldMask.newBuilder().build();
   GoogleApiSource response =
       eventarcClient.updateGoogleApiSourceAsync(googleApiSource, updateMask).get();
 }
Parameters
Name Description
googleApiSource GoogleApiSource

Required. The GoogleApiSource to be updated.
updateMask FieldMask

Optional. The fields to be updated; only fields explicitly provided are updated. If no field mask is provided, all provided fields in the request are updated. To update all fields, provide a field mask of "*".
Returns
Type Description
OperationFuture<GoogleApiSource,OperationMetadata>

updateGoogleApiSourceAsync(UpdateGoogleApiSourceRequest request)

public final OperationFuture<GoogleApiSource,OperationMetadata> updateGoogleApiSourceAsync(UpdateGoogleApiSourceRequest request)

Update a single GoogleApiSource.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   UpdateGoogleApiSourceRequest request =
       UpdateGoogleApiSourceRequest.newBuilder()
           .setGoogleApiSource(GoogleApiSource.newBuilder().build())
           .setUpdateMask(FieldMask.newBuilder().build())
           .setAllowMissing(true)
           .setValidateOnly(true)
           .build();
   GoogleApiSource response = eventarcClient.updateGoogleApiSourceAsync(request).get();
 }
Parameter
Name Description
request UpdateGoogleApiSourceRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
OperationFuture<GoogleApiSource,OperationMetadata>

updateGoogleApiSourceCallable()

public final UnaryCallable<UpdateGoogleApiSourceRequest,Operation> updateGoogleApiSourceCallable()

Update a single GoogleApiSource.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   UpdateGoogleApiSourceRequest request =
       UpdateGoogleApiSourceRequest.newBuilder()
           .setGoogleApiSource(GoogleApiSource.newBuilder().build())
           .setUpdateMask(FieldMask.newBuilder().build())
           .setAllowMissing(true)
           .setValidateOnly(true)
           .build();
   ApiFuture<Operation> future =
       eventarcClient.updateGoogleApiSourceCallable().futureCall(request);
   // Do something.
   Operation response = future.get();
 }
Returns
Type Description
UnaryCallable<UpdateGoogleApiSourceRequest,Operation>

updateGoogleApiSourceOperationCallable()

public final OperationCallable<UpdateGoogleApiSourceRequest,GoogleApiSource,OperationMetadata> updateGoogleApiSourceOperationCallable()

Update a single GoogleApiSource.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   UpdateGoogleApiSourceRequest request =
       UpdateGoogleApiSourceRequest.newBuilder()
           .setGoogleApiSource(GoogleApiSource.newBuilder().build())
           .setUpdateMask(FieldMask.newBuilder().build())
           .setAllowMissing(true)
           .setValidateOnly(true)
           .build();
   OperationFuture<GoogleApiSource, OperationMetadata> future =
       eventarcClient.updateGoogleApiSourceOperationCallable().futureCall(request);
   // Do something.
   GoogleApiSource response = future.get();
 }
Returns
Type Description
OperationCallable<UpdateGoogleApiSourceRequest,GoogleApiSource,OperationMetadata>

updateGoogleChannelConfig(GoogleChannelConfig googleChannelConfig, FieldMask updateMask)

public final GoogleChannelConfig updateGoogleChannelConfig(GoogleChannelConfig googleChannelConfig, FieldMask updateMask)

Update a single GoogleChannelConfig

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   GoogleChannelConfig googleChannelConfig = GoogleChannelConfig.newBuilder().build();
   FieldMask updateMask = FieldMask.newBuilder().build();
   GoogleChannelConfig response =
       eventarcClient.updateGoogleChannelConfig(googleChannelConfig, updateMask);
 }
Parameters
Name Description
googleChannelConfig GoogleChannelConfig

Required. The config to be updated.
updateMask FieldMask

The fields to be updated; only fields explicitly provided are updated. If no field mask is provided, all provided fields in the request are updated. To update all fields, provide a field mask of "*".
Returns
Type Description
GoogleChannelConfig

updateGoogleChannelConfig(UpdateGoogleChannelConfigRequest request)

public final GoogleChannelConfig updateGoogleChannelConfig(UpdateGoogleChannelConfigRequest request)

Update a single GoogleChannelConfig

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   UpdateGoogleChannelConfigRequest request =
       UpdateGoogleChannelConfigRequest.newBuilder()
           .setGoogleChannelConfig(GoogleChannelConfig.newBuilder().build())
           .setUpdateMask(FieldMask.newBuilder().build())
           .build();
   GoogleChannelConfig response = eventarcClient.updateGoogleChannelConfig(request);
 }
Parameter
Name Description
request UpdateGoogleChannelConfigRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
GoogleChannelConfig

updateGoogleChannelConfigCallable()

public final UnaryCallable<UpdateGoogleChannelConfigRequest,GoogleChannelConfig> updateGoogleChannelConfigCallable()

Update a single GoogleChannelConfig

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   UpdateGoogleChannelConfigRequest request =
       UpdateGoogleChannelConfigRequest.newBuilder()
           .setGoogleChannelConfig(GoogleChannelConfig.newBuilder().build())
           .setUpdateMask(FieldMask.newBuilder().build())
           .build();
   ApiFuture<GoogleChannelConfig> future =
       eventarcClient.updateGoogleChannelConfigCallable().futureCall(request);
   // Do something.
   GoogleChannelConfig response = future.get();
 }
Returns
Type Description
UnaryCallable<UpdateGoogleChannelConfigRequest,GoogleChannelConfig>

updateMessageBusAsync(MessageBus messageBus, FieldMask updateMask)

public final OperationFuture<MessageBus,OperationMetadata> updateMessageBusAsync(MessageBus messageBus, FieldMask updateMask)

Update a single message bus.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   MessageBus messageBus = MessageBus.newBuilder().build();
   FieldMask updateMask = FieldMask.newBuilder().build();
   MessageBus response = eventarcClient.updateMessageBusAsync(messageBus, updateMask).get();
 }
Parameters
Name Description
messageBus MessageBus

Required. The MessageBus to be updated.
updateMask FieldMask

Optional. The fields to be updated; only fields explicitly provided are updated. If no field mask is provided, all provided fields in the request are updated. To update all fields, provide a field mask of "*".
Returns
Type Description
OperationFuture<MessageBus,OperationMetadata>

updateMessageBusAsync(UpdateMessageBusRequest request)

public final OperationFuture<MessageBus,OperationMetadata> updateMessageBusAsync(UpdateMessageBusRequest request)

Update a single message bus.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   UpdateMessageBusRequest request =
       UpdateMessageBusRequest.newBuilder()
           .setMessageBus(MessageBus.newBuilder().build())
           .setUpdateMask(FieldMask.newBuilder().build())
           .setAllowMissing(true)
           .setValidateOnly(true)
           .build();
   MessageBus response = eventarcClient.updateMessageBusAsync(request).get();
 }
Parameter
Name Description
request UpdateMessageBusRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
OperationFuture<MessageBus,OperationMetadata>

updateMessageBusCallable()

public final UnaryCallable<UpdateMessageBusRequest,Operation> updateMessageBusCallable()

Update a single message bus.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   UpdateMessageBusRequest request =
       UpdateMessageBusRequest.newBuilder()
           .setMessageBus(MessageBus.newBuilder().build())
           .setUpdateMask(FieldMask.newBuilder().build())
           .setAllowMissing(true)
           .setValidateOnly(true)
           .build();
   ApiFuture<Operation> future = eventarcClient.updateMessageBusCallable().futureCall(request);
   // Do something.
   Operation response = future.get();
 }
Returns
Type Description
UnaryCallable<UpdateMessageBusRequest,Operation>

updateMessageBusOperationCallable()

public final OperationCallable<UpdateMessageBusRequest,MessageBus,OperationMetadata> updateMessageBusOperationCallable()

Update a single message bus.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   UpdateMessageBusRequest request =
       UpdateMessageBusRequest.newBuilder()
           .setMessageBus(MessageBus.newBuilder().build())
           .setUpdateMask(FieldMask.newBuilder().build())
           .setAllowMissing(true)
           .setValidateOnly(true)
           .build();
   OperationFuture<MessageBus, OperationMetadata> future =
       eventarcClient.updateMessageBusOperationCallable().futureCall(request);
   // Do something.
   MessageBus response = future.get();
 }
Returns
Type Description
OperationCallable<UpdateMessageBusRequest,MessageBus,OperationMetadata>

updatePipelineAsync(Pipeline pipeline, FieldMask updateMask)

public final OperationFuture<Pipeline,OperationMetadata> updatePipelineAsync(Pipeline pipeline, FieldMask updateMask)

Update a single pipeline.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   Pipeline pipeline = Pipeline.newBuilder().build();
   FieldMask updateMask = FieldMask.newBuilder().build();
   Pipeline response = eventarcClient.updatePipelineAsync(pipeline, updateMask).get();
 }
Parameters
Name Description
pipeline Pipeline

Required. The Pipeline to be updated.
updateMask FieldMask

Optional. The fields to be updated; only fields explicitly provided are updated. If no field mask is provided, all provided fields in the request are updated. To update all fields, provide a field mask of "*".
Returns
Type Description
OperationFuture<Pipeline,OperationMetadata>

updatePipelineAsync(UpdatePipelineRequest request)

public final OperationFuture<Pipeline,OperationMetadata> updatePipelineAsync(UpdatePipelineRequest request)

Update a single pipeline.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   UpdatePipelineRequest request =
       UpdatePipelineRequest.newBuilder()
           .setPipeline(Pipeline.newBuilder().build())
           .setUpdateMask(FieldMask.newBuilder().build())
           .setAllowMissing(true)
           .setValidateOnly(true)
           .build();
   Pipeline response = eventarcClient.updatePipelineAsync(request).get();
 }
Parameter
Name Description
request UpdatePipelineRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
OperationFuture<Pipeline,OperationMetadata>

updatePipelineCallable()

public final UnaryCallable<UpdatePipelineRequest,Operation> updatePipelineCallable()

Update a single pipeline.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   UpdatePipelineRequest request =
       UpdatePipelineRequest.newBuilder()
           .setPipeline(Pipeline.newBuilder().build())
           .setUpdateMask(FieldMask.newBuilder().build())
           .setAllowMissing(true)
           .setValidateOnly(true)
           .build();
   ApiFuture<Operation> future = eventarcClient.updatePipelineCallable().futureCall(request);
   // Do something.
   Operation response = future.get();
 }
Returns
Type Description
UnaryCallable<UpdatePipelineRequest,Operation>

updatePipelineOperationCallable()

public final OperationCallable<UpdatePipelineRequest,Pipeline,OperationMetadata> updatePipelineOperationCallable()

Update a single pipeline.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   UpdatePipelineRequest request =
       UpdatePipelineRequest.newBuilder()
           .setPipeline(Pipeline.newBuilder().build())
           .setUpdateMask(FieldMask.newBuilder().build())
           .setAllowMissing(true)
           .setValidateOnly(true)
           .build();
   OperationFuture<Pipeline, OperationMetadata> future =
       eventarcClient.updatePipelineOperationCallable().futureCall(request);
   // Do something.
   Pipeline response = future.get();
 }
Returns
Type Description
OperationCallable<UpdatePipelineRequest,Pipeline,OperationMetadata>

updateTriggerAsync(Trigger trigger, FieldMask updateMask, boolean allowMissing)

public final OperationFuture<Trigger,OperationMetadata> updateTriggerAsync(Trigger trigger, FieldMask updateMask, boolean allowMissing)

Update a single trigger.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   Trigger trigger = Trigger.newBuilder().build();
   FieldMask updateMask = FieldMask.newBuilder().build();
   boolean allowMissing = true;
   Trigger response = eventarcClient.updateTriggerAsync(trigger, updateMask, allowMissing).get();
 }
Parameters
Name Description
trigger Trigger

The trigger to be updated.
updateMask FieldMask

The fields to be updated; only fields explicitly provided are updated. If no field mask is provided, all provided fields in the request are updated. To update all fields, provide a field mask of "*".
allowMissing boolean

If set to true, and the trigger is not found, a new trigger will be created. In this situation, update_mask is ignored.
Returns
Type Description
OperationFuture<Trigger,OperationMetadata>

updateTriggerAsync(UpdateTriggerRequest request)

public final OperationFuture<Trigger,OperationMetadata> updateTriggerAsync(UpdateTriggerRequest request)

Update a single trigger.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   UpdateTriggerRequest request =
       UpdateTriggerRequest.newBuilder()
           .setTrigger(Trigger.newBuilder().build())
           .setUpdateMask(FieldMask.newBuilder().build())
           .setAllowMissing(true)
           .setValidateOnly(true)
           .build();
   Trigger response = eventarcClient.updateTriggerAsync(request).get();
 }
Parameter
Name Description
request UpdateTriggerRequest

The request object containing all of the parameters for the API call.
Returns
Type Description
OperationFuture<Trigger,OperationMetadata>

updateTriggerCallable()

public final UnaryCallable<UpdateTriggerRequest,Operation> updateTriggerCallable()

Update a single trigger.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   UpdateTriggerRequest request =
       UpdateTriggerRequest.newBuilder()
           .setTrigger(Trigger.newBuilder().build())
           .setUpdateMask(FieldMask.newBuilder().build())
           .setAllowMissing(true)
           .setValidateOnly(true)
           .build();
   ApiFuture<Operation> future = eventarcClient.updateTriggerCallable().futureCall(request);
   // Do something.
   Operation response = future.get();
 }
Returns
Type Description
UnaryCallable<UpdateTriggerRequest,Operation>

updateTriggerOperationCallable()

public final OperationCallable<UpdateTriggerRequest,Trigger,OperationMetadata> updateTriggerOperationCallable()

Update a single trigger.

Sample code:


 // 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://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (EventarcClient eventarcClient = EventarcClient.create()) {
   UpdateTriggerRequest request =
       UpdateTriggerRequest.newBuilder()
           .setTrigger(Trigger.newBuilder().build())
           .setUpdateMask(FieldMask.newBuilder().build())
           .setAllowMissing(true)
           .setValidateOnly(true)
           .build();
   OperationFuture<Trigger, OperationMetadata> future =
       eventarcClient.updateTriggerOperationCallable().futureCall(request);
   // Do something.
   Trigger response = future.get();
 }
Returns
Type Description
OperationCallable<UpdateTriggerRequest,Trigger,OperationMetadata>