var (
	Channel_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "PENDING",
		2: "ACTIVE",
		3: "INACTIVE",
	}
	Channel_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"PENDING":           1,
		"ACTIVE":            2,
		"INACTIVE":          3,
	}
)

var (
	LoggingConfig_LogSeverity_name = map[int32]string{
		0: "LOG_SEVERITY_UNSPECIFIED",
		1: "NONE",
		2: "DEBUG",
		3: "INFO",
		4: "NOTICE",
		5: "WARNING",
		6: "ERROR",
		7: "CRITICAL",
		8: "ALERT",
		9: "EMERGENCY",
	}
	LoggingConfig_LogSeverity_value = map[string]int32{
		"LOG_SEVERITY_UNSPECIFIED": 0,
		"NONE":                     1,
		"DEBUG":                    2,
		"INFO":                     3,
		"NOTICE":                   4,
		"WARNING":                  5,
		"ERROR":                    6,
		"CRITICAL":                 7,
		"ALERT":                    8,
		"EMERGENCY":                9,
	}
)

var File_google_cloud_eventarc_v1_channel_connection_proto protoreflect.FileDescriptor

var File_google_cloud_eventarc_v1_channel_proto protoreflect.FileDescriptor

var File_google_cloud_eventarc_v1_discovery_proto protoreflect.FileDescriptor

var File_google_cloud_eventarc_v1_enrollment_proto protoreflect.FileDescriptor

var File_google_cloud_eventarc_v1_eventarc_proto protoreflect.FileDescriptor

var File_google_cloud_eventarc_v1_google_api_source_proto protoreflect.FileDescriptor

var File_google_cloud_eventarc_v1_google_channel_config_proto protoreflect.FileDescriptor

var File_google_cloud_eventarc_v1_logging_config_proto protoreflect.FileDescriptor

var File_google_cloud_eventarc_v1_message_bus_proto protoreflect.FileDescriptor

var File_google_cloud_eventarc_v1_network_config_proto protoreflect.FileDescriptor

var File_google_cloud_eventarc_v1_pipeline_proto protoreflect.FileDescriptor

var File_google_cloud_eventarc_v1_trigger_proto protoreflect.FileDescriptor

type Channel struct {

	// Required. The resource name of the channel. Must be unique within the
	// location on the project and must be in
	// `projects/{project}/locations/{location}/channels/{channel_id}` format.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Output only. Server assigned unique identifier for the channel. The value
	// is a UUID4 string and guaranteed to remain unchanged until the resource is
	// deleted.
	Uid string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
	// Output only. The creation time.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The last-modified time.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// The name of the event provider (e.g. Eventarc SaaS partner) associated
	// with the channel. This provider will be granted permissions to publish
	// events to the channel. Format:
	// `projects/{project}/locations/{location}/providers/{provider_id}`.
	Provider string `protobuf:"bytes,7,opt,name=provider,proto3" json:"provider,omitempty"`
	// Types that are assignable to Transport:
	//
	//	*Channel_PubsubTopic
	Transport isChannel_Transport `protobuf_oneof:"transport"`
	// Output only. The state of a Channel.
	State Channel_State `protobuf:"varint,9,opt,name=state,proto3,enum=google.cloud.eventarc.v1.Channel_State" json:"state,omitempty"`
	// Output only. The activation token for the channel. The token must be used
	// by the provider to register the channel for publishing.
	ActivationToken string `protobuf:"bytes,10,opt,name=activation_token,json=activationToken,proto3" json:"activation_token,omitempty"`
	// Resource name of a KMS crypto key (managed by the user) used to
	// encrypt/decrypt their event data.
	//
	// It must match the pattern
	// `projects/*/locations/*/keyRings/*/cryptoKeys/*`.
	CryptoKeyName string `protobuf:"bytes,11,opt,name=crypto_key_name,json=cryptoKeyName,proto3" json:"crypto_key_name,omitempty"`
	// Output only. Whether or not this Channel satisfies the requirements of
	// physical zone separation
	SatisfiesPzs bool `protobuf:"varint,12,opt,name=satisfies_pzs,json=satisfiesPzs,proto3" json:"satisfies_pzs,omitempty"`
	// contains filtered or unexported fields
}

type ChannelConnection struct {

	// Required. The name of the connection.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Output only. Server assigned ID of the resource.
	// The server guarantees uniqueness and immutability until deleted.
	Uid string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
	// Required. The name of the connected subscriber Channel.
	// This is a weak reference to avoid cross project and cross accounts
	// references. This must be in
	// `projects/{project}/location/{location}/channels/{channel_id}` format.
	Channel string `protobuf:"bytes,5,opt,name=channel,proto3" json:"channel,omitempty"`
	// Output only. The creation time.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The last-modified time.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Input only. Activation token for the channel. The token will be used
	// during the creation of ChannelConnection to bind the channel with the
	// provider project. This field will not be stored in the provider resource.
	ActivationToken string `protobuf:"bytes,8,opt,name=activation_token,json=activationToken,proto3" json:"activation_token,omitempty"`
	// contains filtered or unexported fields
}

type Channel_PubsubTopic struct {
	// Output only. The name of the Pub/Sub topic created and managed by
	// Eventarc system as a transport for the event delivery. Format:
	// `projects/{project}/topics/{topic_id}`.
	PubsubTopic string `protobuf:"bytes,8,opt,name=pubsub_topic,json=pubsubTopic,proto3,oneof"`
}

type Channel_State int32

const (
	// Default value. This value is unused.
	Channel_STATE_UNSPECIFIED Channel_State = 0
	// The PENDING state indicates that a Channel has been created successfully
	// and there is a new activation token available for the subscriber to use
	// to convey the Channel to the provider in order to create a Connection.
	Channel_PENDING Channel_State = 1
	// The ACTIVE state indicates that a Channel has been successfully
	// connected with the event provider.
	// An ACTIVE Channel is ready to receive and route events from the
	// event provider.
	Channel_ACTIVE Channel_State = 2
	// The INACTIVE state indicates that the Channel cannot receive events
	// permanently. There are two possible cases this state can happen:
	//
	//  1. The SaaS provider disconnected from this Channel.
	//  2. The Channel activation token has expired but the SaaS provider
	//     wasn't connected.
	//
	// To re-establish a Connection with a provider, the subscriber
	// should create a new Channel and give it to the provider.
	Channel_INACTIVE Channel_State = 3
)

type CloudRun struct {

	// Required. The name of the Cloud Run service being addressed. See
	// https://cloud.google.com/run/docs/reference/rest/v1/namespaces.services.
	//
	// Only services located in the same project as the trigger object
	// can be addressed.
	Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	// Optional. The relative path on the Cloud Run service the events should be
	// sent to.
	//
	// The value must conform to the definition of a URI path segment (section 3.3
	// of RFC2396). Examples: "/route", "route", "route/subroute".
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// Required. The region the Cloud Run service is deployed in.
	Region string `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"`
	// contains filtered or unexported fields
}

type CreateChannelConnectionRequest struct {

	// Required. The parent collection in which to add this channel connection.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. Channel connection to create.
	ChannelConnection *ChannelConnection `protobuf:"bytes,2,opt,name=channel_connection,json=channelConnection,proto3" json:"channel_connection,omitempty"`
	// Required. The user-provided ID to be assigned to the channel connection.
	ChannelConnectionId string `protobuf:"bytes,3,opt,name=channel_connection_id,json=channelConnectionId,proto3" json:"channel_connection_id,omitempty"`
	// contains filtered or unexported fields
}

type CreateChannelRequest struct {

	// Required. The parent collection in which to add this channel.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. The channel to create.
	Channel *Channel `protobuf:"bytes,2,opt,name=channel,proto3" json:"channel,omitempty"`
	// Required. The user-provided ID to be assigned to the channel.
	ChannelId string `protobuf:"bytes,3,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
	// Optional. If set, validate the request and preview the review, but do not
	// post it.
	ValidateOnly bool `protobuf:"varint,4,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// contains filtered or unexported fields
}

type CreateEnrollmentRequest struct {

	// Required. The parent collection in which to add this enrollment.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. The enrollment to create.
	Enrollment *Enrollment `protobuf:"bytes,2,opt,name=enrollment,proto3" json:"enrollment,omitempty"`
	// Required. The user-provided ID to be assigned to the Enrollment. It should
	// match the format (^[a-z]([a-z0-9-]{0,61}[a-z0-9])?$).
	EnrollmentId string `protobuf:"bytes,3,opt,name=enrollment_id,json=enrollmentId,proto3" json:"enrollment_id,omitempty"`
	// Optional. If set, validate the request and preview the review, but do not
	// post it.
	ValidateOnly bool `protobuf:"varint,4,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// contains filtered or unexported fields
}

type CreateGoogleApiSourceRequest struct {

	// Required. The parent collection in which to add this google api source.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. The google api source to create.
	GoogleApiSource *GoogleApiSource `protobuf:"bytes,2,opt,name=google_api_source,json=googleApiSource,proto3" json:"google_api_source,omitempty"`
	// Required. The user-provided ID to be assigned to the GoogleApiSource. It
	// should match the format (^[a-z]([a-z0-9-]{0,61}[a-z0-9])?$).
	GoogleApiSourceId string `protobuf:"bytes,3,opt,name=google_api_source_id,json=googleApiSourceId,proto3" json:"google_api_source_id,omitempty"`
	// Optional. If set, validate the request and preview the review, but do not
	// post it.
	ValidateOnly bool `protobuf:"varint,4,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// contains filtered or unexported fields
}

