eventarcdata

package
v0.9.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 26, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Package eventarcdata provides Eventarc type definitions for CloudEvent data payloads.

Supported CloudEvent Types

  • google.cloud.eventarc.trigger.v1.created
  • google.cloud.eventarc.trigger.v1.updated
  • google.cloud.eventarc.trigger.v1.deleted
  • google.cloud.eventarc.channel.v1.created
  • google.cloud.eventarc.channel.v1.updated
  • google.cloud.eventarc.channel.v1.deleted
  • google.cloud.eventarc.channelConnection.v1.created
  • google.cloud.eventarc.channelConnection.v1.deleted

Index

Constants

This section is empty.

Variables

View Source 
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,
	}
)

Enum value maps for Channel_State.

View Source 
var File_cloud_eventarc_v1_data_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Channel 

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.events.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"`
	// contains filtered or unexported fields
}

A representation of the Channel resource. A Channel is a resource on which event providers publish their events. The published events are delivered through the transport associated with the channel. Note that a channel is associated with exactly one event provider.

func (*Channel) Descriptor deprecated 

func (*Channel) Descriptor() ([]byte, []int)

Deprecated: Use Channel.ProtoReflect.Descriptor instead.

func (*Channel) GetActivationToken 

func (x *Channel) GetActivationToken() string

func (*Channel) GetCreateTime 

func (x *Channel) GetCreateTime() *timestamppb.Timestamp

func (*Channel) GetCryptoKeyName 

func (x *Channel) GetCryptoKeyName() string

func (*Channel) GetName 

func (x *Channel) GetName() string

func (*Channel) GetProvider 

func (x *Channel) GetProvider() string

func (*Channel) GetPubsubTopic 

func (x *Channel) GetPubsubTopic() string

func (*Channel) GetState 

func (x *Channel) GetState() Channel_State

func (*Channel) GetTransport 

func (m *Channel) GetTransport() isChannel_Transport

func (*Channel) GetUid 

func (x *Channel) GetUid() string

func (*Channel) GetUpdateTime 

func (x *Channel) GetUpdateTime() *timestamppb.Timestamp

func (*Channel) ProtoMessage 

func (*Channel) ProtoMessage()

func (*Channel) ProtoReflect 

func (x *Channel) ProtoReflect() protoreflect.Message

func (*Channel) Reset 

func (x *Channel) Reset()

func (*Channel) String 

func (x *Channel) String() string

type ChannelConnection 

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"`
	// contains filtered or unexported fields
}

A representation of the ChannelConnection resource. A ChannelConnection is a resource which event providers create during the activation process to establish a connection between the provider and the subscriber channel.

func (*ChannelConnection) Descriptor deprecated 

func (*ChannelConnection) Descriptor() ([]byte, []int)

Deprecated: Use ChannelConnection.ProtoReflect.Descriptor instead.

func (*ChannelConnection) GetChannel 

func (x *ChannelConnection) GetChannel() string

func (*ChannelConnection) GetCreateTime 

func (x *ChannelConnection) GetCreateTime() *timestamppb.Timestamp

func (*ChannelConnection) GetName 

func (x *ChannelConnection) GetName() string

func (*ChannelConnection) GetUid 

func (x *ChannelConnection) GetUid() string

func (*ChannelConnection) GetUpdateTime 

func (x *ChannelConnection) GetUpdateTime() *timestamppb.Timestamp

func (*ChannelConnection) ProtoMessage 

func (*ChannelConnection) ProtoMessage()

func (*ChannelConnection) ProtoReflect 

func (x *ChannelConnection) ProtoReflect() protoreflect.Message

func (*ChannelConnection) Reset 

func (x *ChannelConnection) Reset()

func (*ChannelConnection) String 

func (x *ChannelConnection) String() string

type ChannelConnectionEventData 

