triggers

type AndPredicate struct {
	Predicate []*Predicate `protobuf:"bytes,1,rep,name=predicate,proto3" json:"predicate,omitempty"`
	// contains filtered or unexported fields
}

type BatchSettings struct {

	// Batch size. Trigger will send the batch of messages to the function
	// when the number of messages in the queue reaches [size], or the [cutoff] time has passed.
	Size int64 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
	// Maximum wait time. Trigger will send the batch of messages to the function when
	// the number of messages in the queue reaches [size], or the [cutoff] time has passed.
	Cutoff *durationpb.Duration `protobuf:"bytes,2,opt,name=cutoff,proto3" json:"cutoff,omitempty"`
	// contains filtered or unexported fields
}

type BillingBudget struct {
	BillingAccountId string `protobuf:"bytes,1,opt,name=billing_account_id,json=billingAccountId,proto3" json:"billing_account_id,omitempty"`
	BudgetId         string `protobuf:"bytes,2,opt,name=budget_id,json=budgetId,proto3" json:"budget_id,omitempty"`
	// Types that are assignable to Action:
	//
	//	*BillingBudget_InvokeFunction
	//	*BillingBudget_InvokeContainer
	//	*BillingBudget_GatewayWebsocketBroadcast
	Action isBillingBudget_Action `protobuf_oneof:"action"`
	// contains filtered or unexported fields
}

type BillingBudget_Action = isBillingBudget_Action

type BillingBudget_GatewayWebsocketBroadcast struct {
	GatewayWebsocketBroadcast *GatewayWebsocketBroadcast `protobuf:"bytes,104,opt,name=gateway_websocket_broadcast,json=gatewayWebsocketBroadcast,proto3,oneof"`
}

type BillingBudget_InvokeContainer struct {
	InvokeContainer *InvokeContainerWithRetry `protobuf:"bytes,103,opt,name=invoke_container,json=invokeContainer,proto3,oneof"`
}

type BillingBudget_InvokeFunction struct {
	InvokeFunction *InvokeFunctionWithRetry `protobuf:"bytes,101,opt,name=invoke_function,json=invokeFunction,proto3,oneof"`
}

type CloudLogsBatchSettings struct {

	// Batch size. Trigger will send the batch of messages to the function
	// when the number of messages in the log group reaches [size], or the [cutoff] time has passed.
	Size int64 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
	// Maximum wait time. Trigger will send the batch of messages to the function when
	// the number of messages in the log group reaches [size], or the [cutoff] time has passed.
	Cutoff *durationpb.Duration `protobuf:"bytes,2,opt,name=cutoff,proto3" json:"cutoff,omitempty"`
	// contains filtered or unexported fields
}

type CreateTriggerMetadata struct {

	// ID of the trigger that is being created.
	TriggerId string `protobuf:"bytes,1,opt,name=trigger_id,json=triggerId,proto3" json:"trigger_id,omitempty"`
	// contains filtered or unexported fields
}

type CreateTriggerRequest struct {

	// ID of the folder to create a trigger in.
	//
	// To get a folder ID make a [yandex.cloud.resourcemanager.v1.FolderService.List] request.
	FolderId string `protobuf:"bytes,1,opt,name=folder_id,json=folderId,proto3" json:"folder_id,omitempty"`
	// Name of the trigger.
	// The name must be unique within the folder.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Description of the trigger.
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// Resource labels as `key:value` pairs.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Trigger type.
	Rule *Trigger_Rule `protobuf:"bytes,5,opt,name=rule,proto3" json:"rule,omitempty"`
	// contains filtered or unexported fields
}

