Variables
Channel_State_name, Channel_State_value
var
(
Channel_State_name
=
map
[
int32
]
string
{
0
:
"STATE_UNSPECIFIED"
,
1
:
"PENDING"
,
2
:
"ACTIVE"
,
3
:
"INACTIVE"
,
}
Channel_State_value
=
map
[
string
]
int32
{
"STATE_UNSPECIFIED"
:
0
,
"PENDING"
:
1
,
"ACTIVE"
:
2
,
"INACTIVE"
:
3
,
}
)
Enum value maps for Channel_State.
File_google_cloud_eventarc_v1_channel_connection_proto
var
File_google_cloud_eventarc_v1_channel_connection_proto
protoreflect
.
FileDescriptor
File_google_cloud_eventarc_v1_channel_proto
var
File_google_cloud_eventarc_v1_channel_proto
protoreflect
.
FileDescriptor
File_google_cloud_eventarc_v1_discovery_proto
var
File_google_cloud_eventarc_v1_discovery_proto
protoreflect
.
FileDescriptor
File_google_cloud_eventarc_v1_eventarc_proto
var
File_google_cloud_eventarc_v1_eventarc_proto
protoreflect
.
FileDescriptor
File_google_cloud_eventarc_v1_google_channel_config_proto
var
File_google_cloud_eventarc_v1_google_channel_config_proto
protoreflect
.
FileDescriptor
File_google_cloud_eventarc_v1_trigger_proto
var
File_google_cloud_eventarc_v1_trigger_proto
protoreflect
.
FileDescriptor
Functions
func RegisterEventarcServer
func
RegisterEventarcServer
(
s
*
grpc
.
Server
,
srv
EventarcServer
)
Channel
type
Channel
struct
{
// Required. The resource name of the channel. Must be unique within the
// location on the project and must be in
// `projects/{project}/locations/{location}/channels/{channel_id}` format.
Name
string
`protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Output only. Server assigned unique identifier for the channel. The value
// is a UUID4 string and guaranteed to remain unchanged until the resource is
// deleted.
Uid
string
`protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
// Output only. The creation time.
CreateTime
*
timestamppb
.
Timestamp
`protobuf:"bytes,5,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
// Output only. The last-modified time.
UpdateTime
*
timestamppb
.
Timestamp
`protobuf:"bytes,6,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
// The name of the event provider (e.g. Eventarc SaaS partner) associated
// with the channel. This provider will be granted permissions to publish
// events to the channel. Format:
// `projects/{project}/locations/{location}/providers/{provider_id}`.
Provider
string
`protobuf:"bytes,7,opt,name=provider,proto3" json:"provider,omitempty"`
// Types that are assignable to Transport:
//
// *Channel_PubsubTopic
Transport
isChannel_Transport
`protobuf_oneof:"transport"`
// Output only. The state of a Channel.
State
Channel_State
`protobuf:"varint,9,opt,name=state,proto3,enum=google.cloud.eventarc.v1.Channel_State" json:"state,omitempty"`
// Output only. The activation token for the channel. The token must be used
// by the provider to register the channel for publishing.
ActivationToken
string
`protobuf:"bytes,10,opt,name=activation_token,json=activationToken,proto3" json:"activation_token,omitempty"`
// Optional. Resource name of a KMS crypto key (managed by the user) used to
// encrypt/decrypt their event data.
//
// It must match the pattern
// `projects/*/locations/*/keyRings/*/cryptoKeys/*`.
CryptoKeyName
string
`protobuf:"bytes,11,opt,name=crypto_key_name,json=cryptoKeyName,proto3" json:"crypto_key_name,omitempty"`
// contains filtered or unexported fields
}
A representation of the Channel resource. A Channel is a resource on which event providers publish their events. The published events are delivered through the transport associated with the channel. Note that a channel is associated with exactly one event provider.
func (*Channel) Descriptor
Deprecated: Use Channel.ProtoReflect.Descriptor instead.
func (*Channel) GetActivationToken
func (*Channel) GetCreateTime
func
(
x
*
Channel
)
GetCreateTime
()
*
timestamppb
.
Timestamp
func (*Channel) GetCryptoKeyName
func (*Channel) GetName
func (*Channel) GetProvider
func (*Channel) GetPubsubTopic
func (*Channel) GetState
func
(
x
*
Channel
)
GetState
()
Channel_State
func (*Channel) GetTransport
func
(
m
*
Channel
)
GetTransport
()
isChannel_Transport
func (*Channel) GetUid
func (*Channel) GetUpdateTime
func
(
x
*
Channel
)
GetUpdateTime
()
*
timestamppb
.
Timestamp
func (*Channel) ProtoMessage
func
(
*
Channel
)
ProtoMessage
()
func (*Channel) ProtoReflect
func
(
x
*
Channel
)
ProtoReflect
()
protoreflect
.
Message
func (*Channel) Reset
func
(
x
*
Channel
)
Reset
()
func (*Channel) String
ChannelConnection
type
ChannelConnection
struct
{
// Required. The name of the connection.
Name
string
`protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Output only. Server assigned ID of the resource.
// The server guarantees uniqueness and immutability until deleted.
Uid
string
`protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
// Required. The name of the connected subscriber Channel.
// This is a weak reference to avoid cross project and cross accounts
// references. This must be in
// `projects/{project}/location/{location}/channels/{channel_id}` format.
Channel
string
`protobuf:"bytes,5,opt,name=channel,proto3" json:"channel,omitempty"`
// Output only. The creation time.
CreateTime
*
timestamppb
.
Timestamp
`protobuf:"bytes,6,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
// Output only. The last-modified time.
UpdateTime
*
timestamppb
.
Timestamp
`protobuf:"bytes,7,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
// Input only. Activation token for the channel. The token will be used
// during the creation of ChannelConnection to bind the channel with the
// provider project. This field will not be stored in the provider resource.
ActivationToken
string
`protobuf:"bytes,8,opt,name=activation_token,json=activationToken,proto3" json:"activation_token,omitempty"`
// contains filtered or unexported fields
}
A representation of the ChannelConnection resource. A ChannelConnection is a resource which event providers create during the activation process to establish a connection between the provider and the subscriber channel.
func (*ChannelConnection) Descriptor
func
(
*
ChannelConnection
)
Descriptor
()
([]
byte
,
[]
int
)
Deprecated: Use ChannelConnection.ProtoReflect.Descriptor instead.
func (*ChannelConnection) GetActivationToken
func
(
x
*
ChannelConnection
)
GetActivationToken
()
string
func (*ChannelConnection) GetChannel
func
(
x
*
ChannelConnection
)
GetChannel
()
string
func (*ChannelConnection) GetCreateTime
func
(
x
*
ChannelConnection
)
GetCreateTime
()
*
timestamppb
.
Timestamp
func (*ChannelConnection) GetName
func
(
x
*
ChannelConnection
)
GetName
()
string
func (*ChannelConnection) GetUid
func
(
x
*
ChannelConnection
)
GetUid
()
string
func (*ChannelConnection) GetUpdateTime
func
(
x
*
ChannelConnection
)
GetUpdateTime
()
*
timestamppb
.
Timestamp
func (*ChannelConnection) ProtoMessage
func
(
*
ChannelConnection
)
ProtoMessage
()
func (*ChannelConnection) ProtoReflect
func
(
x
*
ChannelConnection
)
ProtoReflect
()
protoreflect
.
Message
func (*ChannelConnection) Reset
func
(
x
*
ChannelConnection
)
Reset
()
func (*ChannelConnection) String
func
(
x
*
ChannelConnection
)
String
()
string
Channel_PubsubTopic
type
Channel_PubsubTopic
struct
{
// Output only. The name of the Pub/Sub topic created and managed by
// Eventarc system as a transport for the event delivery. Format:
// `projects/{project}/topics/{topic_id}`.
PubsubTopic
string
`protobuf:"bytes,8,opt,name=pubsub_topic,json=pubsubTopic,proto3,oneof"`
}
Channel_State
type
Channel_State
int32
State lists all the possible states of a Channel
Channel_STATE_UNSPECIFIED, Channel_PENDING, Channel_ACTIVE, Channel_INACTIVE
const
(
// Default value. This value is unused.
Channel_STATE_UNSPECIFIED
Channel_State
=
0
// The PENDING state indicates that a Channel has been created successfully
// and there is a new activation token available for the subscriber to use
// to convey the Channel to the provider in order to create a Connection.
Channel_PENDING
Channel_State
=
1
// The ACTIVE state indicates that a Channel has been successfully
// connected with the event provider.
// An ACTIVE Channel is ready to receive and route events from the
// event provider.
Channel_ACTIVE
Channel_State
=
2
// The INACTIVE state indicates that the Channel cannot receive events
// permanently. There are two possible cases this state can happen:
//
// 1. The SaaS provider disconnected from this Channel.
// 2. The Channel activation token has expired but the SaaS provider
// wasn't connected.
//
// To re-establish a Connection with a provider, the subscriber
// should create a new Channel and give it to the provider.
Channel_INACTIVE
Channel_State
=
3
)
func (Channel_State) Descriptor
func
(
Channel_State
)
Descriptor
()
protoreflect
.
EnumDescriptor
func (Channel_State) Enum
func
(
x
Channel_State
)
Enum
()
*
Channel_State
func (Channel_State) EnumDescriptor
func
(
Channel_State
)
EnumDescriptor
()
([]
byte
,
[]
int
)
Deprecated: Use Channel_State.Descriptor instead.
func (Channel_State) Number
func
(
x
Channel_State
)
Number
()
protoreflect
.
EnumNumber
func (Channel_State) String
func
(
x
Channel_State
)
String
()
string
func (Channel_State) Type
func
(
Channel_State
)
Type
()
protoreflect
.
EnumType
CloudRun
type
CloudRun
struct
{
// Required. The name of the Cloud Run service being addressed. See
// https://cloud.google.com/run/docs/reference/rest/v1/namespaces.services.
//
// Only services located in the same project as the trigger object
// can be addressed.
Service
string
`protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
// Optional. The relative path on the Cloud Run service the events should be sent to.
//
// The value must conform to the definition of a URI path segment (section 3.3
// of RFC2396). Examples: "/route", "route", "route/subroute".
Path
string
`protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
// Required. The region the Cloud Run service is deployed in.
Region
string
`protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"`
// contains filtered or unexported fields
}
Represents a Cloud Run destination.
func (*CloudRun) Descriptor
Deprecated: Use CloudRun.ProtoReflect.Descriptor instead.
func (*CloudRun) GetPath
func (*CloudRun) GetRegion
func (*CloudRun) GetService
func (*CloudRun) ProtoMessage
func
(
*
CloudRun
)
ProtoMessage
()
func (*CloudRun) ProtoReflect
func
(
x
*
CloudRun
)
ProtoReflect
()
protoreflect
.
Message
func (*CloudRun) Reset
func
(
x
*
CloudRun
)
Reset
()
func (*CloudRun) String
CreateChannelConnectionRequest
type
CreateChannelConnectionRequest
struct
{
// Required. The parent collection in which to add this channel connection.
Parent
string
`protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Required. Channel connection to create.
ChannelConnection
*
ChannelConnection
`protobuf:"bytes,2,opt,name=channel_connection,json=channelConnection,proto3" json:"channel_connection,omitempty"`
// Required. The user-provided ID to be assigned to the channel connection.
ChannelConnectionId
string
`protobuf:"bytes,3,opt,name=channel_connection_id,json=channelConnectionId,proto3" json:"channel_connection_id,omitempty"`
// contains filtered or unexported fields
}
The request message for the CreateChannelConnection method.
func (*CreateChannelConnectionRequest) Descriptor
func
(
*
CreateChannelConnectionRequest
)
Descriptor
()
([]
byte
,
[]
int
)
Deprecated: Use CreateChannelConnectionRequest.ProtoReflect.Descriptor instead.
func (*CreateChannelConnectionRequest) GetChannelConnection
func
(
x
*
CreateChannelConnectionRequest
)
GetChannelConnection
()
*
ChannelConnection
func (*CreateChannelConnectionRequest) GetChannelConnectionId
func
(
x
*
CreateChannelConnectionRequest
)
GetChannelConnectionId
()
string
func (*CreateChannelConnectionRequest) GetParent
func
(
x
*
CreateChannelConnectionRequest
)
GetParent
()
string
func (*CreateChannelConnectionRequest) ProtoMessage
func
(
*
CreateChannelConnectionRequest
)
ProtoMessage
()
func (*CreateChannelConnectionRequest) ProtoReflect
func
(
x
*
CreateChannelConnectionRequest
)
ProtoReflect
()
protoreflect
.
Message
func (*CreateChannelConnectionRequest) Reset
func
(
x
*
CreateChannelConnectionRequest
)
Reset
()
func (*CreateChannelConnectionRequest) String
func
(
x
*
CreateChannelConnectionRequest
)
String
()
string
CreateChannelRequest
type
CreateChannelRequest
struct
{
// Required. The parent collection in which to add this channel.
Parent
string
`protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Required. The channel to create.
Channel
*
Channel
`protobuf:"bytes,2,opt,name=channel,proto3" json:"channel,omitempty"`
// Required. The user-provided ID to be assigned to the channel.
ChannelId
string
`protobuf:"bytes,3,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
// Required. If set, validate the request and preview the review, but do not
// post it.
ValidateOnly
bool
`protobuf:"varint,4,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
// contains filtered or unexported fields
}
The request message for the CreateChannel method.
func (*CreateChannelRequest) Descriptor
func
(
*
CreateChannelRequest
)
Descriptor
()
([]
byte
,
[]
int
)
Deprecated: Use CreateChannelRequest.ProtoReflect.Descriptor instead.
func (*CreateChannelRequest) GetChannel
func
(
x
*
CreateChannelRequest
)
GetChannel
()
*
Channel
func (*CreateChannelRequest) GetChannelId
func
(
x
*
CreateChannelRequest
)
GetChannelId
()
string
func (*CreateChannelRequest) GetParent
func
(
x
*
CreateChannelRequest
)
GetParent
()
string
func (*CreateChannelRequest) GetValidateOnly
func
(
x
*
CreateChannelRequest
)
GetValidateOnly
()
bool
func (*CreateChannelRequest) ProtoMessage
func
(
*
CreateChannelRequest
)
ProtoMessage
()
func (*CreateChannelRequest) ProtoReflect
func
(
x
*
CreateChannelRequest
)
ProtoReflect
()
protoreflect
.
Message
func (*CreateChannelRequest) Reset
func
(
x
*
CreateChannelRequest
)
Reset
()
func (*CreateChannelRequest) String
func
(
x
*
CreateChannelRequest
)
String
()
string
CreateTriggerRequest
type
CreateTriggerRequest
struct
{
// Required. The parent collection in which to add this trigger.
Parent
string
`protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Required. The trigger to create.
Trigger
*
Trigger
`protobuf:"bytes,2,opt,name=trigger,proto3" json:"trigger,omitempty"`
// Required. The user-provided ID to be assigned to the trigger.
TriggerId
string
`protobuf:"bytes,3,opt,name=trigger_id,json=triggerId,proto3" json:"trigger_id,omitempty"`
// Required. If set, validate the request and preview the review, but do not
// post it.
ValidateOnly
bool
`protobuf:"varint,4,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
// contains filtered or unexported fields
}
The request message for the CreateTrigger method.
func (*CreateTriggerRequest) Descriptor
func
(
*
CreateTriggerRequest
)
Descriptor
()
([]
byte
,
[]
int
)
Deprecated: Use CreateTriggerRequest.ProtoReflect.Descriptor instead.
func (*CreateTriggerRequest) GetParent
func
(
x
*
CreateTriggerRequest
)
GetParent
()
string
func (*CreateTriggerRequest) GetTrigger
func
(
x
*
CreateTriggerRequest
)
GetTrigger
()
*
Trigger
func (*CreateTriggerRequest) GetTriggerId
func
(
x
*
CreateTriggerRequest
)
GetTriggerId
()
string
func (*CreateTriggerRequest) GetValidateOnly
func
(
x
*
CreateTriggerRequest
)
GetValidateOnly
()
bool
func (*CreateTriggerRequest) ProtoMessage
func
(
*
CreateTriggerRequest
)
ProtoMessage
()
func (*CreateTriggerRequest) ProtoReflect
func
(
x
*
CreateTriggerRequest
)
ProtoReflect
()
protoreflect
.
Message
func (*CreateTriggerRequest) Reset
func
(
x
*
CreateTriggerRequest
)
Reset
()
func (*CreateTriggerRequest) String
func
(
x
*
CreateTriggerRequest
)
String
()
string
DeleteChannelConnectionRequest
type
DeleteChannelConnectionRequest
struct
{
// Required. The name of the channel connection to delete.
Name
string
`protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
The request message for the DeleteChannelConnection method.
func (*DeleteChannelConnectionRequest) Descriptor
func
(
*
DeleteChannelConnectionRequest
)
Descriptor
()
([]
byte
,
[]
int
)
Deprecated: Use DeleteChannelConnectionRequest.ProtoReflect.Descriptor instead.
func (*DeleteChannelConnectionRequest) GetName
func
(
x
*
DeleteChannelConnectionRequest
)
GetName
()
string
func (*DeleteChannelConnectionRequest) ProtoMessage
func
(
*
DeleteChannelConnectionRequest
)
ProtoMessage
()
func (*DeleteChannelConnectionRequest) ProtoReflect
func
(
x
*
DeleteChannelConnectionRequest
)
ProtoReflect
()
protoreflect
.
Message
func (*DeleteChannelConnectionRequest) Reset
func
(
x
*
DeleteChannelConnectionRequest
)
Reset
()
func (*DeleteChannelConnectionRequest) String
func
(
x
*
DeleteChannelConnectionRequest
)
String
()
string
DeleteChannelRequest
type
DeleteChannelRequest
struct
{
// Required. The name of the channel to be deleted.
Name
string
`protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Required. If set, validate the request and preview the review, but do not
// post it.
ValidateOnly
bool
`protobuf:"varint,2,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
// contains filtered or unexported fields
}
The request message for the DeleteChannel method.
func (*DeleteChannelRequest) Descriptor
func
(
*
DeleteChannelRequest
)
Descriptor
()
([]
byte
,
[]
int
)
Deprecated: Use DeleteChannelRequest.ProtoReflect.Descriptor instead.
func (*DeleteChannelRequest) GetName
func
(
x
*
DeleteChannelRequest
)
GetName
()
string
func (*DeleteChannelRequest) GetValidateOnly
func
(
x
*
DeleteChannelRequest
)
GetValidateOnly
()
bool
func (*DeleteChannelRequest) ProtoMessage
func
(
*
DeleteChannelRequest
)
ProtoMessage
()
func (*DeleteChannelRequest) ProtoReflect
func
(
x
*
DeleteChannelRequest
)
ProtoReflect
()
protoreflect
.
Message
func (*DeleteChannelRequest) Reset
func
(
x
*
DeleteChannelRequest
)
Reset
()
func (*DeleteChannelRequest) String
func
(
x
*
DeleteChannelRequest
)
String
()
string
DeleteTriggerRequest
type
DeleteTriggerRequest
struct
{
// Required. The name of the trigger to be deleted.
Name
string
`protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// If provided, the trigger will only be deleted if the etag matches the
// current etag on the resource.
Etag
string
`protobuf:"bytes,2,opt,name=etag,proto3" json:"etag,omitempty"`
// If set to true, and the trigger is not found, the request will succeed
// but no action will be taken on the server.
AllowMissing
bool
`protobuf:"varint,3,opt,name=allow_missing,json=allowMissing,proto3" json:"allow_missing,omitempty"`
// Required. If set, validate the request and preview the review, but do not
// post it.
ValidateOnly
bool
`protobuf:"varint,4,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
// contains filtered or unexported fields
}
The request message for the DeleteTrigger method.
func (*DeleteTriggerRequest) Descriptor
func
(
*
DeleteTriggerRequest
)
Descriptor
()
([]
byte
,
[]
int
)
Deprecated: Use DeleteTriggerRequest.ProtoReflect.Descriptor instead.
func (*DeleteTriggerRequest) GetAllowMissing
func
(
x
*
DeleteTriggerRequest
)
GetAllowMissing
()
bool
func (*DeleteTriggerRequest) GetEtag
func
(
x
*
DeleteTriggerRequest
)
GetEtag
()
string
func (*DeleteTriggerRequest) GetName
func
(
x
*
DeleteTriggerRequest
)
GetName
()
string
func (*DeleteTriggerRequest) GetValidateOnly
func
(
x
*
DeleteTriggerRequest
)
GetValidateOnly
()
bool
func (*DeleteTriggerRequest) ProtoMessage
func
(
*
DeleteTriggerRequest
)
ProtoMessage
()
func (*DeleteTriggerRequest) ProtoReflect
func
(
x
*
DeleteTriggerRequest
)
ProtoReflect
()
protoreflect
.
Message
func (*DeleteTriggerRequest) Reset
func
(
x
*
DeleteTriggerRequest
)
Reset
()
func (*DeleteTriggerRequest) String
func
(
x
*
DeleteTriggerRequest
)
String
()
string
Destination
type
Destination
struct
{
// Types that are assignable to Descriptor_:
//
// *Destination_CloudRun
// *Destination_CloudFunction
// *Destination_Gke
// *Destination_Workflow
Descriptor_
isDestination_Descriptor_
`protobuf_oneof:"descriptor"`
// contains filtered or unexported fields
}
Represents a target of an invocation over HTTP.
func (*Destination) Descriptor
func
(
*
Destination
)
Descriptor
()
([]
byte
,
[]
int
)
Deprecated: Use Destination.ProtoReflect.Descriptor instead.
func (*Destination) GetCloudFunction
func
(
x
*
Destination
)
GetCloudFunction
()
string
func (*Destination) GetCloudRun
func
(
x
*
Destination
)
GetCloudRun
()
*
CloudRun
func (*Destination) GetDescriptor_
func
(
m
*
Destination
)
GetDescriptor_
()
isDestination_Descriptor_
func (*Destination) GetGke
func
(
x
*
Destination
)
GetGke
()
*
GKE
func (*Destination) GetWorkflow
func
(
x
*
Destination
)
GetWorkflow
()
string
func (*Destination) ProtoMessage
func
(
*
Destination
)
ProtoMessage
()
func (*Destination) ProtoReflect
func
(
x
*
Destination
)
ProtoReflect
()
protoreflect
.
Message
func (*Destination) Reset
func
(
x
*
Destination
)
Reset
()
func (*Destination) String
func
(
x
*
Destination
)
String
()
string
Destination_CloudFunction
type
Destination_CloudFunction
struct
{
// The Cloud Function resource name. Only Cloud Functions V2 is supported.
// Format: `projects/{project}/locations/{location}/functions/{function}`
CloudFunction
string
`protobuf:"bytes,2,opt,name=cloud_function,json=cloudFunction,proto3,oneof"`
}
Destination_CloudRun
type
Destination_CloudRun
struct
{
// Cloud Run fully-managed resource that receives the events. The resource
// should be in the same project as the trigger.
CloudRun
*
CloudRun
`protobuf:"bytes,1,opt,name=cloud_run,json=cloudRun,proto3,oneof"`
}
Destination_Gke
type
Destination_Gke
struct
{
// A GKE service capable of receiving events. The service should be running
// in the same project as the trigger.
Gke
*
GKE
`protobuf:"bytes,3,opt,name=gke,proto3,oneof"`
}
Destination_Workflow
type
Destination_Workflow
struct
{
// The resource name of the Workflow whose Executions are triggered by
// the events. The Workflow resource should be deployed in the same project
// as the trigger.
// Format: `projects/{project}/locations/{location}/workflows/{workflow}`
Workflow
string
`protobuf:"bytes,4,opt,name=workflow,proto3,oneof"`
}
EventFilter
type
EventFilter
struct
{
// Required. The name of a CloudEvents attribute. Currently, only a subset of attributes
// are supported for filtering.
//
// All triggers MUST provide a filter for the 'type' attribute.
Attribute
string
`protobuf:"bytes,1,opt,name=attribute,proto3" json:"attribute,omitempty"`
// Required. The value for the attribute.
Value
string
`protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
// Optional. The operator used for matching the events with the value of the
// filter. If not specified, only events that have an exact key-value pair
// specified in the filter are matched. The only allowed value is
// `match-path-pattern`.
Operator
string
`protobuf:"bytes,3,opt,name=operator,proto3" json:"operator,omitempty"`
// contains filtered or unexported fields
}
Filters events based on exact matches on the CloudEvents attributes.
func (*EventFilter) Descriptor
func
(
*
EventFilter
)
Descriptor
()
([]
byte
,
[]
int
)
Deprecated: Use EventFilter.ProtoReflect.Descriptor instead.
func (*EventFilter) GetAttribute
func
(
x
*
EventFilter
)
GetAttribute
()
string
func (*EventFilter) GetOperator
func
(
x
*
EventFilter
)
GetOperator
()
string
func (*EventFilter) GetValue
func
(
x
*
EventFilter
)
GetValue
()
string
func (*EventFilter) ProtoMessage
func
(
*
EventFilter
)
ProtoMessage
()
func (*EventFilter) ProtoReflect
func
(
x
*
EventFilter
)
ProtoReflect
()
protoreflect
.
Message
func (*EventFilter) Reset
func
(
x
*
EventFilter
)
Reset
()
func (*EventFilter) String
func
(
x
*
EventFilter
)
String
()
string
EventType
type
EventType
struct
{
// Output only. The full name of the event type (for example,
// "google.cloud.storage.object.v1.finalized"). In the form of
// {provider-specific-prefix}.{resource}.{version}.{verb}. Types MUST be
// versioned and event schemas are guaranteed to remain backward compatible
// within one version. Note that event type versions and API versions do not
// need to match.
Type
string
`protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
// Output only. Human friendly description of what the event type is about.
// For example "Bucket created in Cloud Storage".
Description
string
`protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
// Output only. Filtering attributes for the event type.
FilteringAttributes
[]
*
FilteringAttribute
`protobuf:"bytes,3,rep,name=filtering_attributes,json=filteringAttributes,proto3" json:"filtering_attributes,omitempty"`
// Output only. URI for the event schema.
// For example
// "https://github.com/googleapis/google-cloudevents/blob/master/proto/google/events/cloud/storage/v1/events.proto"
EventSchemaUri
string
`protobuf:"bytes,4,opt,name=event_schema_uri,json=eventSchemaUri,proto3" json:"event_schema_uri,omitempty"`
// contains filtered or unexported fields
}
A representation of the event type resource.
func (*EventType) Descriptor
Deprecated: Use EventType.ProtoReflect.Descriptor instead.
func (*EventType) GetDescription
func (*EventType) GetEventSchemaUri
func (*EventType) GetFilteringAttributes
func
(
x
*
EventType
)
GetFilteringAttributes
()
[]
*
FilteringAttribute
func (*EventType) GetType
func (*EventType) ProtoMessage
func
(
*
EventType
)
ProtoMessage
()
func (*EventType) ProtoReflect
func
(
x
*
EventType
)
ProtoReflect
()
protoreflect
.
Message
func (*EventType) Reset
func
(
x
*
EventType
)
Reset
()
func (*EventType) String
EventarcClient
type
EventarcClient
interface
{
// Get a single trigger.
GetTrigger
(
ctx
context
.
Context
,
in
*
GetTriggerRequest
,
opts
...
grpc
.
CallOption
)
(
*
Trigger
,
error
)
// List triggers.
ListTriggers
(
ctx
context
.
Context
,
in
*
ListTriggersRequest
,
opts
...
grpc
.
CallOption
)
(
*
ListTriggersResponse
,
error
)
// Create a new trigger in a particular project and location.
CreateTrigger
(
ctx
context
.
Context
,
in
*
CreateTriggerRequest
,
opts
...
grpc
.
CallOption
)
(
*
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
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.
FilteringAttribute
type
FilteringAttribute
struct
{
// Output only. Attribute used for filtering the event type.
Attribute
string
`protobuf:"bytes,1,opt,name=attribute,proto3" json:"attribute,omitempty"`
// Output only. Description of the purpose of the attribute.
Description
string
`protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
// Output only. If true, the triggers for this provider should always specify a filter
// on these attributes. Trigger creation will fail otherwise.
Required
bool
`protobuf:"varint,3,opt,name=required,proto3" json:"required,omitempty"`
// Output only. If true, the attribute accepts matching expressions in the Eventarc
// PathPattern format.
PathPatternSupported
bool
`protobuf:"varint,4,opt,name=path_pattern_supported,json=pathPatternSupported,proto3" json:"path_pattern_supported,omitempty"`
// contains filtered or unexported fields
}
A representation of the FilteringAttribute resource. Filtering attributes are per event type.
func (*FilteringAttribute) Descriptor
func
(
*
FilteringAttribute
)
Descriptor
()
([]
byte
,
[]
int
)
Deprecated: Use FilteringAttribute.ProtoReflect.Descriptor instead.
func (*FilteringAttribute) GetAttribute
func
(
x
*
FilteringAttribute
)
GetAttribute
()
string
func (*FilteringAttribute) GetDescription
func
(
x
*
FilteringAttribute
)
GetDescription
()
string
func (*FilteringAttribute) GetPathPatternSupported
func
(
x
*
FilteringAttribute
)
GetPathPatternSupported
()
bool
func (*FilteringAttribute) GetRequired
func
(
x
*
FilteringAttribute
)
GetRequired
()
bool
func (*FilteringAttribute) ProtoMessage
func
(
*
FilteringAttribute
)
ProtoMessage
()
func (*FilteringAttribute) ProtoReflect
func
(
x
*
FilteringAttribute
)
ProtoReflect
()
protoreflect
.
Message
func (*FilteringAttribute) Reset
func
(
x
*
FilteringAttribute
)
Reset
()
func (*FilteringAttribute) String
func
(
x
*
FilteringAttribute
)
String
()
string
GKE
type
GKE
struct
{
// Required. The name of the cluster the GKE service is running in. The cluster must be
// running in the same project as the trigger being created.
Cluster
string
`protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
// Required. The name of the Google Compute Engine in which the cluster resides, which
// can either be compute zone (for example, us-central1-a) for the zonal
// clusters or region (for example, us-central1) for regional clusters.
Location
string
`protobuf:"bytes,2,opt,name=location,proto3" json:"location,omitempty"`
// Required. The namespace the GKE service is running in.
Namespace
string
`protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
// Required. Name of the GKE service.
Service
string
`protobuf:"bytes,4,opt,name=service,proto3" json:"service,omitempty"`
// Optional. The relative path on the GKE service the events should be sent to.
//
// The value must conform to the definition of a URI path segment (section 3.3
// of RFC2396). Examples: "/route", "route", "route/subroute".
Path
string
`protobuf:"bytes,5,opt,name=path,proto3" json:"path,omitempty"`
// contains filtered or unexported fields
}
Represents a GKE destination.
func (*GKE) Descriptor
Deprecated: Use GKE.ProtoReflect.Descriptor instead.
func (*GKE) GetCluster
func (*GKE) GetLocation
func (*GKE) GetNamespace
func (*GKE) GetPath
func (*GKE) GetService
func (*GKE) ProtoMessage
func
(
*
GKE
)
ProtoMessage
()
func (*GKE) ProtoReflect
func
(
x
*
GKE
)
ProtoReflect
()
protoreflect
.
Message
func (*GKE) Reset
func
(
x
*
GKE
)
Reset
()
func (*GKE) String
GetChannelConnectionRequest
type
GetChannelConnectionRequest
struct
{
// Required. The name of the channel connection to get.
Name
string
`protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
The request message for the GetChannelConnection method.
func (*GetChannelConnectionRequest) Descriptor
func
(
*
GetChannelConnectionRequest
)
Descriptor
()
([]
byte
,
[]
int
)
Deprecated: Use GetChannelConnectionRequest.ProtoReflect.Descriptor instead.
func (*GetChannelConnectionRequest) GetName
func
(
x
*
GetChannelConnectionRequest
)
GetName
()
string
func (*GetChannelConnectionRequest) ProtoMessage
func
(
*
GetChannelConnectionRequest
)
ProtoMessage
()
func (*GetChannelConnectionRequest) ProtoReflect
func
(
x
*
GetChannelConnectionRequest
)
ProtoReflect
()
protoreflect
.
Message
func (*GetChannelConnectionRequest) Reset
func
(
x
*
GetChannelConnectionRequest
)
Reset
()
func (*GetChannelConnectionRequest) String
func
(
x
*
GetChannelConnectionRequest
)
String
()
string
GetChannelRequest
type
GetChannelRequest
struct
{
// Required. The name of the channel to get.
Name
string
`protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
The request message for the GetChannel method.
func (*GetChannelRequest) Descriptor
func
(
*
GetChannelRequest
)
Descriptor
()
([]
byte
,
[]
int
)
Deprecated: Use GetChannelRequest.ProtoReflect.Descriptor instead.
func (*GetChannelRequest) GetName
func
(
x
*
GetChannelRequest
)
GetName
()
string
func (*GetChannelRequest) ProtoMessage
func
(
*
GetChannelRequest
)
ProtoMessage
()
func (*GetChannelRequest) ProtoReflect
func
(
x
*
GetChannelRequest
)
ProtoReflect
()
protoreflect
.
Message
func (*GetChannelRequest) Reset
func
(
x
*
GetChannelRequest
)
Reset
()
func (*GetChannelRequest) String
func
(
x
*
GetChannelRequest
)
String
()
string
GetGoogleChannelConfigRequest
type
GetGoogleChannelConfigRequest
struct
{
// Required. The name of the config to get.
Name
string
`protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
The request message for the GetGoogleChannelConfig method.
func (*GetGoogleChannelConfigRequest) Descriptor
func
(
*
GetGoogleChannelConfigRequest
)
Descriptor
()
([]
byte
,
[]
int
)
Deprecated: Use GetGoogleChannelConfigRequest.ProtoReflect.Descriptor instead.
func (*GetGoogleChannelConfigRequest) GetName
func
(
x
*
GetGoogleChannelConfigRequest
)
GetName
()
string
func (*GetGoogleChannelConfigRequest) ProtoMessage
func
(
*
GetGoogleChannelConfigRequest
)
ProtoMessage
()
func (*GetGoogleChannelConfigRequest) ProtoReflect
func
(
x
*
GetGoogleChannelConfigRequest
)
ProtoReflect
()
protoreflect
.
Message
func (*GetGoogleChannelConfigRequest) Reset
func
(
x
*
GetGoogleChannelConfigRequest
)
Reset
()
func (*GetGoogleChannelConfigRequest) String
func
(
x
*
GetGoogleChannelConfigRequest
)
String
()
string
GetProviderRequest
type
GetProviderRequest
struct
{
// Required. The name of the provider to get.
Name
string
`protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
The request message for the GetProvider method.
func (*GetProviderRequest) Descriptor
func
(
*
GetProviderRequest
)
Descriptor
()
([]
byte
,
[]
int
)
Deprecated: Use GetProviderRequest.ProtoReflect.Descriptor instead.
func (*GetProviderRequest) GetName
func
(
x
*
GetProviderRequest
)
GetName
()
string
func (*GetProviderRequest) ProtoMessage
func
(
*
GetProviderRequest
)
ProtoMessage
()
func (*GetProviderRequest) ProtoReflect
func
(
x
*
GetProviderRequest
)
ProtoReflect
()
protoreflect
.
Message
func (*GetProviderRequest) Reset
func
(
x
*
GetProviderRequest
)
Reset
()
func (*GetProviderRequest) String
func
(
x
*
GetProviderRequest
)
String
()
string
GetTriggerRequest
type
GetTriggerRequest
struct
{
// Required. The name of the trigger to get.
Name
string
`protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
The request message for the GetTrigger method.
func (*GetTriggerRequest) Descriptor
func
(
*
GetTriggerRequest
)
Descriptor
()
([]
byte
,
[]
int
)
Deprecated: Use GetTriggerRequest.ProtoReflect.Descriptor instead.
func (*GetTriggerRequest) GetName
func
(
x
*
GetTriggerRequest
)
GetName
()
string
func (*GetTriggerRequest) ProtoMessage
func
(
*
GetTriggerRequest
)
ProtoMessage
()
func (*GetTriggerRequest) ProtoReflect
func
(
x
*
GetTriggerRequest
)
ProtoReflect
()
protoreflect
.
Message
func (*GetTriggerRequest) Reset
func
(
x
*
GetTriggerRequest
)
Reset
()
func (*GetTriggerRequest) String
func
(
x
*
GetTriggerRequest
)
String
()
string
GoogleChannelConfig
type
GoogleChannelConfig
struct
{
// Required. The resource name of the config. Must be in the format of,
// `projects/{project}/locations/{location}/googleChannelConfig`.
Name
string
`protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Output only. The last-modified time.
UpdateTime
*
timestamppb
.
Timestamp
`protobuf:"bytes,6,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
// Optional. Resource name of a KMS crypto key (managed by the user) used to
// encrypt/decrypt their event data.
//
// It must match the pattern
// `projects/*/locations/*/keyRings/*/cryptoKeys/*`.
CryptoKeyName
string
`protobuf:"bytes,7,opt,name=crypto_key_name,json=cryptoKeyName,proto3" json:"crypto_key_name,omitempty"`
// contains filtered or unexported fields
}
A GoogleChannelConfig is a resource that stores the custom settings respected by Eventarc first-party triggers in the matching region. Once configured, first-party event data will be protected using the specified custom managed encryption key instead of Google-managed encryption keys.
func (*GoogleChannelConfig) Descriptor
func
(
*
GoogleChannelConfig
)
Descriptor
()
([]
byte
,
[]
int
)
Deprecated: Use GoogleChannelConfig.ProtoReflect.Descriptor instead.
func (*GoogleChannelConfig) GetCryptoKeyName
func
(
x
*
GoogleChannelConfig
)
GetCryptoKeyName
()
string
func (*GoogleChannelConfig) GetName
func
(
x
*
GoogleChannelConfig
)
GetName
()
string
func (*GoogleChannelConfig) GetUpdateTime
func
(
x
*
GoogleChannelConfig
)
GetUpdateTime
()
*
timestamppb
.
Timestamp
func (*GoogleChannelConfig) ProtoMessage
func
(
*
GoogleChannelConfig
)
ProtoMessage
()
func (*GoogleChannelConfig) ProtoReflect
func
(
x
*
GoogleChannelConfig
)
ProtoReflect
()
protoreflect
.
Message
func (*GoogleChannelConfig) Reset
func
(
x
*
GoogleChannelConfig
)
Reset
()
func (*GoogleChannelConfig) String
func
(
x
*
GoogleChannelConfig
)
String
()
string
ListChannelConnectionsRequest
type
ListChannelConnectionsRequest
struct
{
// Required. The parent collection from which to list channel connections.
Parent
string
`protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// The maximum number of channel connections to return on each page.
//
// Note: The service may send fewer responses.
PageSize
int32
`protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
// The page token; provide the value from the `next_page_token` field in a
// previous `ListChannelConnections` call to retrieve the subsequent page.
//
// When paginating, all other parameters provided to `ListChannelConnetions`
// match the call that provided the page token.
PageToken
string
`protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
// contains filtered or unexported fields
}
The request message for the ListChannelConnections method.
func (*ListChannelConnectionsRequest) Descriptor
func
(
*
ListChannelConnectionsRequest
)
Descriptor
()
([]
byte
,
[]
int
)
Deprecated: Use ListChannelConnectionsRequest.ProtoReflect.Descriptor instead.
func (*ListChannelConnectionsRequest) GetPageSize
func
(
x
*
ListChannelConnectionsRequest
)
GetPageSize
()
int32
func (*ListChannelConnectionsRequest) GetPageToken
func
(
x
*
ListChannelConnectionsRequest
)
GetPageToken
()
string
func (*ListChannelConnectionsRequest) GetParent
func
(
x
*
ListChannelConnectionsRequest
)
GetParent
()
string
func (*ListChannelConnectionsRequest) ProtoMessage
func
(
*
ListChannelConnectionsRequest
)
ProtoMessage
()
func (*ListChannelConnectionsRequest) ProtoReflect
func
(
x
*
ListChannelConnectionsRequest
)
ProtoReflect
()
protoreflect
.
Message
func (*ListChannelConnectionsRequest) Reset
func
(
x
*
ListChannelConnectionsRequest
)
Reset
()
func (*ListChannelConnectionsRequest) String
func
(
x
*
ListChannelConnectionsRequest
)
String
()
string
ListChannelConnectionsResponse
type
ListChannelConnectionsResponse
struct
{
// The requested channel connections, up to the number specified in
// `page_size`.
ChannelConnections
[]
*
ChannelConnection
`protobuf:"bytes,1,rep,name=channel_connections,json=channelConnections,proto3" json:"channel_connections,omitempty"`
// A page token that can be sent to `ListChannelConnections` to request the
// next page.
// If this is empty, then there are no more pages.
NextPageToken
string
`protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
// Unreachable resources, if any.
Unreachable
[]
string
`protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"`
// contains filtered or unexported fields
}
The response message for the ListChannelConnections
method.
func (*ListChannelConnectionsResponse) Descriptor
func
(
*
ListChannelConnectionsResponse
)
Descriptor
()
([]
byte
,
[]
int
)
Deprecated: Use ListChannelConnectionsResponse.ProtoReflect.Descriptor instead.
func (*ListChannelConnectionsResponse) GetChannelConnections
func
(
x
*
ListChannelConnectionsResponse
)
GetChannelConnections
()
[]
*
ChannelConnection
func (*ListChannelConnectionsResponse) GetNextPageToken
func
(
x
*
ListChannelConnectionsResponse
)
GetNextPageToken
()
string
func (*ListChannelConnectionsResponse) GetUnreachable
func
(
x
*
ListChannelConnectionsResponse
)
GetUnreachable
()
[]
string
func (*ListChannelConnectionsResponse) ProtoMessage
func
(
*
ListChannelConnectionsResponse
)
ProtoMessage
()
func (*ListChannelConnectionsResponse) ProtoReflect
func
(
x
*
ListChannelConnectionsResponse
)
ProtoReflect
()
protoreflect
.
Message
func (*ListChannelConnectionsResponse) Reset
func
(
x
*
ListChannelConnectionsResponse
)
Reset
()
func (*ListChannelConnectionsResponse) String
func
(
x
*
ListChannelConnectionsResponse
)
String
()
string
ListChannelsRequest
type
ListChannelsRequest
struct
{
// Required. The parent collection to list channels on.
Parent
string
`protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// The maximum number of channels to return on each page.
//
// Note: The service may send fewer.
PageSize
int32
`protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
// The page token; provide the value from the `next_page_token` field in a
// previous `ListChannels` call to retrieve the subsequent page.
//
// When paginating, all other parameters provided to `ListChannels` must
// match the call that provided the page token.
PageToken
string
`protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
// The sorting order of the resources returned. Value should be a
// comma-separated list of fields. The default sorting order is ascending. To
// specify descending order for a field, append a `desc` suffix; for example:
// `name desc, channel_id`.
OrderBy
string
`protobuf:"bytes,4,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
// contains filtered or unexported fields
}
The request message for the ListChannels method.
func (*ListChannelsRequest) Descriptor
func
(
*
ListChannelsRequest
)
Descriptor
()
([]
byte
,
[]
int
)
Deprecated: Use ListChannelsRequest.ProtoReflect.Descriptor instead.
func (*ListChannelsRequest) GetOrderBy
func
(
x
*
ListChannelsRequest
)
GetOrderBy
()
string
func (*ListChannelsRequest) GetPageSize
func
(
x
*
ListChannelsRequest
)
GetPageSize
()
int32
func (*ListChannelsRequest) GetPageToken
func
(
x
*
ListChannelsRequest
)
GetPageToken
()
string
func (*ListChannelsRequest) GetParent
func
(
x
*
ListChannelsRequest
)
GetParent
()
string
func (*ListChannelsRequest) ProtoMessage
func
(
*
ListChannelsRequest
)
ProtoMessage
()
func (*ListChannelsRequest) ProtoReflect
func
(
x
*
ListChannelsRequest
)
ProtoReflect
()
protoreflect
.
Message
func (*ListChannelsRequest) Reset
func
(
x
*
ListChannelsRequest
)
Reset
()
func (*ListChannelsRequest) String
func
(
x
*
ListChannelsRequest
)
String
()
string
ListChannelsResponse
type
ListChannelsResponse
struct
{
// The requested channels, up to the number specified in `page_size`.
Channels
[]
*
Channel
`protobuf:"bytes,1,rep,name=channels,proto3" json:"channels,omitempty"`
// A page token that can be sent to `ListChannels` to request the next page.
// If this is empty, then there are no more pages.
NextPageToken
string
`protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
// Unreachable resources, if any.
Unreachable
[]
string
`protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"`
// contains filtered or unexported fields
}
The response message for the ListChannels
method.
func (*ListChannelsResponse) Descriptor
func
(
*
ListChannelsResponse
)
Descriptor
()
([]
byte
,
[]
int
)
Deprecated: Use ListChannelsResponse.ProtoReflect.Descriptor instead.
func (*ListChannelsResponse) GetChannels
func
(
x
*
ListChannelsResponse
)
GetChannels
()
[]
*
Channel
func (*ListChannelsResponse) GetNextPageToken
func
(
x
*
ListChannelsResponse
)
GetNextPageToken
()
string
func (*ListChannelsResponse) GetUnreachable
func
(
x
*
ListChannelsResponse
)
GetUnreachable
()
[]
string
func (*ListChannelsResponse) ProtoMessage
func
(
*
ListChannelsResponse
)
ProtoMessage
()
func (*ListChannelsResponse) ProtoReflect
func
(
x
*
ListChannelsResponse
)
ProtoReflect
()
protoreflect
.
Message
func (*ListChannelsResponse) Reset
func
(
x
*
ListChannelsResponse
)
Reset
()
func (*ListChannelsResponse) String
func
(
x
*
ListChannelsResponse
)
String
()
string
ListProvidersRequest
type
ListProvidersRequest
struct
{
// Required. The parent of the provider to get.
Parent
string
`protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// The maximum number of providers to return on each page.
PageSize
int32
`protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
// The page token; provide the value from the `next_page_token` field in a
// previous `ListProviders` call to retrieve the subsequent page.
//
// When paginating, all other parameters provided to `ListProviders` must
// match the call that provided the page token.
PageToken
string
`protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
// The sorting order of the resources returned. Value should be a
// comma-separated list of fields. The default sorting oder is ascending. To
// specify descending order for a field, append a `desc` suffix; for example:
// `name desc, _id`.
OrderBy
string
`protobuf:"bytes,4,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
// The filter field that the list request will filter on.
Filter
string
`protobuf:"bytes,5,opt,name=filter,proto3" json:"filter,omitempty"`
// contains filtered or unexported fields
}
The request message for the ListProviders method.
func (*ListProvidersRequest) Descriptor
func
(
*
ListProvidersRequest
)
Descriptor
()
([]
byte
,
[]
int
)
Deprecated: Use ListProvidersRequest.ProtoReflect.Descriptor instead.
func (*ListProvidersRequest) GetFilter
func
(
x
*
ListProvidersRequest
)
GetFilter
()
string
func (*ListProvidersRequest) GetOrderBy
func
(
x
*
ListProvidersRequest
)
GetOrderBy
()
string
func (*ListProvidersRequest) GetPageSize
func
(
x
*
ListProvidersRequest
)
GetPageSize
()
int32
func (*ListProvidersRequest) GetPageToken
func
(
x
*
ListProvidersRequest
)
GetPageToken
()
string
func (*ListProvidersRequest) GetParent
func
(
x
*
ListProvidersRequest
)
GetParent
()
string
func (*ListProvidersRequest) ProtoMessage
func
(
*
ListProvidersRequest
)
ProtoMessage
()
func (*ListProvidersRequest) ProtoReflect
func
(
x
*
ListProvidersRequest
)
ProtoReflect
()
protoreflect
.
Message
func (*ListProvidersRequest) Reset
func
(
x
*
ListProvidersRequest
)
Reset
()
func (*ListProvidersRequest) String
func
(
x
*
ListProvidersRequest
)
String
()
string
ListProvidersResponse
type
ListProvidersResponse
struct
{
// The requested providers, up to the number specified in `page_size`.
Providers
[]
*
Provider
`protobuf:"bytes,1,rep,name=providers,proto3" json:"providers,omitempty"`
// A page token that can be sent to `ListProviders` to request the next page.
// If this is empty, then there are no more pages.
NextPageToken
string
`protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
// Unreachable resources, if any.
Unreachable
[]
string
`protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"`
// contains filtered or unexported fields
}
The response message for the ListProviders
method.
func (*ListProvidersResponse) Descriptor
func
(
*
ListProvidersResponse
)
Descriptor
()
([]
byte
,
[]
int
)
Deprecated: Use ListProvidersResponse.ProtoReflect.Descriptor instead.
func (*ListProvidersResponse) GetNextPageToken
func
(
x
*
ListProvidersResponse
)
GetNextPageToken
()
string
func (*ListProvidersResponse) GetProviders
func
(
x
*
ListProvidersResponse
)
GetProviders
()
[]
*
Provider
func (*ListProvidersResponse) GetUnreachable
func
(
x
*
ListProvidersResponse
)
GetUnreachable
()
[]
string
func (*ListProvidersResponse) ProtoMessage
func
(
*
ListProvidersResponse
)
ProtoMessage
()
func (*ListProvidersResponse) ProtoReflect
func
(
x
*
ListProvidersResponse
)
ProtoReflect
()
protoreflect
.
Message
func (*ListProvidersResponse) Reset
func
(
x
*
ListProvidersResponse
)
Reset
()
func (*ListProvidersResponse) String
func
(
x
*
ListProvidersResponse
)
String
()
string
ListTriggersRequest
type
ListTriggersRequest
struct
{
// Required. The parent collection to list triggers on.
Parent
string
`protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// The maximum number of triggers to return on each page.
//
// Note: The service may send fewer.
PageSize
int32
`protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
// The page token; provide the value from the `next_page_token` field in a
// previous `ListTriggers` call to retrieve the subsequent page.
//
// When paginating, all other parameters provided to `ListTriggers` must match
// the call that provided the page token.
PageToken
string
`protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
// The sorting order of the resources returned. Value should be a
// comma-separated list of fields. The default sorting order is ascending. To
// specify descending order for a field, append a `desc` suffix; for example:
// `name desc, trigger_id`.
OrderBy
string
`protobuf:"bytes,4,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
// Filter field. Used to filter the Triggers to be listed. Possible filters
// are described in https://google.aip.dev/160. For example, using
// "?filter=destination:gke" would list only Triggers with a gke destination.
Filter
string
`protobuf:"bytes,5,opt,name=filter,proto3" json:"filter,omitempty"`
// contains filtered or unexported fields
}
The request message for the ListTriggers method.
func (*ListTriggersRequest) Descriptor
func
(
*
ListTriggersRequest
)
Descriptor
()
([]
byte
,
[]
int
)
Deprecated: Use ListTriggersRequest.ProtoReflect.Descriptor instead.
func (*ListTriggersRequest) GetFilter
func
(
x
*
ListTriggersRequest
)
GetFilter
()
string
func (*ListTriggersRequest) GetOrderBy
func
(
x
*
ListTriggersRequest
)
GetOrderBy
()
string
func (*ListTriggersRequest) GetPageSize
func
(
x
*
ListTriggersRequest
)
GetPageSize
()
int32
func (*ListTriggersRequest) GetPageToken
func
(
x
*
ListTriggersRequest
)
GetPageToken
()
string
func (*ListTriggersRequest) GetParent
func
(
x
*
ListTriggersRequest
)
GetParent
()
string
func (*ListTriggersRequest) ProtoMessage
func
(
*
ListTriggersRequest
)
ProtoMessage
()
func (*ListTriggersRequest) ProtoReflect
func
(
x
*
ListTriggersRequest
)
ProtoReflect
()
protoreflect
.
Message
func (*ListTriggersRequest) Reset
func
(
x
*
ListTriggersRequest
)
Reset
()
func (*ListTriggersRequest) String
func
(
x
*
ListTriggersRequest
)
String
()
string
ListTriggersResponse
type
ListTriggersResponse
struct
{
// The requested triggers, up to the number specified in `page_size`.
Triggers
[]
*
Trigger
`protobuf:"bytes,1,rep,name=triggers,proto3" json:"triggers,omitempty"`
// A page token that can be sent to `ListTriggers` to request the next page.
// If this is empty, then there are no more pages.
NextPageToken
string
`protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
// Unreachable resources, if any.
Unreachable
[]
string
`protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"`
// contains filtered or unexported fields
}
The response message for the ListTriggers
method.
func (*ListTriggersResponse) Descriptor
func
(
*
ListTriggersResponse
)
Descriptor
()
([]
byte
,
[]
int
)
Deprecated: Use ListTriggersResponse.ProtoReflect.Descriptor instead.
func (*ListTriggersResponse) GetNextPageToken
func
(
x
*
ListTriggersResponse
)
GetNextPageToken
()
string
func (*ListTriggersResponse) GetTriggers
func
(
x
*
ListTriggersResponse
)
GetTriggers
()
[]
*
Trigger
func (*ListTriggersResponse) GetUnreachable
func
(
x
*
ListTriggersResponse
)
GetUnreachable
()
[]
string
func (*ListTriggersResponse) ProtoMessage
func
(
*
ListTriggersResponse
)
ProtoMessage
()
func (*ListTriggersResponse) ProtoReflect
func
(
x
*
ListTriggersResponse
)
ProtoReflect
()
protoreflect
.
Message
func (*ListTriggersResponse) Reset
func
(
x
*
ListTriggersResponse
)
Reset
()
func (*ListTriggersResponse) String
func
(
x
*
ListTriggersResponse
)
String
()
string
OperationMetadata
type
OperationMetadata
struct
{
// Output only. The time the operation was created.
CreateTime
*
timestamppb
.
Timestamp
`protobuf:"bytes,1,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
// Output only. The time the operation finished running.
EndTime
*
timestamppb
.
Timestamp
`protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
// Output only. Server-defined resource path for the target of the operation.
Target
string
`protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
// Output only. Name of the verb executed by the operation.
Verb
string
`protobuf:"bytes,4,opt,name=verb,proto3" json:"verb,omitempty"`
// Output only. Human-readable status of the operation, if any.
StatusMessage
string
`protobuf:"bytes,5,opt,name=status_message,json=statusMessage,proto3" json:"status_message,omitempty"`
// Output only. Identifies whether the user has requested cancellation
// of the operation. Operations that have successfully been cancelled
// have [Operation.error][] value with a [google.rpc.Status.code][google.rpc.Status.code] of 1,
// corresponding to `Code.CANCELLED`.
RequestedCancellation
bool
`protobuf:"varint,6,opt,name=requested_cancellation,json=requestedCancellation,proto3" json:"requested_cancellation,omitempty"`
// Output only. API version used to start the operation.
ApiVersion
string
`protobuf:"bytes,7,opt,name=api_version,json=apiVersion,proto3" json:"api_version,omitempty"`
// contains filtered or unexported fields
}
Represents the metadata of the long-running operation.
func (*OperationMetadata) Descriptor
func
(
*
OperationMetadata
)
Descriptor
()
([]
byte
,
[]
int
)
Deprecated: Use OperationMetadata.ProtoReflect.Descriptor instead.
func (*OperationMetadata) GetApiVersion
func
(
x
*
OperationMetadata
)
GetApiVersion
()
string
func (*OperationMetadata) GetCreateTime
func
(
x
*
OperationMetadata
)
GetCreateTime
()
*
timestamppb
.
Timestamp
func (*OperationMetadata) GetEndTime
func
(
x
*
OperationMetadata
)
GetEndTime
()
*
timestamppb
.
Timestamp
func (*OperationMetadata) GetRequestedCancellation
func
(
x
*
OperationMetadata
)
GetRequestedCancellation
()
bool
func (*OperationMetadata) GetStatusMessage
func
(
x
*
OperationMetadata
)
GetStatusMessage
()
string
func (*OperationMetadata) GetTarget
func
(
x
*
OperationMetadata
)
GetTarget
()
string
func (*OperationMetadata) GetVerb
func
(
x
*
OperationMetadata
)
GetVerb
()
string
func (*OperationMetadata) ProtoMessage
func
(
*
OperationMetadata
)
ProtoMessage
()
func (*OperationMetadata) ProtoReflect
func
(
x
*
OperationMetadata
)
ProtoReflect
()
protoreflect
.
Message
func (*OperationMetadata) Reset
func
(
x
*
OperationMetadata
)
Reset
()
func (*OperationMetadata) String
func
(
x
*
OperationMetadata
)
String
()
string
Provider
type
Provider
struct
{
// Output only. In `projects/{project}/locations/{location}/providers/{provider_id}`
// format.
Name
string
`protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Output only. Human friendly name for the Provider. For example "Cloud Storage".
DisplayName
string
`protobuf:"bytes,2,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
// Output only. Event types for this provider.
EventTypes
[]
*
EventType
`protobuf:"bytes,3,rep,name=event_types,json=eventTypes,proto3" json:"event_types,omitempty"`
// contains filtered or unexported fields
}
A representation of the Provider resource.
func (*Provider) Descriptor
Deprecated: Use Provider.ProtoReflect.Descriptor instead.
func (*Provider) GetDisplayName
func (*Provider) GetEventTypes
func (*Provider) GetName
func (*Provider) ProtoMessage
func
(
*
Provider
)
ProtoMessage
()
func (*Provider) ProtoReflect
func
(
x
*
Provider
)
ProtoReflect
()
protoreflect
.
Message
func (*Provider) Reset
func
(
x
*
Provider
)
Reset
()
func (*Provider) String
Pubsub
type
Pubsub
struct
{
// Optional. The name of the Pub/Sub topic created and managed by Eventarc as
// a transport for the event delivery. Format:
// `projects/{PROJECT_ID}/topics/{TOPIC_NAME}`.
//
// You can set an existing topic for triggers of the type
// `google.cloud.pubsub.topic.v1.messagePublished`. The topic you provide
// here is not deleted by Eventarc at trigger deletion.
Topic
string
`protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
// Output only. The name of the Pub/Sub subscription created and managed by Eventarc
// as a transport for the event delivery. Format:
// `projects/{PROJECT_ID}/subscriptions/{SUBSCRIPTION_NAME}`.
Subscription
string
`protobuf:"bytes,2,opt,name=subscription,proto3" json:"subscription,omitempty"`
// contains filtered or unexported fields
}
Represents a Pub/Sub transport.
func (*Pubsub) Descriptor
Deprecated: Use Pubsub.ProtoReflect.Descriptor instead.
func (*Pubsub) GetSubscription
func (*Pubsub) GetTopic
func (*Pubsub) ProtoMessage
func
(
*
Pubsub
)
ProtoMessage
()
func (*Pubsub) ProtoReflect
func
(
x
*
Pubsub
)
ProtoReflect
()
protoreflect
.
Message
func (*Pubsub) Reset
func
(
x
*
Pubsub
)
Reset
()
func (*Pubsub) String
StateCondition
type
StateCondition
struct
{
// The canonical code of the condition.
Code
code
.
Code
`protobuf:"varint,1,opt,name=code,proto3,enum=google.rpc.Code" json:"code,omitempty"`
// Human-readable message.
Message
string
`protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
// contains filtered or unexported fields
}
A condition that is part of the trigger state computation.
func (*StateCondition) Descriptor
func
(
*
StateCondition
)
Descriptor
()
([]
byte
,
[]
int
)
Deprecated: Use StateCondition.ProtoReflect.Descriptor instead.
func (*StateCondition) GetCode
func
(
x
*
StateCondition
)
GetCode
()
code
.
Code
func (*StateCondition) GetMessage
func
(
x
*
StateCondition
)
GetMessage
()
string
func (*StateCondition) ProtoMessage
func
(
*
StateCondition
)
ProtoMessage
()
func (*StateCondition) ProtoReflect
func
(
x
*
StateCondition
)
ProtoReflect
()
protoreflect
.
Message
func (*StateCondition) Reset
func
(
x
*
StateCondition
)
Reset
()
func (*StateCondition) String
func
(
x
*
StateCondition
)
String
()
string
Transport
type
Transport
struct
{
// Types that are assignable to Intermediary:
//
// *Transport_Pubsub
Intermediary
isTransport_Intermediary
`protobuf_oneof:"intermediary"`
// contains filtered or unexported fields
}
Represents the transport intermediaries created for the trigger to deliver events.
func (*Transport) Descriptor
Deprecated: Use Transport.ProtoReflect.Descriptor instead.
func (*Transport) GetIntermediary
func
(
m
*
Transport
)
GetIntermediary
()
isTransport_Intermediary
func (*Transport) GetPubsub
func (*Transport) ProtoMessage
func
(
*
Transport
)
ProtoMessage
()
func (*Transport) ProtoReflect
func
(
x
*
Transport
)
ProtoReflect
()
protoreflect
.
Message
func (*Transport) Reset
func
(
x
*
Transport
)
Reset
()
func (*Transport) String
Transport_Pubsub
type
Transport_Pubsub
struct
{
// The Pub/Sub topic and subscription used by Eventarc as a transport
// intermediary.
Pubsub
*
Pubsub
`protobuf:"bytes,1,opt,name=pubsub,proto3,oneof"`
}
Trigger
type
Trigger
struct
{
Name
string
`protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Uid
string
`protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
CreateTime
*
timestamppb
.
Timestamp
`protobuf:"bytes,5,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
UpdateTime
*
timestamppb
.
Timestamp
`protobuf:"bytes,6,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
EventFilters
[]
*
EventFilter
`protobuf:"bytes,8,rep,name=event_filters,json=eventFilters,proto3" json:"event_filters,omitempty"`
ServiceAccount
string
`protobuf:"bytes,9,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"`
Destination
*
Destination
`protobuf:"bytes,10,opt,name=destination,proto3" json:"destination,omitempty"`
Transport
*
Transport
`protobuf:"bytes,11,opt,name=transport,proto3" json:"transport,omitempty"`
Labels
map
[
string
]
string
""
/* 154 byte string literal not displayed */
Channel
string
`protobuf:"bytes,13,opt,name=channel,proto3" json:"channel,omitempty"`
Conditions
map
[
string
]
*
StateCondition
""
/* 162 byte string literal not displayed */
Etag
string
`protobuf:"bytes,99,opt,name=etag,proto3" json:"etag,omitempty"`
}
A representation of the trigger resource.
func (*Trigger) Descriptor
Deprecated: Use Trigger.ProtoReflect.Descriptor instead.
func (*Trigger) GetChannel
func (*Trigger) GetConditions
func
(
x
*
Trigger
)
GetConditions
()
map
[
string
]
*
StateCondition
func (*Trigger) GetCreateTime
func
(
x
*
Trigger
)
GetCreateTime
()
*
timestamppb
.
Timestamp
func (*Trigger) GetDestination
func
(
x
*
Trigger
)
GetDestination
()
*
Destination
func (*Trigger) GetEtag
func (*Trigger) GetEventFilters
func
(
x
*
Trigger
)
GetEventFilters
()
[]
*
EventFilter
func (*Trigger) GetLabels
func (*Trigger) GetName
func (*Trigger) GetServiceAccount
func (*Trigger) GetTransport
func (*Trigger) GetUid
func (*Trigger) GetUpdateTime
func
(
x
*
Trigger
)
GetUpdateTime
()
*
timestamppb
.
Timestamp
func (*Trigger) ProtoMessage
func
(
*
Trigger
)
ProtoMessage
()
func (*Trigger) ProtoReflect
func
(
x
*
Trigger
)
ProtoReflect
()
protoreflect
.
Message
func (*Trigger) Reset
func
(
x
*
Trigger
)
Reset
()
func (*Trigger) String
UnimplementedEventarcServer
type
UnimplementedEventarcServer
struct
{
}
UnimplementedEventarcServer can be embedded to have forward compatible implementations.
func (*UnimplementedEventarcServer) CreateChannel
func
(
*
UnimplementedEventarcServer
)
CreateChannel
(
context
.
Context
,
*
CreateChannelRequest
)
(
*
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
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
func
(
*
UnimplementedEventarcServer
)
UpdateGoogleChannelConfig
(
context
.
Context
,
*
UpdateGoogleChannelConfigRequest
)
(
*
GoogleChannelConfig
,
error
)
func (*UnimplementedEventarcServer) UpdateTrigger
func
(
*
UnimplementedEventarcServer
)
UpdateTrigger
(
context
.
Context
,
*
UpdateTriggerRequest
)
(
*
longrunningpb
.
Operation
,
error
)
UpdateChannelRequest
type
UpdateChannelRequest
struct
{
// The channel to be updated.
Channel
*
Channel
`protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
// The fields to be updated; only fields explicitly provided are updated.
// If no field mask is provided, all provided fields in the request are
// updated. To update all fields, provide a field mask of "*".
UpdateMask
*
fieldmaskpb
.
FieldMask
`protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
// Required. If set, validate the request and preview the review, but do not
// post it.
ValidateOnly
bool
`protobuf:"varint,3,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
// contains filtered or unexported fields
}
The request message for the UpdateChannel method.
func (*UpdateChannelRequest) Descriptor
func
(
*
UpdateChannelRequest
)
Descriptor
()
([]
byte
,
[]
int
)
Deprecated: Use UpdateChannelRequest.ProtoReflect.Descriptor instead.
func (*UpdateChannelRequest) GetChannel
func
(
x
*
UpdateChannelRequest
)
GetChannel
()
*
Channel
func (*UpdateChannelRequest) GetUpdateMask
func
(
x
*
UpdateChannelRequest
)
GetUpdateMask
()
*
fieldmaskpb
.
FieldMask
func (*UpdateChannelRequest) GetValidateOnly
func
(
x
*
UpdateChannelRequest
)
GetValidateOnly
()
bool
func (*UpdateChannelRequest) ProtoMessage
func
(
*
UpdateChannelRequest
)
ProtoMessage
()
func (*UpdateChannelRequest) ProtoReflect
func
(
x
*
UpdateChannelRequest
)
ProtoReflect
()
protoreflect
.
Message
func (*UpdateChannelRequest) Reset
func
(
x
*
UpdateChannelRequest
)
Reset
()
func (*UpdateChannelRequest) String
func
(
x
*
UpdateChannelRequest
)
String
()
string
UpdateGoogleChannelConfigRequest
type
UpdateGoogleChannelConfigRequest
struct
{
// Required. The config to be updated.
GoogleChannelConfig
*
GoogleChannelConfig
`protobuf:"bytes,1,opt,name=google_channel_config,json=googleChannelConfig,proto3" json:"google_channel_config,omitempty"`
// The fields to be updated; only fields explicitly provided are updated.
// If no field mask is provided, all provided fields in the request are
// updated. To update all fields, provide a field mask of "*".
UpdateMask
*
fieldmaskpb
.
FieldMask
`protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
// contains filtered or unexported fields
}
The request message for the UpdateGoogleChannelConfig method.
func (*UpdateGoogleChannelConfigRequest) Descriptor
func
(
*
UpdateGoogleChannelConfigRequest
)
Descriptor
()
([]
byte
,
[]
int
)
Deprecated: Use UpdateGoogleChannelConfigRequest.ProtoReflect.Descriptor instead.
func (*UpdateGoogleChannelConfigRequest) GetGoogleChannelConfig
func
(
x
*
UpdateGoogleChannelConfigRequest
)
GetGoogleChannelConfig
()
*
GoogleChannelConfig
func (*UpdateGoogleChannelConfigRequest) GetUpdateMask
func
(
x
*
UpdateGoogleChannelConfigRequest
)
GetUpdateMask
()
*
fieldmaskpb
.
FieldMask
func (*UpdateGoogleChannelConfigRequest) ProtoMessage
func
(
*
UpdateGoogleChannelConfigRequest
)
ProtoMessage
()
func (*UpdateGoogleChannelConfigRequest) ProtoReflect
func
(
x
*
UpdateGoogleChannelConfigRequest
)
ProtoReflect
()
protoreflect
.
Message
func (*UpdateGoogleChannelConfigRequest) Reset
func
(
x
*
UpdateGoogleChannelConfigRequest
)
Reset
()
func (*UpdateGoogleChannelConfigRequest) String
func
(
x
*
UpdateGoogleChannelConfigRequest
)
String
()
string
UpdateTriggerRequest
type
UpdateTriggerRequest
struct
{
// The trigger to be updated.
Trigger
*
Trigger
`protobuf:"bytes,1,opt,name=trigger,proto3" json:"trigger,omitempty"`
// The fields to be updated; only fields explicitly provided are updated.
// If no field mask is provided, all provided fields in the request are
// updated. To update all fields, provide a field mask of "*".
UpdateMask
*
fieldmaskpb
.
FieldMask
`protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
// If set to true, and the trigger is not found, a new trigger will be
// created. In this situation, `update_mask` is ignored.
AllowMissing
bool
`protobuf:"varint,3,opt,name=allow_missing,json=allowMissing,proto3" json:"allow_missing,omitempty"`
// Required. If set, validate the request and preview the review, but do not
// post it.
ValidateOnly
bool
`protobuf:"varint,4,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
// contains filtered or unexported fields
}
The request message for the UpdateTrigger method.
func (*UpdateTriggerRequest) Descriptor
func
(
*
UpdateTriggerRequest
)
Descriptor
()
([]
byte
,
[]
int
)
Deprecated: Use UpdateTriggerRequest.ProtoReflect.Descriptor instead.
func (*UpdateTriggerRequest) GetAllowMissing
func
(
x
*
UpdateTriggerRequest
)
GetAllowMissing
()
bool
func (*UpdateTriggerRequest) GetTrigger
func
(
x
*
UpdateTriggerRequest
)
GetTrigger
()
*
Trigger
func (*UpdateTriggerRequest) GetUpdateMask
func
(
x
*
UpdateTriggerRequest
)
GetUpdateMask
()
*
fieldmaskpb
.
FieldMask
func (*UpdateTriggerRequest) GetValidateOnly
func
(
x
*
UpdateTriggerRequest
)
GetValidateOnly
()
bool
func (*UpdateTriggerRequest) ProtoMessage
func
(
*
UpdateTriggerRequest
)
ProtoMessage
()
func (*UpdateTriggerRequest) ProtoReflect
func
(
x
*
UpdateTriggerRequest
)
ProtoReflect
()
protoreflect
.
Message
func (*UpdateTriggerRequest) Reset
func
(
x
*
UpdateTriggerRequest
)
Reset
()
func (*UpdateTriggerRequest) String
func
(
x
*
UpdateTriggerRequest
)
String
()
string