type ChannelConnectionEventData struct {

	// The ChannelConnection event payload.
	Payload *ChannelConnection `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

The data within all ChannelConnection events.

func (*ChannelConnectionEventData) Descriptor deprecated 

func (*ChannelConnectionEventData) Descriptor() ([]byte, []int)

Deprecated: Use ChannelConnectionEventData.ProtoReflect.Descriptor instead.

func (*ChannelConnectionEventData) GetPayload 

func (x *ChannelConnectionEventData) GetPayload() *ChannelConnection

func (*ChannelConnectionEventData) ProtoMessage 

func (*ChannelConnectionEventData) ProtoMessage()

func (*ChannelConnectionEventData) ProtoReflect 

func (x *ChannelConnectionEventData) ProtoReflect() protoreflect.Message

func (*ChannelConnectionEventData) Reset 

func (x *ChannelConnectionEventData) Reset()

func (*ChannelConnectionEventData) String 

func (x *ChannelConnectionEventData) String() string

type ChannelEventData 

type ChannelEventData struct {

	// The Channel event payload.
	Payload *Channel `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

The data within all Channel events.

func (*ChannelEventData) Descriptor deprecated 

func (*ChannelEventData) Descriptor() ([]byte, []int)

Deprecated: Use ChannelEventData.ProtoReflect.Descriptor instead.

func (*ChannelEventData) GetPayload 

func (x *ChannelEventData) GetPayload() *Channel

func (*ChannelEventData) ProtoMessage 

func (*ChannelEventData) ProtoMessage()

func (*ChannelEventData) ProtoReflect 

func (x *ChannelEventData) ProtoReflect() protoreflect.Message

func (*ChannelEventData) Reset 

func (x *ChannelEventData) Reset()

func (*ChannelEventData) String 

func (x *ChannelEventData) String() string

type Channel_PubsubTopic 

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 

type Channel_State int32

State lists all the possible states of a Channel 

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
)

func (Channel_State) Descriptor 

func (Channel_State) Descriptor() protoreflect.EnumDescriptor

func (Channel_State) Enum 

func (x Channel_State) Enum() *Channel_State

func (Channel_State) EnumDescriptor deprecated 

func (Channel_State) EnumDescriptor() ([]byte, []int)

Deprecated: Use Channel_State.Descriptor instead.

func (Channel_State) Number 

func (x Channel_State) Number() protoreflect.EnumNumber

func (Channel_State) String 

func (x Channel_State) String() string

func (Channel_State) Type 

func (Channel_State) Type() protoreflect.EnumType

type CloudRun 

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
}

Represents a Cloud Run destination.

func (*CloudRun) Descriptor deprecated 

func (*CloudRun) Descriptor() ([]byte, []int)

Deprecated: Use CloudRun.ProtoReflect.Descriptor instead.

func (*CloudRun) GetPath 

func (x *CloudRun) GetPath() string

func (*CloudRun) GetRegion 

func (x *CloudRun) GetRegion() string

func (*CloudRun) GetService 

func (x *CloudRun) GetService() string

func (*CloudRun) ProtoMessage 

func (*CloudRun) ProtoMessage()

func (*CloudRun) ProtoReflect 

func (x *CloudRun) ProtoReflect() protoreflect.Message

func (*CloudRun) Reset 

func (x *CloudRun) Reset()

func (*CloudRun) String 

func (x *CloudRun) String() string

type Destination 

type Destination struct {

	// Types that are assignable to Descriptor_:
	//
	//	*Destination_CloudRun
	//	*Destination_CloudFunction
	//	*Destination_Gke
	//	*Destination_Workflow
	Descriptor_ isDestination_Descriptor_ `protobuf_oneof:"descriptor"`
	// contains filtered or unexported fields
}

Represents a target of an invocation over HTTP.

func (*Destination) Descriptor deprecated 

func (*Destination) Descriptor() ([]byte, []int)

Deprecated: Use Destination.ProtoReflect.Descriptor instead.

func (*Destination) GetCloudFunction 

func (x *Destination) GetCloudFunction() string

func (*Destination) GetCloudRun 

func (x *Destination) GetCloudRun() *CloudRun

func (*Destination) GetDescriptor_ 

func (m *Destination) GetDescriptor_() isDestination_Descriptor_

func (*Destination) GetGke 

func (x *Destination) GetGke() *GKE

func (*Destination) GetWorkflow 

func (x *Destination) GetWorkflow() string

func (*Destination) ProtoMessage 

func (*Destination) ProtoMessage()

func (*Destination) ProtoReflect 

func (x *Destination) ProtoReflect() protoreflect.Message

func (*Destination) Reset 

func (x *Destination) Reset()

func (*Destination) String 

func (x *Destination) String() string

type Destination_CloudFunction 

type Destination_CloudFunction struct {
	// The Cloud Function resource name. Only Cloud Functions V2 is supported.
	// Format: `projects/{project}/locations/{location}/functions/{function}`
	//
	// This is a read-only field. Creating Cloud Functions 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 

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 

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_Workflow 

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 EventFilter 

type EventFilter struct {

	// Required. The name of a CloudEvents attribute. Currently, only a subset of
	// attributes are supported for filtering.
	//
	// 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 only allowed value is
	// `match-path-pattern`.
	Operator string `protobuf:"bytes,3,opt,name=operator,proto3" json:"operator,omitempty"`
	// contains filtered or unexported fields
}

Filters events based on exact matches on the CloudEvents attributes.

func (*EventFilter) Descriptor deprecated 

func (*EventFilter) Descriptor() ([]byte, []int)

Deprecated: Use EventFilter.ProtoReflect.Descriptor instead.

func (*EventFilter) GetAttribute 

func (x *EventFilter) GetAttribute() string

func (*EventFilter) GetOperator 

func (x *EventFilter) GetOperator() string

func (*EventFilter) GetValue 

func (x *EventFilter) GetValue() string

func (*EventFilter) ProtoMessage 

func (*EventFilter) ProtoMessage()

func (*EventFilter) ProtoReflect 

func (x *EventFilter) ProtoReflect() protoreflect.Message

func (*EventFilter) Reset 

func (x *EventFilter) Reset()

func (*EventFilter) String 

func (x *EventFilter) String() string

type GKE 

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
}

