Package cloud.google.com/go/eventarc/apiv1/eventarcpb (v1.7.0)

Version 1.7.0

• 1.13.5 (latest)
• 1.13.4

Note: To get more information about this package, such as access to older versions, view this package on pkg.go.dev.

Variables

Channel_State_name, Channel_State_value

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.

File_google_cloud_eventarc_v1_channel_connection_proto

var File_google_cloud_eventarc_v1_channel_connection_proto protoreflect.FileDescriptor

File_google_cloud_eventarc_v1_channel_proto

var File_google_cloud_eventarc_v1_channel_proto protoreflect.FileDescriptor

File_google_cloud_eventarc_v1_discovery_proto

var File_google_cloud_eventarc_v1_discovery_proto protoreflect.FileDescriptor

File_google_cloud_eventarc_v1_eventarc_proto

var File_google_cloud_eventarc_v1_eventarc_proto protoreflect.FileDescriptor

File_google_cloud_eventarc_v1_trigger_proto

var File_google_cloud_eventarc_v1_trigger_proto protoreflect.FileDescriptor

Functions

func RegisterEventarcServer

func RegisterEventarcServer(s *grpc.Server, srv EventarcServer)

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 *timestamp.Timestamp `protobuf:"bytes,5,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The last-modified time.
	UpdateTime *timestamp.Timestamp `protobuf:"bytes,6,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Required. 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"`
	// 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

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() *timestamp.Timestamp

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() *timestamp.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

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 *timestamp.Timestamp `protobuf:"bytes,6,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The last-modified time.
	UpdateTime *timestamp.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
}

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

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

Deprecated: Use ChannelConnection.ProtoReflect.Descriptor instead.

func (*ChannelConnection) GetActivationToken

func (x *ChannelConnection) GetActivationToken() string

func (*ChannelConnection) GetChannel

func (x *ChannelConnection) GetChannel() string

func (*ChannelConnection) GetCreateTime

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

func (*ChannelConnection) GetName

func (x *ChannelConnection) GetName() string

func (*ChannelConnection) GetUid

func (x *ChannelConnection) GetUid() string

func (*ChannelConnection) GetUpdateTime

func (x *ChannelConnection) GetUpdateTime() *timestamp.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

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"`
}

Channel_State

type Channel_State int32

State lists all the possible states of a Channel

Channel_STATE_UNSPECIFIED, Channel_PENDING, Channel_ACTIVE, Channel_INACTIVE

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 means 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

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

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

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

CreateChannelConnectionRequest

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
}

The request message for the CreateChannelConnection method.

func (*CreateChannelConnectionRequest) Descriptor

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

Deprecated: Use CreateChannelConnectionRequest.ProtoReflect.Descriptor instead.

func (*CreateChannelConnectionRequest) GetChannelConnection

func (x *CreateChannelConnectionRequest) GetChannelConnection() *ChannelConnection

func (*CreateChannelConnectionRequest) GetChannelConnectionId

func (x *CreateChannelConnectionRequest) GetChannelConnectionId() string

func (*CreateChannelConnectionRequest) GetParent

func (x *CreateChannelConnectionRequest) GetParent() string

func (*CreateChannelConnectionRequest) ProtoMessage

func (*CreateChannelConnectionRequest) ProtoMessage()

func (*CreateChannelConnectionRequest) ProtoReflect

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

func (*CreateChannelConnectionRequest) Reset

func (x *CreateChannelConnectionRequest) Reset()

func (*CreateChannelConnectionRequest) String

func (x *CreateChannelConnectionRequest) String() string

CreateChannelRequest

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"`
	// Required. 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
}

The request message for the CreateChannel method.

func (*CreateChannelRequest) Descriptor

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

Deprecated: Use CreateChannelRequest.ProtoReflect.Descriptor instead.

func (*CreateChannelRequest) GetChannel

func (x *CreateChannelRequest) GetChannel() *Channel

func (*CreateChannelRequest) GetChannelId

func (x *CreateChannelRequest) GetChannelId() string

func (*CreateChannelRequest) GetParent

func (x *CreateChannelRequest) GetParent() string

func (*CreateChannelRequest) GetValidateOnly