type DataStream struct {

	// Data stream endpoint.
	Endpoint string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// Data stream database.
	Database string `protobuf:"bytes,2,opt,name=database,proto3" json:"database,omitempty"`
	// Stream name.
	Stream string `protobuf:"bytes,3,opt,name=stream,proto3" json:"stream,omitempty"`
	// ID of the service account which has permission to read data stream.
	ServiceAccountId string `protobuf:"bytes,4,opt,name=service_account_id,json=serviceAccountId,proto3" json:"service_account_id,omitempty"`
	// Batch settings for processing events.
	BatchSettings *DataStreamBatchSettings `protobuf:"bytes,5,opt,name=batch_settings,json=batchSettings,proto3" json:"batch_settings,omitempty"`
	// Types that are assignable to Action:
	//
	//	*DataStream_InvokeFunction
	//	*DataStream_InvokeContainer
	//	*DataStream_GatewayWebsocketBroadcast
	Action isDataStream_Action `protobuf_oneof:"action"`
	// contains filtered or unexported fields
}

type DataStreamBatchSettings struct {

	// Batch size in bytes. Trigger will send the batch of messages to the associated function
	// when size of log events reaches this value, or the [cutoff] time has passed.
	Size int64 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
	// Maximum wait time. Trigger will send the batch of messages the time since the last batch
	// exceeds the `cutoff` value, regardless of the amount of log events.
	Cutoff *durationpb.Duration `protobuf:"bytes,2,opt,name=cutoff,proto3" json:"cutoff,omitempty"`
	// contains filtered or unexported fields
}

type DataStream_Action = isDataStream_Action

type DataStream_GatewayWebsocketBroadcast struct {
	GatewayWebsocketBroadcast *GatewayWebsocketBroadcast `protobuf:"bytes,16,opt,name=gateway_websocket_broadcast,json=gatewayWebsocketBroadcast,proto3,oneof"`
}

type DataStream_InvokeContainer struct {
	InvokeContainer *InvokeContainerWithRetry `protobuf:"bytes,15,opt,name=invoke_container,json=invokeContainer,proto3,oneof"`
}

type DataStream_InvokeFunction struct {
	InvokeFunction *InvokeFunctionWithRetry `protobuf:"bytes,13,opt,name=invoke_function,json=invokeFunction,proto3,oneof"`
}

type DeleteTriggerMetadata struct {

	// ID of the trigger that is being deleted.
	TriggerId string `protobuf:"bytes,1,opt,name=trigger_id,json=triggerId,proto3" json:"trigger_id,omitempty"`
	// contains filtered or unexported fields
}

type DeleteTriggerRequest struct {

	// ID of the trigger to delete.
	//
	// To get a trigger ID make a [TriggerService.List] request.
	TriggerId string `protobuf:"bytes,1,opt,name=trigger_id,json=triggerId,proto3" json:"trigger_id,omitempty"`
	// contains filtered or unexported fields
}