Represents a GKE destination.

func (*GKE) Descriptor deprecated 

func (*GKE) Descriptor() ([]byte, []int)

Deprecated: Use GKE.ProtoReflect.Descriptor instead.

func (*GKE) GetCluster 

func (x *GKE) GetCluster() string

func (*GKE) GetLocation 

func (x *GKE) GetLocation() string

func (*GKE) GetNamespace 

func (x *GKE) GetNamespace() string

func (*GKE) GetPath 

func (x *GKE) GetPath() string

func (*GKE) GetService 

func (x *GKE) GetService() string

func (*GKE) ProtoMessage 

func (*GKE) ProtoMessage()

func (*GKE) ProtoReflect 

func (x *GKE) ProtoReflect() protoreflect.Message

func (*GKE) Reset 

func (x *GKE) Reset()

func (*GKE) String 

func (x *GKE) String() string

type Pubsub 

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
}

Represents a Pub/Sub transport.

func (*Pubsub) Descriptor deprecated 

func (*Pubsub) Descriptor() ([]byte, []int)

Deprecated: Use Pubsub.ProtoReflect.Descriptor instead.

func (*Pubsub) GetSubscription 

func (x *Pubsub) GetSubscription() string

func (*Pubsub) GetTopic 

func (x *Pubsub) GetTopic() string

func (*Pubsub) ProtoMessage 

func (*Pubsub) ProtoMessage()

func (*Pubsub) ProtoReflect 

func (x *Pubsub) ProtoReflect() protoreflect.Message

func (*Pubsub) Reset 

func (x *Pubsub) Reset()

func (*Pubsub) String 

func (x *Pubsub) String() string

type StateCondition 

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
}

A condition that is part of the trigger state computation.

func (*StateCondition) Descriptor deprecated 

func (*StateCondition) Descriptor() ([]byte, []int)

Deprecated: Use StateCondition.ProtoReflect.Descriptor instead.

func (*StateCondition) GetCode 

func (x *StateCondition) GetCode() code.Code

func (*StateCondition) GetMessage 

func (x *StateCondition) GetMessage() string

func (*StateCondition) ProtoMessage 

func (*StateCondition) ProtoMessage()

func (*StateCondition) ProtoReflect 

func (x *StateCondition) ProtoReflect() protoreflect.Message

func (*StateCondition) Reset 

func (x *StateCondition) Reset()

func (*StateCondition) String 

func (x *StateCondition) String() string

type Transport 

type Transport struct {

	// Types that are assignable to Intermediary:
	//
	//	*Transport_Pubsub
	Intermediary isTransport_Intermediary `protobuf_oneof:"intermediary"`
	// contains filtered or unexported fields
}

Represents the transport intermediaries created for the trigger to deliver events.

func (*Transport) Descriptor deprecated 

func (*Transport) Descriptor() ([]byte, []int)

Deprecated: Use Transport.ProtoReflect.Descriptor instead.

func (*Transport) GetIntermediary 

func (m *Transport) GetIntermediary() isTransport_Intermediary

func (*Transport) GetPubsub 

func (x *Transport) GetPubsub() *Pubsub

func (*Transport) ProtoMessage 

func (*Transport) ProtoMessage()

func (*Transport) ProtoReflect 

func (x *Transport) ProtoReflect() protoreflect.Message

func (*Transport) Reset 

func (x *Transport) Reset()

func (*Transport) String 

func (x *Transport) String() string

type Transport_Pubsub 

type Transport_Pubsub struct {
	// The Pub/Sub topic and subscription used by Eventarc as a transport
	// intermediary.
	Pubsub *Pubsub `protobuf:"bytes,1,opt,name=pubsub,proto3,oneof"`
}

type Trigger 