func (x *CreateChannelRequest) GetValidateOnly() bool

func (*CreateChannelRequest) ProtoMessage

func (*CreateChannelRequest) ProtoMessage()

func (*CreateChannelRequest) ProtoReflect

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

func (*CreateChannelRequest) Reset

func (x *CreateChannelRequest) Reset()

func (*CreateChannelRequest) String

func (x *CreateChannelRequest) String() string

CreateTriggerRequest

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"`
	// Required. 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
}

The request message for the CreateTrigger method.

func (*CreateTriggerRequest) Descriptor

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

Deprecated: Use CreateTriggerRequest.ProtoReflect.Descriptor instead.

func (*CreateTriggerRequest) GetParent

func (x *CreateTriggerRequest) GetParent() string

func (*CreateTriggerRequest) GetTrigger

func (x *CreateTriggerRequest) GetTrigger() *Trigger

func (*CreateTriggerRequest) GetTriggerId

func (x *CreateTriggerRequest) GetTriggerId() string

func (*CreateTriggerRequest) GetValidateOnly

func (x *CreateTriggerRequest) GetValidateOnly() bool

func (*CreateTriggerRequest) ProtoMessage

func (*CreateTriggerRequest) ProtoMessage()

func (*CreateTriggerRequest) ProtoReflect

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

func (*CreateTriggerRequest) Reset

func (x *CreateTriggerRequest) Reset()

func (*CreateTriggerRequest) String

func (x *CreateTriggerRequest) String() string

DeleteChannelConnectionRequest

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
}

The request message for the DeleteChannelConnection method.

func (*DeleteChannelConnectionRequest) Descriptor

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

Deprecated: Use DeleteChannelConnectionRequest.ProtoReflect.Descriptor instead.

func (*DeleteChannelConnectionRequest) GetName

func (x *DeleteChannelConnectionRequest) GetName() string

func (*DeleteChannelConnectionRequest) ProtoMessage

func (*DeleteChannelConnectionRequest) ProtoMessage()

func (*DeleteChannelConnectionRequest) ProtoReflect

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

func (*DeleteChannelConnectionRequest) Reset

func (x *DeleteChannelConnectionRequest) Reset()

func (*DeleteChannelConnectionRequest) String

func (x *DeleteChannelConnectionRequest) String() string

DeleteChannelRequest

type DeleteChannelRequest struct {

	// Required. The name of the channel to be deleted.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Required. 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
}

The request message for the DeleteChannel method.

func (*DeleteChannelRequest) Descriptor

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

Deprecated: Use DeleteChannelRequest.ProtoReflect.Descriptor instead.

func (*DeleteChannelRequest) GetName

func (x *DeleteChannelRequest) GetName() string

func (*DeleteChannelRequest) GetValidateOnly

func (x *DeleteChannelRequest) GetValidateOnly() bool

func (*DeleteChannelRequest) ProtoMessage

func (*DeleteChannelRequest) ProtoMessage()

func (*DeleteChannelRequest) ProtoReflect

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

func (*DeleteChannelRequest) Reset

func (x *DeleteChannelRequest) Reset()

func (*DeleteChannelRequest) String

func (x *DeleteChannelRequest) String() string

DeleteTriggerRequest

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"`
	// Required. 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
}

The request message for the DeleteTrigger method.

func (*DeleteTriggerRequest) Descriptor

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

Deprecated: Use DeleteTriggerRequest.ProtoReflect.Descriptor instead.

func (*DeleteTriggerRequest) GetAllowMissing

func (x *DeleteTriggerRequest) GetAllowMissing() bool

func (*DeleteTriggerRequest) GetEtag

func (x *DeleteTriggerRequest) GetEtag() string

func (*DeleteTriggerRequest) GetName

func (x *DeleteTriggerRequest) GetName() string

func (*DeleteTriggerRequest) GetValidateOnly

func (x *DeleteTriggerRequest) GetValidateOnly() bool

func (*DeleteTriggerRequest) ProtoMessage

func (*DeleteTriggerRequest) ProtoMessage()

func (*DeleteTriggerRequest) ProtoReflect

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

