yandex-cloud 2025.4.14

#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Predicate {
    #[prost(oneof = "predicate::Predicate", tags = "2, 4")]
    pub predicate: ::core::option::Option<predicate::Predicate>,
}
/// Nested message and enum types in `Predicate`.
pub mod predicate {
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Predicate {
        #[prost(message, tag = "2")]
        AndPredicate(super::AndPredicate),
        #[prost(message, tag = "4")]
        FieldValuePredicate(super::FieldValuePredicate),
    }
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AndPredicate {
    #[prost(message, repeated, tag = "1")]
    pub predicate: ::prost::alloc::vec::Vec<Predicate>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FieldValuePredicate {
    #[prost(string, tag = "1")]
    pub field_path: ::prost::alloc::string::String,
    #[prost(oneof = "field_value_predicate::Value", tags = "3, 8, 9")]
    pub value: ::core::option::Option<field_value_predicate::Value>,
}
/// Nested message and enum types in `FieldValuePredicate`.
pub mod field_value_predicate {
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Value {
        /// string representation of the value matches exactly to the given string
        #[prost(string, tag = "3")]
        Exact(::prost::alloc::string::String),
        /// value has given prefix
        #[prost(string, tag = "8")]
        Prefix(::prost::alloc::string::String),
        /// value has given suffix
        #[prost(string, tag = "9")]
        Suffix(::prost::alloc::string::String),
    }
}
/// A trigger to invoke a serverless function. For more information, see \[Triggers\](/docs/functions/concepts/trigger).
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Trigger {
    /// ID of the trigger. Generated at creation time.
    #[prost(string, tag = "1")]
    pub id: ::prost::alloc::string::String,
    /// ID of the folder that the trigger belongs to.
    #[prost(string, tag = "2")]
    pub folder_id: ::prost::alloc::string::String,
    /// Creation timestamp for the trigger.
    #[prost(message, optional, tag = "3")]
    pub created_at: ::core::option::Option<::prost_types::Timestamp>,
    /// Name of the trigger.
    #[prost(string, tag = "4")]
    pub name: ::prost::alloc::string::String,
    /// Description of the trigger.
    #[prost(string, tag = "5")]
    pub description: ::prost::alloc::string::String,
    /// Trigger labels as `key:value` pairs.
    #[prost(map = "string, string", tag = "6")]
    pub labels: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    /// Rule for trigger activation (always consistent with the trigger type).
    #[prost(message, optional, tag = "8")]
    pub rule: ::core::option::Option<trigger::Rule>,
    /// Trigger status.
    #[prost(enumeration = "trigger::Status", tag = "9")]
    pub status: i32,
}
/// Nested message and enum types in `Trigger`.
pub mod trigger {
    /// Description of a rule for trigger activation.
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct Rule {
        #[prost(oneof = "rule::Rule", tags = "2, 3, 4, 14, 5, 6, 9, 10, 11, 12, 13")]
        pub rule: ::core::option::Option<rule::Rule>,
    }
    /// Nested message and enum types in `Rule`.
    pub mod rule {
        #[allow(clippy::derive_partial_eq_without_eq)]
        #[derive(Clone, PartialEq, ::prost::Oneof)]
        pub enum Rule {
            /// Rule for a timed trigger.
            #[prost(message, tag = "2")]
            Timer(super::Timer),
            /// Rule for a message queue trigger.
            #[prost(message, tag = "3")]
            MessageQueue(super::MessageQueue),
            /// Rule for a IoT Core trigger.
            #[prost(message, tag = "4")]
            IotMessage(super::IoTMessage),
            #[prost(message, tag = "14")]
            IotBrokerMessage(super::IoTBrokerMessage),
            #[prost(message, tag = "5")]
            ObjectStorage(super::ObjectStorage),
            #[prost(message, tag = "6")]
            ContainerRegistry(super::ContainerRegistry),
            #[prost(message, tag = "9")]
            CloudLogs(super::CloudLogs),
            #[prost(message, tag = "10")]
            Logging(super::Logging),
            #[prost(message, tag = "11")]
            BillingBudget(super::super::BillingBudget),
            #[prost(message, tag = "12")]
            DataStream(super::super::DataStream),
            #[prost(message, tag = "13")]
            Mail(super::super::Mail),
        }
    }
    /// Rule for activating a timed trigger.
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct Timer {
        /// Description of a schedule as a [cron expression](/docs/functions/concepts/trigger/timer).
        #[prost(string, tag = "1")]
        pub cron_expression: ::prost::alloc::string::String,
        /// Payload to be passed to function.
        #[prost(string, tag = "2")]
        pub payload: ::prost::alloc::string::String,
        /// Action to be executed when the current time matches the \[cron_expression\].
        #[prost(oneof = "timer::Action", tags = "101, 103, 104, 105")]
        pub action: ::core::option::Option<timer::Action>,
    }
    /// Nested message and enum types in `Timer`.
    pub mod timer {
        /// Action to be executed when the current time matches the \[cron_expression\].
        #[allow(clippy::derive_partial_eq_without_eq)]
        #[derive(Clone, PartialEq, ::prost::Oneof)]
        pub enum Action {
            /// Instructions for invoking a function once.
            #[prost(message, tag = "101")]
            InvokeFunction(super::super::InvokeFunctionOnce),
            /// Instructions for invoking a function with retry.
            #[prost(message, tag = "103")]
            InvokeFunctionWithRetry(super::super::InvokeFunctionWithRetry),
            /// Instructions for invoking a container with retry.
            #[prost(message, tag = "104")]
            InvokeContainerWithRetry(super::super::InvokeContainerWithRetry),
            /// Instructions for broadcasting to API gateway websocket once.
            #[prost(message, tag = "105")]
            GatewayWebsocketBroadcast(super::super::GatewayWebsocketBroadcast),
        }
    }
    /// Rule for activating a message queue trigger.
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct MessageQueue {
        /// ID of the message queue in Message Queue.
        #[prost(string, tag = "11")]
        pub queue_id: ::prost::alloc::string::String,
        /// ID of the service account which has read access to the message queue.
        #[prost(string, tag = "3")]
        pub service_account_id: ::prost::alloc::string::String,
        /// Batch settings for processing messages in the queue.
        #[prost(message, optional, tag = "4")]
        pub batch_settings: ::core::option::Option<super::BatchSettings>,
        /// Queue visibility timeout override.
        #[prost(message, optional, tag = "5")]
        pub visibility_timeout: ::core::option::Option<::prost_types::Duration>,
        /// Action to be executed when the there's a new message in the queue.
        #[prost(oneof = "message_queue::Action", tags = "101, 102, 103")]
        pub action: ::core::option::Option<message_queue::Action>,
    }
    /// Nested message and enum types in `MessageQueue`.
    pub mod message_queue {
        /// Action to be executed when the there's a new message in the queue.
        #[allow(clippy::derive_partial_eq_without_eq)]
        #[derive(Clone, PartialEq, ::prost::Oneof)]
        pub enum Action {
            /// Instructions for invoking a function once.
            #[prost(message, tag = "101")]
            InvokeFunction(super::super::InvokeFunctionOnce),
            /// Instructions for invoking a container once.
            #[prost(message, tag = "102")]
            InvokeContainer(super::super::InvokeContainerOnce),
            /// Instructions for broadcasting to API gateway websocket once.
            #[prost(message, tag = "103")]
            GatewayWebsocketBroadcast(super::super::GatewayWebsocketBroadcast),
        }
    }
    /// Rule for activating a IoT Core trigger.
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct IoTMessage {
        /// ID of the IoT Core registry.
        #[prost(string, tag = "1")]
        pub registry_id: ::prost::alloc::string::String,
        /// ID of the IoT Core device in the registry.
        #[prost(string, tag = "2")]
        pub device_id: ::prost::alloc::string::String,
        /// MQTT topic whose messages activate the trigger.
        #[prost(string, tag = "3")]
        pub mqtt_topic: ::prost::alloc::string::String,
        /// Batch settings for processing events.
        #[prost(message, optional, tag = "4")]
        pub batch_settings: ::core::option::Option<super::BatchSettings>,
        /// Action to be executed when the there's a new message in the MQTT topic.
        #[prost(oneof = "io_t_message::Action", tags = "101, 102, 103")]
        pub action: ::core::option::Option<io_t_message::Action>,
    }
    /// Nested message and enum types in `IoTMessage`.
    pub mod io_t_message {
        /// Action to be executed when the there's a new message in the MQTT topic.
        #[allow(clippy::derive_partial_eq_without_eq)]
        #[derive(Clone, PartialEq, ::prost::Oneof)]
        pub enum Action {
            /// Instructions for invoking a function with retries as needed.
            #[prost(message, tag = "101")]
            InvokeFunction(super::super::InvokeFunctionWithRetry),
            /// Instructions for invoking a container with retries as needed.
            #[prost(message, tag = "102")]
            InvokeContainer(super::super::InvokeContainerWithRetry),
            /// Instructions for broadcasting to API gateway websocket once.
            #[prost(message, tag = "103")]
            GatewayWebsocketBroadcast(super::super::GatewayWebsocketBroadcast),
        }
    }
    /// Rule for activating a IoT Core Broker trigger.
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct IoTBrokerMessage {
        /// ID of the IoT Core broker.
        #[prost(string, tag = "1")]
        pub broker_id: ::prost::alloc::string::String,
        /// MQTT topic whose messages activate the trigger.
        #[prost(string, tag = "2")]
        pub mqtt_topic: ::prost::alloc::string::String,
        /// Batch settings for processing events.
        #[prost(message, optional, tag = "3")]
        pub batch_settings: ::core::option::Option<super::BatchSettings>,
        /// Action to be executed when the there's a new message in the MQTT topic.
        #[prost(oneof = "io_t_broker_message::Action", tags = "101, 102, 103")]
        pub action: ::core::option::Option<io_t_broker_message::Action>,
    }
    /// Nested message and enum types in `IoTBrokerMessage`.
    pub mod io_t_broker_message {
        /// Action to be executed when the there's a new message in the MQTT topic.
        #[allow(clippy::derive_partial_eq_without_eq)]
        #[derive(Clone, PartialEq, ::prost::Oneof)]
        pub enum Action {
            /// Instructions for invoking a function with retries as needed.
            #[prost(message, tag = "101")]
            InvokeFunction(super::super::InvokeFunctionWithRetry),
            /// Instructions for invoking a container with retries as needed.
            #[prost(message, tag = "102")]
            InvokeContainer(super::super::InvokeContainerWithRetry),
            /// Instructions for broadcasting to API gateway websocket once.
            #[prost(message, tag = "103")]
            GatewayWebsocketBroadcast(super::super::GatewayWebsocketBroadcast),
        }
    }
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct ObjectStorage {
        /// Type (name) of events, at least one value is required.
        #[prost(
            enumeration = "ObjectStorageEventType",
            repeated,
            packed = "false",
            tag = "3"
        )]
        pub event_type: ::prost::alloc::vec::Vec<i32>,
        /// ID of the bucket.
        #[prost(string, tag = "4")]
        pub bucket_id: ::prost::alloc::string::String,
        /// Prefix of the object key. Filter, optional.
        #[prost(string, tag = "6")]
        pub prefix: ::prost::alloc::string::String,
        /// Suffix of the object key. Filter, optional.
        #[prost(string, tag = "7")]
        pub suffix: ::prost::alloc::string::String,
        /// Batch settings for processing events.
        #[prost(message, optional, tag = "8")]
        pub batch_settings: ::core::option::Option<super::BatchSettings>,
        #[prost(oneof = "object_storage::Action", tags = "101, 102, 103")]
        pub action: ::core::option::Option<object_storage::Action>,
    }
    /// Nested message and enum types in `ObjectStorage`.
    pub mod object_storage {
        #[allow(clippy::derive_partial_eq_without_eq)]
        #[derive(Clone, PartialEq, ::prost::Oneof)]
        pub enum Action {
            /// Instructions for invoking a function with retries as needed.
            #[prost(message, tag = "101")]
            InvokeFunction(super::super::InvokeFunctionWithRetry),
            /// Instructions for invoking a container with retries as needed.
            #[prost(message, tag = "102")]
            InvokeContainer(super::super::InvokeContainerWithRetry),
            /// Instructions for broadcasting to API gateway websocket once.
            #[prost(message, tag = "103")]
            GatewayWebsocketBroadcast(super::super::GatewayWebsocketBroadcast),
        }
    }
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct ContainerRegistry {
        /// Type (name) of events, at least one value is required.
        #[prost(
            enumeration = "ContainerRegistryEventType",
            repeated,
            packed = "false",
            tag = "3"
        )]
        pub event_type: ::prost::alloc::vec::Vec<i32>,
        /// ID of the registry.
        #[prost(string, tag = "4")]
        pub registry_id: ::prost::alloc::string::String,
        /// Docker-image name. Filter, optional.
        #[prost(string, tag = "5")]
        pub image_name: ::prost::alloc::string::String,
        /// Docker-image tag. Filter, optional.
        #[prost(string, tag = "6")]
        pub tag: ::prost::alloc::string::String,
        /// Batch settings for processing events.
        #[prost(message, optional, tag = "7")]
        pub batch_settings: ::core::option::Option<super::BatchSettings>,
        #[prost(oneof = "container_registry::Action", tags = "101, 102, 103")]
        pub action: ::core::option::Option<container_registry::Action>,
    }
    /// Nested message and enum types in `ContainerRegistry`.
    pub mod container_registry {
        #[allow(clippy::derive_partial_eq_without_eq)]
        #[derive(Clone, PartialEq, ::prost::Oneof)]
        pub enum Action {
            /// Instructions for invoking a function with retries as needed.
            #[prost(message, tag = "101")]
            InvokeFunction(super::super::InvokeFunctionWithRetry),
            /// Instructions for invoking a container with retries as needed.
            #[prost(message, tag = "102")]
            InvokeContainer(super::super::InvokeContainerWithRetry),
            /// Instructions for broadcasting to API gateway websocket once.
            #[prost(message, tag = "103")]
            GatewayWebsocketBroadcast(super::super::GatewayWebsocketBroadcast),
        }
    }
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct CloudLogs {
        /// Log group identifiers, at least one value is required.
        #[prost(string, repeated, tag = "1")]
        pub log_group_id: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
        /// Batch settings for processing log events.
        #[prost(message, optional, tag = "2")]
        pub batch_settings: ::core::option::Option<super::CloudLogsBatchSettings>,
        #[prost(oneof = "cloud_logs::Action", tags = "101, 102")]
        pub action: ::core::option::Option<cloud_logs::Action>,
    }
    /// Nested message and enum types in `CloudLogs`.
    pub mod cloud_logs {
        #[allow(clippy::derive_partial_eq_without_eq)]
        #[derive(Clone, PartialEq, ::prost::Oneof)]
        pub enum Action {
            /// Instructions for invoking a function with retries as needed.
            #[prost(message, tag = "101")]
            InvokeFunction(super::super::InvokeFunctionWithRetry),
            /// Instructions for invoking a container with retries as needed.
            #[prost(message, tag = "102")]
            InvokeContainer(super::super::InvokeContainerWithRetry),
        }
    }
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct Logging {
        /// Log events filter settings.
        #[prost(string, tag = "1")]
        pub log_group_id: ::prost::alloc::string::String,
        #[prost(string, repeated, tag = "3")]
        pub resource_type: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
        #[prost(string, repeated, tag = "4")]
        pub resource_id: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
        #[prost(string, repeated, tag = "7")]
        pub stream_name: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
        #[prost(
            enumeration = "super::super::super::super::logging::v1::log_level::Level",
            repeated,
            packed = "false",
            tag = "5"
        )]
        pub levels: ::prost::alloc::vec::Vec<i32>,
        /// Batch settings for processing log events.
        #[prost(message, optional, tag = "6")]
        pub batch_settings: ::core::option::Option<super::LoggingBatchSettings>,
        #[prost(oneof = "logging::Action", tags = "101, 103, 104")]
        pub action: ::core::option::Option<logging::Action>,
    }
    /// Nested message and enum types in `Logging`.
    pub mod logging {
        #[allow(clippy::derive_partial_eq_without_eq)]
        #[derive(Clone, PartialEq, ::prost::Oneof)]
        pub enum Action {
            /// Instructions for invoking a function with retries as needed.
            #[prost(message, tag = "101")]
            InvokeFunction(super::super::InvokeFunctionWithRetry),
            /// Instructions for invoking a container with retries as needed.
            #[prost(message, tag = "103")]
            InvokeContainer(super::super::InvokeContainerWithRetry),
            /// Instructions for broadcasting to API gateway websocket once.
            #[prost(message, tag = "104")]
            GatewayWebsocketBroadcast(super::super::GatewayWebsocketBroadcast),
        }
    }
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum ObjectStorageEventType {
        Unspecified = 0,
        CreateObject = 1,
        UpdateObject = 2,
        DeleteObject = 3,
    }
    impl ObjectStorageEventType {
        /// String value of the enum field names used in the ProtoBuf definition.
        ///
        /// The values are not transformed in any way and thus are considered stable
        /// (if the ProtoBuf definition does not change) and safe for programmatic use.
        pub fn as_str_name(&self) -> &'static str {
            match self {
                ObjectStorageEventType::Unspecified => {
                    "OBJECT_STORAGE_EVENT_TYPE_UNSPECIFIED"
                }
                ObjectStorageEventType::CreateObject => {
                    "OBJECT_STORAGE_EVENT_TYPE_CREATE_OBJECT"
                }
                ObjectStorageEventType::UpdateObject => {
                    "OBJECT_STORAGE_EVENT_TYPE_UPDATE_OBJECT"
                }
                ObjectStorageEventType::DeleteObject => {
                    "OBJECT_STORAGE_EVENT_TYPE_DELETE_OBJECT"
                }
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "OBJECT_STORAGE_EVENT_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
                "OBJECT_STORAGE_EVENT_TYPE_CREATE_OBJECT" => Some(Self::CreateObject),
                "OBJECT_STORAGE_EVENT_TYPE_UPDATE_OBJECT" => Some(Self::UpdateObject),
                "OBJECT_STORAGE_EVENT_TYPE_DELETE_OBJECT" => Some(Self::DeleteObject),
                _ => None,
            }
        }
    }
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum ContainerRegistryEventType {
        Unspecified = 0,
        CreateImage = 1,
        DeleteImage = 2,
        CreateImageTag = 3,
        DeleteImageTag = 4,
    }
    impl ContainerRegistryEventType {
        /// String value of the enum field names used in the ProtoBuf definition.
        ///
        /// The values are not transformed in any way and thus are considered stable
        /// (if the ProtoBuf definition does not change) and safe for programmatic use.
        pub fn as_str_name(&self) -> &'static str {
            match self {
                ContainerRegistryEventType::Unspecified => {
                    "CONTAINER_REGISTRY_EVENT_TYPE_UNSPECIFIED"
                }
                ContainerRegistryEventType::CreateImage => {
                    "CONTAINER_REGISTRY_EVENT_TYPE_CREATE_IMAGE"
                }
                ContainerRegistryEventType::DeleteImage => {
                    "CONTAINER_REGISTRY_EVENT_TYPE_DELETE_IMAGE"
                }
                ContainerRegistryEventType::CreateImageTag => {
                    "CONTAINER_REGISTRY_EVENT_TYPE_CREATE_IMAGE_TAG"
                }
                ContainerRegistryEventType::DeleteImageTag => {
                    "CONTAINER_REGISTRY_EVENT_TYPE_DELETE_IMAGE_TAG"
                }
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "CONTAINER_REGISTRY_EVENT_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
                "CONTAINER_REGISTRY_EVENT_TYPE_CREATE_IMAGE" => Some(Self::CreateImage),
                "CONTAINER_REGISTRY_EVENT_TYPE_DELETE_IMAGE" => Some(Self::DeleteImage),
                "CONTAINER_REGISTRY_EVENT_TYPE_CREATE_IMAGE_TAG" => {
                    Some(Self::CreateImageTag)
                }
                "CONTAINER_REGISTRY_EVENT_TYPE_DELETE_IMAGE_TAG" => {
                    Some(Self::DeleteImageTag)
                }
                _ => None,
            }
        }
    }
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum Status {
        Unspecified = 0,
        Active = 1,
        Paused = 2,
    }
    impl Status {
        /// String value of the enum field names used in the ProtoBuf definition.
        ///
        /// The values are not transformed in any way and thus are considered stable
        /// (if the ProtoBuf definition does not change) and safe for programmatic use.
        pub fn as_str_name(&self) -> &'static str {
            match self {
                Status::Unspecified => "STATUS_UNSPECIFIED",
                Status::Active => "ACTIVE",
                Status::Paused => "PAUSED",
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "STATUS_UNSPECIFIED" => Some(Self::Unspecified),
                "ACTIVE" => Some(Self::Active),
                "PAUSED" => Some(Self::Paused),
                _ => None,
            }
        }
    }
}
/// A single function invocation.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct InvokeFunctionOnce {
    /// ID of the function to invoke.
    #[prost(string, tag = "1")]
    pub function_id: ::prost::alloc::string::String,
    /// Version tag of the function to execute.
    #[prost(string, tag = "2")]
    pub function_tag: ::prost::alloc::string::String,
    /// ID of the service account that should be used to invoke the function.
    #[prost(string, tag = "3")]
    pub service_account_id: ::prost::alloc::string::String,
}
/// A function invocation with retries.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct InvokeFunctionWithRetry {
    /// ID of the function to invoke.
    #[prost(string, tag = "1")]
    pub function_id: ::prost::alloc::string::String,
    /// Version tag of the function to execute.
    #[prost(string, tag = "2")]
    pub function_tag: ::prost::alloc::string::String,
    /// ID of the service account which has permission to invoke the function.
    #[prost(string, tag = "3")]
    pub service_account_id: ::prost::alloc::string::String,
    /// Retry policy. If the field is not specified, or the value is empty, no retries will be attempted.
    #[prost(message, optional, tag = "4")]
    pub retry_settings: ::core::option::Option<RetrySettings>,
    /// DLQ policy (no value means discarding a message).
    #[prost(message, optional, tag = "5")]
    pub dead_letter_queue: ::core::option::Option<PutQueueMessage>,
}
/// A single container invocation.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct InvokeContainerOnce {
    /// ID of the container to invoke.
    #[prost(string, tag = "1")]
    pub container_id: ::prost::alloc::string::String,
    /// Endpoint HTTP path to invoke.
    #[prost(string, tag = "3")]
    pub path: ::prost::alloc::string::String,
    /// ID of the service account which has permission to invoke the container.
    #[prost(string, tag = "4")]
    pub service_account_id: ::prost::alloc::string::String,
}
/// A container invocation with retries.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct InvokeContainerWithRetry {
    /// ID of the container to invoke.
    #[prost(string, tag = "1")]
    pub container_id: ::prost::alloc::string::String,
    /// Endpoint HTTP path to invoke.
    #[prost(string, tag = "3")]
    pub path: ::prost::alloc::string::String,
    /// ID of the service account which has permission to invoke the container.
    #[prost(string, tag = "4")]
    pub service_account_id: ::prost::alloc::string::String,
    /// Retry policy. If the field is not specified, or the value is empty, no retries will be attempted.
    #[prost(message, optional, tag = "5")]
    pub retry_settings: ::core::option::Option<RetrySettings>,
    /// DLQ policy (no value means discarding a message).
    #[prost(message, optional, tag = "6")]
    pub dead_letter_queue: ::core::option::Option<PutQueueMessage>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GatewayWebsocketBroadcast {
    #[prost(string, tag = "1")]
    pub gateway_id: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub path: ::prost::alloc::string::String,
    /// sa which has permission for writing to websockets
    #[prost(string, tag = "3")]
    pub service_account_id: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PutQueueMessage {
    /// ID of the queue.
    #[prost(string, tag = "11")]
    pub queue_id: ::prost::alloc::string::String,
    /// Service account which has write permission on the queue.
    #[prost(string, tag = "2")]
    pub service_account_id: ::prost::alloc::string::String,
}
/// Settings for batch processing of messages in a queue.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchSettings {
    /// 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.
    #[prost(int64, tag = "1")]
    pub size: i64,
    /// 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.
    #[prost(message, optional, tag = "2")]
    pub cutoff: ::core::option::Option<::prost_types::Duration>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CloudLogsBatchSettings {
    /// 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.
    #[prost(int64, tag = "1")]
    pub size: i64,
    /// 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.
    #[prost(message, optional, tag = "2")]
    pub cutoff: ::core::option::Option<::prost_types::Duration>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct LoggingBatchSettings {
    /// 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.
    #[prost(int64, tag = "1")]
    pub size: i64,
    /// 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.
    #[prost(message, optional, tag = "2")]
    pub cutoff: ::core::option::Option<::prost_types::Duration>,
}
/// Settings for retrying to invoke a function.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct RetrySettings {
    /// Maximum number of retries (extra invokes) before the action is considered failed.
    #[prost(int64, tag = "1")]
    pub retry_attempts: i64,
    /// Time in seconds to wait between individual retries.
    #[prost(message, optional, tag = "2")]
    pub interval: ::core::option::Option<::prost_types::Duration>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BillingBudget {
    #[prost(string, tag = "1")]
    pub billing_account_id: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub budget_id: ::prost::alloc::string::String,
    #[prost(oneof = "billing_budget::Action", tags = "101, 103, 104")]
    pub action: ::core::option::Option<billing_budget::Action>,
}
/// Nested message and enum types in `BillingBudget`.
pub mod billing_budget {
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Action {
        #[prost(message, tag = "101")]
        InvokeFunction(super::InvokeFunctionWithRetry),
        #[prost(message, tag = "103")]
        InvokeContainer(super::InvokeContainerWithRetry),
        #[prost(message, tag = "104")]
        GatewayWebsocketBroadcast(super::GatewayWebsocketBroadcast),
    }
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DataStreamBatchSettings {
    /// 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.
    #[prost(int64, tag = "1")]
    pub size: i64,
    /// 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.
    #[prost(message, optional, tag = "2")]
    pub cutoff: ::core::option::Option<::prost_types::Duration>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DataStream {
    /// Data stream endpoint.
    #[prost(string, tag = "1")]
    pub endpoint: ::prost::alloc::string::String,
    /// Data stream database.
    #[prost(string, tag = "2")]
    pub database: ::prost::alloc::string::String,
    /// Stream name.
    #[prost(string, tag = "3")]
    pub stream: ::prost::alloc::string::String,
    /// ID of the service account which has permission to read data stream.
    #[prost(string, tag = "4")]
    pub service_account_id: ::prost::alloc::string::String,
    /// Batch settings for processing events.
    #[prost(message, optional, tag = "5")]
    pub batch_settings: ::core::option::Option<DataStreamBatchSettings>,
    #[prost(oneof = "data_stream::Action", tags = "13, 15, 16")]
    pub action: ::core::option::Option<data_stream::Action>,
}
/// Nested message and enum types in `DataStream`.
pub mod data_stream {
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Action {
        #[prost(message, tag = "13")]
        InvokeFunction(super::InvokeFunctionWithRetry),
        #[prost(message, tag = "15")]
        InvokeContainer(super::InvokeContainerWithRetry),
        #[prost(message, tag = "16")]
        GatewayWebsocketBroadcast(super::GatewayWebsocketBroadcast),
    }
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ObjectStorageBucketSettings {
    /// Bucket for saving.
    #[prost(string, tag = "1")]
    pub bucket_id: ::prost::alloc::string::String,
    /// SA which has write permission on storage.
    #[prost(string, tag = "2")]
    pub service_account_id: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Mail {
    /// Address to receive emails for trigger activation.
    /// Field is ignored for write requests and populated on trigger creation.
    #[prost(string, tag = "2")]
    pub email: ::prost::alloc::string::String,
    /// Batch settings for processing events.
    #[prost(message, optional, tag = "3")]
    pub batch_settings: ::core::option::Option<BatchSettings>,
    /// Bucket settings for saving attachments.
    #[prost(message, optional, tag = "4")]
    pub attachments_bucket: ::core::option::Option<ObjectStorageBucketSettings>,
    #[prost(oneof = "mail::Action", tags = "101, 103, 104")]
    pub action: ::core::option::Option<mail::Action>,
}
/// Nested message and enum types in `Mail`.
pub mod mail {
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Action {
        #[prost(message, tag = "101")]
        InvokeFunction(super::InvokeFunctionWithRetry),
        #[prost(message, tag = "103")]
        InvokeContainer(super::InvokeContainerWithRetry),
        #[prost(message, tag = "104")]
        GatewayWebsocketBroadcast(super::GatewayWebsocketBroadcast),
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum TriggerType {
    Unspecified = 0,
    /// The trigger is activated on a timer.
    Timer = 2,
    /// The trigger is activated by messages from a message queue.
    ///
    /// Only Message Queue is currently supported.
    MessageQueue = 3,
    /// The trigger is activated by messages from IoT Core.
    IotMessage = 4,
    IotBrokerMessage = 12,
    ObjectStorage = 5,
    ContainerRegistry = 6,
    /// The trigger is activated by cloud log group events
    CloudLogs = 7,
    /// The trigger is activated by logging group events
    Logging = 8,
    /// The trigger is activated by billing events
    BillingBudget = 9,
    /// The trigger is activated by YDS events
    Yds = 10,
    /// The trigger is activated by email
    Mail = 11,
}
impl TriggerType {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            TriggerType::Unspecified => "TRIGGER_TYPE_UNSPECIFIED",
            TriggerType::Timer => "TIMER",
            TriggerType::MessageQueue => "MESSAGE_QUEUE",
            TriggerType::IotMessage => "IOT_MESSAGE",
            TriggerType::IotBrokerMessage => "IOT_BROKER_MESSAGE",
            TriggerType::ObjectStorage => "OBJECT_STORAGE",
            TriggerType::ContainerRegistry => "CONTAINER_REGISTRY",
            TriggerType::CloudLogs => "CLOUD_LOGS",
            TriggerType::Logging => "LOGGING",
            TriggerType::BillingBudget => "BILLING_BUDGET",
            TriggerType::Yds => "YDS",
            TriggerType::Mail => "MAIL",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "TRIGGER_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
            "TIMER" => Some(Self::Timer),
            "MESSAGE_QUEUE" => Some(Self::MessageQueue),
            "IOT_MESSAGE" => Some(Self::IotMessage),
            "IOT_BROKER_MESSAGE" => Some(Self::IotBrokerMessage),
            "OBJECT_STORAGE" => Some(Self::ObjectStorage),
            "CONTAINER_REGISTRY" => Some(Self::ContainerRegistry),
            "CLOUD_LOGS" => Some(Self::CloudLogs),
            "LOGGING" => Some(Self::Logging),
            "BILLING_BUDGET" => Some(Self::BillingBudget),
            "YDS" => Some(Self::Yds),
            "MAIL" => Some(Self::Mail),
            _ => None,
        }
    }
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetTriggerRequest {
    /// ID of the trigger to return.
    ///
    /// To get a trigger ID make a \[TriggerService.List\] request.
    #[prost(string, tag = "1")]
    pub trigger_id: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListTriggersRequest {
    /// ID of the folder to list triggers in.
    ///
    /// To get a folder ID use a \[yandex.cloud.resourcemanager.v1.FolderService.List\] request.
    #[prost(string, tag = "1")]
    pub folder_id: ::prost::alloc::string::String,
    /// 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.
    #[prost(int64, tag = "2")]
    pub page_size: i64,
    /// Page token. To get the next page of results, set `pageToken` to the
    /// \[ListTriggersResponse.next_page_token\] returned by a previous list request.
    #[prost(string, tag = "3")]
    pub page_token: ::prost::alloc::string::String,
    /// 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`.
    #[prost(string, tag = "4")]
    pub filter: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListTriggersResponse {
    /// List of triggers in the specified folder.
    #[prost(message, repeated, tag = "1")]
    pub triggers: ::prost::alloc::vec::Vec<Trigger>,
    /// 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.
    #[prost(string, tag = "2")]
    pub next_page_token: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateTriggerRequest {
    /// ID of the folder to create a trigger in.
    ///
    /// To get a folder ID make a \[yandex.cloud.resourcemanager.v1.FolderService.List\] request.
    #[prost(string, tag = "1")]
    pub folder_id: ::prost::alloc::string::String,
    /// Name of the trigger.
    /// The name must be unique within the folder.
    #[prost(string, tag = "2")]
    pub name: ::prost::alloc::string::String,
    /// Description of the trigger.
    #[prost(string, tag = "3")]
    pub description: ::prost::alloc::string::String,
    /// Resource labels as `key:value` pairs.
    #[prost(map = "string, string", tag = "4")]
    pub labels: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    /// Trigger type.
    #[prost(message, optional, tag = "5")]
    pub rule: ::core::option::Option<trigger::Rule>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateTriggerMetadata {
    /// ID of the trigger that is being created.
    #[prost(string, tag = "1")]
    pub trigger_id: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdateTriggerRequest {
    /// ID of the trigger to update.
    ///
    /// To get a trigger ID make a \[TriggerService.List\] request.
    #[prost(string, tag = "1")]
    pub trigger_id: ::prost::alloc::string::String,
    /// Field mask that specifies which attributes of the trigger should be updated.
    #[prost(message, optional, tag = "2")]
    pub update_mask: ::core::option::Option<::prost_types::FieldMask>,
    /// New name for the trigger.
    /// The name must be unique within the folder.
    #[prost(string, tag = "3")]
    pub name: ::prost::alloc::string::String,
    /// New description of the trigger.
    #[prost(string, tag = "4")]
    pub description: ::prost::alloc::string::String,
    /// Trigger labels as `key:value` pairs.
    ///
    /// Existing set of labels is completely replaced by the provided set, so if you just want
    /// to add or remove a label, request the current set of labels with a \[TriggerService.Get\] request.
    #[prost(map = "string, string", tag = "5")]
    pub labels: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    /// New parameters for trigger.
    #[prost(message, optional, tag = "6")]
    pub rule: ::core::option::Option<trigger::Rule>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdateTriggerMetadata {
    /// ID of the trigger that is being updated.
    #[prost(string, tag = "1")]
    pub trigger_id: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DeleteTriggerRequest {
    /// ID of the trigger to delete.
    ///
    /// To get a trigger ID make a \[TriggerService.List\] request.
    #[prost(string, tag = "1")]
    pub trigger_id: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DeleteTriggerMetadata {
    /// ID of the trigger that is being deleted.
    #[prost(string, tag = "1")]
    pub trigger_id: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PauseTriggerRequest {
    /// ID of the trigger to pause
    ///
    /// To get a trigger ID make a \[TriggerService.List\] request.
    #[prost(string, tag = "1")]
    pub trigger_id: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PauseTriggerMetadata {
    /// ID of the trigger that is being paused.
    #[prost(string, tag = "1")]
    pub trigger_id: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ResumeTriggerRequest {
    /// ID of the trigger to pause
    ///
    /// To get a trigger ID make a \[TriggerService.List\] request.
    #[prost(string, tag = "1")]
    pub trigger_id: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ResumeTriggerMetadata {
    /// ID of the trigger that is being paused.
    #[prost(string, tag = "1")]
    pub trigger_id: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListTriggerOperationsRequest {
    /// ID of the trigger to list operations for.
    #[prost(string, tag = "1")]
    pub trigger_id: ::prost::alloc::string::String,
    /// 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.
    #[prost(int64, tag = "2")]
    pub page_size: i64,
    /// Page token. To get the next page of results, set `pageToken` to the
    /// \[ListTriggerOperationsResponse.next_page_token\] returned by a previous list request.
    #[prost(string, tag = "3")]
    pub page_token: ::prost::alloc::string::String,
    /// 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`.
    #[prost(string, tag = "4")]
    pub filter: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListTriggerOperationsResponse {
    /// List of operations for the specified trigger.
    #[prost(message, repeated, tag = "1")]
    pub operations: ::prost::alloc::vec::Vec<super::super::super::operation::Operation>,
    /// 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.
    #[prost(string, tag = "2")]
    pub next_page_token: ::prost::alloc::string::String,
}
/// Generated client implementations.
pub mod trigger_service_client {
    #![allow(unused_variables, dead_code, missing_docs, clippy::let_unit_value)]
    use tonic::codegen::*;
    use tonic::codegen::http::Uri;
    /// A set of methods for managing triggers for serverless functions.
    #[derive(Debug, Clone)]
    pub struct TriggerServiceClient<T> {
        inner: tonic::client::Grpc<T>,
    }
    impl TriggerServiceClient<tonic::transport::Channel> {
        /// Attempt to create a new client by connecting to a given endpoint.
        pub async fn connect<D>(dst: D) -> Result<Self, tonic::transport::Error>
        where
            D: TryInto<tonic::transport::Endpoint>,
            D::Error: Into<StdError>,
        {
            let conn = tonic::transport::Endpoint::new(dst)?.connect().await?;
            Ok(Self::new(conn))
        }
    }
    impl<T> TriggerServiceClient<T>
    where
        T: tonic::client::GrpcService<tonic::body::BoxBody>,
        T::Error: Into<StdError>,
        T::ResponseBody: Body<Data = Bytes> + Send + 'static,
        <T::ResponseBody as Body>::Error: Into<StdError> + Send,
    {
        pub fn new(inner: T) -> Self {
            let inner = tonic::client::Grpc::new(inner);
            Self { inner }
        }
        pub fn with_origin(inner: T, origin: Uri) -> Self {
            let inner = tonic::client::Grpc::with_origin(inner, origin);
            Self { inner }
        }
        pub fn with_interceptor<F>(
            inner: T,
            interceptor: F,
        ) -> TriggerServiceClient<InterceptedService<T, F>>
        where
            F: tonic::service::Interceptor,
            T::ResponseBody: Default,
            T: tonic::codegen::Service<
                http::Request<tonic::body::BoxBody>,
                Response = http::Response<
                    <T as tonic::client::GrpcService<tonic::body::BoxBody>>::ResponseBody,
                >,
            >,
            <T as tonic::codegen::Service<
                http::Request<tonic::body::BoxBody>,
            >>::Error: Into<StdError> + Send + Sync,
        {
            TriggerServiceClient::new(InterceptedService::new(inner, interceptor))
        }
        /// Compress requests with the given encoding.
        ///
        /// This requires the server to support it otherwise it might respond with an
        /// error.
        #[must_use]
        pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
            self.inner = self.inner.send_compressed(encoding);
            self
        }
        /// Enable decompressing responses.
        #[must_use]
        pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
            self.inner = self.inner.accept_compressed(encoding);
            self
        }
        /// Limits the maximum size of a decoded message.
        ///
        /// Default: `4MB`
        #[must_use]
        pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
            self.inner = self.inner.max_decoding_message_size(limit);
            self
        }
        /// Limits the maximum size of an encoded message.
        ///
        /// Default: `usize::MAX`
        #[must_use]
        pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
            self.inner = self.inner.max_encoding_message_size(limit);
            self
        }
        /// Returns the specified trigger.
        ///
        /// To get the list of all available triggers, make a [List] request.
        pub async fn get(
            &mut self,
            request: impl tonic::IntoRequest<super::GetTriggerRequest>,
        ) -> std::result::Result<tonic::Response<super::Trigger>, tonic::Status> {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::new(
                        tonic::Code::Unknown,
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/yandex.cloud.serverless.triggers.v1.TriggerService/Get",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "yandex.cloud.serverless.triggers.v1.TriggerService",
                        "Get",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        /// Retrieves the list of triggers in the specified folder.
        pub async fn list(
            &mut self,
            request: impl tonic::IntoRequest<super::ListTriggersRequest>,
        ) -> std::result::Result<
            tonic::Response<super::ListTriggersResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::new(
                        tonic::Code::Unknown,
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/yandex.cloud.serverless.triggers.v1.TriggerService/List",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "yandex.cloud.serverless.triggers.v1.TriggerService",
                        "List",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        /// Creates a trigger in the specified folder.
        pub async fn create(
            &mut self,
            request: impl tonic::IntoRequest<super::CreateTriggerRequest>,
        ) -> std::result::Result<
            tonic::Response<super::super::super::super::operation::Operation>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::new(
                        tonic::Code::Unknown,
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/yandex.cloud.serverless.triggers.v1.TriggerService/Create",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "yandex.cloud.serverless.triggers.v1.TriggerService",
                        "Create",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        /// Updates the specified trigger.
        pub async fn update(
            &mut self,
            request: impl tonic::IntoRequest<super::UpdateTriggerRequest>,
        ) -> std::result::Result<
            tonic::Response<super::super::super::super::operation::Operation>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::new(
                        tonic::Code::Unknown,
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/yandex.cloud.serverless.triggers.v1.TriggerService/Update",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "yandex.cloud.serverless.triggers.v1.TriggerService",
                        "Update",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        /// Deletes the specified trigger.
        pub async fn delete(
            &mut self,
            request: impl tonic::IntoRequest<super::DeleteTriggerRequest>,
        ) -> std::result::Result<
            tonic::Response<super::super::super::super::operation::Operation>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::new(
                        tonic::Code::Unknown,
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/yandex.cloud.serverless.triggers.v1.TriggerService/Delete",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "yandex.cloud.serverless.triggers.v1.TriggerService",
                        "Delete",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        /// Pauses the specified trigger.
        pub async fn pause(
            &mut self,
            request: impl tonic::IntoRequest<super::PauseTriggerRequest>,
        ) -> std::result::Result<
            tonic::Response<super::super::super::super::operation::Operation>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::new(
                        tonic::Code::Unknown,
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/yandex.cloud.serverless.triggers.v1.TriggerService/Pause",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "yandex.cloud.serverless.triggers.v1.TriggerService",
                        "Pause",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        /// Restarts the specified trigger.
        pub async fn resume(
            &mut self,
            request: impl tonic::IntoRequest<super::ResumeTriggerRequest>,
        ) -> std::result::Result<
            tonic::Response<super::super::super::super::operation::Operation>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::new(
                        tonic::Code::Unknown,
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/yandex.cloud.serverless.triggers.v1.TriggerService/Resume",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "yandex.cloud.serverless.triggers.v1.TriggerService",
                        "Resume",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        /// Lists operations for the specified trigger.
        pub async fn list_operations(
            &mut self,
            request: impl tonic::IntoRequest<super::ListTriggerOperationsRequest>,
        ) -> std::result::Result<
            tonic::Response<super::ListTriggerOperationsResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::new(
                        tonic::Code::Unknown,
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/yandex.cloud.serverless.triggers.v1.TriggerService/ListOperations",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "yandex.cloud.serverless.triggers.v1.TriggerService",
                        "ListOperations",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
    }
}