type FieldValuePredicate struct {
	FieldPath string `protobuf:"bytes,1,opt,name=field_path,json=fieldPath,proto3" json:"field_path,omitempty"`
	// Types that are assignable to Value:
	//
	//	*FieldValuePredicate_Exact
	//	*FieldValuePredicate_Prefix
	//	*FieldValuePredicate_Suffix
	Value isFieldValuePredicate_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

type FieldValuePredicate_Exact struct {
	Exact string `protobuf:"bytes,3,opt,name=exact,proto3,oneof"` // string representation of the value matches exactly to the given string
}

type FieldValuePredicate_Prefix struct {
	Prefix string `protobuf:"bytes,8,opt,name=prefix,proto3,oneof"` // value has given prefix
}

type FieldValuePredicate_Suffix struct {
	Suffix string `protobuf:"bytes,9,opt,name=suffix,proto3,oneof"` // value has given suffix
}

type FieldValuePredicate_Value = isFieldValuePredicate_Value

type GatewayWebsocketBroadcast struct {
	GatewayId string `protobuf:"bytes,1,opt,name=gateway_id,json=gatewayId,proto3" json:"gateway_id,omitempty"`
	Path      string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// sa which has permission for writing to websockets
	ServiceAccountId string `protobuf:"bytes,3,opt,name=service_account_id,json=serviceAccountId,proto3" json:"service_account_id,omitempty"`
	// contains filtered or unexported fields
}

type GetTriggerRequest struct {

	// ID of the trigger to return.
	//
	// To get a trigger ID make a [TriggerService.List] request.
	TriggerId string `protobuf:"bytes,1,opt,name=trigger_id,json=triggerId,proto3" json:"trigger_id,omitempty"`
	// contains filtered or unexported fields
}

type InvokeContainerOnce struct {

	// ID of the container to invoke.
	ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	// Endpoint HTTP path to invoke.
	Path string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	// ID of the service account which has permission to invoke the container.
	ServiceAccountId string `protobuf:"bytes,4,opt,name=service_account_id,json=serviceAccountId,proto3" json:"service_account_id,omitempty"`
	// contains filtered or unexported fields
}

type InvokeContainerWithRetry struct {

	// ID of the container to invoke.
	ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	// Endpoint HTTP path to invoke.
	Path string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	// ID of the service account which has permission to invoke the container.
	ServiceAccountId string `protobuf:"bytes,4,opt,name=service_account_id,json=serviceAccountId,proto3" json:"service_account_id,omitempty"`
	// Retry policy. If the field is not specified, or the value is empty, no retries will be attempted.
	RetrySettings *RetrySettings `protobuf:"bytes,5,opt,name=retry_settings,json=retrySettings,proto3" json:"retry_settings,omitempty"`
	// DLQ policy (no value means discarding a message).
	DeadLetterQueue *PutQueueMessage `protobuf:"bytes,6,opt,name=dead_letter_queue,json=deadLetterQueue,proto3" json:"dead_letter_queue,omitempty"`
	// contains filtered or unexported fields
}

type InvokeFunctionOnce struct {

	// ID of the function to invoke.
	FunctionId string `protobuf:"bytes,1,opt,name=function_id,json=functionId,proto3" json:"function_id,omitempty"`
	// Version tag of the function to execute.
	FunctionTag string `protobuf:"bytes,2,opt,name=function_tag,json=functionTag,proto3" json:"function_tag,omitempty"`
	// ID of the service account that should be used to invoke the function.
	ServiceAccountId string `protobuf:"bytes,3,opt,name=service_account_id,json=serviceAccountId,proto3" json:"service_account_id,omitempty"`
	// contains filtered or unexported fields
}

type InvokeFunctionWithRetry struct {

	// ID of the function to invoke.
	FunctionId string `protobuf:"bytes,1,opt,name=function_id,json=functionId,proto3" json:"function_id,omitempty"`
	// Version tag of the function to execute.
	FunctionTag string `protobuf:"bytes,2,opt,name=function_tag,json=functionTag,proto3" json:"function_tag,omitempty"`
	// ID of the service account which has permission to invoke the function.
	ServiceAccountId string `protobuf:"bytes,3,opt,name=service_account_id,json=serviceAccountId,proto3" json:"service_account_id,omitempty"`
	// Retry policy. If the field is not specified, or the value is empty, no retries will be attempted.
	RetrySettings *RetrySettings `protobuf:"bytes,4,opt,name=retry_settings,json=retrySettings,proto3" json:"retry_settings,omitempty"`
	// DLQ policy (no value means discarding a message).
	DeadLetterQueue *PutQueueMessage `protobuf:"bytes,5,opt,name=dead_letter_queue,json=deadLetterQueue,proto3" json:"dead_letter_queue,omitempty"`
	// contains filtered or unexported fields
}

type ListTriggerOperationsRequest struct {

	// ID of the trigger to list operations for.
	TriggerId string `protobuf:"bytes,1,opt,name=trigger_id,json=triggerId,proto3" json:"trigger_id,omitempty"`
	// The maximum number of results per page that should be returned. If the number of available
	// results is larger than `pageSize`, the service returns a [ListTriggerOperationsResponse.next_page_token]
	// that can be used to get the next page of results in subsequent list requests.
	//
	// Default value: 100.
	PageSize int64 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Page token. To get the next page of results, set `pageToken` to the
	// [ListTriggerOperationsResponse.next_page_token] returned by a previous list request.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// A filter expression that filters resources listed in the response.
	//
	// The expression must specify:
	// 1. The field name. Currently filtering can only be applied to the [Trigger.name] field.
	// 2. An `=` operator.
	// 3. The value in double quotes (`"`). Must be 3-63 characters long and match the regular expression `[a-z][-a-z0-9]{1,61}[a-z0-9]`.
	// Example of a filter: `name=my-function`.
	Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

type ListTriggerOperationsResponse struct {

	// List of operations for the specified trigger.
	Operations []*operation.Operation `protobuf:"bytes,1,rep,name=operations,proto3" json:"operations,omitempty"`
	// Token for getting the next page of the list. If the number of results is greater than
	// the specified [ListTriggerOperationsRequest.page_size], use `nextPageToken` as the value
	// for the [ListTriggerOperationsRequest.page_token] parameter in the next list request.
	//
	// Each subsequent page will have its own `nextPageToken` to continue paging through the results.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

type ListTriggersRequest struct {

	// ID of the folder to list triggers in.
	//
	// To get a folder ID use a [yandex.cloud.resourcemanager.v1.FolderService.List] request.
	FolderId string `protobuf:"bytes,1,opt,name=folder_id,json=folderId,proto3" json:"folder_id,omitempty"`
	// The maximum number of results per page to return. If the number of available
	// results is larger than `pageSize`, the service returns a [ListTriggersResponse.next_page_token]
	// that can be used to get the next page of results in subsequent list requests.
	//
	// Default value: 100.
	PageSize int64 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Page token. To get the next page of results, set `pageToken` to the
	// [ListTriggersResponse.next_page_token] returned by a previous list request.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// A filter expression that filters triggers listed in the response.
	//
	// The expression must specify:
	// 1. The field name. Currently filtering can only be applied to the [Trigger.name] field.
	// 2. An `=` operator.
	// 3. The value in double quotes (`"`). Must be 3-63 characters long and match the regular expression `[a-z][-a-z0-9]{1,61}[a-z0-9]`.
	// Example of a filter: `name=my-trigger`.
	Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

type ListTriggersResponse struct {

	// List of triggers in the specified folder.
	Triggers []*Trigger `protobuf:"bytes,1,rep,name=triggers,proto3" json:"triggers,omitempty"`
	// Token for getting the next page of the list. If the number of results is greater than
	// the specified [ListTriggersRequest.page_size], use `nextPageToken` as the value
	// for the [ListTriggersRequest.page_token] parameter in the next list request.
	//
	// Each subsequent page will have its own `nextPageToken` to continue paging through the results.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

type LoggingBatchSettings struct {

	// Batch size. Trigger will send the batch of messages to the associated function
	// when the number of log events reaches this value, or the [cutoff] time has passed.
	Size int64 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
	// Maximum wait time. Trigger will send the batch of messages the time since the last batch
	// exceeds the `cutoff` value, regardless of the amount of log events.
	Cutoff *durationpb.Duration `protobuf:"bytes,2,opt,name=cutoff,proto3" json:"cutoff,omitempty"`
	// contains filtered or unexported fields
}

type Mail struct {

	// Address to receive emails for trigger activation.
	// Field is ignored for write requests and populated on trigger creation.
	Email string `protobuf:"bytes,2,opt,name=email,proto3" json:"email,omitempty"`
	// Batch settings for processing events.
	BatchSettings *BatchSettings `protobuf:"bytes,3,opt,name=batch_settings,json=batchSettings,proto3" json:"batch_settings,omitempty"`
	// Bucket settings for saving attachments.
	AttachmentsBucket *ObjectStorageBucketSettings `protobuf:"bytes,4,opt,name=attachments_bucket,json=attachmentsBucket,proto3" json:"attachments_bucket,omitempty"`
	// Types that are assignable to Action:
	//
	//	*Mail_InvokeFunction
	//	*Mail_InvokeContainer
	//	*Mail_GatewayWebsocketBroadcast
	Action isMail_Action `protobuf_oneof:"action"`
	// contains filtered or unexported fields
}

type Mail_Action = isMail_Action

type Mail_GatewayWebsocketBroadcast struct {
	GatewayWebsocketBroadcast *GatewayWebsocketBroadcast `protobuf:"bytes,104,opt,name=gateway_websocket_broadcast,json=gatewayWebsocketBroadcast,proto3,oneof"`
}

type Mail_InvokeContainer struct {
	InvokeContainer *InvokeContainerWithRetry `protobuf:"bytes,103,opt,name=invoke_container,json=invokeContainer,proto3,oneof"`
}

type Mail_InvokeFunction struct {
	InvokeFunction *InvokeFunctionWithRetry `protobuf:"bytes,101,opt,name=invoke_function,json=invokeFunction,proto3,oneof"`
}

type ObjectStorageBucketSettings struct {

	// Bucket for saving.
	BucketId string `protobuf:"bytes,1,opt,name=bucket_id,json=bucketId,proto3" json:"bucket_id,omitempty"`
	// SA which has write permission on storage.
	ServiceAccountId string `protobuf:"bytes,2,opt,name=service_account_id,json=serviceAccountId,proto3" json:"service_account_id,omitempty"`
	// contains filtered or unexported fields
}

type PauseTriggerMetadata struct {

	// ID of the trigger that is being paused.
	TriggerId string `protobuf:"bytes,1,opt,name=trigger_id,json=triggerId,proto3" json:"trigger_id,omitempty"`
	// contains filtered or unexported fields
}

type PauseTriggerRequest struct {

	// ID of the trigger to pause
	//
	// To get a trigger ID make a [TriggerService.List] request.
	TriggerId string `protobuf:"bytes,1,opt,name=trigger_id,json=triggerId,proto3" json:"trigger_id,omitempty"`
	// contains filtered or unexported fields
}

type Predicate struct {

	// Types that are assignable to Predicate:
	//
	//	*Predicate_AndPredicate
	//	*Predicate_FieldValuePredicate
	Predicate isPredicate_Predicate `protobuf_oneof:"predicate"`
	// contains filtered or unexported fields
}

type Predicate_AndPredicate struct {
	AndPredicate *AndPredicate `protobuf:"bytes,2,opt,name=and_predicate,json=andPredicate,proto3,oneof"`
}

type Predicate_FieldValuePredicate struct {
	FieldValuePredicate *FieldValuePredicate `protobuf:"bytes,4,opt,name=field_value_predicate,json=fieldValuePredicate,proto3,oneof"`
}

type Predicate_Predicate = isPredicate_Predicate

type PutQueueMessage struct {

	// ID of the queue.
	QueueId string `protobuf:"bytes,11,opt,name=queue_id,json=queueId,proto3" json:"queue_id,omitempty"`
	// Service account which has write permission on the queue.
	ServiceAccountId string `protobuf:"bytes,2,opt,name=service_account_id,json=serviceAccountId,proto3" json:"service_account_id,omitempty"`
	// contains filtered or unexported fields
}

type ResumeTriggerMetadata struct {

	// ID of the trigger that is being paused.
	TriggerId string `protobuf:"bytes,1,opt,name=trigger_id,json=triggerId,proto3" json:"trigger_id,omitempty"`
	// contains filtered or unexported fields
}

type ResumeTriggerRequest struct {

	// ID of the trigger to pause
	//
	// To get a trigger ID make a [TriggerService.List] request.
	TriggerId string `protobuf:"bytes,1,opt,name=trigger_id,json=triggerId,proto3" json:"trigger_id,omitempty"`
	// contains filtered or unexported fields
}

type RetrySettings struct {

	// Maximum number of retries (extra invokes) before the action is considered failed.
	RetryAttempts int64 `protobuf:"varint,1,opt,name=retry_attempts,json=retryAttempts,proto3" json:"retry_attempts,omitempty"`
	// Time in seconds to wait between individual retries.
	Interval *durationpb.Duration `protobuf:"bytes,2,opt,name=interval,proto3" json:"interval,omitempty"`
	// contains filtered or unexported fields
}

type Trigger struct {

	// ID of the trigger. Generated at creation time.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// ID of the folder that the trigger belongs to.
	FolderId string `protobuf:"bytes,2,opt,name=folder_id,json=folderId,proto3" json:"folder_id,omitempty"`
	// Creation timestamp for the trigger.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Name of the trigger.
	Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	// Description of the trigger.
	Description string `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"`
	// Trigger labels as `key:value` pairs.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Rule for trigger activation (always consistent with the trigger type).
	Rule *Trigger_Rule `protobuf:"bytes,8,opt,name=rule,proto3" json:"rule,omitempty"`
	// Trigger status.
	Status Trigger_Status `protobuf:"varint,9,opt,name=status,proto3,enum=yandex.cloud.serverless.triggers.v1.Trigger_Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type TriggerServiceClient interface {
	// Returns the specified trigger.
	//
	// To get the list of all available triggers, make a [List] request.
	Get(ctx context.Context, in *GetTriggerRequest, opts ...grpc.CallOption) (*Trigger, error)
	// Retrieves the list of triggers in the specified folder.
	List(ctx context.Context, in *ListTriggersRequest, opts ...grpc.CallOption) (*ListTriggersResponse, error)
	// Creates a trigger in the specified folder.
	Create(ctx context.Context, in *CreateTriggerRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Updates the specified trigger.
	Update(ctx context.Context, in *UpdateTriggerRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Deletes the specified trigger.
	Delete(ctx context.Context, in *DeleteTriggerRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Pauses the specified trigger.
	Pause(ctx context.Context, in *PauseTriggerRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Restarts the specified trigger.
	Resume(ctx context.Context, in *ResumeTriggerRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Lists operations for the specified trigger.
	ListOperations(ctx context.Context, in *ListTriggerOperationsRequest, opts ...grpc.CallOption) (*ListTriggerOperationsResponse, error)
}

type TriggerServiceServer interface {
	// Returns the specified trigger.
	//
	// To get the list of all available triggers, make a [List] request.
	Get(context.Context, *GetTriggerRequest) (*Trigger, error)
	// Retrieves the list of triggers in the specified folder.
	List(context.Context, *ListTriggersRequest) (*ListTriggersResponse, error)
	// Creates a trigger in the specified folder.
	Create(context.Context, *CreateTriggerRequest) (*operation.Operation, error)
	// Updates the specified trigger.
	Update(context.Context, *UpdateTriggerRequest) (*operation.Operation, error)
	// Deletes the specified trigger.
	Delete(context.Context, *DeleteTriggerRequest) (*operation.Operation, error)
	// Pauses the specified trigger.
	Pause(context.Context, *PauseTriggerRequest) (*operation.Operation, error)
	// Restarts the specified trigger.
	Resume(context.Context, *ResumeTriggerRequest) (*operation.Operation, error)
	// Lists operations for the specified trigger.
	ListOperations(context.Context, *ListTriggerOperationsRequest) (*ListTriggerOperationsResponse, error)
}

type TriggerType int32

type Trigger_CloudLogs struct {

	// Log group identifiers, at least one value is required.
	LogGroupId []string `protobuf:"bytes,1,rep,name=log_group_id,json=logGroupId,proto3" json:"log_group_id,omitempty"`
	// Batch settings for processing log events.
	BatchSettings *CloudLogsBatchSettings `protobuf:"bytes,2,opt,name=batch_settings,json=batchSettings,proto3" json:"batch_settings,omitempty"`
	// Types that are assignable to Action:
	//
	//	*Trigger_CloudLogs_InvokeFunction
	//	*Trigger_CloudLogs_InvokeContainer
	Action isTrigger_CloudLogs_Action `protobuf_oneof:"action"`
	// contains filtered or unexported fields
}

type Trigger_CloudLogs_Action = isTrigger_CloudLogs_Action

type Trigger_CloudLogs_InvokeContainer struct {
	// Instructions for invoking a container with retries as needed.
	InvokeContainer *InvokeContainerWithRetry `protobuf:"bytes,102,opt,name=invoke_container,json=invokeContainer,proto3,oneof"`
}

type Trigger_CloudLogs_InvokeFunction struct {
	// Instructions for invoking a function with retries as needed.
	InvokeFunction *InvokeFunctionWithRetry `protobuf:"bytes,101,opt,name=invoke_function,json=invokeFunction,proto3,oneof"`
}

type Trigger_ContainerRegistry struct {

	// Type (name) of events, at least one value is required.
	EventType []Trigger_ContainerRegistryEventType `` /* 172-byte string literal not displayed */
	// ID of the registry.
	RegistryId string `protobuf:"bytes,4,opt,name=registry_id,json=registryId,proto3" json:"registry_id,omitempty"`
	// Docker-image name. Filter, optional.
	ImageName string `protobuf:"bytes,5,opt,name=image_name,json=imageName,proto3" json:"image_name,omitempty"`
	// Docker-image tag. Filter, optional.
	Tag string `protobuf:"bytes,6,opt,name=tag,proto3" json:"tag,omitempty"`
	// Batch settings for processing events.
	BatchSettings *BatchSettings `protobuf:"bytes,7,opt,name=batch_settings,json=batchSettings,proto3" json:"batch_settings,omitempty"`
	// Types that are assignable to Action:
	//
	//	*Trigger_ContainerRegistry_InvokeFunction
	//	*Trigger_ContainerRegistry_InvokeContainer
	//	*Trigger_ContainerRegistry_GatewayWebsocketBroadcast
	Action isTrigger_ContainerRegistry_Action `protobuf_oneof:"action"`
	// contains filtered or unexported fields
}

type Trigger_ContainerRegistryEventType int32

type Trigger_ContainerRegistry_Action = isTrigger_ContainerRegistry_Action

type Trigger_ContainerRegistry_GatewayWebsocketBroadcast struct {
	// Instructions for broadcasting to API gateway websocket once.
	GatewayWebsocketBroadcast *GatewayWebsocketBroadcast `protobuf:"bytes,103,opt,name=gateway_websocket_broadcast,json=gatewayWebsocketBroadcast,proto3,oneof"`
}

type Trigger_ContainerRegistry_InvokeContainer struct {
	// Instructions for invoking a container with retries as needed.
	InvokeContainer *InvokeContainerWithRetry `protobuf:"bytes,102,opt,name=invoke_container,json=invokeContainer,proto3,oneof"`
}

type Trigger_ContainerRegistry_InvokeFunction struct {
	// Instructions for invoking a function with retries as needed.
	InvokeFunction *InvokeFunctionWithRetry `protobuf:"bytes,101,opt,name=invoke_function,json=invokeFunction,proto3,oneof"`
}

type Trigger_IoTBrokerMessage struct {

	// ID of the IoT Core broker.
	BrokerId string `protobuf:"bytes,1,opt,name=broker_id,json=brokerId,proto3" json:"broker_id,omitempty"`
	// MQTT topic whose messages activate the trigger.
	MqttTopic string `protobuf:"bytes,2,opt,name=mqtt_topic,json=mqttTopic,proto3" json:"mqtt_topic,omitempty"`
	// Batch settings for processing events.
	BatchSettings *BatchSettings `protobuf:"bytes,3,opt,name=batch_settings,json=batchSettings,proto3" json:"batch_settings,omitempty"`
	// Action to be executed when the there's a new message in the MQTT topic.
	//
	// Types that are assignable to Action:
	//
	//	*Trigger_IoTBrokerMessage_InvokeFunction
	//	*Trigger_IoTBrokerMessage_InvokeContainer
	//	*Trigger_IoTBrokerMessage_GatewayWebsocketBroadcast
	Action isTrigger_IoTBrokerMessage_Action `protobuf_oneof:"action"`
	// contains filtered or unexported fields
}

type Trigger_IoTBrokerMessage_Action = isTrigger_IoTBrokerMessage_Action

type Trigger_IoTBrokerMessage_GatewayWebsocketBroadcast struct {
	// Instructions for broadcasting to API gateway websocket once.
	GatewayWebsocketBroadcast *GatewayWebsocketBroadcast `protobuf:"bytes,103,opt,name=gateway_websocket_broadcast,json=gatewayWebsocketBroadcast,proto3,oneof"`
}

type Trigger_IoTBrokerMessage_InvokeContainer struct {
	// Instructions for invoking a container with retries as needed.
	InvokeContainer *InvokeContainerWithRetry `protobuf:"bytes,102,opt,name=invoke_container,json=invokeContainer,proto3,oneof"`
}

type Trigger_IoTBrokerMessage_InvokeFunction struct {
	// Instructions for invoking a function with retries as needed.
	InvokeFunction *InvokeFunctionWithRetry `protobuf:"bytes,101,opt,name=invoke_function,json=invokeFunction,proto3,oneof"`
}

type Trigger_IoTMessage struct {

	// ID of the IoT Core registry.
	RegistryId string `protobuf:"bytes,1,opt,name=registry_id,json=registryId,proto3" json:"registry_id,omitempty"`
	// ID of the IoT Core device in the registry.
	DeviceId string `protobuf:"bytes,2,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	// MQTT topic whose messages activate the trigger.
	MqttTopic string `protobuf:"bytes,3,opt,name=mqtt_topic,json=mqttTopic,proto3" json:"mqtt_topic,omitempty"`
	// Batch settings for processing events.
	BatchSettings *BatchSettings `protobuf:"bytes,4,opt,name=batch_settings,json=batchSettings,proto3" json:"batch_settings,omitempty"`
	// Action to be executed when the there's a new message in the MQTT topic.
	//
	// Types that are assignable to Action:
	//
	//	*Trigger_IoTMessage_InvokeFunction
	//	*Trigger_IoTMessage_InvokeContainer
	//	*Trigger_IoTMessage_GatewayWebsocketBroadcast
	Action isTrigger_IoTMessage_Action `protobuf_oneof:"action"`
	// contains filtered or unexported fields
}

type Trigger_IoTMessage_Action = isTrigger_IoTMessage_Action

type Trigger_IoTMessage_GatewayWebsocketBroadcast struct {
	// Instructions for broadcasting to API gateway websocket once.
	GatewayWebsocketBroadcast *GatewayWebsocketBroadcast `protobuf:"bytes,103,opt,name=gateway_websocket_broadcast,json=gatewayWebsocketBroadcast,proto3,oneof"`
}

type Trigger_IoTMessage_InvokeContainer struct {
	// Instructions for invoking a container with retries as needed.
	InvokeContainer *InvokeContainerWithRetry `protobuf:"bytes,102,opt,name=invoke_container,json=invokeContainer,proto3,oneof"`
}

type Trigger_IoTMessage_InvokeFunction struct {
	// Instructions for invoking a function with retries as needed.
	InvokeFunction *InvokeFunctionWithRetry `protobuf:"bytes,101,opt,name=invoke_function,json=invokeFunction,proto3,oneof"`
}

type Trigger_Logging struct {

	// Log events filter settings.
	LogGroupId   string              `protobuf:"bytes,1,opt,name=log_group_id,json=logGroupId,proto3" json:"log_group_id,omitempty"`
	ResourceType []string            `protobuf:"bytes,3,rep,name=resource_type,json=resourceType,proto3" json:"resource_type,omitempty"`
	ResourceId   []string            `protobuf:"bytes,4,rep,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	StreamName   []string            `protobuf:"bytes,7,rep,name=stream_name,json=streamName,proto3" json:"stream_name,omitempty"`
	Levels       []v1.LogLevel_Level `protobuf:"varint,5,rep,packed,name=levels,proto3,enum=yandex.cloud.logging.v1.LogLevel_Level" json:"levels,omitempty"`
	// Batch settings for processing log events.
	BatchSettings *LoggingBatchSettings `protobuf:"bytes,6,opt,name=batch_settings,json=batchSettings,proto3" json:"batch_settings,omitempty"`
	// Types that are assignable to Action:
	//
	//	*Trigger_Logging_InvokeFunction
	//	*Trigger_Logging_InvokeContainer
	//	*Trigger_Logging_GatewayWebsocketBroadcast
	Action isTrigger_Logging_Action `protobuf_oneof:"action"`
	// contains filtered or unexported fields
}