func (*DeleteTriggerRequest) Reset

func (x *DeleteTriggerRequest) Reset()

func (*DeleteTriggerRequest) String

func (x *DeleteTriggerRequest) String() string

Destination

type Destination struct {

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

Represents a target of an invocation over HTTP.

func (*Destination) Descriptor

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) 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

Destination_CloudFunction

type Destination_CloudFunction struct {
	// The Cloud Function resource name. Only Cloud Functions V2 is supported.
	// Format: `projects/{project}/locations/{location}/functions/{function}`
	CloudFunction string `protobuf:"bytes,2,opt,name=cloud_function,json=cloudFunction,proto3,oneof"`
}

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"`
}

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"`
}

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

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

EventType

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
}

A representation of the event type resource.

func (*EventType) Descriptor

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

Deprecated: Use EventType.ProtoReflect.Descriptor instead.

func (*EventType) GetDescription

func (x *EventType) GetDescription() string

func (*EventType) GetEventSchemaUri

func (x *EventType) GetEventSchemaUri() string

func (*EventType) GetFilteringAttributes

func (x *EventType) GetFilteringAttributes() []*FilteringAttribute

func (*EventType) GetType

func (x *EventType) GetType() string

func (*EventType) ProtoMessage

func (*EventType) ProtoMessage()

func (*EventType) ProtoReflect

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

func (*EventType) Reset

func (x *EventType) Reset()

func (*EventType) String

func (x *EventType) String() string

EventarcClient

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) (*longrunning.Operation, error)
	// Update a single trigger.
	UpdateTrigger(ctx context.Context, in *UpdateTriggerRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// Delete a single trigger.
	DeleteTrigger(ctx context.Context, in *DeleteTriggerRequest, opts ...grpc.CallOption) (*longrunning.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) (*longrunning.Operation, error)
	// Update a single channel.
	UpdateChannel(ctx context.Context, in *UpdateChannelRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// Delete a single channel.
	DeleteChannel(ctx context.Context, in *DeleteChannelRequest, opts ...grpc.CallOption) (*longrunning.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) (*longrunning.Operation, error)
	// Delete a single ChannelConnection.
	DeleteChannelConnection(ctx context.Context, in *DeleteChannelConnectionRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
}

EventarcClient is the client API for Eventarc service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewEventarcClient

func NewEventarcClient(cc grpc.ClientConnInterface) EventarcClient

EventarcServer

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) (*longrunning.Operation, error)
	// Update a single trigger.
	UpdateTrigger(context.Context, *UpdateTriggerRequest) (*longrunning.Operation, error)
	// Delete a single trigger.
	DeleteTrigger(context.Context, *DeleteTriggerRequest) (*longrunning.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) (*longrunning.Operation, error)
	// Update a single channel.
	UpdateChannel(context.Context, *UpdateChannelRequest) (*longrunning.Operation, error)
	// Delete a single channel.
	DeleteChannel(context.Context, *DeleteChannelRequest) (*longrunning.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) (*longrunning.Operation, error)
	// Delete a single ChannelConnection.
	DeleteChannelConnection(context.Context, *DeleteChannelConnectionRequest) (*longrunning.Operation, error)
}

EventarcServer is the server API for Eventarc service.

FilteringAttribute

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
}

A representation of the FilteringAttribute resource. Filtering attributes are per event type.

func (*FilteringAttribute) Descriptor

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

Deprecated: Use FilteringAttribute.ProtoReflect.Descriptor instead.

func (*FilteringAttribute) GetAttribute

func (x *FilteringAttribute) GetAttribute() string

func (*FilteringAttribute) GetDescription

func (x *FilteringAttribute) GetDescription() string

func (*FilteringAttribute) GetPathPatternSupported

func (x *FilteringAttribute) GetPathPatternSupported() bool

func (*FilteringAttribute) GetRequired

func (x *FilteringAttribute) GetRequired() bool

func (*FilteringAttribute) ProtoMessage

func (*FilteringAttribute) ProtoMessage()

func (*FilteringAttribute) ProtoReflect

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

func (*FilteringAttribute) Reset

func (x *FilteringAttribute) Reset()