type CreateMessageBusRequest struct {

	// Required. The parent collection in which to add this message bus.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. The message bus to create.
	MessageBus *MessageBus `protobuf:"bytes,2,opt,name=message_bus,json=messageBus,proto3" json:"message_bus,omitempty"`
	// Required. The user-provided ID to be assigned to the MessageBus. It should
	// match the format (^[a-z]([a-z0-9-]{0,61}[a-z0-9])?$)
	MessageBusId string `protobuf:"bytes,3,opt,name=message_bus_id,json=messageBusId,proto3" json:"message_bus_id,omitempty"`
	// Optional. If set, validate the request and preview the review, but do not
	// post it.
	ValidateOnly bool `protobuf:"varint,4,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// contains filtered or unexported fields
}

type CreatePipelineRequest struct {

	// Required. The parent collection in which to add this pipeline.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. The pipeline to create.
	Pipeline *Pipeline `protobuf:"bytes,2,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// Required. The user-provided ID to be assigned to the Pipeline.
	PipelineId string `protobuf:"bytes,3,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	// Optional. If set, validate the request and preview the review, but do not
	// post it.
	ValidateOnly bool `protobuf:"varint,4,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// contains filtered or unexported fields
}

type CreateTriggerRequest struct {

	// Required. The parent collection in which to add this trigger.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. The trigger to create.
	Trigger *Trigger `protobuf:"bytes,2,opt,name=trigger,proto3" json:"trigger,omitempty"`
	// Required. The user-provided ID to be assigned to the trigger.
	TriggerId string `protobuf:"bytes,3,opt,name=trigger_id,json=triggerId,proto3" json:"trigger_id,omitempty"`
	// Optional. If set, validate the request and preview the review, but do not
	// post it.
	ValidateOnly bool `protobuf:"varint,4,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// contains filtered or unexported fields
}

type DeleteChannelConnectionRequest struct {

	// Required. The name of the channel connection to delete.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type DeleteChannelRequest struct {

	// Required. The name of the channel to be deleted.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional. If set, validate the request and preview the review, but do not
	// post it.
	ValidateOnly bool `protobuf:"varint,2,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// contains filtered or unexported fields
}

type DeleteEnrollmentRequest struct {

	// Required. The name of the Enrollment to be deleted.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional. If provided, the Enrollment will only be deleted if the etag
	// matches the current etag on the resource.
	Etag string `protobuf:"bytes,2,opt,name=etag,proto3" json:"etag,omitempty"`
	// Optional. If set to true, and the Enrollment is not found, the request will
	// succeed but no action will be taken on the server.
	AllowMissing bool `protobuf:"varint,3,opt,name=allow_missing,json=allowMissing,proto3" json:"allow_missing,omitempty"`
	// Optional. If set, validate the request and preview the review, but do not
	// post it.
	ValidateOnly bool `protobuf:"varint,4,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// contains filtered or unexported fields
}

type DeleteGoogleApiSourceRequest struct {

	// Required. The name of the GoogleApiSource to be deleted.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional. If provided, the MessageBus will only be deleted if the etag
	// matches the current etag on the resource.
	Etag string `protobuf:"bytes,2,opt,name=etag,proto3" json:"etag,omitempty"`
	// Optional. If set to true, and the MessageBus is not found, the request will
	// succeed but no action will be taken on the server.
	AllowMissing bool `protobuf:"varint,3,opt,name=allow_missing,json=allowMissing,proto3" json:"allow_missing,omitempty"`
	// Optional. If set, validate the request and preview the review, but do not
	// post it.
	ValidateOnly bool `protobuf:"varint,4,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// contains filtered or unexported fields
}

type DeleteMessageBusRequest struct {

	// Required. The name of the MessageBus to be deleted.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional. If provided, the MessageBus will only be deleted if the etag
	// matches the current etag on the resource.
	Etag string `protobuf:"bytes,2,opt,name=etag,proto3" json:"etag,omitempty"`
	// Optional. If set to true, and the MessageBus is not found, the request will
	// succeed but no action will be taken on the server.
	AllowMissing bool `protobuf:"varint,3,opt,name=allow_missing,json=allowMissing,proto3" json:"allow_missing,omitempty"`
	// Optional. If set, validate the request and preview the review, but do not
	// post it.
	ValidateOnly bool `protobuf:"varint,4,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// contains filtered or unexported fields
}

type DeletePipelineRequest struct {

	// Required. The name of the Pipeline to be deleted.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional. If provided, the Pipeline will only be deleted if the etag
	// matches the current etag on the resource.
	Etag string `protobuf:"bytes,2,opt,name=etag,proto3" json:"etag,omitempty"`
	// Optional. If set to true, and the Pipeline is not found, the request will
	// succeed but no action will be taken on the server.
	AllowMissing bool `protobuf:"varint,3,opt,name=allow_missing,json=allowMissing,proto3" json:"allow_missing,omitempty"`
	// Optional. If set, validate the request and preview the review, but do not
	// post it.
	ValidateOnly bool `protobuf:"varint,4,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// contains filtered or unexported fields
}

type DeleteTriggerRequest struct {

	// Required. The name of the trigger to be deleted.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// If provided, the trigger will only be deleted if the etag matches the
	// current etag on the resource.
	Etag string `protobuf:"bytes,2,opt,name=etag,proto3" json:"etag,omitempty"`
	// If set to true, and the trigger is not found, the request will succeed
	// but no action will be taken on the server.
	AllowMissing bool `protobuf:"varint,3,opt,name=allow_missing,json=allowMissing,proto3" json:"allow_missing,omitempty"`
	// Optional. If set, validate the request and preview the review, but do not
	// post it.
	ValidateOnly bool `protobuf:"varint,4,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// contains filtered or unexported fields
}

type Destination struct {

	// Types that are assignable to Descriptor_:
	//
	//	*Destination_CloudRun
	//	*Destination_CloudFunction
	//	*Destination_Gke
	//	*Destination_Workflow
	//	*Destination_HttpEndpoint
	Descriptor_ isDestination_Descriptor_ `protobuf_oneof:"descriptor"`
	// Optional. Network config is used to configure how Eventarc resolves and
	// connect to a destination.
	// This should only be used with HttpEndpoint destination type.
	NetworkConfig *NetworkConfig `protobuf:"bytes,6,opt,name=network_config,json=networkConfig,proto3" json:"network_config,omitempty"`
	// contains filtered or unexported fields
}

type Destination_CloudFunction struct {
	// The Cloud Function resource name. Cloud Functions V1 and V2 are
	// supported.
	// Format: `projects/{project}/locations/{location}/functions/{function}`
	//
	// This is a read-only field. Creating Cloud Functions V1/V2 triggers is
	// only supported via the Cloud Functions product. An error will be returned
	// if the user sets this value.
	CloudFunction string `protobuf:"bytes,2,opt,name=cloud_function,json=cloudFunction,proto3,oneof"`
}

type Destination_CloudRun struct {
	// Cloud Run fully-managed resource that receives the events. The resource
	// should be in the same project as the trigger.
	CloudRun *CloudRun `protobuf:"bytes,1,opt,name=cloud_run,json=cloudRun,proto3,oneof"`
}

type Destination_Gke struct {
	// A GKE service capable of receiving events. The service should be running
	// in the same project as the trigger.
	Gke *GKE `protobuf:"bytes,3,opt,name=gke,proto3,oneof"`
}

type Destination_HttpEndpoint struct {
	// An HTTP endpoint destination described by an URI.
	HttpEndpoint *HttpEndpoint `protobuf:"bytes,5,opt,name=http_endpoint,json=httpEndpoint,proto3,oneof"`
}

type Destination_Workflow struct {
	// The resource name of the Workflow whose Executions are triggered by
	// the events. The Workflow resource should be deployed in the same project
	// as the trigger.
	// Format: `projects/{project}/locations/{location}/workflows/{workflow}`
	Workflow string `protobuf:"bytes,4,opt,name=workflow,proto3,oneof"`
}

type Enrollment struct {

	// Identifier. Resource name of the form
	// projects/{project}/locations/{location}/enrollments/{enrollment}
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Output only. Server assigned unique identifier for the channel. The value
	// is a UUID4 string and guaranteed to remain unchanged until the resource is
	// deleted.
	Uid string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
	// Output only. This checksum is computed by the server based on the value of
	// other fields, and might be sent only on update and delete requests to
	// ensure that the client has an up-to-date value before proceeding.
	Etag string `protobuf:"bytes,3,opt,name=etag,proto3" json:"etag,omitempty"`
	// Output only. The creation time.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The last-modified time.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Optional. Resource labels.
	Labels map[string]string `protobuf:"bytes,6,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	// Optional. Resource annotations.
	Annotations map[string]string `protobuf:"bytes,7,rep,name=annotations,proto3" json:"annotations,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	// Optional. Resource display name.
	DisplayName string `protobuf:"bytes,8,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// Required. A CEL expression identifying which messages this enrollment
	// applies to.
	CelMatch string `protobuf:"bytes,9,opt,name=cel_match,json=celMatch,proto3" json:"cel_match,omitempty"`
	// Required. Resource name of the message bus identifying the source of the
	// messages. It matches the form
	// projects/{project}/locations/{location}/messageBuses/{messageBus}.
	MessageBus string `protobuf:"bytes,10,opt,name=message_bus,json=messageBus,proto3" json:"message_bus,omitempty"`
	// Required. Destination is the Pipeline that the Enrollment is delivering to.
	// It must point to the full resource name of a Pipeline. Format:
	// "projects/{PROJECT_ID}/locations/{region}/pipelines/{PIPELINE_ID)"
	Destination string `protobuf:"bytes,11,opt,name=destination,proto3" json:"destination,omitempty"`
	// contains filtered or unexported fields
}

type EventFilter struct {

	// Required. The name of a CloudEvents attribute. Currently, only a subset of
	// attributes are supported for filtering. You can [retrieve a specific
	// provider's supported event
	// types](/eventarc/docs/list-providers#describe-provider).
	//
	// All triggers MUST provide a filter for the 'type' attribute.
	Attribute string `protobuf:"bytes,1,opt,name=attribute,proto3" json:"attribute,omitempty"`
	// Required. The value for the attribute.
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// Optional. The operator used for matching the events with the value of the
	// filter. If not specified, only events that have an exact key-value pair
	// specified in the filter are matched. The allowed values are `path_pattern`
	// and `match-path-pattern`. `path_pattern` is only allowed for GCFv1
	// triggers.
	Operator string `protobuf:"bytes,3,opt,name=operator,proto3" json:"operator,omitempty"`
	// contains filtered or unexported fields
}

