Documentation ¶
Index ¶
- Variables
- func RegisterEventarcServer(s *grpc.Server, srv EventarcServer)
- type Channel
- func (*Channel) Descriptor() ([]byte, []int)deprecated
- func (x *Channel) GetActivationToken() string
- func (x *Channel) GetCreateTime() *timestamppb.Timestamp
- func (x *Channel) GetCryptoKeyName() string
- func (x *Channel) GetName() string
- func (x *Channel) GetProvider() string
- func (x *Channel) GetPubsubTopic() string
- func (x *Channel) GetState() Channel_State
- func (m *Channel) GetTransport() isChannel_Transport
- func (x *Channel) GetUid() string
- func (x *Channel) GetUpdateTime() *timestamppb.Timestamp
- func (*Channel) ProtoMessage()
- func (x *Channel) ProtoReflect() protoreflect.Message
- func (x *Channel) Reset()
- func (x *Channel) String() string
- type ChannelConnection
- func (*ChannelConnection) Descriptor() ([]byte, []int)deprecated
- func (x *ChannelConnection) GetActivationToken() string
- func (x *ChannelConnection) GetChannel() string
- func (x *ChannelConnection) GetCreateTime() *timestamppb.Timestamp
- func (x *ChannelConnection) GetName() string
- func (x *ChannelConnection) GetUid() string
- func (x *ChannelConnection) GetUpdateTime() *timestamppb.Timestamp
- func (*ChannelConnection) ProtoMessage()
- func (x *ChannelConnection) ProtoReflect() protoreflect.Message
- func (x *ChannelConnection) Reset()
- func (x *ChannelConnection) String() string
- type Channel_PubsubTopic
- type Channel_State
- func (Channel_State) Descriptor() protoreflect.EnumDescriptor
- func (x Channel_State) Enum() *Channel_State
- func (Channel_State) EnumDescriptor() ([]byte, []int)deprecated
- func (x Channel_State) Number() protoreflect.EnumNumber
- func (x Channel_State) String() string
- func (Channel_State) Type() protoreflect.EnumType
- type CloudRun
- func (*CloudRun) Descriptor() ([]byte, []int)deprecated
- func (x *CloudRun) GetPath() string
- func (x *CloudRun) GetRegion() string
- func (x *CloudRun) GetService() string
- func (*CloudRun) ProtoMessage()
- func (x *CloudRun) ProtoReflect() protoreflect.Message
- func (x *CloudRun) Reset()
- func (x *CloudRun) String() string
- type CreateChannelConnectionRequest
- func (*CreateChannelConnectionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateChannelConnectionRequest) GetChannelConnection() *ChannelConnection
- func (x *CreateChannelConnectionRequest) GetChannelConnectionId() string
- func (x *CreateChannelConnectionRequest) GetParent() string
- func (*CreateChannelConnectionRequest) ProtoMessage()
- func (x *CreateChannelConnectionRequest) ProtoReflect() protoreflect.Message
- func (x *CreateChannelConnectionRequest) Reset()
- func (x *CreateChannelConnectionRequest) String() string
- type CreateChannelRequest
- func (*CreateChannelRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateChannelRequest) GetChannel() *Channel
- func (x *CreateChannelRequest) GetChannelId() string
- func (x *CreateChannelRequest) GetParent() string
- func (x *CreateChannelRequest) GetValidateOnly() bool
- func (*CreateChannelRequest) ProtoMessage()
- func (x *CreateChannelRequest) ProtoReflect() protoreflect.Message
- func (x *CreateChannelRequest) Reset()
- func (x *CreateChannelRequest) String() string
- type CreateTriggerRequest
- func (*CreateTriggerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateTriggerRequest) GetParent() string
- func (x *CreateTriggerRequest) GetTrigger() *Trigger
- func (x *CreateTriggerRequest) GetTriggerId() string
- func (x *CreateTriggerRequest) GetValidateOnly() bool
- func (*CreateTriggerRequest) ProtoMessage()
- func (x *CreateTriggerRequest) ProtoReflect() protoreflect.Message
- func (x *CreateTriggerRequest) Reset()
- func (x *CreateTriggerRequest) String() string
- type DeleteChannelConnectionRequest
- func (*DeleteChannelConnectionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteChannelConnectionRequest) GetName() string
- func (*DeleteChannelConnectionRequest) ProtoMessage()
- func (x *DeleteChannelConnectionRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteChannelConnectionRequest) Reset()
- func (x *DeleteChannelConnectionRequest) String() string
- type DeleteChannelRequest
- func (*DeleteChannelRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteChannelRequest) GetName() string
- func (x *DeleteChannelRequest) GetValidateOnly() bool
- func (*DeleteChannelRequest) ProtoMessage()
- func (x *DeleteChannelRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteChannelRequest) Reset()
- func (x *DeleteChannelRequest) String() string
- type DeleteTriggerRequest
- func (*DeleteTriggerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteTriggerRequest) GetAllowMissing() bool
- func (x *DeleteTriggerRequest) GetEtag() string
- func (x *DeleteTriggerRequest) GetName() string
- func (x *DeleteTriggerRequest) GetValidateOnly() bool
- func (*DeleteTriggerRequest) ProtoMessage()
- func (x *DeleteTriggerRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteTriggerRequest) Reset()
- func (x *DeleteTriggerRequest) String() string
- type Destination
- func (*Destination) Descriptor() ([]byte, []int)deprecated
- func (x *Destination) GetCloudFunction() string
- func (x *Destination) GetCloudRun() *CloudRun
- func (m *Destination) GetDescriptor_() isDestination_Descriptor_
- func (x *Destination) GetGke() *GKE
- func (x *Destination) GetWorkflow() string
- func (*Destination) ProtoMessage()
- func (x *Destination) ProtoReflect() protoreflect.Message
- func (x *Destination) Reset()
- func (x *Destination) String() string
- type Destination_CloudFunction
- type Destination_CloudRun
- type Destination_Gke
- type Destination_Workflow
- type EventFilter
- func (*EventFilter) Descriptor() ([]byte, []int)deprecated
- func (x *EventFilter) GetAttribute() string
- func (x *EventFilter) GetOperator() string
- func (x *EventFilter) GetValue() string
- func (*EventFilter) ProtoMessage()
- func (x *EventFilter) ProtoReflect() protoreflect.Message
- func (x *EventFilter) Reset()
- func (x *EventFilter) String() string
- type EventType
- func (*EventType) Descriptor() ([]byte, []int)deprecated
- func (x *EventType) GetDescription() string
- func (x *EventType) GetEventSchemaUri() string
- func (x *EventType) GetFilteringAttributes() []*FilteringAttribute
- func (x *EventType) GetType() string
- func (*EventType) ProtoMessage()
- func (x *EventType) ProtoReflect() protoreflect.Message
- func (x *EventType) Reset()
- func (x *EventType) String() string
- type EventarcClient
- type EventarcServer
- type FilteringAttribute
- func (*FilteringAttribute) Descriptor() ([]byte, []int)deprecated
- func (x *FilteringAttribute) GetAttribute() string
- func (x *FilteringAttribute) GetDescription() string
- func (x *FilteringAttribute) GetPathPatternSupported() bool
- func (x *FilteringAttribute) GetRequired() bool
- func (*FilteringAttribute) ProtoMessage()
- func (x *FilteringAttribute) ProtoReflect() protoreflect.Message
- func (x *FilteringAttribute) Reset()
- func (x *FilteringAttribute) String() string
- type GKE
- func (*GKE) Descriptor() ([]byte, []int)deprecated
- func (x *GKE) GetCluster() string
- func (x *GKE) GetLocation() string
- func (x *GKE) GetNamespace() string
- func (x *GKE) GetPath() string
- func (x *GKE) GetService() string
- func (*GKE) ProtoMessage()
- func (x *GKE) ProtoReflect() protoreflect.Message
- func (x *GKE) Reset()
- func (x *GKE) String() string
- type GetChannelConnectionRequest
- func (*GetChannelConnectionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetChannelConnectionRequest) GetName() string
- func (*GetChannelConnectionRequest) ProtoMessage()
- func (x *GetChannelConnectionRequest) ProtoReflect() protoreflect.Message
- func (x *GetChannelConnectionRequest) Reset()
- func (x *GetChannelConnectionRequest) String() string
- type GetChannelRequest
- type GetGoogleChannelConfigRequest
- func (*GetGoogleChannelConfigRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetGoogleChannelConfigRequest) GetName() string
- func (*GetGoogleChannelConfigRequest) ProtoMessage()
- func (x *GetGoogleChannelConfigRequest) ProtoReflect() protoreflect.Message
- func (x *GetGoogleChannelConfigRequest) Reset()
- func (x *GetGoogleChannelConfigRequest) String() string
- type GetProviderRequest
- func (*GetProviderRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetProviderRequest) GetName() string
- func (*GetProviderRequest) ProtoMessage()
- func (x *GetProviderRequest) ProtoReflect() protoreflect.Message
- func (x *GetProviderRequest) Reset()
- func (x *GetProviderRequest) String() string
- type GetTriggerRequest
- type GoogleChannelConfig
- func (*GoogleChannelConfig) Descriptor() ([]byte, []int)deprecated
- func (x *GoogleChannelConfig) GetCryptoKeyName() string
- func (x *GoogleChannelConfig) GetName() string
- func (x *GoogleChannelConfig) GetUpdateTime() *timestamppb.Timestamp
- func (*GoogleChannelConfig) ProtoMessage()
- func (x *GoogleChannelConfig) ProtoReflect() protoreflect.Message
- func (x *GoogleChannelConfig) Reset()
- func (x *GoogleChannelConfig) String() string
- type ListChannelConnectionsRequest
- func (*ListChannelConnectionsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListChannelConnectionsRequest) GetPageSize() int32
- func (x *ListChannelConnectionsRequest) GetPageToken() string
- func (x *ListChannelConnectionsRequest) GetParent() string
- func (*ListChannelConnectionsRequest) ProtoMessage()
- func (x *ListChannelConnectionsRequest) ProtoReflect() protoreflect.Message
- func (x *ListChannelConnectionsRequest) Reset()
- func (x *ListChannelConnectionsRequest) String() string
- type ListChannelConnectionsResponse
- func (*ListChannelConnectionsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListChannelConnectionsResponse) GetChannelConnections() []*ChannelConnection
- func (x *ListChannelConnectionsResponse) GetNextPageToken() string
- func (x *ListChannelConnectionsResponse) GetUnreachable() []string
- func (*ListChannelConnectionsResponse) ProtoMessage()
- func (x *ListChannelConnectionsResponse) ProtoReflect() protoreflect.Message
- func (x *ListChannelConnectionsResponse) Reset()
- func (x *ListChannelConnectionsResponse) String() string
- type ListChannelsRequest
- func (*ListChannelsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListChannelsRequest) GetOrderBy() string
- func (x *ListChannelsRequest) GetPageSize() int32
- func (x *ListChannelsRequest) GetPageToken() string
- func (x *ListChannelsRequest) GetParent() string
- func (*ListChannelsRequest) ProtoMessage()
- func (x *ListChannelsRequest) ProtoReflect() protoreflect.Message
- func (x *ListChannelsRequest) Reset()
- func (x *ListChannelsRequest) String() string
- type ListChannelsResponse
- func (*ListChannelsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListChannelsResponse) GetChannels() []*Channel
- func (x *ListChannelsResponse) GetNextPageToken() string
- func (x *ListChannelsResponse) GetUnreachable() []string
- func (*ListChannelsResponse) ProtoMessage()
- func (x *ListChannelsResponse) ProtoReflect() protoreflect.Message
- func (x *ListChannelsResponse) Reset()
- func (x *ListChannelsResponse) String() string
- type ListProvidersRequest
- func (*ListProvidersRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListProvidersRequest) GetFilter() string
- func (x *ListProvidersRequest) GetOrderBy() string
- func (x *ListProvidersRequest) GetPageSize() int32
- func (x *ListProvidersRequest) GetPageToken() string
- func (x *ListProvidersRequest) GetParent() string
- func (*ListProvidersRequest) ProtoMessage()
- func (x *ListProvidersRequest) ProtoReflect() protoreflect.Message
- func (x *ListProvidersRequest) Reset()
- func (x *ListProvidersRequest) String() string
- type ListProvidersResponse
- func (*ListProvidersResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListProvidersResponse) GetNextPageToken() string
- func (x *ListProvidersResponse) GetProviders() []*Provider
- func (x *ListProvidersResponse) GetUnreachable() []string
- func (*ListProvidersResponse) ProtoMessage()
- func (x *ListProvidersResponse) ProtoReflect() protoreflect.Message
- func (x *ListProvidersResponse) Reset()
- func (x *ListProvidersResponse) String() string
- type ListTriggersRequest
- func (*ListTriggersRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListTriggersRequest) GetFilter() string
- func (x *ListTriggersRequest) GetOrderBy() string
- func (x *ListTriggersRequest) GetPageSize() int32
- func (x *ListTriggersRequest) GetPageToken() string
- func (x *ListTriggersRequest) GetParent() string
- func (*ListTriggersRequest) ProtoMessage()
- func (x *ListTriggersRequest) ProtoReflect() protoreflect.Message
- func (x *ListTriggersRequest) Reset()
- func (x *ListTriggersRequest) String() string
- type ListTriggersResponse
- func (*ListTriggersResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListTriggersResponse) GetNextPageToken() string
- func (x *ListTriggersResponse) GetTriggers() []*Trigger
- func (x *ListTriggersResponse) GetUnreachable() []string
- func (*ListTriggersResponse) ProtoMessage()
- func (x *ListTriggersResponse) ProtoReflect() protoreflect.Message
- func (x *ListTriggersResponse) Reset()
- func (x *ListTriggersResponse) String() string
- type OperationMetadata
- func (*OperationMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *OperationMetadata) GetApiVersion() string
- func (x *OperationMetadata) GetCreateTime() *timestamppb.Timestamp
- func (x *OperationMetadata) GetEndTime() *timestamppb.Timestamp
- func (x *OperationMetadata) GetRequestedCancellation() bool
- func (x *OperationMetadata) GetStatusMessage() string
- func (x *OperationMetadata) GetTarget() string
- func (x *OperationMetadata) GetVerb() string
- func (*OperationMetadata) ProtoMessage()
- func (x *OperationMetadata) ProtoReflect() protoreflect.Message
- func (x *OperationMetadata) Reset()
- func (x *OperationMetadata) String() string
- type Provider
- func (*Provider) Descriptor() ([]byte, []int)deprecated
- func (x *Provider) GetDisplayName() string
- func (x *Provider) GetEventTypes() []*EventType
- func (x *Provider) GetName() string
- func (*Provider) ProtoMessage()
- func (x *Provider) ProtoReflect() protoreflect.Message
- func (x *Provider) Reset()
- func (x *Provider) String() string
- type Pubsub
- type StateCondition
- func (*StateCondition) Descriptor() ([]byte, []int)deprecated
- func (x *StateCondition) GetCode() code.Code
- func (x *StateCondition) GetMessage() string
- func (*StateCondition) ProtoMessage()
- func (x *StateCondition) ProtoReflect() protoreflect.Message
- func (x *StateCondition) Reset()
- func (x *StateCondition) String() string
- type Transport
- func (*Transport) Descriptor() ([]byte, []int)deprecated
- func (m *Transport) GetIntermediary() isTransport_Intermediary
- func (x *Transport) GetPubsub() *Pubsub
- func (*Transport) ProtoMessage()
- func (x *Transport) ProtoReflect() protoreflect.Message
- func (x *Transport) Reset()
- func (x *Transport) String() string
- type Transport_Pubsub
- type Trigger
- func (*Trigger) Descriptor() ([]byte, []int)deprecated
- func (x *Trigger) GetChannel() string
- func (x *Trigger) GetConditions() map[string]*StateCondition
- func (x *Trigger) GetCreateTime() *timestamppb.Timestamp
- func (x *Trigger) GetDestination() *Destination
- func (x *Trigger) GetEtag() string
- func (x *Trigger) GetEventFilters() []*EventFilter
- func (x *Trigger) GetLabels() map[string]string
- func (x *Trigger) GetName() string
- func (x *Trigger) GetServiceAccount() string
- func (x *Trigger) GetTransport() *Transport
- func (x *Trigger) GetUid() string
- func (x *Trigger) GetUpdateTime() *timestamppb.Timestamp
- func (*Trigger) ProtoMessage()
- func (x *Trigger) ProtoReflect() protoreflect.Message
- func (x *Trigger) Reset()
- func (x *Trigger) String() string
- type UnimplementedEventarcServer
- func (*UnimplementedEventarcServer) CreateChannel(context.Context, *CreateChannelRequest) (*longrunningpb.Operation, error)
- func (*UnimplementedEventarcServer) CreateChannelConnection(context.Context, *CreateChannelConnectionRequest) (*longrunningpb.Operation, error)
- func (*UnimplementedEventarcServer) CreateTrigger(context.Context, *CreateTriggerRequest) (*longrunningpb.Operation, error)
- func (*UnimplementedEventarcServer) DeleteChannel(context.Context, *DeleteChannelRequest) (*longrunningpb.Operation, error)
- func (*UnimplementedEventarcServer) DeleteChannelConnection(context.Context, *DeleteChannelConnectionRequest) (*longrunningpb.Operation, error)
- func (*UnimplementedEventarcServer) DeleteTrigger(context.Context, *DeleteTriggerRequest) (*longrunningpb.Operation, error)
- func (*UnimplementedEventarcServer) GetChannel(context.Context, *GetChannelRequest) (*Channel, error)
- func (*UnimplementedEventarcServer) GetChannelConnection(context.Context, *GetChannelConnectionRequest) (*ChannelConnection, error)
- func (*UnimplementedEventarcServer) GetGoogleChannelConfig(context.Context, *GetGoogleChannelConfigRequest) (*GoogleChannelConfig, error)
- func (*UnimplementedEventarcServer) GetProvider(context.Context, *GetProviderRequest) (*Provider, error)
- func (*UnimplementedEventarcServer) GetTrigger(context.Context, *GetTriggerRequest) (*Trigger, error)
- func (*UnimplementedEventarcServer) ListChannelConnections(context.Context, *ListChannelConnectionsRequest) (*ListChannelConnectionsResponse, error)
- func (*UnimplementedEventarcServer) ListChannels(context.Context, *ListChannelsRequest) (*ListChannelsResponse, error)
- func (*UnimplementedEventarcServer) ListProviders(context.Context, *ListProvidersRequest) (*ListProvidersResponse, error)
- func (*UnimplementedEventarcServer) ListTriggers(context.Context, *ListTriggersRequest) (*ListTriggersResponse, error)
- func (*UnimplementedEventarcServer) UpdateChannel(context.Context, *UpdateChannelRequest) (*longrunningpb.Operation, error)
- func (*UnimplementedEventarcServer) UpdateGoogleChannelConfig(context.Context, *UpdateGoogleChannelConfigRequest) (*GoogleChannelConfig, error)
- func (*UnimplementedEventarcServer) UpdateTrigger(context.Context, *UpdateTriggerRequest) (*longrunningpb.Operation, error)
- type UpdateChannelRequest
- func (*UpdateChannelRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateChannelRequest) GetChannel() *Channel
- func (x *UpdateChannelRequest) GetUpdateMask() *fieldmaskpb.FieldMask
- func (x *UpdateChannelRequest) GetValidateOnly() bool
- func (*UpdateChannelRequest) ProtoMessage()
- func (x *UpdateChannelRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateChannelRequest) Reset()
- func (x *UpdateChannelRequest) String() string
- type UpdateGoogleChannelConfigRequest
- func (*UpdateGoogleChannelConfigRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateGoogleChannelConfigRequest) GetGoogleChannelConfig() *GoogleChannelConfig
- func (x *UpdateGoogleChannelConfigRequest) GetUpdateMask() *fieldmaskpb.FieldMask
- func (*UpdateGoogleChannelConfigRequest) ProtoMessage()
- func (x *UpdateGoogleChannelConfigRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateGoogleChannelConfigRequest) Reset()
- func (x *UpdateGoogleChannelConfigRequest) String() string
- type UpdateTriggerRequest
- func (*UpdateTriggerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateTriggerRequest) GetAllowMissing() bool
- func (x *UpdateTriggerRequest) GetTrigger() *Trigger
- func (x *UpdateTriggerRequest) GetUpdateMask() *fieldmaskpb.FieldMask
- func (x *UpdateTriggerRequest) GetValidateOnly() bool
- func (*UpdateTriggerRequest) ProtoMessage()
- func (x *UpdateTriggerRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateTriggerRequest) Reset()
- func (x *UpdateTriggerRequest) String() string
Constants ¶
This section is empty.
Variables ¶
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.
var File_google_cloud_eventarc_v1_channel_connection_proto protoreflect.FileDescriptor
var File_google_cloud_eventarc_v1_channel_proto protoreflect.FileDescriptor
var File_google_cloud_eventarc_v1_discovery_proto protoreflect.FileDescriptor
var File_google_cloud_eventarc_v1_eventarc_proto protoreflect.FileDescriptor
var File_google_cloud_eventarc_v1_google_channel_config_proto protoreflect.FileDescriptor
var File_google_cloud_eventarc_v1_trigger_proto protoreflect.FileDescriptor
Functions ¶
func RegisterEventarcServer ¶
func RegisterEventarcServer(s *grpc.Server, srv EventarcServer)
Types ¶
type Channel ¶
type Channel struct { // Required. The resource name of the channel. Must be unique within the // location on the project and must be in // `projects/{project}/locations/{location}/channels/{channel_id}` format. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Output only. Server assigned unique identifier for the channel. The value // is a UUID4 string and guaranteed to remain unchanged until the resource is // deleted. Uid string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"` // Output only. The creation time. CreateTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"` // Output only. The last-modified time. UpdateTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"` // The name of the event provider (e.g. Eventarc SaaS partner) associated // with the channel. This provider will be granted permissions to publish // events to the channel. Format: // `projects/{project}/locations/{location}/providers/{provider_id}`. Provider string `protobuf:"bytes,7,opt,name=provider,proto3" json:"provider,omitempty"` // Types that are assignable to Transport: // // *Channel_PubsubTopic Transport isChannel_Transport `protobuf_oneof:"transport"` // Output only. The state of a Channel. State Channel_State `protobuf:"varint,9,opt,name=state,proto3,enum=google.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
func (*Channel) GetActivationToken ¶
func (*Channel) GetCreateTime ¶
func (x *Channel) GetCreateTime() *timestamppb.Timestamp
func (*Channel) GetCryptoKeyName ¶ added in v1.9.0
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) GetUpdateTime ¶
func (x *Channel) GetUpdateTime() *timestamppb.Timestamp
func (*Channel) ProtoMessage ¶
func (*Channel) ProtoMessage()
func (*Channel) ProtoReflect ¶
func (x *Channel) ProtoReflect() protoreflect.Message
type ChannelConnection ¶
type ChannelConnection struct { // Required. The name of the connection. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Output only. Server assigned ID of the resource. // The server guarantees uniqueness and immutability until deleted. Uid string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"` // Required. The name of the connected subscriber Channel. // This is a weak reference to avoid cross project and cross accounts // references. This must be in // `projects/{project}/location/{location}/channels/{channel_id}` format. Channel string `protobuf:"bytes,5,opt,name=channel,proto3" json:"channel,omitempty"` // Output only. The creation time. CreateTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"` // Output only. The last-modified time. UpdateTime *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"` // 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
deprecated
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
type Channel_PubsubTopic ¶
type Channel_PubsubTopic struct { // Output only. The name of the Pub/Sub topic created and managed by // Eventarc system as a transport for the event delivery. Format: // `projects/{project}/topics/{topic_id}`. PubsubTopic string `protobuf:"bytes,8,opt,name=pubsub_topic,json=pubsubTopic,proto3,oneof"` }
type Channel_State ¶
type Channel_State int32
State lists all the possible states of a Channel
const ( // Default value. This value is unused. Channel_STATE_UNSPECIFIED Channel_State = 0 // The PENDING state indicates that a Channel has been created successfully // and there is a new activation token available for the subscriber to use // to convey the Channel to the provider in order to create a Connection. Channel_PENDING Channel_State = 1 // The ACTIVE state indicates that a Channel has been successfully // connected with the event provider. // An ACTIVE Channel is ready to receive and route events from the // event provider. Channel_ACTIVE Channel_State = 2 // The INACTIVE state indicates that the Channel cannot receive events // permanently. There are two possible cases this state can happen: // // 1. The SaaS provider disconnected from this Channel. // 2. The Channel activation token has expired but the SaaS provider // wasn't connected. // // To re-establish a Connection with a provider, the subscriber // should create a new Channel and give it to the provider. Channel_INACTIVE Channel_State = 3 )
func (Channel_State) Descriptor ¶
func (Channel_State) Descriptor() protoreflect.EnumDescriptor
func (Channel_State) Enum ¶
func (x Channel_State) Enum() *Channel_State
func (Channel_State) EnumDescriptor
deprecated
func (Channel_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use Channel_State.Descriptor instead.
func (Channel_State) Number ¶
func (x Channel_State) Number() protoreflect.EnumNumber
func (Channel_State) String ¶
func (x Channel_State) String() string
func (Channel_State) Type ¶
func (Channel_State) Type() protoreflect.EnumType
type CloudRun ¶
type CloudRun struct { // Required. The name of the Cloud Run service being addressed. See // https://cloud.google.com/run/docs/reference/rest/v1/namespaces.services. // // Only services located in the same project as the trigger object // can be addressed. Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"` // Optional. The relative path on the Cloud Run service the events should be sent to. // // The value must conform to the definition of a URI path segment (section 3.3 // of RFC2396). Examples: "/route", "route", "route/subroute". Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` // Required. The region the Cloud Run service is deployed in. Region string `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"` // contains filtered or unexported fields }
Represents a Cloud Run destination.
func (*CloudRun) Descriptor
deprecated
func (*CloudRun) GetService ¶
func (*CloudRun) ProtoMessage ¶
func (*CloudRun) ProtoMessage()
func (*CloudRun) ProtoReflect ¶
func (x *CloudRun) ProtoReflect() protoreflect.Message
type 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
deprecated
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
type 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
deprecated
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
type 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
deprecated
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
type 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
deprecated
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
type 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
deprecated
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
type 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
deprecated
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
type Destination ¶
type Destination struct { // Types that are assignable to Descriptor_: // // *Destination_CloudRun // *Destination_CloudFunction // *Destination_Gke // *Destination_Workflow Descriptor_ isDestination_Descriptor_ `protobuf_oneof:"descriptor"` // contains filtered or unexported fields }
Represents a target of an invocation over HTTP.
func (*Destination) Descriptor
deprecated
func (*Destination) Descriptor() ([]byte, []int)
Deprecated: Use Destination.ProtoReflect.Descriptor instead.
func (*Destination) GetCloudFunction ¶
func (x *Destination) GetCloudFunction() string
func (*Destination) GetCloudRun ¶
func (x *Destination) GetCloudRun() *CloudRun
func (*Destination) GetDescriptor_ ¶
func (m *Destination) GetDescriptor_() isDestination_Descriptor_
func (*Destination) GetGke ¶
func (x *Destination) GetGke() *GKE
func (*Destination) GetWorkflow ¶ added in v1.9.0
func (x *Destination) GetWorkflow() string
func (*Destination) ProtoMessage ¶
func (*Destination) ProtoMessage()
func (*Destination) ProtoReflect ¶
func (x *Destination) ProtoReflect() protoreflect.Message
func (*Destination) Reset ¶
func (x *Destination) Reset()
func (*Destination) String ¶
func (x *Destination) String() string
type Destination_CloudFunction ¶
type Destination_CloudFunction struct { // The Cloud Function resource name. Only Cloud Functions V2 is supported. // Format: `projects/{project}/locations/{location}/functions/{function}` CloudFunction string `protobuf:"bytes,2,opt,name=cloud_function,json=cloudFunction,proto3,oneof"` }
type Destination_CloudRun ¶
type Destination_CloudRun struct { // Cloud Run fully-managed resource that receives the events. The resource // should be in the same project as the trigger. CloudRun *CloudRun `protobuf:"bytes,1,opt,name=cloud_run,json=cloudRun,proto3,oneof"` }
type Destination_Gke ¶
type Destination_Gke struct { // A GKE service capable of receiving events. The service should be running // in the same project as the trigger. Gke *GKE `protobuf:"bytes,3,opt,name=gke,proto3,oneof"` }
type Destination_Workflow ¶ added in v1.9.0
type Destination_Workflow struct { // The resource name of the Workflow whose Executions are triggered by // the events. The Workflow resource should be deployed in the same project // as the trigger. // Format: `projects/{project}/locations/{location}/workflows/{workflow}` Workflow string `protobuf:"bytes,4,opt,name=workflow,proto3,oneof"` }
type EventFilter ¶
type EventFilter struct { // Required. The name of a CloudEvents attribute. Currently, only a subset of attributes // are supported for filtering. // // All triggers MUST provide a filter for the 'type' attribute. Attribute string `protobuf:"bytes,1,opt,name=attribute,proto3" json:"attribute,omitempty"` // Required. The value for the attribute. Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // Optional. The operator used for matching the events with the value of the // filter. If not specified, only events that have an exact key-value pair // specified in the filter are matched. The only allowed value is // `match-path-pattern`. Operator string `protobuf:"bytes,3,opt,name=operator,proto3" json:"operator,omitempty"` // contains filtered or unexported fields }
Filters events based on exact matches on the CloudEvents attributes.
func (*EventFilter) Descriptor
deprecated
func (*EventFilter) Descriptor() ([]byte, []int)
Deprecated: Use EventFilter.ProtoReflect.Descriptor instead.
func (*EventFilter) GetAttribute ¶
func (x *EventFilter) GetAttribute() string
func (*EventFilter) GetOperator ¶
func (x *EventFilter) GetOperator() string
func (*EventFilter) GetValue ¶
func (x *EventFilter) GetValue() string
func (*EventFilter) ProtoMessage ¶
func (*EventFilter) ProtoMessage()
func (*EventFilter) ProtoReflect ¶
func (x *EventFilter) ProtoReflect() protoreflect.Message
func (*EventFilter) Reset ¶
func (x *EventFilter) Reset()
func (*EventFilter) String ¶
func (x *EventFilter) String() string
type 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
func (*EventType) GetDescription ¶
func (*EventType) GetEventSchemaUri ¶
func (*EventType) GetFilteringAttributes ¶
func (x *EventType) GetFilteringAttributes() []*FilteringAttribute
func (*EventType) ProtoMessage ¶
func (*EventType) ProtoMessage()
func (*EventType) ProtoReflect ¶
func (x *EventType) ProtoReflect() protoreflect.Message
type 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) (*longrunningpb.Operation, error) // Update a single trigger. UpdateTrigger(ctx context.Context, in *UpdateTriggerRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error) // Delete a single trigger. DeleteTrigger(ctx context.Context, in *DeleteTriggerRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error) // Get a single Channel. GetChannel(ctx context.Context, in *GetChannelRequest, opts ...grpc.CallOption) (*Channel, error) // List channels. ListChannels(ctx context.Context, in *ListChannelsRequest, opts ...grpc.CallOption) (*ListChannelsResponse, error) // Create a new channel in a particular project and location. CreateChannel(ctx context.Context, in *CreateChannelRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error) // Update a single channel. UpdateChannel(ctx context.Context, in *UpdateChannelRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error) // Delete a single channel. DeleteChannel(ctx context.Context, in *DeleteChannelRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error) // Get a single Provider. GetProvider(ctx context.Context, in *GetProviderRequest, opts ...grpc.CallOption) (*Provider, error) // List providers. ListProviders(ctx context.Context, in *ListProvidersRequest, opts ...grpc.CallOption) (*ListProvidersResponse, error) // Get a single ChannelConnection. GetChannelConnection(ctx context.Context, in *GetChannelConnectionRequest, opts ...grpc.CallOption) (*ChannelConnection, error) // List channel connections. ListChannelConnections(ctx context.Context, in *ListChannelConnectionsRequest, opts ...grpc.CallOption) (*ListChannelConnectionsResponse, error) // Create a new ChannelConnection in a particular project and location. CreateChannelConnection(ctx context.Context, in *CreateChannelConnectionRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error) // Delete a single ChannelConnection. DeleteChannelConnection(ctx context.Context, in *DeleteChannelConnectionRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error) // Get a GoogleChannelConfig GetGoogleChannelConfig(ctx context.Context, in *GetGoogleChannelConfigRequest, opts ...grpc.CallOption) (*GoogleChannelConfig, error) // Update a single GoogleChannelConfig UpdateGoogleChannelConfig(ctx context.Context, in *UpdateGoogleChannelConfigRequest, opts ...grpc.CallOption) (*GoogleChannelConfig, error) }
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
type 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) (*longrunningpb.Operation, error) // Update a single trigger. UpdateTrigger(context.Context, *UpdateTriggerRequest) (*longrunningpb.Operation, error) // Delete a single trigger. DeleteTrigger(context.Context, *DeleteTriggerRequest) (*longrunningpb.Operation, error) // Get a single Channel. GetChannel(context.Context, *GetChannelRequest) (*Channel, error) // List channels. ListChannels(context.Context, *ListChannelsRequest) (*ListChannelsResponse, error) // Create a new channel in a particular project and location. CreateChannel(context.Context, *CreateChannelRequest) (*longrunningpb.Operation, error) // Update a single channel. UpdateChannel(context.Context, *UpdateChannelRequest) (*longrunningpb.Operation, error) // Delete a single channel. DeleteChannel(context.Context, *DeleteChannelRequest) (*longrunningpb.Operation, error) // Get a single Provider. GetProvider(context.Context, *GetProviderRequest) (*Provider, error) // List providers. ListProviders(context.Context, *ListProvidersRequest) (*ListProvidersResponse, error) // Get a single ChannelConnection. GetChannelConnection(context.Context, *GetChannelConnectionRequest) (*ChannelConnection, error) // List channel connections. ListChannelConnections(context.Context, *ListChannelConnectionsRequest) (*ListChannelConnectionsResponse, error) // Create a new ChannelConnection in a particular project and location. CreateChannelConnection(context.Context, *CreateChannelConnectionRequest) (*longrunningpb.Operation, error) // Delete a single ChannelConnection. DeleteChannelConnection(context.Context, *DeleteChannelConnectionRequest) (*longrunningpb.Operation, error) // Get a GoogleChannelConfig GetGoogleChannelConfig(context.Context, *GetGoogleChannelConfigRequest) (*GoogleChannelConfig, error) // Update a single GoogleChannelConfig UpdateGoogleChannelConfig(context.Context, *UpdateGoogleChannelConfigRequest) (*GoogleChannelConfig, error) }
EventarcServer is the server API for Eventarc service.
type 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
deprecated
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
type GKE ¶
type GKE struct { // Required. The name of the cluster the GKE service is running in. The cluster must be // running in the same project as the trigger being created. Cluster string `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"` // Required. The name of the Google Compute Engine in which the cluster resides, which // can either be compute zone (for example, us-central1-a) for the zonal // clusters or region (for example, us-central1) for regional clusters. Location string `protobuf:"bytes,2,opt,name=location,proto3" json:"location,omitempty"` // Required. The namespace the GKE service is running in. Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"` // Required. Name of the GKE service. Service string `protobuf:"bytes,4,opt,name=service,proto3" json:"service,omitempty"` // Optional. The relative path on the GKE service the events should be sent to. // // The value must conform to the definition of a URI path segment (section 3.3 // of RFC2396). Examples: "/route", "route", "route/subroute". Path string `protobuf:"bytes,5,opt,name=path,proto3" json:"path,omitempty"` // contains filtered or unexported fields }
Represents a GKE destination.
func (*GKE) Descriptor
deprecated
func (*GKE) GetCluster ¶
func (*GKE) GetLocation ¶
func (*GKE) GetNamespace ¶
func (*GKE) GetService ¶
func (*GKE) ProtoMessage ¶
func (*GKE) ProtoMessage()
func (*GKE) ProtoReflect ¶
func (x *GKE) ProtoReflect() protoreflect.Message
type 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
deprecated
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
type 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
deprecated
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
type GetGoogleChannelConfigRequest ¶ added in v1.9.0
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
deprecated
added in
v1.9.0
func (*GetGoogleChannelConfigRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetGoogleChannelConfigRequest.ProtoReflect.Descriptor instead.
func (*GetGoogleChannelConfigRequest) GetName ¶ added in v1.9.0
func (x *GetGoogleChannelConfigRequest) GetName() string
func (*GetGoogleChannelConfigRequest) ProtoMessage ¶ added in v1.9.0
func (*GetGoogleChannelConfigRequest) ProtoMessage()
func (*GetGoogleChannelConfigRequest) ProtoReflect ¶ added in v1.9.0
func (x *GetGoogleChannelConfigRequest) ProtoReflect() protoreflect.Message
func (*GetGoogleChannelConfigRequest) Reset ¶ added in v1.9.0
func (x *GetGoogleChannelConfigRequest) Reset()
func (*GetGoogleChannelConfigRequest) String ¶ added in v1.9.0
func (x *GetGoogleChannelConfigRequest) String() string
type 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
deprecated
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
type 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
deprecated
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
type GoogleChannelConfig ¶ added in v1.9.0
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
deprecated
added in
v1.9.0
func (*GoogleChannelConfig) Descriptor() ([]byte, []int)
Deprecated: Use GoogleChannelConfig.ProtoReflect.Descriptor instead.
func (*GoogleChannelConfig) GetCryptoKeyName ¶ added in v1.9.0
func (x *GoogleChannelConfig) GetCryptoKeyName() string
func (*GoogleChannelConfig) GetName ¶ added in v1.9.0
func (x *GoogleChannelConfig) GetName() string
func (*GoogleChannelConfig) GetUpdateTime ¶ added in v1.9.0
func (x *GoogleChannelConfig) GetUpdateTime() *timestamppb.Timestamp
func (*GoogleChannelConfig) ProtoMessage ¶ added in v1.9.0
func (*GoogleChannelConfig) ProtoMessage()
func (*GoogleChannelConfig) ProtoReflect ¶ added in v1.9.0
func (x *GoogleChannelConfig) ProtoReflect() protoreflect.Message
func (*GoogleChannelConfig) Reset ¶ added in v1.9.0
func (x *GoogleChannelConfig) Reset()
func (*GoogleChannelConfig) String ¶ added in v1.9.0
func (x *GoogleChannelConfig) String() string
type 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
deprecated
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
type 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
deprecated
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
type 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
deprecated
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
type 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
deprecated
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
type 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
deprecated
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
type 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
deprecated
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
type 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
deprecated
func (*ListTriggersRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListTriggersRequest.ProtoReflect.Descriptor instead.
func (*ListTriggersRequest) GetFilter ¶ added in v1.9.0
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
type 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
deprecated
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
type 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
deprecated
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
type 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
func (*Provider) GetDisplayName ¶
func (*Provider) GetEventTypes ¶
func (*Provider) ProtoMessage ¶
func (*Provider) ProtoMessage()
func (*Provider) ProtoReflect ¶
func (x *Provider) ProtoReflect() protoreflect.Message
type Pubsub ¶
type Pubsub struct { // Optional. The name of the Pub/Sub topic created and managed by Eventarc as // a transport for the event delivery. Format: // `projects/{PROJECT_ID}/topics/{TOPIC_NAME}`. // // You can set an existing topic for triggers of the type // `google.cloud.pubsub.topic.v1.messagePublished`. The topic you provide // here is not deleted by Eventarc at trigger deletion. Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` // Output only. The name of the Pub/Sub subscription created and managed by Eventarc // as a transport for the event delivery. Format: // `projects/{PROJECT_ID}/subscriptions/{SUBSCRIPTION_NAME}`. Subscription string `protobuf:"bytes,2,opt,name=subscription,proto3" json:"subscription,omitempty"` // contains filtered or unexported fields }
Represents a Pub/Sub transport.
func (*Pubsub) Descriptor
deprecated
func (*Pubsub) GetSubscription ¶
func (*Pubsub) ProtoMessage ¶
func (*Pubsub) ProtoMessage()
func (*Pubsub) ProtoReflect ¶
func (x *Pubsub) ProtoReflect() protoreflect.Message
type StateCondition ¶ added in v1.9.0
type StateCondition struct { // The canonical code of the condition. Code code.Code `protobuf:"varint,1,opt,name=code,proto3,enum=google.rpc.Code" json:"code,omitempty"` // Human-readable message. Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
A condition that is part of the trigger state computation.
func (*StateCondition) Descriptor
deprecated
added in
v1.9.0
func (*StateCondition) Descriptor() ([]byte, []int)
Deprecated: Use StateCondition.ProtoReflect.Descriptor instead.
func (*StateCondition) GetCode ¶ added in v1.9.0
func (x *StateCondition) GetCode() code.Code
func (*StateCondition) GetMessage ¶ added in v1.9.0
func (x *StateCondition) GetMessage() string
func (*StateCondition) ProtoMessage ¶ added in v1.9.0
func (*StateCondition) ProtoMessage()
func (*StateCondition) ProtoReflect ¶ added in v1.9.0
func (x *StateCondition) ProtoReflect() protoreflect.Message
func (*StateCondition) Reset ¶ added in v1.9.0
func (x *StateCondition) Reset()
func (*StateCondition) String ¶ added in v1.9.0
func (x *StateCondition) String() string
type Transport ¶
type Transport struct { // Types that are assignable to Intermediary: // // *Transport_Pubsub Intermediary isTransport_Intermediary `protobuf_oneof:"intermediary"` // contains filtered or unexported fields }
Represents the transport intermediaries created for the trigger to deliver events.
func (*Transport) Descriptor
deprecated
func (*Transport) GetIntermediary ¶
func (m *Transport) GetIntermediary() isTransport_Intermediary
func (*Transport) ProtoMessage ¶
func (*Transport) ProtoMessage()
func (*Transport) ProtoReflect ¶
func (x *Transport) ProtoReflect() protoreflect.Message
type Transport_Pubsub ¶
type Transport_Pubsub struct { // The Pub/Sub topic and subscription used by Eventarc as a transport // intermediary. Pubsub *Pubsub `protobuf:"bytes,1,opt,name=pubsub,proto3,oneof"` }
type Trigger ¶
type Trigger struct { // Required. The resource name of the trigger. Must be unique within the location of the // project and must be in // `projects/{project}/locations/{location}/triggers/{trigger}` format. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Output only. Server-assigned unique identifier for the trigger. The value is a UUID4 // string and guaranteed to remain unchanged until the resource is deleted. Uid string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"` // Output only. The creation time. CreateTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"` // Output only. The last-modified time. UpdateTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"` // Required. Unordered list. The list of filters that applies to event attributes. Only events that // match all the provided filters are sent to the destination. EventFilters []*EventFilter `protobuf:"bytes,8,rep,name=event_filters,json=eventFilters,proto3" json:"event_filters,omitempty"` // Optional. The IAM service account email associated with the trigger. The // service account represents the identity of the trigger. // // The principal who calls this API must have the `iam.serviceAccounts.actAs` // permission in the service account. See // https://cloud.google.com/iam/docs/understanding-service-accounts?hl=en#sa_common // for more information. // // For Cloud Run destinations, this service account is used to generate // identity tokens when invoking the service. See // https://cloud.google.com/run/docs/triggering/pubsub-push#create-service-account // for information on how to invoke authenticated Cloud Run services. // To create Audit Log triggers, the service account should also // have the `roles/eventarc.eventReceiver` IAM role. ServiceAccount string `protobuf:"bytes,9,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"` // Required. Destination specifies where the events should be sent to. Destination *Destination `protobuf:"bytes,10,opt,name=destination,proto3" json:"destination,omitempty"` // Optional. To deliver messages, Eventarc might use other GCP // products as a transport intermediary. This field contains a reference to // that transport intermediary. This information can be used for debugging // purposes. Transport *Transport `protobuf:"bytes,11,opt,name=transport,proto3" json:"transport,omitempty"` // Optional. User labels attached to the triggers that can be used to group resources. Labels map[string]string `` /* 154-byte string literal not displayed */ // Optional. The name of the channel associated with the trigger in // `projects/{project}/locations/{location}/channels/{channel}` format. // You must provide a channel to receive events from Eventarc SaaS partners. Channel string `protobuf:"bytes,13,opt,name=channel,proto3" json:"channel,omitempty"` // Output only. The reason(s) why a trigger is in FAILED state. Conditions map[string]*StateCondition `` /* 162-byte string literal not displayed */ // Output only. This checksum is computed by the server based on the value of other // fields, and might be sent only on create requests to ensure that the // client has an up-to-date value before proceeding. Etag string `protobuf:"bytes,99,opt,name=etag,proto3" json:"etag,omitempty"` // contains filtered or unexported fields }
A representation of the trigger resource.
func (*Trigger) Descriptor
deprecated
func (*Trigger) GetChannel ¶
func (*Trigger) GetConditions ¶ added in v1.9.0
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) GetEventFilters ¶
func (x *Trigger) GetEventFilters() []*EventFilter
func (*Trigger) GetServiceAccount ¶
func (*Trigger) GetTransport ¶
func (*Trigger) GetUpdateTime ¶
func (x *Trigger) GetUpdateTime() *timestamppb.Timestamp
func (*Trigger) ProtoMessage ¶
func (*Trigger) ProtoMessage()
func (*Trigger) ProtoReflect ¶
func (x *Trigger) ProtoReflect() protoreflect.Message
type UnimplementedEventarcServer ¶
type UnimplementedEventarcServer struct { }
UnimplementedEventarcServer can be embedded to have forward compatible implementations.
func (*UnimplementedEventarcServer) CreateChannel ¶
func (*UnimplementedEventarcServer) CreateChannel(context.Context, *CreateChannelRequest) (*longrunningpb.Operation, error)
func (*UnimplementedEventarcServer) CreateChannelConnection ¶
func (*UnimplementedEventarcServer) CreateChannelConnection(context.Context, *CreateChannelConnectionRequest) (*longrunningpb.Operation, error)
func (*UnimplementedEventarcServer) CreateTrigger ¶
func (*UnimplementedEventarcServer) CreateTrigger(context.Context, *CreateTriggerRequest) (*longrunningpb.Operation, error)
func (*UnimplementedEventarcServer) DeleteChannel ¶
func (*UnimplementedEventarcServer) DeleteChannel(context.Context, *DeleteChannelRequest) (*longrunningpb.Operation, error)
func (*UnimplementedEventarcServer) DeleteChannelConnection ¶
func (*UnimplementedEventarcServer) DeleteChannelConnection(context.Context, *DeleteChannelConnectionRequest) (*longrunningpb.Operation, error)
func (*UnimplementedEventarcServer) DeleteTrigger ¶
func (*UnimplementedEventarcServer) DeleteTrigger(context.Context, *DeleteTriggerRequest) (*longrunningpb.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 ¶ added in v1.9.0
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) (*longrunningpb.Operation, error)
func (*UnimplementedEventarcServer) UpdateGoogleChannelConfig ¶ added in v1.9.0
func (*UnimplementedEventarcServer) UpdateGoogleChannelConfig(context.Context, *UpdateGoogleChannelConfigRequest) (*GoogleChannelConfig, error)
func (*UnimplementedEventarcServer) UpdateTrigger ¶
func (*UnimplementedEventarcServer) UpdateTrigger(context.Context, *UpdateTriggerRequest) (*longrunningpb.Operation, error)
type 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
deprecated
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
type UpdateGoogleChannelConfigRequest ¶ added in v1.9.0
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
deprecated
added in
v1.9.0
func (*UpdateGoogleChannelConfigRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateGoogleChannelConfigRequest.ProtoReflect.Descriptor instead.
func (*UpdateGoogleChannelConfigRequest) GetGoogleChannelConfig ¶ added in v1.9.0
func (x *UpdateGoogleChannelConfigRequest) GetGoogleChannelConfig() *GoogleChannelConfig
func (*UpdateGoogleChannelConfigRequest) GetUpdateMask ¶ added in v1.9.0
func (x *UpdateGoogleChannelConfigRequest) GetUpdateMask() *fieldmaskpb.FieldMask
func (*UpdateGoogleChannelConfigRequest) ProtoMessage ¶ added in v1.9.0
func (*UpdateGoogleChannelConfigRequest) ProtoMessage()
func (*UpdateGoogleChannelConfigRequest) ProtoReflect ¶ added in v1.9.0
func (x *UpdateGoogleChannelConfigRequest) ProtoReflect() protoreflect.Message
func (*UpdateGoogleChannelConfigRequest) Reset ¶ added in v1.9.0
func (x *UpdateGoogleChannelConfigRequest) Reset()
func (*UpdateGoogleChannelConfigRequest) String ¶ added in v1.9.0
func (x *UpdateGoogleChannelConfigRequest) String() string
type 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
deprecated
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