func (*FilteringAttribute) String

func (x *FilteringAttribute) String() string

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

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

GetChannelConnectionRequest

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
}

The request message for the GetChannelConnection method.

func (*GetChannelConnectionRequest) Descriptor

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

Deprecated: Use GetChannelConnectionRequest.ProtoReflect.Descriptor instead.

func (*GetChannelConnectionRequest) GetName

func (x *GetChannelConnectionRequest) GetName() string

func (*GetChannelConnectionRequest) ProtoMessage

func (*GetChannelConnectionRequest) ProtoMessage()

func (*GetChannelConnectionRequest) ProtoReflect

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

func (*GetChannelConnectionRequest) Reset

func (x *GetChannelConnectionRequest) Reset()

func (*GetChannelConnectionRequest) String

func (x *GetChannelConnectionRequest) String() string

GetChannelRequest

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
}

The request message for the GetChannel method.

func (*GetChannelRequest) Descriptor

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

Deprecated: Use GetChannelRequest.ProtoReflect.Descriptor instead.

func (*GetChannelRequest) GetName

func (x *GetChannelRequest) GetName() string

func (*GetChannelRequest) ProtoMessage

func (*GetChannelRequest) ProtoMessage()

func (*GetChannelRequest) ProtoReflect

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

func (*GetChannelRequest) Reset

func (x *GetChannelRequest) Reset()

func (*GetChannelRequest) String

func (x *GetChannelRequest) String() string

GetProviderRequest

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
}

The request message for the GetProvider method.

func (*GetProviderRequest) Descriptor

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

Deprecated: Use GetProviderRequest.ProtoReflect.Descriptor instead.

func (*GetProviderRequest) GetName

func (x *GetProviderRequest) GetName() string

func (*GetProviderRequest) ProtoMessage

func (*GetProviderRequest) ProtoMessage()

func (*GetProviderRequest) ProtoReflect

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

func (*GetProviderRequest) Reset

func (x *GetProviderRequest) Reset()

func (*GetProviderRequest) String

func (x *GetProviderRequest) String() string

GetTriggerRequest

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
}

The request message for the GetTrigger method.

func (*GetTriggerRequest) Descriptor

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

Deprecated: Use GetTriggerRequest.ProtoReflect.Descriptor instead.

func (*GetTriggerRequest) GetName

func (x *GetTriggerRequest) GetName() string

func (*GetTriggerRequest) ProtoMessage

func (*GetTriggerRequest) ProtoMessage()

func (*GetTriggerRequest) ProtoReflect

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

func (*GetTriggerRequest) Reset

func (x *GetTriggerRequest) Reset()

func (*GetTriggerRequest) String

func (x *GetTriggerRequest) String() string

ListChannelConnectionsRequest

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
}

The request message for the ListChannelConnections method.

func (*ListChannelConnectionsRequest) Descriptor

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

Deprecated: Use ListChannelConnectionsRequest.ProtoReflect.Descriptor instead.

func (*ListChannelConnectionsRequest) GetPageSize

func (x *ListChannelConnectionsRequest) GetPageSize() int32

func (*ListChannelConnectionsRequest) GetPageToken

func (x *ListChannelConnectionsRequest) GetPageToken() string

func (*ListChannelConnectionsRequest) GetParent

func (x *ListChannelConnectionsRequest) GetParent() string

func (*ListChannelConnectionsRequest) ProtoMessage

func (*ListChannelConnectionsRequest) ProtoMessage()

func (*ListChannelConnectionsRequest) ProtoReflect

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

func (*ListChannelConnectionsRequest) Reset

func (x *ListChannelConnectionsRequest) Reset()

func (*ListChannelConnectionsRequest) String

func (x *ListChannelConnectionsRequest) String() string

ListChannelConnectionsResponse

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
}

The response message for the ListChannelConnections method.

func (*ListChannelConnectionsResponse) Descriptor

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

Deprecated: Use ListChannelConnectionsResponse.ProtoReflect.Descriptor instead.

func (*ListChannelConnectionsResponse) GetChannelConnections

func (x *ListChannelConnectionsResponse) GetChannelConnections() []*ChannelConnection