type Trigger struct {

	// Required. The resource name of the trigger. Must be unique within the
	// location of the project and must be in
	// `projects/{project}/locations/{location}/triggers/{trigger}` format.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Output only. Server-assigned unique identifier for the trigger. 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"`
	// Required. Unordered list. The list of filters that applies to event
	// attributes. Only events that match all the provided filters are sent to the
	// destination.
	EventFilters []*EventFilter `protobuf:"bytes,8,rep,name=event_filters,json=eventFilters,proto3" json:"event_filters,omitempty"`
	// Optional. The IAM service account email associated with the trigger. The
	// service account represents the identity of the trigger.
	//
	// The principal who calls this API must have the `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.
	//
	// For Cloud Run destinations, this service account is used to generate
	// identity tokens when invoking the service. See
	// https://cloud.google.com/run/docs/triggering/pubsub-push#create-service-account
	// for information on how to invoke authenticated Cloud Run services.
	// To create Audit Log triggers, the service account should also
	// have the `roles/eventarc.eventReceiver` IAM role.
	ServiceAccount string `protobuf:"bytes,9,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"`
	// Required. Destination specifies where the events should be sent to.
	Destination *Destination `protobuf:"bytes,10,opt,name=destination,proto3" json:"destination,omitempty"`
	// Optional. To deliver messages, Eventarc might use other Google Cloud
	// products as a transport intermediary. This field contains a reference to
	// that transport intermediary. This information can be used for debugging
	// purposes.
	Transport *Transport `protobuf:"bytes,11,opt,name=transport,proto3" json:"transport,omitempty"`
	// Optional. User labels attached to the triggers that can be used to group
	// resources.
	Labels map[string]string `` /* 154-byte string literal not displayed */
	// Optional. The name of the channel associated with the trigger in
	// `projects/{project}/locations/{location}/channels/{channel}` format.
	// You must provide a channel to receive events from Eventarc SaaS partners.
	Channel string `protobuf:"bytes,13,opt,name=channel,proto3" json:"channel,omitempty"`
	// Output only. The reason(s) why a trigger is in FAILED state.
	Conditions map[string]*StateCondition `` /* 162-byte string literal not displayed */
	// Optional. EventDataContentType specifies the type of payload in MIME
	// format that is expected from the CloudEvent data field. This is set to
	// `application/json` if the value is not defined.
	EventDataContentType string `` /* 126-byte string literal not displayed */
	// 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
}

A representation of the trigger resource.

func (*Trigger) Descriptor deprecated 

func (*Trigger) Descriptor() ([]byte, []int)

Deprecated: Use Trigger.ProtoReflect.Descriptor instead.

func (*Trigger) GetChannel 

func (x *Trigger) GetChannel() string

func (*Trigger) GetConditions 

func (x *Trigger) GetConditions() map[string]*StateCondition

func (*Trigger) GetCreateTime 

func (x *Trigger) GetCreateTime() *timestamppb.Timestamp

func (*Trigger) GetDestination 

func (x *Trigger) GetDestination() *Destination

func (*Trigger) GetEtag 

func (x *Trigger) GetEtag() string

func (*Trigger) GetEventDataContentType added in v0.5.0 

func (x *Trigger) GetEventDataContentType() string

func (*Trigger) GetEventFilters 

func (x *Trigger) GetEventFilters() []*EventFilter

func (*Trigger) GetLabels 

func (x *Trigger) GetLabels() map[string]string

func (*Trigger) GetName 

func (x *Trigger) GetName() string

func (*Trigger) GetServiceAccount 

func (x *Trigger) GetServiceAccount() string

func (*Trigger) GetTransport 

func (x *Trigger) GetTransport() *Transport

func (*Trigger) GetUid 

func (x *Trigger) GetUid() string

func (*Trigger) GetUpdateTime 

func (x *Trigger) GetUpdateTime() *timestamppb.Timestamp

func (*Trigger) ProtoMessage 

func (*Trigger) ProtoMessage()

func (*Trigger) ProtoReflect 

func (x *Trigger) ProtoReflect() protoreflect.Message

func (*Trigger) Reset 

func (x *Trigger) Reset()

func (*Trigger) String 

func (x *Trigger) String() string

type TriggerEventData 

type TriggerEventData struct {

	// The Trigger event payload.
	Payload *Trigger `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

The data within all Trigger events.

func (*TriggerEventData) Descriptor deprecated 

func (*TriggerEventData) Descriptor() ([]byte, []int)

Deprecated: Use TriggerEventData.ProtoReflect.Descriptor instead.

func (*TriggerEventData) GetPayload 

func (x *TriggerEventData) GetPayload() *Trigger

func (*TriggerEventData) ProtoMessage 

func (*TriggerEventData) ProtoMessage()

func (*TriggerEventData) ProtoReflect 

func (x *TriggerEventData) ProtoReflect() protoreflect.Message

func (*TriggerEventData) Reset 

func (x *TriggerEventData) Reset()

func (*TriggerEventData) String 

func (x *TriggerEventData) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.