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_google_channel_config_proto
var File_google_cloud_eventarc_v1_google_channel_config_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 *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
// Output only. The last-modified time.
UpdateTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
// The name of the event provider (e.g. Eventarc SaaS partner) associated
// with the channel. This provider will be granted permissions to publish
// events to the channel. Format:
// `projects/{project}/locations/{location}/providers/{provider_id}`.
Provider string `protobuf:"bytes,7,opt,name=provider,proto3" json:"provider,omitempty"`
// Types that are assignable to Transport:
//
// *Channel_PubsubTopic
Transport isChannel_Transport `protobuf_oneof:"transport"`
// Output only. The state of a Channel.
State Channel_State `protobuf:"varint,9,opt,name=state,proto3,enum=google.cloud.eventarc.v1.Channel_State" json:"state,omitempty"`
// Output only. The activation token for the channel. The token must be used
// by the provider to register the channel for publishing.
ActivationToken string `protobuf:"bytes,10,opt,name=activation_token,json=activationToken,proto3" json:"activation_token,omitempty"`
// Optional. Resource name of a KMS crypto key (managed by the user) used to
// encrypt/decrypt their event data.
//
// It must match the pattern
// `projects/*/locations/*/keyRings/*/cryptoKeys/*`.
CryptoKeyName string `protobuf:"bytes,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: Use Channel.ProtoReflect.Descriptor instead.
func (*Channel) GetActivationToken
func (*Channel) GetCreateTime
func (x *Channel) GetCreateTime() *timestamppb.Timestamp
func (*Channel) GetCryptoKeyName
func (*Channel) GetName
func (*Channel) GetProvider
func (*Channel) GetPubsubTopic
func (*Channel) GetState
func (x *Channel) GetState() Channel_State
func (*Channel) GetTransport
func (m *Channel) GetTransport() isChannel_Transport
func (*Channel) GetUid
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
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"`
// 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() *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
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 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
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
Deprecated: Use CloudRun.ProtoReflect.Descriptor instead.
func (*CloudRun) GetPath
func (*CloudRun) GetRegion
func (*CloudRun) GetService
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
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
// *Destination_Workflow
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) 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
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"`
}
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"`
}
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
Deprecated: Use EventType.ProtoReflect.Descriptor instead.
func (*EventType) GetDescription
func (*EventType) GetEventSchemaUri
func (*EventType) GetFilteringAttributes
func (x *EventType) GetFilteringAttributes() []*FilteringAttribute
func (*EventType) GetType
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
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)
// Get a GoogleChannelConfig
GetGoogleChannelConfig(ctx context.Context, in *GetGoogleChannelConfigRequest, opts ...grpc.CallOption) (*GoogleChannelConfig, error)
// Update a single GoogleChannelConfig
UpdateGoogleChannelConfig(ctx context.Context, in *UpdateGoogleChannelConfigRequest, opts ...grpc.CallOption) (*GoogleChannelConfig, error)
}
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)
// Get a GoogleChannelConfig
GetGoogleChannelConfig(context.Context, *GetGoogleChannelConfigRequest) (*GoogleChannelConfig, error)
// Update a single GoogleChannelConfig
UpdateGoogleChannelConfig(context.Context, *UpdateGoogleChannelConfigRequest) (*GoogleChannelConfig, 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
Deprecated: Use GKE.ProtoReflect.Descriptor instead.
func (*GKE) GetCluster
func (*GKE) GetLocation
func (*GKE) GetNamespace
func (*GKE) GetPath
func (*GKE) GetService
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
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
GetGoogleChannelConfigRequest
type GetGoogleChannelConfigRequest struct {
// Required. The name of the config to get.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
The request message for the GetGoogleChannelConfig method.
func (*GetGoogleChannelConfigRequest) Descriptor
func (*GetGoogleChannelConfigRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetGoogleChannelConfigRequest.ProtoReflect.Descriptor instead.
func (*GetGoogleChannelConfigRequest) GetName
func (x *GetGoogleChannelConfigRequest) GetName() string
func (*GetGoogleChannelConfigRequest) ProtoMessage
func (*GetGoogleChannelConfigRequest) ProtoMessage()
func (*GetGoogleChannelConfigRequest) ProtoReflect
func (x *GetGoogleChannelConfigRequest) ProtoReflect() protoreflect.Message
func (*GetGoogleChannelConfigRequest) Reset
func (x *GetGoogleChannelConfigRequest) Reset()
func (*GetGoogleChannelConfigRequest) String
func (x *GetGoogleChannelConfigRequest) 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
GoogleChannelConfig
type GoogleChannelConfig struct {
// Required. The resource name of the config. Must be in the format of,
// `projects/{project}/locations/{location}/googleChannelConfig`.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Output only. The last-modified time.
UpdateTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
// Optional. Resource name of a KMS crypto key (managed by the user) used to
// encrypt/decrypt their event data.
//
// It must match the pattern
// `projects/*/locations/*/keyRings/*/cryptoKeys/*`.
CryptoKeyName string `protobuf:"bytes,7,opt,name=crypto_key_name,json=cryptoKeyName,proto3" json:"crypto_key_name,omitempty"`
// contains filtered or unexported fields
}
A GoogleChannelConfig is a resource that stores the custom settings respected by Eventarc first-party triggers in the matching region. Once configured, first-party event data will be protected using the specified custom managed encryption key instead of Google-managed encryption keys.
func (*GoogleChannelConfig) Descriptor
func (*GoogleChannelConfig) Descriptor() ([]byte, []int)
Deprecated: Use GoogleChannelConfig.ProtoReflect.Descriptor instead.
func (*GoogleChannelConfig) GetCryptoKeyName
func (x *GoogleChannelConfig) GetCryptoKeyName() string
func (*GoogleChannelConfig) GetName
func (x *GoogleChannelConfig) GetName() string
func (*GoogleChannelConfig) GetUpdateTime
func (x *GoogleChannelConfig) GetUpdateTime() *timestamppb.Timestamp
func (*GoogleChannelConfig) ProtoMessage
func (*GoogleChannelConfig) ProtoMessage()
func (*GoogleChannelConfig) ProtoReflect
func (x *GoogleChannelConfig) ProtoReflect() protoreflect.Message
func (*GoogleChannelConfig) Reset
func (x *GoogleChannelConfig) Reset()
func (*GoogleChannelConfig) String
func (x *GoogleChannelConfig) 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"`
// Filter field. Used to filter the Triggers to be listed. Possible filters
// are described in https://google.aip.dev/160. For example, using
// "?filter=destination:gke" would list only Triggers with a gke destination.
Filter string `protobuf:"bytes,5,opt,name=filter,proto3" json:"filter,omitempty"`
// contains filtered or unexported fields
}
The request message for the ListTriggers method.
func (*ListTriggersRequest) Descriptor
func (*ListTriggersRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListTriggersRequest.ProtoReflect.Descriptor instead.
func (*ListTriggersRequest) GetFilter
func (x *ListTriggersRequest) GetFilter() string
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 *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
// Output only. The time the operation finished running.
EndTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
// Output only. Server-defined resource path for the target of the operation.
Target string `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
// Output only. Name of the verb executed by the operation.
Verb string `protobuf:"bytes,4,opt,name=verb,proto3" json:"verb,omitempty"`
// Output only. Human-readable status of the operation, if any.
StatusMessage string `protobuf:"bytes,5,opt,name=status_message,json=statusMessage,proto3" json:"status_message,omitempty"`
// Output only. Identifies whether the user has requested cancellation
// of the operation. Operations that have successfully been cancelled
// have [Operation.error][] value with a [google.rpc.Status.code][google.rpc.Status.code] of 1,
// corresponding to `Code.CANCELLED`.
RequestedCancellation bool `protobuf:"varint,6,opt,name=requested_cancellation,json=requestedCancellation,proto3" json:"requested_cancellation,omitempty"`
// Output only. API version used to start the operation.
ApiVersion string `protobuf:"bytes,7,opt,name=api_version,json=apiVersion,proto3" json:"api_version,omitempty"`
// contains filtered or unexported fields
}
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() *timestamppb.Timestamp
func (*OperationMetadata) GetEndTime
func (x *OperationMetadata) GetEndTime() *timestamppb.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
Deprecated: Use Provider.ProtoReflect.Descriptor instead.
func (*Provider) GetDisplayName
func (*Provider) GetEventTypes
func (*Provider) GetName
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
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: Use Pubsub.ProtoReflect.Descriptor instead.
func (*Pubsub) GetSubscription
func (*Pubsub) GetTopic
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
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
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
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: Use Transport.ProtoReflect.Descriptor instead.
func (*Transport) GetIntermediary
func (m *Transport) GetIntermediary() isTransport_Intermediary
func (*Transport) GetPubsub
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
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 *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
UpdateTime *timestamppb.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"`
Conditions map[string]*StateCondition "" /* 162 byte string literal not displayed */
Etag string `protobuf:"bytes,99,opt,name=etag,proto3" json:"etag,omitempty"`
}
A representation of the trigger resource.
func (*Trigger) Descriptor
Deprecated: Use Trigger.ProtoReflect.Descriptor instead.
func (*Trigger) GetChannel
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 (*Trigger) GetEventFilters
func (x *Trigger) GetEventFilters() []*EventFilter
func (*Trigger) GetLabels
func (*Trigger) GetName
func (*Trigger) GetServiceAccount
func (*Trigger) GetTransport
func (*Trigger) GetUid
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
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) GetGoogleChannelConfig
func (*UnimplementedEventarcServer) GetGoogleChannelConfig(context.Context, *GetGoogleChannelConfigRequest) (*GoogleChannelConfig, 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) UpdateGoogleChannelConfig
func (*UnimplementedEventarcServer) UpdateGoogleChannelConfig(context.Context, *UpdateGoogleChannelConfigRequest) (*GoogleChannelConfig, 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 *fieldmaskpb.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() *fieldmaskpb.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
UpdateGoogleChannelConfigRequest
type UpdateGoogleChannelConfigRequest struct {
// Required. The config to be updated.
GoogleChannelConfig *GoogleChannelConfig `protobuf:"bytes,1,opt,name=google_channel_config,json=googleChannelConfig,proto3" json:"google_channel_config,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 *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
// contains filtered or unexported fields
}
The request message for the UpdateGoogleChannelConfig method.
func (*UpdateGoogleChannelConfigRequest) Descriptor
func (*UpdateGoogleChannelConfigRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateGoogleChannelConfigRequest.ProtoReflect.Descriptor instead.
func (*UpdateGoogleChannelConfigRequest) GetGoogleChannelConfig
func (x *UpdateGoogleChannelConfigRequest) GetGoogleChannelConfig() *GoogleChannelConfig
func (*UpdateGoogleChannelConfigRequest) GetUpdateMask
func (x *UpdateGoogleChannelConfigRequest) GetUpdateMask() *fieldmaskpb.FieldMask
func (*UpdateGoogleChannelConfigRequest) ProtoMessage
func (*UpdateGoogleChannelConfigRequest) ProtoMessage()
func (*UpdateGoogleChannelConfigRequest) ProtoReflect
func (x *UpdateGoogleChannelConfigRequest) ProtoReflect() protoreflect.Message
func (*UpdateGoogleChannelConfigRequest) Reset
func (x *UpdateGoogleChannelConfigRequest) Reset()
func (*UpdateGoogleChannelConfigRequest) String
func (x *UpdateGoogleChannelConfigRequest) 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 *fieldmaskpb.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() *fieldmaskpb.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