func (*ListChannelConnectionsResponse) GetNextPageToken

func (x *ListChannelConnectionsResponse) GetNextPageToken() string

func (*ListChannelConnectionsResponse) GetUnreachable

func (x *ListChannelConnectionsResponse) GetUnreachable() []string

func (*ListChannelConnectionsResponse) ProtoMessage

func (*ListChannelConnectionsResponse) ProtoMessage()

func (*ListChannelConnectionsResponse) ProtoReflect

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

func (*ListChannelConnectionsResponse) Reset

func (x *ListChannelConnectionsResponse) Reset()

func (*ListChannelConnectionsResponse) String

func (x *ListChannelConnectionsResponse) String() string

ListChannelsRequest

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
}

The request message for the ListChannels method.

func (*ListChannelsRequest) Descriptor

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

Deprecated: Use ListChannelsRequest.ProtoReflect.Descriptor instead.

func (*ListChannelsRequest) GetOrderBy

func (x *ListChannelsRequest) GetOrderBy() string

func (*ListChannelsRequest) GetPageSize

func (x *ListChannelsRequest) GetPageSize() int32

func (*ListChannelsRequest) GetPageToken

func (x *ListChannelsRequest) GetPageToken() string

func (*ListChannelsRequest) GetParent

func (x *ListChannelsRequest) GetParent() string

func (*ListChannelsRequest) ProtoMessage

func (*ListChannelsRequest) ProtoMessage()

func (*ListChannelsRequest) ProtoReflect

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

func (*ListChannelsRequest) Reset

func (x *ListChannelsRequest) Reset()

func (*ListChannelsRequest) String

func (x *ListChannelsRequest) String() string

ListChannelsResponse

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
}

The response message for the ListChannels method.

func (*ListChannelsResponse) Descriptor

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

Deprecated: Use ListChannelsResponse.ProtoReflect.Descriptor instead.

func (*ListChannelsResponse) GetChannels

func (x *ListChannelsResponse) GetChannels() []*Channel

func (*ListChannelsResponse) GetNextPageToken

func (x *ListChannelsResponse) GetNextPageToken() string

func (*ListChannelsResponse) GetUnreachable

func (x *ListChannelsResponse) GetUnreachable() []string

func (*ListChannelsResponse) ProtoMessage

func (*ListChannelsResponse) ProtoMessage()

func (*ListChannelsResponse) ProtoReflect

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

func (*ListChannelsResponse) Reset

func (x *ListChannelsResponse) Reset()

func (*ListChannelsResponse) String

func (x *ListChannelsResponse) String() string

ListProvidersRequest

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
}

The request message for the ListProviders method.

func (*ListProvidersRequest) Descriptor

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

Deprecated: Use ListProvidersRequest.ProtoReflect.Descriptor instead.

func (*ListProvidersRequest) GetFilter

func (x *ListProvidersRequest) GetFilter() string

func (*ListProvidersRequest) GetOrderBy

func (x *ListProvidersRequest) GetOrderBy() string

func (*ListProvidersRequest) GetPageSize

func (x *ListProvidersRequest) GetPageSize() int32

func (*ListProvidersRequest) GetPageToken

func (x *ListProvidersRequest) GetPageToken() string

func (*ListProvidersRequest) GetParent

func (x *ListProvidersRequest) GetParent() string

func (*ListProvidersRequest) ProtoMessage

func (*ListProvidersRequest) ProtoMessage()

func (*ListProvidersRequest) ProtoReflect

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

func (*ListProvidersRequest) Reset

func (x *ListProvidersRequest) Reset()

func (*ListProvidersRequest) String

func (x *ListProvidersRequest) String() string

ListProvidersResponse

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
}

The response message for the ListProviders method.

func (*ListProvidersResponse) Descriptor

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

Deprecated: Use ListProvidersResponse.ProtoReflect.Descriptor instead.

func (*ListProvidersResponse) GetNextPageToken

func (x *ListProvidersResponse) GetNextPageToken() string

func (*ListProvidersResponse) GetProviders

func (x *ListProvidersResponse) GetProviders() []*Provider

func (*ListProvidersResponse) GetUnreachable

