eventarc

package
v0.0.0-...-b395a37 Latest Latest
Warning

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

 Go to latest Published: Sep 17, 2021 License: Apache-2.0 Imports: 12 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_google_cloud_eventarc_v1_eventarc_proto protoreflect.FileDescriptor
View Source 
var File_google_cloud_eventarc_v1_trigger_proto protoreflect.FileDescriptor

Functions

func RegisterEventarcServer 

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

Types

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 of 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 URI path segment (section 3.3
	// of RFC2396). Examples: "/route", "route", "route/subroute".
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// Required. The region the Cloud Run service is deployed in.
	Region string `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"`
	// contains filtered or unexported fields
}

Represents a Cloud Run destination.

func (*CloudRun) Descriptor deprecated 

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

Deprecated: Use CloudRun.ProtoReflect.Descriptor instead.

func (*CloudRun) GetPath 

func (x *CloudRun) GetPath() string

func (*CloudRun) GetRegion 

func (x *CloudRun) GetRegion() string

func (*CloudRun) GetService 

func (x *CloudRun) GetService() string

func (*CloudRun) ProtoMessage 

func (*CloudRun) ProtoMessage()

func (*CloudRun) ProtoReflect 

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

func (*CloudRun) Reset 

func (x *CloudRun) Reset()

func (*CloudRun) String 

func (x *CloudRun) String() string

type 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 actually
	// 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 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 actually
	// 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
	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) GetCloudRun 

func (x *Destination) GetCloudRun() *CloudRun

func (*Destination) GetDescriptor_ 

func (m *Destination) GetDescriptor_() isDestination_Descriptor_

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_CloudRun 