type EventType struct {

	// Output only. The full name of the event type (for example,
	// "google.cloud.storage.object.v1.finalized"). In the form of
	// {provider-specific-prefix}.{resource}.{version}.{verb}. Types MUST be
	// versioned and event schemas are guaranteed to remain backward compatible
	// within one version. Note that event type versions and API versions do not
	// need to match.
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// Output only. Human friendly description of what the event type is about.
	// For example "Bucket created in Cloud Storage".
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// Output only. Filtering attributes for the event type.
	FilteringAttributes []*FilteringAttribute `protobuf:"bytes,3,rep,name=filtering_attributes,json=filteringAttributes,proto3" json:"filtering_attributes,omitempty"`
	// Output only. URI for the event schema.
	// For example
	// "https://github.com/googleapis/google-cloudevents/blob/master/proto/google/events/cloud/storage/v1/events.proto"
	EventSchemaUri string `protobuf:"bytes,4,opt,name=event_schema_uri,json=eventSchemaUri,proto3" json:"event_schema_uri,omitempty"`
	// contains filtered or unexported fields
}

type EventarcClient interface {
	// Get a single trigger.
	GetTrigger(ctx context.Context, in *GetTriggerRequest, opts ...grpc.CallOption) (*Trigger, error)
	// List triggers.
	ListTriggers(ctx context.Context, in *ListTriggersRequest, opts ...grpc.CallOption) (*ListTriggersResponse, error)
	// Create a new trigger in a particular project and location.
	CreateTrigger(ctx context.Context, in *CreateTriggerRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Update a single trigger.
	UpdateTrigger(ctx context.Context, in *UpdateTriggerRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Delete a single trigger.
	DeleteTrigger(ctx context.Context, in *DeleteTriggerRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Get a single Channel.
	GetChannel(ctx context.Context, in *GetChannelRequest, opts ...grpc.CallOption) (*Channel, error)
	// List channels.
	ListChannels(ctx context.Context, in *ListChannelsRequest, opts ...grpc.CallOption) (*ListChannelsResponse, error)
	// Create a new channel in a particular project and location.
	CreateChannel(ctx context.Context, in *CreateChannelRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Update a single channel.
	UpdateChannel(ctx context.Context, in *UpdateChannelRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Delete a single channel.
	DeleteChannel(ctx context.Context, in *DeleteChannelRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Get a single Provider.
	GetProvider(ctx context.Context, in *GetProviderRequest, opts ...grpc.CallOption) (*Provider, error)
	// List providers.
	ListProviders(ctx context.Context, in *ListProvidersRequest, opts ...grpc.CallOption) (*ListProvidersResponse, error)
	// Get a single ChannelConnection.
	GetChannelConnection(ctx context.Context, in *GetChannelConnectionRequest, opts ...grpc.CallOption) (*ChannelConnection, error)
	// List channel connections.
	ListChannelConnections(ctx context.Context, in *ListChannelConnectionsRequest, opts ...grpc.CallOption) (*ListChannelConnectionsResponse, error)
	// Create a new ChannelConnection in a particular project and location.
	CreateChannelConnection(ctx context.Context, in *CreateChannelConnectionRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Delete a single ChannelConnection.
	DeleteChannelConnection(ctx context.Context, in *DeleteChannelConnectionRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Get a GoogleChannelConfig
	GetGoogleChannelConfig(ctx context.Context, in *GetGoogleChannelConfigRequest, opts ...grpc.CallOption) (*GoogleChannelConfig, error)
	// Update a single GoogleChannelConfig
	UpdateGoogleChannelConfig(ctx context.Context, in *UpdateGoogleChannelConfigRequest, opts ...grpc.CallOption) (*GoogleChannelConfig, error)
	// Get a single MessageBus.
	GetMessageBus(ctx context.Context, in *GetMessageBusRequest, opts ...grpc.CallOption) (*MessageBus, error)
	// List message buses.
	ListMessageBuses(ctx context.Context, in *ListMessageBusesRequest, opts ...grpc.CallOption) (*ListMessageBusesResponse, error)
	// List message bus enrollments.
	ListMessageBusEnrollments(ctx context.Context, in *ListMessageBusEnrollmentsRequest, opts ...grpc.CallOption) (*ListMessageBusEnrollmentsResponse, error)
	// Create a new MessageBus in a particular project and location.
	CreateMessageBus(ctx context.Context, in *CreateMessageBusRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Update a single message bus.
	UpdateMessageBus(ctx context.Context, in *UpdateMessageBusRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Delete a single message bus.
	DeleteMessageBus(ctx context.Context, in *DeleteMessageBusRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Get a single Enrollment.
	GetEnrollment(ctx context.Context, in *GetEnrollmentRequest, opts ...grpc.CallOption) (*Enrollment, error)
	// List Enrollments.
	ListEnrollments(ctx context.Context, in *ListEnrollmentsRequest, opts ...grpc.CallOption) (*ListEnrollmentsResponse, error)
	// Create a new Enrollment in a particular project and location.
	CreateEnrollment(ctx context.Context, in *CreateEnrollmentRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Update a single Enrollment.
	UpdateEnrollment(ctx context.Context, in *UpdateEnrollmentRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Delete a single Enrollment.
	DeleteEnrollment(ctx context.Context, in *DeleteEnrollmentRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Get a single Pipeline.
	GetPipeline(ctx context.Context, in *GetPipelineRequest, opts ...grpc.CallOption) (*Pipeline, error)
	// List pipelines.
	ListPipelines(ctx context.Context, in *ListPipelinesRequest, opts ...grpc.CallOption) (*ListPipelinesResponse, error)
	// Create a new Pipeline in a particular project and location.
	CreatePipeline(ctx context.Context, in *CreatePipelineRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Update a single pipeline.
	UpdatePipeline(ctx context.Context, in *UpdatePipelineRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Delete a single pipeline.
	DeletePipeline(ctx context.Context, in *DeletePipelineRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Get a single GoogleApiSource.
	GetGoogleApiSource(ctx context.Context, in *GetGoogleApiSourceRequest, opts ...grpc.CallOption) (*GoogleApiSource, error)
	// List GoogleApiSources.
	ListGoogleApiSources(ctx context.Context, in *ListGoogleApiSourcesRequest, opts ...grpc.CallOption) (*ListGoogleApiSourcesResponse, error)
	// Create a new GoogleApiSource in a particular project and location.
	CreateGoogleApiSource(ctx context.Context, in *CreateGoogleApiSourceRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Update a single GoogleApiSource.
	UpdateGoogleApiSource(ctx context.Context, in *UpdateGoogleApiSourceRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Delete a single GoogleApiSource.
	DeleteGoogleApiSource(ctx context.Context, in *DeleteGoogleApiSourceRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
}

type EventarcServer interface {
	// Get a single trigger.
	GetTrigger(context.Context, *GetTriggerRequest) (*Trigger, error)
	// List triggers.
	ListTriggers(context.Context, *ListTriggersRequest) (*ListTriggersResponse, error)
	// Create a new trigger in a particular project and location.
	CreateTrigger(context.Context, *CreateTriggerRequest) (*longrunningpb.Operation, error)
	// Update a single trigger.
	UpdateTrigger(context.Context, *UpdateTriggerRequest) (*longrunningpb.Operation, error)
	// Delete a single trigger.
	DeleteTrigger(context.Context, *DeleteTriggerRequest) (*longrunningpb.Operation, error)
	// Get a single Channel.
	GetChannel(context.Context, *GetChannelRequest) (*Channel, error)
	// List channels.
	ListChannels(context.Context, *ListChannelsRequest) (*ListChannelsResponse, error)
	// Create a new channel in a particular project and location.
	CreateChannel(context.Context, *CreateChannelRequest) (*longrunningpb.Operation, error)
	// Update a single channel.
	UpdateChannel(context.Context, *UpdateChannelRequest) (*longrunningpb.Operation, error)
	// Delete a single channel.
	DeleteChannel(context.Context, *DeleteChannelRequest) (*longrunningpb.Operation, error)
	// Get a single Provider.
	GetProvider(context.Context, *GetProviderRequest) (*Provider, error)
	// List providers.
	ListProviders(context.Context, *ListProvidersRequest) (*ListProvidersResponse, error)
	// Get a single ChannelConnection.
	GetChannelConnection(context.Context, *GetChannelConnectionRequest) (*ChannelConnection, error)
	// List channel connections.
	ListChannelConnections(context.Context, *ListChannelConnectionsRequest) (*ListChannelConnectionsResponse, error)
	// Create a new ChannelConnection in a particular project and location.
	CreateChannelConnection(context.Context, *CreateChannelConnectionRequest) (*longrunningpb.Operation, error)
	// Delete a single ChannelConnection.
	DeleteChannelConnection(context.Context, *DeleteChannelConnectionRequest) (*longrunningpb.Operation, error)
	// Get a GoogleChannelConfig
	GetGoogleChannelConfig(context.Context, *GetGoogleChannelConfigRequest) (*GoogleChannelConfig, error)
	// Update a single GoogleChannelConfig
	UpdateGoogleChannelConfig(context.Context, *UpdateGoogleChannelConfigRequest) (*GoogleChannelConfig, error)
	// Get a single MessageBus.
	GetMessageBus(context.Context, *GetMessageBusRequest) (*MessageBus, error)
	// List message buses.
	ListMessageBuses(context.Context, *ListMessageBusesRequest) (*ListMessageBusesResponse, error)
	// List message bus enrollments.
	ListMessageBusEnrollments(context.Context, *ListMessageBusEnrollmentsRequest) (*ListMessageBusEnrollmentsResponse, error)
	// Create a new MessageBus in a particular project and location.
	CreateMessageBus(context.Context, *CreateMessageBusRequest) (*longrunningpb.Operation, error)
	// Update a single message bus.
	UpdateMessageBus(context.Context, *UpdateMessageBusRequest) (*longrunningpb.Operation, error)
	// Delete a single message bus.
	DeleteMessageBus(context.Context, *DeleteMessageBusRequest) (*longrunningpb.Operation, error)
	// Get a single Enrollment.
	GetEnrollment(context.Context, *GetEnrollmentRequest) (*Enrollment, error)
	// List Enrollments.
	ListEnrollments(context.Context, *ListEnrollmentsRequest) (*ListEnrollmentsResponse, error)
	// Create a new Enrollment in a particular project and location.
	CreateEnrollment(context.Context, *CreateEnrollmentRequest) (*longrunningpb.Operation, error)
	// Update a single Enrollment.
	UpdateEnrollment(context.Context, *UpdateEnrollmentRequest) (*longrunningpb.Operation, error)
	// Delete a single Enrollment.
	DeleteEnrollment(context.Context, *DeleteEnrollmentRequest) (*longrunningpb.Operation, error)
	// Get a single Pipeline.
	GetPipeline(context.Context, *GetPipelineRequest) (*Pipeline, error)
	// List pipelines.
	ListPipelines(context.Context, *ListPipelinesRequest) (*ListPipelinesResponse, error)
	// Create a new Pipeline in a particular project and location.
	CreatePipeline(context.Context, *CreatePipelineRequest) (*longrunningpb.Operation, error)
	// Update a single pipeline.
	UpdatePipeline(context.Context, *UpdatePipelineRequest) (*longrunningpb.Operation, error)
	// Delete a single pipeline.
	DeletePipeline(context.Context, *DeletePipelineRequest) (*longrunningpb.Operation, error)
	// Get a single GoogleApiSource.
	GetGoogleApiSource(context.Context, *GetGoogleApiSourceRequest) (*GoogleApiSource, error)
	// List GoogleApiSources.
	ListGoogleApiSources(context.Context, *ListGoogleApiSourcesRequest) (*ListGoogleApiSourcesResponse, error)
	// Create a new GoogleApiSource in a particular project and location.
	CreateGoogleApiSource(context.Context, *CreateGoogleApiSourceRequest) (*longrunningpb.Operation, error)
	// Update a single GoogleApiSource.
	UpdateGoogleApiSource(context.Context, *UpdateGoogleApiSourceRequest) (*longrunningpb.Operation, error)
	// Delete a single GoogleApiSource.
	DeleteGoogleApiSource(context.Context, *DeleteGoogleApiSourceRequest) (*longrunningpb.Operation, error)
}

type FilteringAttribute struct {

	// Output only. Attribute used for filtering the event type.
	Attribute string `protobuf:"bytes,1,opt,name=attribute,proto3" json:"attribute,omitempty"`
	// Output only. Description of the purpose of the attribute.
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// Output only. If true, the triggers for this provider should always specify
	// a filter on these attributes. Trigger creation will fail otherwise.
	Required bool `protobuf:"varint,3,opt,name=required,proto3" json:"required,omitempty"`
	// Output only. If true, the attribute accepts matching expressions in the
	// Eventarc PathPattern format.
	PathPatternSupported bool `protobuf:"varint,4,opt,name=path_pattern_supported,json=pathPatternSupported,proto3" json:"path_pattern_supported,omitempty"`
	// contains filtered or unexported fields
}

type GKE struct {

	// Required. The name of the cluster the GKE service is running in. The
	// cluster must be running in the same project as the trigger being created.
	Cluster string `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// Required. The name of the Google Compute Engine in which the cluster
	// resides, which can either be compute zone (for example, us-central1-a) for
	// the zonal clusters or region (for example, us-central1) for regional
	// clusters.
	Location string `protobuf:"bytes,2,opt,name=location,proto3" json:"location,omitempty"`
	// Required. The namespace the GKE service is running in.
	Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Required. Name of the GKE service.
	Service string `protobuf:"bytes,4,opt,name=service,proto3" json:"service,omitempty"`
	// Optional. The relative path on the GKE service the events should be sent
	// to.
	//
	// The value must conform to the definition of a URI path segment (section 3.3
	// of RFC2396). Examples: "/route", "route", "route/subroute".
	Path string `protobuf:"bytes,5,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

type GetChannelConnectionRequest struct {

	// Required. The name of the channel connection to get.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type GetChannelRequest struct {

	// Required. The name of the channel to get.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type GetEnrollmentRequest struct {

	// Required. The name of the Enrollment to get.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type GetGoogleApiSourceRequest struct {

	// Required. The name of the google api source to get.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type GetGoogleChannelConfigRequest struct {

	// Required. The name of the config to get.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type GetMessageBusRequest struct {

	// Required. The name of the message bus to get.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type GetPipelineRequest struct {

	// Required. The name of the pipeline to get.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type GetProviderRequest struct {

	// Required. The name of the provider to get.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type GetTriggerRequest struct {

	// Required. The name of the trigger to get.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type GoogleApiSource struct {

	// Identifier. Resource name of the form
	// projects/{project}/locations/{location}/googleApiSources/{google_api_source}
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Output only. Server assigned unique identifier for the channel. The value
	// is a UUID4 string and guaranteed to remain unchanged until the resource is
	// deleted.
	Uid string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
	// Output only. This checksum is computed by the server based on the value of
	// other fields, and might be sent only on update and delete requests to
	// ensure that the client has an up-to-date value before proceeding.
	Etag string `protobuf:"bytes,3,opt,name=etag,proto3" json:"etag,omitempty"`
	// Output only. The creation time.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The last-modified time.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Optional. Resource labels.
	Labels map[string]string `protobuf:"bytes,6,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	// Optional. Resource annotations.
	Annotations map[string]string `protobuf:"bytes,7,rep,name=annotations,proto3" json:"annotations,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	// Optional. Resource display name.
	DisplayName string `protobuf:"bytes,8,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// Required. Destination is the message bus that the GoogleApiSource is
	// delivering to. It must be point to the full resource name of a MessageBus.
	// Format:
	// "projects/{PROJECT_ID}/locations/{region}/messagesBuses/{MESSAGE_BUS_ID)
	Destination string `protobuf:"bytes,9,opt,name=destination,proto3" json:"destination,omitempty"`
	// Optional. Resource name of a KMS crypto key (managed by the user) used to
	// encrypt/decrypt their event data.
	//
	// It must match the pattern
	// `projects/*/locations/*/keyRings/*/cryptoKeys/*`.
	CryptoKeyName string `protobuf:"bytes,10,opt,name=crypto_key_name,json=cryptoKeyName,proto3" json:"crypto_key_name,omitempty"`
	// Optional. Config to control Platform logging for the GoogleApiSource.
	LoggingConfig *LoggingConfig `protobuf:"bytes,11,opt,name=logging_config,json=loggingConfig,proto3" json:"logging_config,omitempty"`
	// contains filtered or unexported fields
}

type GoogleChannelConfig struct {

	// Required. The resource name of the config. Must be in the format of,
	// `projects/{project}/locations/{location}/googleChannelConfig`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Output only. The last-modified time.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Optional. Resource name of a KMS crypto key (managed by the user) used to
	// encrypt/decrypt their event data.
	//
	// It must match the pattern
	// `projects/*/locations/*/keyRings/*/cryptoKeys/*`.
	CryptoKeyName string `protobuf:"bytes,7,opt,name=crypto_key_name,json=cryptoKeyName,proto3" json:"crypto_key_name,omitempty"`
	// contains filtered or unexported fields
}

type HttpEndpoint struct {

	// Required. The URI of the HTTP enpdoint.
	//
	// The value must be a RFC2396 URI string.
	// Examples: `http://10.10.10.8:80/route`,
	// `http://svc.us-central1.p.local:8080/`.
	// Only HTTP and HTTPS protocols are supported. The host can be either a
	// static IP addressable from the VPC specified by the network config, or
	// an internal DNS hostname of the service resolvable via Cloud DNS.
	Uri string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
	// contains filtered or unexported fields
}

type ListChannelConnectionsRequest struct {

	// Required. The parent collection from which to list channel connections.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// The maximum number of channel connections to return on each page.
	//
	// Note: The service may send fewer responses.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// The page token; provide the value from the `next_page_token` field in a
	// previous `ListChannelConnections` call to retrieve the subsequent page.
	//
	// When paginating, all other parameters provided to `ListChannelConnetions`
	// match the call that provided the page token.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

type ListChannelConnectionsResponse struct {

	// The requested channel connections, up to the number specified in
	// `page_size`.
	ChannelConnections []*ChannelConnection `protobuf:"bytes,1,rep,name=channel_connections,json=channelConnections,proto3" json:"channel_connections,omitempty"`
	// A page token that can be sent to `ListChannelConnections` to request the
	// next page.
	// If this is empty, then there are no more pages.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// Unreachable resources, if any.
	Unreachable []string `protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"`
	// contains filtered or unexported fields
}

type ListChannelsRequest struct {

	// Required. The parent collection to list channels on.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// The maximum number of channels to return on each page.
	//
	// Note: The service may send fewer.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// The page token; provide the value from the `next_page_token` field in a
	// previous `ListChannels` call to retrieve the subsequent page.
	//
	// When paginating, all other parameters provided to `ListChannels` must
	// match the call that provided the page token.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// The sorting order of the resources returned. Value should be a
	// comma-separated list of fields. The default sorting order is ascending. To
	// specify descending order for a field, append a `desc` suffix; for example:
	// `name desc, channel_id`.
	OrderBy string `protobuf:"bytes,4,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
	// contains filtered or unexported fields
}

type ListChannelsResponse struct {

	// The requested channels, up to the number specified in `page_size`.
	Channels []*Channel `protobuf:"bytes,1,rep,name=channels,proto3" json:"channels,omitempty"`
	// A page token that can be sent to `ListChannels` to request the next page.
	// If this is empty, then there are no more pages.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// Unreachable resources, if any.
	Unreachable []string `protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"`
	// contains filtered or unexported fields
}

type ListEnrollmentsRequest struct {

	// Required. The parent collection to list triggers on.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Optional. The maximum number of results to return on each page.
	//
	// Note: The service may send fewer.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Optional. The page token; provide the value from the `next_page_token`
	// field in a previous call to retrieve the subsequent page.
	//
	// When paginating, all other parameters provided must match
	// the previous call that provided the page token.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Optional. The sorting order of the resources returned. Value should be a
	// comma-separated list of fields. The default sorting order is ascending. To
	// specify descending order for a field, append a `desc` suffix; for example:
	// `name desc, update_time`.
	OrderBy string `protobuf:"bytes,4,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
	// Optional. The filter field that the list request will filter on.
	// Possible filtersare described in https://google.aip.dev/160.
	Filter string `protobuf:"bytes,5,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

type ListEnrollmentsResponse struct {

	// The requested Enrollments, up to the number specified in `page_size`.
	Enrollments []*Enrollment `protobuf:"bytes,1,rep,name=enrollments,proto3" json:"enrollments,omitempty"`
	// A page token that can be sent to `ListEnrollments` to request the next
	// page. If this is empty, then there are no more pages.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// Unreachable resources, if any.
	Unreachable []string `protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"`
	// contains filtered or unexported fields
}

type ListGoogleApiSourcesRequest struct {

	// Required. The parent collection to list GoogleApiSources on.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Optional. The maximum number of results to return on each page.
	//
	// Note: The service may send fewer.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Optional. The page token; provide the value from the `next_page_token`
	// field in a previous call to retrieve the subsequent page.
	//
	// When paginating, all other parameters provided must match
	// the previous call that provided the page token.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Optional. The sorting order of the resources returned. Value should be a
	// comma-separated list of fields. The default sorting order is ascending. To
	// specify descending order for a field, append a `desc` suffix; for example:
	// `name desc, update_time`.
	OrderBy string `protobuf:"bytes,4,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
	// Optional. The filter field that the list request will filter on.
	// Possible filtersare described in https://google.aip.dev/160.
	Filter string `protobuf:"bytes,5,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

type ListGoogleApiSourcesResponse struct {

	// The requested GoogleApiSources, up to the number specified in `page_size`.
	GoogleApiSources []*GoogleApiSource `protobuf:"bytes,1,rep,name=google_api_sources,json=googleApiSources,proto3" json:"google_api_sources,omitempty"`
	// A page token that can be sent to `ListMessageBusEnrollments` to request the
	// next page. If this is empty, then there are no more pages.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// Unreachable resources, if any.
	Unreachable []string `protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"`
	// contains filtered or unexported fields
}

type ListMessageBusEnrollmentsRequest struct {

	// Required. The parent message bus to list enrollments on.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Optional. The maximum number of results to return on each page.
	//
	// Note: The service may send fewer.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Optional. The page token; provide the value from the `next_page_token`
	// field in a previous call to retrieve the subsequent page.
	//
	// When paginating, all other parameters provided must match
	// the previous call that provided the page token.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

type ListMessageBusEnrollmentsResponse struct {

	// The requested enrollments, up to the number specified in `page_size`.
	Enrollments []string `protobuf:"bytes,1,rep,name=enrollments,proto3" json:"enrollments,omitempty"`
	// A page token that can be sent to `ListMessageBusEnrollments` to request the
	// next page. If this is empty, then there are no more pages.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// Unreachable resources, if any.
	Unreachable []string `protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"`
	// contains filtered or unexported fields
}

type ListMessageBusesRequest struct {

	// Required. The parent collection to list triggers on.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Optional. The maximum number of results to return on each page.
	//
	// Note: The service may send fewer.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Optional. The page token; provide the value from the `next_page_token`
	// field in a previous call to retrieve the subsequent page.
	//
	// When paginating, all other parameters provided must match
	// the previous call that provided the page token.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Optional. The sorting order of the resources returned. Value should be a
	// comma-separated list of fields. The default sorting order is ascending. To
	// specify descending order for a field, append a `desc` suffix; for example:
	// `name desc, update_time`.
	OrderBy string `protobuf:"bytes,4,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
	// Optional. The filter field that the list request will filter on.
	// Possible filtersare described in https://google.aip.dev/160.
	Filter string `protobuf:"bytes,5,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

type ListMessageBusesResponse struct {

	// The requested message buses, up to the number specified in `page_size`.
	MessageBuses []*MessageBus `protobuf:"bytes,1,rep,name=message_buses,json=messageBuses,proto3" json:"message_buses,omitempty"`
	// A page token that can be sent to `ListMessageBuses` to request the next
	// page. If this is empty, then there are no more pages.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// Unreachable resources, if any.
	Unreachable []string `protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"`
	// contains filtered or unexported fields
}

type ListPipelinesRequest struct {

	// Required. The parent collection to list pipelines on.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Optional. The maximum number of results to return on each page.
	//
	// Note: The service may send fewer.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Optional. The page token; provide the value from the `next_page_token`
	// field in a previous call to retrieve the subsequent page.
	//
	// When paginating, all other parameters provided must match
	// the previous call that provided the page token.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Optional. The sorting order of the resources returned. Value should be a
	// comma-separated list of fields. The default sorting order is ascending. To
	// specify descending order for a field, append a `desc` suffix; for example:
	// `name desc, update_time`.
	OrderBy string `protobuf:"bytes,4,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
	// Optional. The filter field that the list request will filter on.
	// Possible filters are described in https://google.aip.dev/160.
	Filter string `protobuf:"bytes,5,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

type ListPipelinesResponse struct {

	// The requested pipelines, up to the number specified in `page_size`.
	Pipelines []*Pipeline `protobuf:"bytes,1,rep,name=pipelines,proto3" json:"pipelines,omitempty"`
	// A page token that can be sent to `ListPipelines` to request the next
	// page. If this is empty, then there are no more pages.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// Unreachable resources, if any.
	Unreachable []string `protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"`
	// contains filtered or unexported fields
}

type ListProvidersRequest struct {

	// Required. The parent of the provider to get.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// The maximum number of providers to return on each page.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// The page token; provide the value from the `next_page_token` field in a
	// previous `ListProviders` call to retrieve the subsequent page.
	//
	// When paginating, all other parameters provided to `ListProviders` must
	// match the call that provided the page token.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// The sorting order of the resources returned. Value should be a
	// comma-separated list of fields. The default sorting oder is ascending. To
	// specify descending order for a field, append a `desc` suffix; for example:
	// `name desc, _id`.
	OrderBy string `protobuf:"bytes,4,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
	// The filter field that the list request will filter on.
	Filter string `protobuf:"bytes,5,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

type ListProvidersResponse struct {

	// The requested providers, up to the number specified in `page_size`.
	Providers []*Provider `protobuf:"bytes,1,rep,name=providers,proto3" json:"providers,omitempty"`
	// A page token that can be sent to `ListProviders` to request the next page.
	// If this is empty, then there are no more pages.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// Unreachable resources, if any.
	Unreachable []string `protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"`
	// contains filtered or unexported fields
}

type ListTriggersRequest struct {

	// Required. The parent collection to list triggers on.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// The maximum number of triggers to return on each page.
	//
	// Note: The service may send fewer.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// The page token; provide the value from the `next_page_token` field in a
	// previous `ListTriggers` call to retrieve the subsequent page.
	//
	// When paginating, all other parameters provided to `ListTriggers` must match
	// the call that provided the page token.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// The sorting order of the resources returned. Value should be a
	// comma-separated list of fields. The default sorting order is ascending. To
	// specify descending order for a field, append a `desc` suffix; for example:
	// `name desc, trigger_id`.
	OrderBy string `protobuf:"bytes,4,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
	// Filter field. Used to filter the Triggers to be listed. Possible filters
	// are described in https://google.aip.dev/160. For example, using
	// "?filter=destination:gke" would list only Triggers with a gke destination.
	Filter string `protobuf:"bytes,5,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

type ListTriggersResponse struct {

	// The requested triggers, up to the number specified in `page_size`.
	Triggers []*Trigger `protobuf:"bytes,1,rep,name=triggers,proto3" json:"triggers,omitempty"`
	// A page token that can be sent to `ListTriggers` to request the next page.
	// If this is empty, then there are no more pages.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// Unreachable resources, if any.
	Unreachable []string `protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"`
	// contains filtered or unexported fields
}

type LoggingConfig struct {

	// Optional. The minimum severity of logs that will be sent to
	// Stackdriver/Platform Telemetry. Logs at severitiy ≥ this value will be
	// sent, unless it is NONE.
	LogSeverity LoggingConfig_LogSeverity `protobuf:"varint,1,opt,name=log_severity,json=logSeverity,proto3,enum=google.cloud.eventarc.v1.LoggingConfig_LogSeverity" json:"log_severity,omitempty"`
	// contains filtered or unexported fields
}

type LoggingConfig_LogSeverity int32

const (
	// Log severity is not specified. This value is treated the same as NONE,
	// but is used to distinguish between no update and update to NONE in
	// update_masks.
	LoggingConfig_LOG_SEVERITY_UNSPECIFIED LoggingConfig_LogSeverity = 0
	// Default value at resource creation, presence of this value must be
	// treated as no logging/disable logging.
	LoggingConfig_NONE LoggingConfig_LogSeverity = 1
	// Debug or trace level logging.
	LoggingConfig_DEBUG LoggingConfig_LogSeverity = 2
	// Routine information, such as ongoing status or performance.
	LoggingConfig_INFO LoggingConfig_LogSeverity = 3
	// Normal but significant events, such as start up, shut down, or a
	// configuration change.
	LoggingConfig_NOTICE LoggingConfig_LogSeverity = 4
	// Warning events might cause problems.
	LoggingConfig_WARNING LoggingConfig_LogSeverity = 5
	// Error events are likely to cause problems.
	LoggingConfig_ERROR LoggingConfig_LogSeverity = 6
	// Critical events cause more severe problems or outages.
	LoggingConfig_CRITICAL LoggingConfig_LogSeverity = 7
	// A person must take action immediately.
	LoggingConfig_ALERT LoggingConfig_LogSeverity = 8
	// One or more systems are unusable.
	LoggingConfig_EMERGENCY LoggingConfig_LogSeverity = 9
)

type MessageBus struct {

	// Identifier. Resource name of the form
	// projects/{project}/locations/{location}/messageBuses/{message_bus}
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Output only. Server assigned unique identifier for the channel. The value
	// is a UUID4 string and guaranteed to remain unchanged until the resource is
	// deleted.
	Uid string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
	// Output only. This checksum is computed by the server based on the value of
	// other fields, and might be sent only on update and delete requests to
	// ensure that the client has an up-to-date value before proceeding.
	Etag string `protobuf:"bytes,3,opt,name=etag,proto3" json:"etag,omitempty"`
	// Output only. The creation time.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The last-modified time.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Optional. Resource labels.
	Labels map[string]string `protobuf:"bytes,6,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	// Optional. Resource annotations.
	Annotations map[string]string `protobuf:"bytes,7,rep,name=annotations,proto3" json:"annotations,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	// Optional. Resource display name.
	DisplayName string `protobuf:"bytes,8,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// Optional. Resource name of a KMS crypto key (managed by the user) used to
	// encrypt/decrypt their event data.
	//
	// It must match the pattern
	// `projects/*/locations/*/keyRings/*/cryptoKeys/*`.
	CryptoKeyName string `protobuf:"bytes,10,opt,name=crypto_key_name,json=cryptoKeyName,proto3" json:"crypto_key_name,omitempty"`
	// Optional. Config to control Platform logging for the Message Bus. This log
	// configuration is applied to the Message Bus itself, and all the Enrollments
	// attached to it.
	LoggingConfig *LoggingConfig `protobuf:"bytes,11,opt,name=logging_config,json=loggingConfig,proto3" json:"logging_config,omitempty"`
	// contains filtered or unexported fields
}

type NetworkConfig struct {

	// Required. Name of the NetworkAttachment that allows access to the
	// customer's VPC. Format:
	// `projects/{PROJECT_ID}/regions/{REGION}/networkAttachments/{NETWORK_ATTACHMENT_NAME}`
	NetworkAttachment string `protobuf:"bytes,1,opt,name=network_attachment,json=networkAttachment,proto3" json:"network_attachment,omitempty"`
	// contains filtered or unexported fields
}

type OperationMetadata struct {

	// Output only. The time the operation was created.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The time the operation finished running.
	EndTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// Output only. Server-defined resource path for the target of the operation.
	Target string `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	// Output only. Name of the verb executed by the operation.
	Verb string `protobuf:"bytes,4,opt,name=verb,proto3" json:"verb,omitempty"`
	// Output only. Human-readable status of the operation, if any.
	StatusMessage string `protobuf:"bytes,5,opt,name=status_message,json=statusMessage,proto3" json:"status_message,omitempty"`
	// Output only. Identifies whether the user has requested cancellation
	// of the operation. Operations that have successfully been cancelled
	// have [Operation.error][] value with a
	// [google.rpc.Status.code][google.rpc.Status.code] of 1, corresponding to
	// `Code.CANCELLED`.
	RequestedCancellation bool `protobuf:"varint,6,opt,name=requested_cancellation,json=requestedCancellation,proto3" json:"requested_cancellation,omitempty"`
	// Output only. API version used to start the operation.
	ApiVersion string `protobuf:"bytes,7,opt,name=api_version,json=apiVersion,proto3" json:"api_version,omitempty"`
	// contains filtered or unexported fields
}

type Pipeline struct {

	// Identifier. The resource name of the Pipeline. Must be unique within the
	// location of the project and must be in
	// `projects/{project}/locations/{location}/pipelines/{pipeline}` format.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Output only. The creation time.
	// A timestamp in RFC3339 UTC "Zulu" format, with nanosecond resolution and up
	// to nine fractional digits. Examples: "2014-10-02T15:01:23Z" and
	// "2014-10-02T15:01:23.045123456Z".
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The last-modified time.
	// A timestamp in RFC3339 UTC "Zulu" format, with nanosecond resolution and up
	// to nine fractional digits. Examples: "2014-10-02T15:01:23Z" and
	// "2014-10-02T15:01:23.045123456Z".
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Optional. User labels attached to the Pipeline that can be used to group
	// resources. An object containing a list of "key": value pairs. Example: {
	// "name": "wrench", "mass": "1.3kg", "count": "3" }.
	Labels map[string]string `protobuf:"bytes,4,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	// Output only. Server-assigned unique identifier for the Pipeline. The value
	// is a UUID4 string and guaranteed to remain unchanged until the resource is
	// deleted.
	Uid string `protobuf:"bytes,5,opt,name=uid,proto3" json:"uid,omitempty"`
	// Optional. User-defined annotations. See
	// https://google.aip.dev/128#annotations.
	Annotations map[string]string `protobuf:"bytes,6,rep,name=annotations,proto3" json:"annotations,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	// Optional. Display name of resource.
	DisplayName string `protobuf:"bytes,7,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// Required. List of destinations to which messages will be forwarded.
	// Currently, exactly one destination is supported per Pipeline.
	Destinations []*Pipeline_Destination `protobuf:"bytes,8,rep,name=destinations,proto3" json:"destinations,omitempty"`
	// Optional. List of mediation operations to be performed on the message.
	// Currently, only one Transformation operation is allowed in each Pipeline.
	Mediations []*Pipeline_Mediation `protobuf:"bytes,9,rep,name=mediations,proto3" json:"mediations,omitempty"`
	// Optional. Resource name of a KMS crypto key (managed by the user) used to
	// encrypt/decrypt the event data. If not set, an internal Google-owned key
	// will be used to encrypt messages. It must match the pattern
	// "projects/{project}/locations/{location}/keyRings/{keyring}/cryptoKeys/{key}".
	CryptoKeyName string `protobuf:"bytes,10,opt,name=crypto_key_name,json=cryptoKeyName,proto3" json:"crypto_key_name,omitempty"`
	// Optional. The payload format expected for the messages received by the
	// Pipeline. If input_payload_format is set then any messages not matching
	// this format will be treated as persistent errors. If input_payload_format
	// is not set, then the message data will be treated as an opaque binary and
	// no output format can be set on the Pipeline through the
	// Pipeline.Destination.output_payload_format field. Any Mediations on the
	// Pipeline that involve access to the data field will fail as persistent
	// errors.
	InputPayloadFormat *Pipeline_MessagePayloadFormat `protobuf:"bytes,11,opt,name=input_payload_format,json=inputPayloadFormat,proto3" json:"input_payload_format,omitempty"`
	// Optional. Config to control Platform Logging for Pipelines.
	LoggingConfig *LoggingConfig `protobuf:"bytes,12,opt,name=logging_config,json=loggingConfig,proto3" json:"logging_config,omitempty"`
	// Optional. The retry policy to use in the pipeline.
	RetryPolicy *Pipeline_RetryPolicy `protobuf:"bytes,13,opt,name=retry_policy,json=retryPolicy,proto3" json:"retry_policy,omitempty"`
	// Output only. This checksum is computed by the server based on the value of
	// other fields, and might be sent only on create requests to ensure that the
	// client has an up-to-date value before proceeding.
	Etag string `protobuf:"bytes,99,opt,name=etag,proto3" json:"etag,omitempty"`
	// contains filtered or unexported fields
}

type Pipeline_Destination struct {

	// Optional. Network config is used to configure how Pipeline resolves and
	// connects to a destination.
	NetworkConfig *Pipeline_Destination_NetworkConfig `protobuf:"bytes,1,opt,name=network_config,json=networkConfig,proto3" json:"network_config,omitempty"`
	// The destination identifier to which the request should be routed to.
	//
	// Types that are assignable to DestinationDescriptor:
	//
	//	*Pipeline_Destination_HttpEndpoint_
	//	*Pipeline_Destination_Workflow
	//	*Pipeline_Destination_MessageBus
	//	*Pipeline_Destination_Topic
	DestinationDescriptor isPipeline_Destination_DestinationDescriptor `protobuf_oneof:"destination_descriptor"`
	// Optional. An authentication config used to authenticate message requests,
	// such that destinations can verify the source. For example, this can be
	// used with private GCP destinations that require GCP credentials to access
	// like Cloud Run. This field is optional and should be set only by users
	// interested in authenticated push
	AuthenticationConfig *Pipeline_Destination_AuthenticationConfig `protobuf:"bytes,5,opt,name=authentication_config,json=authenticationConfig,proto3" json:"authentication_config,omitempty"`
	// Optional. The message format before it is delivered to the destination.
	// If not set, the message will be delivered in the format it was originally
	// delivered to the Pipeline. This field can only be set if
	// Pipeline.input_payload_format is also set.
	OutputPayloadFormat *Pipeline_MessagePayloadFormat `protobuf:"bytes,6,opt,name=output_payload_format,json=outputPayloadFormat,proto3" json:"output_payload_format,omitempty"`
	// contains filtered or unexported fields
}

type Pipeline_Destination_AuthenticationConfig struct {

	// The type of authentication method.
	//
	// Types that are assignable to AuthenticationMethodDescriptor:
	//
	//	*Pipeline_Destination_AuthenticationConfig_GoogleOidc
	//	*Pipeline_Destination_AuthenticationConfig_OauthToken
	AuthenticationMethodDescriptor isPipeline_Destination_AuthenticationConfig_AuthenticationMethodDescriptor `protobuf_oneof:"authentication_method_descriptor"`
	// contains filtered or unexported fields
}

type Pipeline_Destination_AuthenticationConfig_GoogleOidc struct {
	// Optional. This authenticate method will apply Google OIDC tokens
	// signed by a GCP service account to the requests.
	GoogleOidc *Pipeline_Destination_AuthenticationConfig_OidcToken `protobuf:"bytes,1,opt,name=google_oidc,json=googleOidc,proto3,oneof"`
}

type Pipeline_Destination_AuthenticationConfig_OAuthToken struct {

	// Required. Service account email used to generate the [OAuth
	// token](https://developers.google.com/identity/protocols/OAuth2).
	// The principal who calls this API must have
	// iam.serviceAccounts.actAs permission in the service account. See
	// https://cloud.google.com/iam/docs/understanding-service-accounts?hl=en#sa_common
	// for more information. Eventarc service agents must have
	// roles/roles/iam.serviceAccountTokenCreator role to allow Pipeline
	// to create OAuth2 tokens for authenticated requests.
	ServiceAccount string `protobuf:"bytes,1,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"`
	// Optional. OAuth scope to be used for generating OAuth access token.
	// If not specified, "https://www.googleapis.com/auth/cloud-platform"
	// will be used.
	Scope string `protobuf:"bytes,2,opt,name=scope,proto3" json:"scope,omitempty"`
	// contains filtered or unexported fields
}

type Pipeline_Destination_AuthenticationConfig_OauthToken struct {
	// Optional. If specified, an [OAuth
	// token](https://developers.google.com/identity/protocols/OAuth2) will
	// be generated and attached as an `Authorization` header in the HTTP
	// request.
	//
	// This type of authorization should generally only be used when calling
	// Google APIs hosted on *.googleapis.com.
	OauthToken *Pipeline_Destination_AuthenticationConfig_OAuthToken `protobuf:"bytes,2,opt,name=oauth_token,json=oauthToken,proto3,oneof"`
}

type Pipeline_Destination_AuthenticationConfig_OidcToken struct {

	// Required. Service account email used to generate the OIDC Token.
	// The principal who calls this API must have
	// iam.serviceAccounts.actAs permission in the service account. See
	// https://cloud.google.com/iam/docs/understanding-service-accounts?hl=en#sa_common
	// for more information. Eventarc service agents must have
	// roles/roles/iam.serviceAccountTokenCreator role to allow the
	// Pipeline to create OpenID tokens for authenticated requests.
	ServiceAccount string `protobuf:"bytes,1,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"`
	// Optional. Audience to be used to generate the OIDC Token. The
	// audience claim identifies the recipient that the JWT is intended for.
	// If unspecified, the destination URI will be used.
	Audience string `protobuf:"bytes,2,opt,name=audience,proto3" json:"audience,omitempty"`
	// contains filtered or unexported fields
}

type Pipeline_Destination_HttpEndpoint struct {

	// Required. The URI of the HTTP enpdoint.
	//
	// The value must be a RFC2396 URI string.
	// Examples: `https://svc.us-central1.p.local:8080/route`.
	// Only the HTTPS protocol is supported.
	Uri string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
	// Optional. The CEL expression used to modify how the destination-bound
	// HTTP request is constructed.
	//
	// If a binding expression is not specified here, the message
	// is treated as a CloudEvent and is mapped to the HTTP request according
	// to the CloudEvent HTTP Protocol Binding Binary Content Mode. In this
	// representation, all fields except the `data` and `datacontenttype`
	// field on the message are mapped to HTTP request headers with a prefix
	// of `ce-`.
	//
	// To construct the HTTP request payload and the value of the content-type
	// HTTP header, the payload format is defined as follows:
	//  1. Use the output_payload_format_type on the Pipeline.Destination if it
	//     is set, else:
	//  2. Use the input_payload_format_type on the Pipeline if it is set,
	//     else:
	//  3. Treat the payload as opaque binary data.
	//
	// The `data` field of the message is converted to the payload format or
	// left as-is for case 3) and then attached as the payload of the HTTP
	// request. The `content-type` header on the HTTP request is set to the
	// payload format type or left empty for case 3). However, if a mediation
	// has updated the `datacontenttype` field on the message so that it is
	// not the same as the payload format type but it is still a prefix of the
	// payload format type, then the `content-type` header on the HTTP request
	// is set to this `datacontenttype` value. For example, if the
	// `datacontenttype` is "application/json" and the payload format type is
	// "application/json; charset=utf-8", then the `content-type` header on
	// the HTTP request is set to "application/json; charset=utf-8".
	//
	// If a non-empty binding expression is specified then this expression is
	// used to modify the default CloudEvent HTTP Protocol Binding Binary
	// Content representation.
	// The result of the CEL expression must be a map of key/value pairs
	// which is used as follows:
	// - If a map named `headers` exists on the result of the expression,
	// then its key/value pairs are directly mapped to the HTTP request
	// headers. The headers values are constructed from the corresponding
	// value type’s canonical representation. If the `headers` field doesn’t
	// exist then the resulting HTTP request will be the headers of the
	// CloudEvent HTTP Binding Binary Content Mode representation of the final
	// message. Note: If the specified binding expression, has updated the
	// `datacontenttype` field on the message so that it is not the same as
	// the payload format type but it is still a prefix of the payload format
	// type, then the `content-type` header in the `headers` map is set to
	// this `datacontenttype` value.
	// - If a field named `body` exists on the result of the expression then
	// its value is directly mapped to the body of the request. If the value
	// of the `body` field is of type bytes or string then it is used for
	// the HTTP request body as-is, with no conversion. If the body field is
	// of any other type then it is converted to a JSON string. If the body
	// field does not exist then the resulting payload of the HTTP request
	// will be data value of the CloudEvent HTTP Binding Binary Content Mode
	// representation of the final message as described earlier.
	// - Any other fields in the resulting expression will be ignored.
	//
	// The CEL expression may access the incoming CloudEvent message in its
	// definition, as follows:
	// - The `data` field of the incoming CloudEvent message can be accessed
	// using the `message.data` value. Subfields of `message.data` may also be
	// accessed if an input_payload_format has been specified on the Pipeline.
	// - Each attribute of the incoming CloudEvent message can be accessed
	// using the `message.<key>` value, where <key> is replaced with the
	// name of the attribute.
	// - Existing headers can be accessed in the CEL expression using the
	// `headers` variable. The `headers` variable defines a map of key/value
	// pairs corresponding to the HTTP headers of the CloudEvent HTTP Binding
	// Binary Content Mode representation of the final message as described
	// earlier. For example, the following CEL expression can be used to
	// construct an HTTP request by adding an additional header to the HTTP
	// headers of the CloudEvent HTTP Binding Binary Content Mode
	// representation of the final message and by overwriting the body of the
	// request:
	//
	// ```
	//
	//	{
	//	  "headers": headers.merge({"new-header-key": "new-header-value"}),
	//	  "body": "new-body"
	//	}
	//
	// ```
	//
	// Additionally, the following CEL extension functions are provided for
	// use in this CEL expression:
	//   - toBase64Url:
	//     map.toBase64Url() -> string
	//   - Converts a CelValue to a base64url encoded string
	//   - toJsonString: map.toJsonString() -> string
	//   - Converts a CelValue to a JSON string
	//   - merge:
	//     map1.merge(map2) -> map3
	//   - Merges the passed CEL map with the existing CEL map the
	//     function is applied to.
	//   - If the same key exists in both maps, if the key's value is type
	//     map both maps are merged else the value from the passed map is
	//     used.
	//   - denormalize:
	//     map.denormalize() -> map
	//   - Denormalizes a CEL map such that every value of type map or key
	//     in the map is expanded to return a single level map.
	//   - The resulting keys are "." separated indices of the map keys.
	//   - For example:
	//     {
	//     "a": 1,
	//     "b": {
	//     "c": 2,
	//     "d": 3
	//     }
	//     "e": [4, 5]
	//     }
	//     .denormalize()
	//     -> {
	//     "a": 1,
	//     "b.c": 2,
	//     "b.d": 3,
	//     "e.0": 4,
	//     "e.1": 5
	//     }
	//   - setField:
	//     map.setField(key, value) -> message
	//   - Sets the field of the message with the given key to the
	//     given value.
	//   - If the field is not present it will be added.
	//   - If the field is present it will be overwritten.
	//   - The key can be a dot separated path to set a field in a nested
	//     message.
	//   - Key must be of type string.
	//   - Value may be any valid type.
	//   - removeFields:
	//     map.removeFields([key1, key2, ...]) -> message
	//   - Removes the fields of the map with the given keys.
	//   - The keys can be a dot separated path to remove a field in a
	//     nested message.
	//   - If a key is not found it will be ignored.
	//   - Keys must be of type string.
	//   - toMap:
	//     [map1, map2, ...].toMap() -> map
	//   - Converts a CEL list of CEL maps to a single CEL map
	//   - toDestinationPayloadFormat():
	//     message.data.toDestinationPayloadFormat() -> string or bytes
	//   - Converts the message data to the destination payload format
	//     specified in Pipeline.Destination.output_payload_format
	//   - This function is meant to be applied to the message.data field.
	//   - If the destination payload format is not set, the function will
	//     return the message data unchanged.
	//   - toCloudEventJsonWithPayloadFormat:
	//     message.toCloudEventJsonWithPayloadFormat() -> map
	//   - Converts a message to the corresponding structure of JSON
	//     format for CloudEvents
	//   - This function applies toDestinationPayloadFormat() to the
	//     message data. It also sets the corresponding datacontenttype of
	//     the CloudEvent, as indicated by
	//     Pipeline.Destination.output_payload_format. If no
	//     output_payload_format is set it will use the existing
	//     datacontenttype on the CloudEvent if present, else leave
	//     datacontenttype absent.
	//   - This function expects that the content of the message will
	//     adhere to the standard CloudEvent format. If it doesn’t then this
	//     function will fail.
	//   - The result is a CEL map that corresponds to the JSON
	//     representation of the CloudEvent. To convert that data to a JSON
	//     string it can be chained with the toJsonString function.
	//
	// The Pipeline expects that the message it receives adheres to the
	// standard CloudEvent format. If it doesn’t then the outgoing message
	// request may fail with a persistent error.
	MessageBindingTemplate string `protobuf:"bytes,3,opt,name=message_binding_template,json=messageBindingTemplate,proto3" json:"message_binding_template,omitempty"`
	// contains filtered or unexported fields
}

type Pipeline_Destination_HttpEndpoint_ struct {
	// Optional. An HTTP endpoint destination described by an URI.
	// If a DNS FQDN is provided as the endpoint, Pipeline will create a
	// peering zone to the consumer VPC and forward DNS requests to the VPC
	// specified by network config to resolve the service endpoint. See:
	// https://cloud.google.com/dns/docs/zones/zones-overview#peering_zones
	HttpEndpoint *Pipeline_Destination_HttpEndpoint `protobuf:"bytes,2,opt,name=http_endpoint,json=httpEndpoint,proto3,oneof"`
}

type Pipeline_Destination_MessageBus struct {
	// Optional. The resource name of the Message Bus to which events should
	// be published. The Message Bus resource should exist in the same project
	// as the Pipeline. Format:
	// `projects/{project}/locations/{location}/messageBuses/{message_bus}`
	MessageBus string `protobuf:"bytes,4,opt,name=message_bus,json=messageBus,proto3,oneof"`
}

type Pipeline_Destination_NetworkConfig struct {

	// Required. Name of the NetworkAttachment that allows access to the
	// consumer VPC. Format:
	// `projects/{PROJECT_ID}/regions/{REGION}/networkAttachments/{NETWORK_ATTACHMENT_NAME}`
	NetworkAttachment string `protobuf:"bytes,1,opt,name=network_attachment,json=networkAttachment,proto3" json:"network_attachment,omitempty"`
	// contains filtered or unexported fields
}

type Pipeline_Destination_Topic struct {
	// Optional. The resource name of the Pub/Sub topic to which events should
	// be published. Format:
	// `projects/{project}/locations/{location}/topics/{topic}`
	Topic string `protobuf:"bytes,8,opt,name=topic,proto3,oneof"`
}

type Pipeline_Destination_Workflow struct {
	// Optional. The resource name of the Workflow whose Executions are
	// triggered by the events. The Workflow resource should be deployed in
	// the same project as the Pipeline. Format:
	// `projects/{project}/locations/{location}/workflows/{workflow}`
	Workflow string `protobuf:"bytes,3,opt,name=workflow,proto3,oneof"`
}

type Pipeline_Mediation struct {

	// The config of mediation.
	//
	// Types that are assignable to MediationDescriptor:
	//
	//	*Pipeline_Mediation_Transformation_
	MediationDescriptor isPipeline_Mediation_MediationDescriptor `protobuf_oneof:"mediation_descriptor"`
	// contains filtered or unexported fields
}

type Pipeline_Mediation_Transformation struct {

	// Optional. The CEL expression template to apply to transform messages.
	// The following CEL extension functions are provided for
	// use in this CEL expression:
	//   - merge:
	//     map1.merge(map2) -> map3
	//   - Merges the passed CEL map with the existing CEL map the
	//     function is applied to.
	//   - If the same key exists in both maps, if the key's value is type
	//     map both maps are merged else the value from the passed map is
	//     used.
	//   - denormalize:
	//     map.denormalize() -> map
	//   - Denormalizes a CEL map such that every value of type map or key
	//     in the map is expanded to return a single level map.
	//   - The resulting keys are "." separated indices of the map keys.
	//   - For example:
	//     {
	//     "a": 1,
	//     "b": {
	//     "c": 2,
	//     "d": 3
	//     }
	//     "e": [4, 5]
	//     }
	//     .denormalize()
	//     -> {
	//     "a": 1,
	//     "b.c": 2,
	//     "b.d": 3,
	//     "e.0": 4,
	//     "e.1": 5
	//     }
	//   - setField:
	//     map.setField(key, value) -> message
	//   - Sets the field of the message with the given key to the
	//     given value.
	//   - If the field is not present it will be added.
	//   - If the field is present it will be overwritten.
	//   - The key can be a dot separated path to set a field in a nested
	//     message.
	//   - Key must be of type string.
	//   - Value may be any valid type.
	//   - removeFields:
	//     map.removeFields([key1, key2, ...]) -> message
	//   - Removes the fields of the map with the given keys.
	//   - The keys can be a dot separated path to remove a field in a
	//     nested message.
	//   - If a key is not found it will be ignored.
	//   - Keys must be of type string.
	//   - toMap:
	//     [map1, map2, ...].toMap() -> map
	//   - Converts a CEL list of CEL maps to a single CEL map
	//   - toDestinationPayloadFormat():
	//     message.data.toDestinationPayloadFormat() -> string or bytes
	//   - Converts the message data to the destination payload format
	//     specified in Pipeline.Destination.output_payload_format
	//   - This function is meant to be applied to the message.data field.
	//   - If the destination payload format is not set, the function will
	//     return the message data unchanged.
	//   - toCloudEventJsonWithPayloadFormat:
	//     message.toCloudEventJsonWithPayloadFormat() -> map
	//   - Converts a message to the corresponding structure of JSON
	//     format for CloudEvents
	//   - This function applies toDestinationPayloadFormat() to the
	//     message data. It also sets the corresponding datacontenttype of
	//     the CloudEvent, as indicated by
	//     Pipeline.Destination.output_payload_format. If no
	//     output_payload_format is set it will use the existing
	//     datacontenttype on the CloudEvent if present, else leave
	//     datacontenttype absent.
	//   - This function expects that the content of the message will
	//     adhere to the standard CloudEvent format. If it doesn’t then this
	//     function will fail.
	//   - The result is a CEL map that corresponds to the JSON
	//     representation of the CloudEvent. To convert that data to a JSON
	//     string it can be chained with the toJsonString function.
	TransformationTemplate string `protobuf:"bytes,1,opt,name=transformation_template,json=transformationTemplate,proto3" json:"transformation_template,omitempty"`
	// contains filtered or unexported fields
}

type Pipeline_Mediation_Transformation_ struct {
	// Optional. How the Pipeline is to transform messages
	Transformation *Pipeline_Mediation_Transformation `protobuf:"bytes,1,opt,name=transformation,proto3,oneof"`
}

type Pipeline_MessagePayloadFormat struct {

	// The kind of message format.
	// One of Protobuf, Avro, and JSON supported.
	// This allows specification of what specific format
	// messages are sent and received.
	//
	// Types that are assignable to Kind:
	//
	//	*Pipeline_MessagePayloadFormat_Protobuf
	//	*Pipeline_MessagePayloadFormat_Avro
	//	*Pipeline_MessagePayloadFormat_Json
	Kind isPipeline_MessagePayloadFormat_Kind `protobuf_oneof:"kind"`
	// contains filtered or unexported fields
}

type Pipeline_MessagePayloadFormat_Avro struct {
	// Optional. Avro format.
	Avro *Pipeline_MessagePayloadFormat_AvroFormat `protobuf:"bytes,2,opt,name=avro,proto3,oneof"`
}

type Pipeline_MessagePayloadFormat_AvroFormat struct {

	// Optional. The entire schema definition is stored in this field.
	SchemaDefinition string `protobuf:"bytes,1,opt,name=schema_definition,json=schemaDefinition,proto3" json:"schema_definition,omitempty"`
	// contains filtered or unexported fields
}

type Pipeline_MessagePayloadFormat_Json struct {
	// Optional. JSON format.
	Json *Pipeline_MessagePayloadFormat_JsonFormat `protobuf:"bytes,3,opt,name=json,proto3,oneof"`
}

type Pipeline_MessagePayloadFormat_JsonFormat struct {
	// contains filtered or unexported fields
}

type Pipeline_MessagePayloadFormat_Protobuf struct {
	// Optional. Protobuf format.
	Protobuf *Pipeline_MessagePayloadFormat_ProtobufFormat `protobuf:"bytes,1,opt,name=protobuf,proto3,oneof"`
}

type Pipeline_MessagePayloadFormat_ProtobufFormat struct {

	// Optional. The entire schema definition is stored in this field.
	SchemaDefinition string `protobuf:"bytes,1,opt,name=schema_definition,json=schemaDefinition,proto3" json:"schema_definition,omitempty"`
	// contains filtered or unexported fields
}

type Pipeline_RetryPolicy struct {

	// Optional. The maximum number of delivery attempts for any message. The
	// value must be between 1 and 100. The default value for this field is 5.
	MaxAttempts int32 `protobuf:"varint,1,opt,name=max_attempts,json=maxAttempts,proto3" json:"max_attempts,omitempty"`
	// Optional. The minimum amount of seconds to wait between retry attempts.
	// The value must be between 1 and 600. The default value for this field
	// is 5.
	MinRetryDelay *durationpb.Duration `protobuf:"bytes,2,opt,name=min_retry_delay,json=minRetryDelay,proto3" json:"min_retry_delay,omitempty"`
	// Optional. The maximum amount of seconds to wait between retry attempts.
	// The value must be between 1 and 600. The default value for this field
	// is 60.
	MaxRetryDelay *durationpb.Duration `protobuf:"bytes,3,opt,name=max_retry_delay,json=maxRetryDelay,proto3" json:"max_retry_delay,omitempty"`
	// contains filtered or unexported fields
}

type Provider struct {

	// Output only. In
	// `projects/{project}/locations/{location}/providers/{provider_id}` format.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Output only. Human friendly name for the Provider. For example "Cloud
	// Storage".
	DisplayName string `protobuf:"bytes,2,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// Output only. Event types for this provider.
	EventTypes []*EventType `protobuf:"bytes,3,rep,name=event_types,json=eventTypes,proto3" json:"event_types,omitempty"`
	// contains filtered or unexported fields
}

type Pubsub struct {

	// Optional. The name of the Pub/Sub topic created and managed by Eventarc as
	// a transport for the event delivery. Format:
	// `projects/{PROJECT_ID}/topics/{TOPIC_NAME}`.
	//
	// You can set an existing topic for triggers of the type
	// `google.cloud.pubsub.topic.v1.messagePublished`. The topic you provide
	// here is not deleted by Eventarc at trigger deletion.
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// Output only. The name of the Pub/Sub subscription created and managed by
	// Eventarc as a transport for the event delivery. Format:
	// `projects/{PROJECT_ID}/subscriptions/{SUBSCRIPTION_NAME}`.
	Subscription string `protobuf:"bytes,2,opt,name=subscription,proto3" json:"subscription,omitempty"`
	// contains filtered or unexported fields
}

type StateCondition struct {

	// The canonical code of the condition.
	Code code.Code `protobuf:"varint,1,opt,name=code,proto3,enum=google.rpc.Code" json:"code,omitempty"`
	// Human-readable message.
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}