func (x *ListProvidersResponse) GetUnreachable() []string

func (*ListProvidersResponse) ProtoMessage

func (*ListProvidersResponse) ProtoMessage()

func (*ListProvidersResponse) ProtoReflect

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

func (*ListProvidersResponse) Reset

func (x *ListProvidersResponse) Reset()

func (*ListProvidersResponse) String

func (x *ListProvidersResponse) String() string

ListTriggersRequest

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

The request message for the ListTriggers method.

func (*ListTriggersRequest) Descriptor

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

Deprecated: Use ListTriggersRequest.ProtoReflect.Descriptor instead.

func (*ListTriggersRequest) GetOrderBy

func (x *ListTriggersRequest) GetOrderBy() string

func (*ListTriggersRequest) GetPageSize

func (x *ListTriggersRequest) GetPageSize() int32

func (*ListTriggersRequest) GetPageToken

func (x *ListTriggersRequest) GetPageToken() string

func (*ListTriggersRequest) GetParent

func (x *ListTriggersRequest) GetParent() string

func (*ListTriggersRequest) ProtoMessage

func (*ListTriggersRequest) ProtoMessage()

func (*ListTriggersRequest) ProtoReflect

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

func (*ListTriggersRequest) Reset

func (x *ListTriggersRequest) Reset()

func (*ListTriggersRequest) String

func (x *ListTriggersRequest) String() string

ListTriggersResponse

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
}

The response message for the ListTriggers method.

func (*ListTriggersResponse) Descriptor

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

Deprecated: Use ListTriggersResponse.ProtoReflect.Descriptor instead.

func (*ListTriggersResponse) GetNextPageToken

func (x *ListTriggersResponse) GetNextPageToken() string

func (*ListTriggersResponse) GetTriggers

func (x *ListTriggersResponse) GetTriggers() []*Trigger

func (*ListTriggersResponse) GetUnreachable

func (x *ListTriggersResponse) GetUnreachable() []string

func (*ListTriggersResponse) ProtoMessage

func (*ListTriggersResponse) ProtoMessage()

func (*ListTriggersResponse) ProtoReflect

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

func (*ListTriggersResponse) Reset

func (x *ListTriggersResponse) Reset()

func (*ListTriggersResponse) String

func (x *ListTriggersResponse) String() string

OperationMetadata

type OperationMetadata struct {

	// Output only. The time the operation was created.
	CreateTime *timestamp.Timestamp `protobuf:"bytes,1,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The time the operation finished running.
	EndTime *timestamp.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
}

Represents the metadata of the long-running operation.

func (*OperationMetadata) Descriptor

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

Deprecated: Use OperationMetadata.ProtoReflect.Descriptor instead.

func (*OperationMetadata) GetApiVersion

func (x *OperationMetadata) GetApiVersion() string

func (*OperationMetadata) GetCreateTime

func (x *OperationMetadata) GetCreateTime() *timestamp.Timestamp

func (*OperationMetadata) GetEndTime

func (x *OperationMetadata) GetEndTime() *timestamp.Timestamp

func (*OperationMetadata) GetRequestedCancellation

func (x *OperationMetadata) GetRequestedCancellation() bool

func (*OperationMetadata) GetStatusMessage

func (x *OperationMetadata) GetStatusMessage() string

func (*OperationMetadata) GetTarget

func (x *OperationMetadata) GetTarget() string

func (*OperationMetadata) GetVerb

func (x *OperationMetadata) GetVerb() string

func (*OperationMetadata) ProtoMessage

func (*OperationMetadata) ProtoMessage()

func (*OperationMetadata) ProtoReflect

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

func (*OperationMetadata) Reset

func (x *OperationMetadata) Reset()

func (*OperationMetadata) String

func (x *OperationMetadata) String() string

Provider

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
}

A representation of the Provider resource.

func (*Provider) Descriptor

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

Deprecated: Use Provider.ProtoReflect.Descriptor instead.

func (*Provider) GetDisplayName

func (x *Provider) GetDisplayName() string

func (*Provider) GetEventTypes

func (x *Provider) GetEventTypes() []*EventType

func (*Provider) GetName

func (x *Provider) GetName() string

func (*Provider) ProtoMessage

func (*Provider) ProtoMessage()

func (*Provider) ProtoReflect

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

func (*Provider) Reset

func (x *Provider) Reset()

func (*Provider) String

func (x *Provider) String() string

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

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

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

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

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"`
}