type Destination_CloudRun struct {
	// Cloud Run fully-managed service that receives the events. The service
	// should be running in the same project of the trigger.
	CloudRun *CloudRun `protobuf:"bytes,1,opt,name=cloud_run,json=cloudRun,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"`
	// 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) 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 EventarcClient 

type EventarcClient interface {
	// Get a single trigger.
	GetTrigger(ctx context.Context, in *GetTriggerRequest, opts ...grpc.CallOption) (*Trigger, error)
	// List triggers.
	ListTriggers(ctx context.Context, in *ListTriggersRequest, opts ...grpc.CallOption) (*ListTriggersResponse, error)
	// Create a new trigger in a particular project and location.
	CreateTrigger(ctx context.Context, in *CreateTriggerRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// Update a single trigger.
	UpdateTrigger(ctx context.Context, in *UpdateTriggerRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// Delete a single trigger.
	DeleteTrigger(ctx context.Context, in *DeleteTriggerRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
}

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) (*longrunning.Operation, error)
	// Update a single trigger.
	UpdateTrigger(context.Context, *UpdateTriggerRequest) (*longrunning.Operation, error)
	// Delete a single trigger.
	DeleteTrigger(context.Context, *DeleteTriggerRequest) (*longrunning.Operation, error)
}

EventarcServer is the server API for Eventarc service.

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 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 oder is ascending. To specify
	// descending order for a field, append a ` desc` suffix; for example:
	// `name desc, trigger_id`.
	OrderBy string `protobuf:"bytes,4,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
	// contains filtered or unexported fields
}

The request message for the ListTriggers method.

func (*ListTriggersRequest) Descriptor deprecated 

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

Deprecated: Use ListTriggersRequest.ProtoReflect.Descriptor instead.

func (*ListTriggersRequest) GetOrderBy 

func (x *ListTriggersRequest) GetOrderBy() string

func (*ListTriggersRequest) GetPageSize 

func (x *ListTriggersRequest) GetPageSize() int32

func (*ListTriggersRequest) GetPageToken 

func (x *ListTriggersRequest) GetPageToken() string

func (*ListTriggersRequest) GetParent 

func (x *ListTriggersRequest) GetParent() string

func (*ListTriggersRequest) ProtoMessage 

func (*ListTriggersRequest) ProtoMessage()

func (*ListTriggersRequest) ProtoReflect 

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

func (*ListTriggersRequest) Reset 

func (x *ListTriggersRequest) Reset()

func (*ListTriggersRequest) String 

func (x *ListTriggersRequest) String() string

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 Pubsub 

type Pubsub struct {

	// Optional. The name of the Pub/Sub topic created and managed by Eventarc
	// system as a transport for the event delivery. Format:
	// `projects/{PROJECT_ID}/topics/{TOPIC_NAME}`.
	//
	// You may set an existing topic for triggers of the type
	// `google.cloud.pubsub.topic.v1.messagePublished` only. The topic you provide
	// here will not be 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 system as a transport for the event delivery. Format:
	// `projects/{PROJECT_ID}/subscriptions/{SUBSCRIPTION_NAME}`.
	Subscription string `protobuf:"bytes,2,opt,name=subscription,proto3" json:"subscription,omitempty"`
	// contains filtered or unexported fields
}

Represents a Pub/Sub transport.

func (*Pubsub) Descriptor deprecated 

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

Deprecated: Use Pubsub.ProtoReflect.Descriptor instead.

func (*Pubsub) GetSubscription 

func (x *Pubsub) GetSubscription() string

func (*Pubsub) GetTopic 

func (x *Pubsub) GetTopic() string

func (*Pubsub) ProtoMessage 

func (*Pubsub) ProtoMessage()

func (*Pubsub) ProtoReflect 

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

func (*Pubsub) Reset 

func (x *Pubsub) Reset()

func (*Pubsub) String 

func (x *Pubsub) String() string

type 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 in order to deliver events.

func (*Transport) Descriptor deprecated 

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

Deprecated: Use Transport.ProtoReflect.Descriptor instead.

func (*Transport) GetIntermediary 

func (m *Transport) GetIntermediary() isTransport_Intermediary

func (*Transport) GetPubsub 

func (x *Transport) GetPubsub() *Pubsub

func (*Transport) ProtoMessage 

func (*Transport) ProtoMessage()

func (*Transport) ProtoReflect 

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

func (*Transport) Reset 

func (x *Transport) Reset()

func (*Transport) String 

func (x *Transport) String() string

type Transport_Pubsub 

type Transport_Pubsub struct {
	// The Pub/Sub topic and subscription used by Eventarc as delivery
	// 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 on 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. null The list of filters that applies to event attributes. Only
	// events that match all the provided filters will be 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 `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.
	// In order to create Audit Log triggers, the service account should also
	// have `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. In order to deliver messages, Eventarc may use other GCP
	// products as 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 */
	// Output only. This checksum is computed by the server based on the value of
	// other fields, and may be sent only on create requests to ensure the client
	// has an up-to-date value before proceeding.
	Etag string `protobuf:"bytes,99,opt,name=etag,proto3" json:"etag,omitempty"`
	// contains filtered or unexported fields
}

A representation of the trigger resource.

func (*Trigger) Descriptor deprecated 

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

Deprecated: Use Trigger.ProtoReflect.Descriptor instead.

func (*Trigger) GetCreateTime 

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

func (*Trigger) GetDestination 

func (x *Trigger) GetDestination() *Destination

func (*Trigger) GetEtag 

func (x *Trigger) GetEtag() string

func (*Trigger) GetEventFilters 

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

func (*Trigger) GetLabels 

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

func (*Trigger) GetName 

func (x *Trigger) GetName() string

func (*Trigger) GetServiceAccount 

func (x *Trigger) GetServiceAccount() string

func (*Trigger) GetTransport 

func (x *Trigger) GetTransport() *Transport

func (*Trigger) GetUid 

func (x *Trigger) GetUid() string

func (*Trigger) GetUpdateTime 

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

func (*Trigger) ProtoMessage 

func (*Trigger) ProtoMessage()

func (*Trigger) ProtoReflect 

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

func (*Trigger) Reset 

func (x *Trigger) Reset()

func (*Trigger) String 

func (x *Trigger) String() string

type UnimplementedEventarcServer 

type UnimplementedEventarcServer struct {
}

UnimplementedEventarcServer can be embedded to have forward compatible implementations.

func (*UnimplementedEventarcServer) CreateTrigger 

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

func (*UnimplementedEventarcServer) DeleteTrigger 

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

func (*UnimplementedEventarcServer) GetTrigger 

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

func (*UnimplementedEventarcServer) ListTriggers 

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

func (*UnimplementedEventarcServer) UpdateTrigger 

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

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 will be updated.
	// If no field mask is provided, all provided fields in the request will be
	// 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 actually
	// 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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