Trigger

type Trigger struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`

	Uid string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`

	CreateTime *timestamp.Timestamp `protobuf:"bytes,5,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`

	UpdateTime *timestamp.Timestamp `protobuf:"bytes,6,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`

	EventFilters []*EventFilter `protobuf:"bytes,8,rep,name=event_filters,json=eventFilters,proto3" json:"event_filters,omitempty"`

	ServiceAccount string `protobuf:"bytes,9,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"`

	Destination *Destination `protobuf:"bytes,10,opt,name=destination,proto3" json:"destination,omitempty"`

	Transport *Transport `protobuf:"bytes,11,opt,name=transport,proto3" json:"transport,omitempty"`

	Labels map[string]string "" /* 154 byte string literal not displayed */

	Channel string `protobuf:"bytes,13,opt,name=channel,proto3" json:"channel,omitempty"`

	Etag string `protobuf:"bytes,99,opt,name=etag,proto3" json:"etag,omitempty"`

}

A representation of the trigger resource.

func (*Trigger) Descriptor

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

Deprecated: Use Trigger.ProtoReflect.Descriptor instead.

func (*Trigger) GetChannel

func (x *Trigger) GetChannel() string

func (*Trigger) GetCreateTime

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

func (*Trigger) GetDestination

func (x *Trigger) GetDestination() *Destination

func (*Trigger) GetEtag

func (x *Trigger) GetEtag() 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() *timestamp.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

UnimplementedEventarcServer

type UnimplementedEventarcServer struct {
}

UnimplementedEventarcServer can be embedded to have forward compatible implementations.

func (*UnimplementedEventarcServer) CreateChannel

func (*UnimplementedEventarcServer) CreateChannel(context.Context, *CreateChannelRequest) (*longrunning.Operation, error)

func (*UnimplementedEventarcServer) CreateChannelConnection

func (*UnimplementedEventarcServer) CreateChannelConnection(context.Context, *CreateChannelConnectionRequest) (*longrunning.Operation, error)

func (*UnimplementedEventarcServer) CreateTrigger

func (*UnimplementedEventarcServer) CreateTrigger(context.Context, *CreateTriggerRequest) (*longrunning.Operation, error)

func (*UnimplementedEventarcServer) DeleteChannel

func (*UnimplementedEventarcServer) DeleteChannel(context.Context, *DeleteChannelRequest) (*longrunning.Operation, error)

func (*UnimplementedEventarcServer) DeleteChannelConnection

func (*UnimplementedEventarcServer) DeleteChannelConnection(context.Context, *DeleteChannelConnectionRequest) (*longrunning.Operation, error)

func (*UnimplementedEventarcServer) DeleteTrigger

func (*UnimplementedEventarcServer) DeleteTrigger(context.Context, *DeleteTriggerRequest) (*longrunning.Operation, error)

func (*UnimplementedEventarcServer) GetChannel

func (*UnimplementedEventarcServer) GetChannel(context.Context, *GetChannelRequest) (*Channel, error)

func (*UnimplementedEventarcServer) GetChannelConnection

func (*UnimplementedEventarcServer) GetChannelConnection(context.Context, *GetChannelConnectionRequest) (*ChannelConnection, error)

func (*UnimplementedEventarcServer) GetProvider

func (*UnimplementedEventarcServer) GetProvider(context.Context, *GetProviderRequest) (*Provider, error)

func (*UnimplementedEventarcServer) GetTrigger

func (*UnimplementedEventarcServer) GetTrigger(context.Context, *GetTriggerRequest) (*Trigger, error)

func (*UnimplementedEventarcServer) ListChannelConnections

func (*UnimplementedEventarcServer) ListChannelConnections(context.Context, *ListChannelConnectionsRequest) (*ListChannelConnectionsResponse, error)

func (*UnimplementedEventarcServer) ListChannels

func (*UnimplementedEventarcServer) ListChannels(context.Context, *ListChannelsRequest) (*ListChannelsResponse, error)

func (*UnimplementedEventarcServer) ListProviders

func (*UnimplementedEventarcServer) ListProviders(context.Context, *ListProvidersRequest) (*ListProvidersResponse, error)

func (*UnimplementedEventarcServer) ListTriggers

func (*UnimplementedEventarcServer) ListTriggers(context.Context, *ListTriggersRequest) (*ListTriggersResponse, error)

func (*UnimplementedEventarcServer) UpdateChannel

func (*UnimplementedEventarcServer) UpdateChannel(context.Context, *UpdateChannelRequest) (*longrunning.Operation, error)

func (*UnimplementedEventarcServer) UpdateTrigger

func (*UnimplementedEventarcServer) UpdateTrigger(context.Context, *UpdateTriggerRequest) (*longrunning.Operation, error)

UpdateChannelRequest

type UpdateChannelRequest struct {

	// The channel to be updated.
	Channel *Channel `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	// The fields to be updated; only fields explicitly provided are updated.
	// If no field mask is provided, all provided fields in the request are
	// updated. To update all fields, provide a field mask of "*".
	UpdateMask *field_mask.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// Required. If set, validate the request and preview the review, but do not
	// post it.
	ValidateOnly bool `protobuf:"varint,3,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// contains filtered or unexported fields
}

The request message for the UpdateChannel method.

func (*UpdateChannelRequest) Descriptor

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

Deprecated: Use UpdateChannelRequest.ProtoReflect.Descriptor instead.

func (*UpdateChannelRequest) GetChannel

func (x *UpdateChannelRequest) GetChannel() *Channel

func (*UpdateChannelRequest) GetUpdateMask

func (x *UpdateChannelRequest) GetUpdateMask() *field_mask.FieldMask

func (*UpdateChannelRequest) GetValidateOnly

func (x *UpdateChannelRequest) GetValidateOnly() bool

func (*UpdateChannelRequest) ProtoMessage

func (*UpdateChannelRequest) ProtoMessage()

func (*UpdateChannelRequest) ProtoReflect

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

func (*UpdateChannelRequest) Reset

func (x *UpdateChannelRequest) Reset()

func (*UpdateChannelRequest) String

func (x *UpdateChannelRequest) String() string

UpdateTriggerRequest

type UpdateTriggerRequest struct {

	// The trigger to be updated.
	Trigger *Trigger `protobuf:"bytes,1,opt,name=trigger,proto3" json:"trigger,omitempty"`
	// The fields to be updated; only fields explicitly provided are updated.
	// If no field mask is provided, all provided fields in the request are
	// updated. To update all fields, provide a field mask of "*".
	UpdateMask *field_mask.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// If set to true, and the trigger is not found, a new trigger will be
	// created. In this situation, `update_mask` is ignored.
	AllowMissing bool `protobuf:"varint,3,opt,name=allow_missing,json=allowMissing,proto3" json:"allow_missing,omitempty"`
	// Required. 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
}

The request message for the UpdateTrigger method.

func (*UpdateTriggerRequest) Descriptor

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

Deprecated: Use UpdateTriggerRequest.ProtoReflect.Descriptor instead.

func (*UpdateTriggerRequest) GetAllowMissing

func (x *UpdateTriggerRequest) GetAllowMissing() bool

func (*UpdateTriggerRequest) GetTrigger

func (x *UpdateTriggerRequest) GetTrigger() *Trigger

func (*UpdateTriggerRequest) GetUpdateMask

func (x *UpdateTriggerRequest) GetUpdateMask() *field_mask.FieldMask

func (*UpdateTriggerRequest) GetValidateOnly

func (x *UpdateTriggerRequest) GetValidateOnly() bool

func (*UpdateTriggerRequest) ProtoMessage

func (*UpdateTriggerRequest) ProtoMessage()

func (*UpdateTriggerRequest) ProtoReflect

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

func (*UpdateTriggerRequest) Reset

func (x *UpdateTriggerRequest) Reset()

func (*UpdateTriggerRequest) String

func (x *UpdateTriggerRequest) String() string