pole_specification/

v1.rs

// This file is @generated by prost-build.
/// 主调服务信息数据
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Caller {
    #[prost(string, tag = "2")]
    pub namespace: ::prost::alloc::string::String,
    #[prost(string, tag = "3")]
    pub service: ::prost::alloc::string::String,
    /// 客户端标签
    #[prost(message, repeated, tag = "10")]
    pub labels: ::prost::alloc::vec::Vec<ClientLabel>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct Location {
    #[prost(string, tag = "1")]
    pub region: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub zone: ::prost::alloc::string::String,
    #[prost(string, tag = "3")]
    pub campus: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct MatchString {
    #[prost(enumeration = "match_string::MatchStringType", tag = "1")]
    pub r#type: i32,
    #[prost(string, tag = "2")]
    pub value: ::prost::alloc::string::String,
    #[prost(enumeration = "match_string::ValueType", tag = "3")]
    pub value_type: i32,
}
/// Nested message and enum types in `MatchString`.
pub mod match_string {
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum MatchStringType {
        /// Equivalent match
        Exact = 0,
        /// Regular match
        Regex = 1,
        /// Not equals match
        NotEquals = 2,
        /// Include match
        In = 3,
        /// Not include match
        NotIn = 4,
        /// Range match
        Range = 5,
    }
    impl MatchStringType {
        /// 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 {
                Self::Exact => "EXACT",
                Self::Regex => "REGEX",
                Self::NotEquals => "NOT_EQUALS",
                Self::In => "IN",
                Self::NotIn => "NOT_IN",
                Self::Range => "RANGE",
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "EXACT" => Some(Self::Exact),
                "REGEX" => Some(Self::Regex),
                "NOT_EQUALS" => Some(Self::NotEquals),
                "IN" => Some(Self::In),
                "NOT_IN" => Some(Self::NotIn),
                "RANGE" => Some(Self::Range),
                _ => None,
            }
        }
    }
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum ValueType {
        Text = 0,
        Parameter = 1,
        Variable = 2,
    }
    impl ValueType {
        /// 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 {
                Self::Text => "TEXT",
                Self::Parameter => "PARAMETER",
                Self::Variable => "VARIABLE",
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "TEXT" => Some(Self::Text),
                "PARAMETER" => Some(Self::Parameter),
                "VARIABLE" => Some(Self::Variable),
                _ => None,
            }
        }
    }
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct StringList {
    #[prost(string, repeated, tag = "1")]
    pub values: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
/// 汇总查询数据
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct Summary {
    /// 服务总数
    #[prost(uint32, tag = "1")]
    pub total_service_count: u32,
    /// 健康实例总数
    #[prost(uint32, tag = "2")]
    pub total_health_instance_count: u32,
    /// 实例总数
    #[prost(uint32, tag = "3")]
    pub total_instance_count: u32,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct ClientLabel {
    #[prost(string, tag = "1")]
    pub key: ::prost::alloc::string::String,
    #[prost(message, optional, tag = "2")]
    pub value: ::core::option::Option<MatchString>,
}
/// API统一数据结构
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct Api {
    /// API的协议，\*或者为空代表全部
    #[prost(string, tag = "1")]
    pub protocol: ::prost::alloc::string::String,
    /// API的方法，\*或者为空代表全部
    #[prost(string, tag = "2")]
    pub method: ::prost::alloc::string::String,
    /// API的路径，支持多种匹配方式
    #[prost(message, optional, tag = "3")]
    pub path: ::core::option::Option<MatchString>,
}
/// 治理规则发布请求
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct RuleRelease {
    #[prost(string, tag = "1")]
    pub id: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub rule_id: ::prost::alloc::string::String,
    #[prost(string, tag = "3")]
    pub rule_name: ::prost::alloc::string::String,
    #[prost(string, tag = "4")]
    pub release_name: ::prost::alloc::string::String,
    #[prost(string, tag = "5")]
    pub description: ::prost::alloc::string::String,
    #[prost(string, tag = "6")]
    pub release_type: ::prost::alloc::string::String,
    #[prost(message, repeated, tag = "7")]
    pub client_labels: ::prost::alloc::vec::Vec<ClientLabel>,
    #[prost(uint64, tag = "8")]
    pub version: u64,
    #[prost(enumeration = "rule_release::RuleType", tag = "9")]
    pub resource: i32,
    #[prost(bool, tag = "10")]
    pub active: bool,
    #[prost(string, tag = "20")]
    pub ctime: ::prost::alloc::string::String,
    #[prost(string, tag = "21")]
    pub mtime: ::prost::alloc::string::String,
}
/// Nested message and enum types in `RuleRelease`.
pub mod rule_release {
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum RuleType {
        RouteRules = 0,
        RateLimitRules = 1,
        CircuitBreakerRules = 2,
        FaultDetectRules = 3,
        LaneRules = 4,
        LosslessRules = 5,
        TrafficMirrorRules = 6,
        TrafficSecurityRules = 7,
    }
    impl RuleType {
        /// 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 {
                Self::RouteRules => "RouteRules",
                Self::RateLimitRules => "RateLimitRules",
                Self::CircuitBreakerRules => "CircuitBreakerRules",
                Self::FaultDetectRules => "FaultDetectRules",
                Self::LaneRules => "LaneRules",
                Self::LosslessRules => "LosslessRules",
                Self::TrafficMirrorRules => "TrafficMirrorRules",
                Self::TrafficSecurityRules => "TrafficSecurityRules",
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "RouteRules" => Some(Self::RouteRules),
                "RateLimitRules" => Some(Self::RateLimitRules),
                "CircuitBreakerRules" => Some(Self::CircuitBreakerRules),
                "FaultDetectRules" => Some(Self::FaultDetectRules),
                "LaneRules" => Some(Self::LaneRules),
                "LosslessRules" => Some(Self::LosslessRules),
                "TrafficMirrorRules" => Some(Self::TrafficMirrorRules),
                "TrafficSecurityRules" => Some(Self::TrafficSecurityRules),
                _ => None,
            }
        }
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ConfigFileGroup {
    #[prost(string, tag = "1")]
    pub id: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub name: ::prost::alloc::string::String,
    #[prost(string, tag = "3")]
    pub namespace: ::prost::alloc::string::String,
    #[prost(string, tag = "4")]
    pub comment: ::prost::alloc::string::String,
    #[prost(string, tag = "5")]
    pub ctime: ::prost::alloc::string::String,
    #[prost(string, tag = "7")]
    pub mtime: ::prost::alloc::string::String,
    #[prost(string, tag = "8")]
    pub business: ::prost::alloc::string::String,
    #[prost(string, tag = "9")]
    pub department: ::prost::alloc::string::String,
    #[prost(map = "string, string", tag = "10")]
    pub metadata: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    #[prost(uint64, tag = "11")]
    pub file_count: u64,
    /// 删除操作标志位
    #[prost(bool, tag = "15")]
    pub editable: bool,
    #[prost(bool, tag = "20")]
    pub deleteable: bool,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct ConfigFilePersistent {
    #[prost(string, tag = "1")]
    pub encoding: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub path: ::prost::alloc::string::String,
    #[prost(string, tag = "3")]
    pub post_cmd: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PlaceholderValue {
    /// 占位符名称
    #[prost(string, tag = "1")]
    pub placeholder: ::prost::alloc::string::String,
    /// 占位符对应的值
    #[prost(message, repeated, tag = "2")]
    pub values: ::prost::alloc::vec::Vec<MatchString>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ConfigFile {
    #[prost(string, tag = "1")]
    pub id: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub name: ::prost::alloc::string::String,
    #[prost(string, tag = "3")]
    pub namespace: ::prost::alloc::string::String,
    #[prost(string, tag = "4")]
    pub group: ::prost::alloc::string::String,
    #[prost(string, tag = "5")]
    pub content: ::prost::alloc::string::String,
    #[prost(string, tag = "6")]
    pub format: ::prost::alloc::string::String,
    #[prost(string, tag = "7")]
    pub comment: ::prost::alloc::string::String,
    #[prost(string, tag = "8")]
    pub status: ::prost::alloc::string::String,
    #[prost(map = "string, string", tag = "9")]
    pub labels: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    #[prost(string, tag = "10")]
    pub ctime: ::prost::alloc::string::String,
    #[prost(string, tag = "12")]
    pub mtime: ::prost::alloc::string::String,
    #[prost(string, tag = "14")]
    pub rtime: ::prost::alloc::string::String,
    /// 是否为加密配置文件
    #[prost(bool, tag = "16")]
    pub encrypted: bool,
    /// 加密算法
    #[prost(string, tag = "17")]
    pub encrypt_algo: ::prost::alloc::string::String,
    #[prost(enumeration = "ConfigFileSupportedClient", tag = "18")]
    pub supported_client: i32,
    #[prost(message, optional, tag = "19")]
    pub persistent: ::core::option::Option<ConfigFilePersistent>,
    #[prost(enumeration = "config_file::ConfigFileType", tag = "200")]
    pub config_type: i32,
    /// 如果是配置模板，还需要添加占位符对应的 value 值匹配信息
    #[prost(map = "string, message", tag = "201")]
    pub placeholder_value_map: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        PlaceholderValue,
    >,
}
/// Nested message and enum types in `ConfigFile`.
pub mod config_file {
    /// 文件类型
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum ConfigFileType {
        /// 普通配置文件
        ConfigFile = 0,
        /// 配置模板
        ConfigTemplate = 1,
    }
    impl ConfigFileType {
        /// 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 {
                Self::ConfigFile => "CONFIG_FILE",
                Self::ConfigTemplate => "CONFIG_TEMPLATE",
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "CONFIG_FILE" => Some(Self::ConfigFile),
                "CONFIG_TEMPLATE" => Some(Self::ConfigTemplate),
                _ => None,
            }
        }
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ConfigFileRelease {
    #[prost(string, tag = "1")]
    pub id: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub name: ::prost::alloc::string::String,
    #[prost(string, tag = "3")]
    pub namespace: ::prost::alloc::string::String,
    #[prost(string, tag = "4")]
    pub group: ::prost::alloc::string::String,
    #[prost(string, tag = "5")]
    pub file_name: ::prost::alloc::string::String,
    #[prost(string, tag = "6")]
    pub content: ::prost::alloc::string::String,
    #[prost(string, tag = "7")]
    pub comment: ::prost::alloc::string::String,
    #[prost(string, tag = "8")]
    pub md5: ::prost::alloc::string::String,
    #[prost(uint64, tag = "9")]
    pub version: u64,
    #[prost(string, tag = "10")]
    pub ctime: ::prost::alloc::string::String,
    #[prost(string, tag = "11")]
    pub create_by: ::prost::alloc::string::String,
    #[prost(string, tag = "12")]
    pub mtime: ::prost::alloc::string::String,
    #[prost(string, tag = "13")]
    pub modify_by: ::prost::alloc::string::String,
    #[prost(map = "string, string", tag = "14")]
    pub labels: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    /// 当前生效配置
    #[prost(bool, tag = "15")]
    pub active: bool,
    #[prost(string, tag = "16")]
    pub format: ::prost::alloc::string::String,
    #[prost(string, tag = "17")]
    pub release_description: ::prost::alloc::string::String,
    #[prost(string, tag = "18")]
    pub release_type: ::prost::alloc::string::String,
    /// 配置灰度发布时需要匹配的客户端标签信息
    #[prost(message, repeated, tag = "19")]
    pub beta_labels: ::prost::alloc::vec::Vec<ClientLabel>,
    #[prost(enumeration = "ConfigFileSupportedClient", tag = "21")]
    pub supported_client: i32,
    #[prost(message, optional, tag = "22")]
    pub persistent: ::core::option::Option<ConfigFilePersistent>,
    /// 是否为加密配置文件
    #[prost(bool, tag = "23")]
    pub encrypted: bool,
    /// 加密算法
    #[prost(string, tag = "24")]
    pub encrypt_algo: ::prost::alloc::string::String,
    #[prost(enumeration = "config_file_release::ConfigFileType", tag = "200")]
    pub config_type: i32,
    /// 如果是配置模板，还需要添加占位符对应的 value 值匹配信息
    #[prost(map = "string, message", tag = "201")]
    pub placeholder_value_map: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        PlaceholderValue,
    >,
}
/// Nested message and enum types in `ConfigFileRelease`.
pub mod config_file_release {
    /// 文件类型
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum ConfigFileType {
        /// 普通配置文件
        ConfigFile = 0,
        /// 配置模板
        ConfigTemplate = 1,
    }
    impl ConfigFileType {
        /// 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 {
                Self::ConfigFile => "CONFIG_FILE",
                Self::ConfigTemplate => "CONFIG_TEMPLATE",
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "CONFIG_FILE" => Some(Self::ConfigFile),
                "CONFIG_TEMPLATE" => Some(Self::ConfigTemplate),
                _ => None,
            }
        }
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ConfigFileReleaseHistory {
    #[prost(string, tag = "1")]
    pub id: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub name: ::prost::alloc::string::String,
    #[prost(string, tag = "3")]
    pub namespace: ::prost::alloc::string::String,
    #[prost(string, tag = "4")]
    pub group: ::prost::alloc::string::String,
    #[prost(string, tag = "5")]
    pub file_name: ::prost::alloc::string::String,
    #[prost(string, tag = "6")]
    pub content: ::prost::alloc::string::String,
    #[prost(string, tag = "7")]
    pub format: ::prost::alloc::string::String,
    #[prost(string, tag = "8")]
    pub comment: ::prost::alloc::string::String,
    #[prost(string, tag = "9")]
    pub md5: ::prost::alloc::string::String,
    #[prost(string, tag = "10")]
    pub r#type: ::prost::alloc::string::String,
    #[prost(string, tag = "11")]
    pub status: ::prost::alloc::string::String,
    #[prost(map = "string, string", tag = "12")]
    pub labels: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    #[prost(string, tag = "13")]
    pub ctime: ::prost::alloc::string::String,
    #[prost(string, tag = "14")]
    pub create_by: ::prost::alloc::string::String,
    #[prost(string, tag = "15")]
    pub mtime: ::prost::alloc::string::String,
    #[prost(string, tag = "16")]
    pub modify_by: ::prost::alloc::string::String,
    /// 配置发布失败的原因
    #[prost(string, tag = "17")]
    pub reason: ::prost::alloc::string::String,
    #[prost(string, tag = "18")]
    pub release_description: ::prost::alloc::string::String,
    #[prost(enumeration = "config_file_release_history::ConfigFileType", tag = "200")]
    pub config_type: i32,
    /// 如果是配置模板，还需要添加占位符对应的 value 值匹配信息
    #[prost(map = "string, message", tag = "201")]
    pub placeholder_value_map: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        PlaceholderValue,
    >,
}
/// Nested message and enum types in `ConfigFileReleaseHistory`.
pub mod config_file_release_history {
    /// 文件类型
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum ConfigFileType {
        /// 普通配置文件
        ConfigFile = 0,
        /// 配置模板
        ConfigTemplate = 1,
    }
    impl ConfigFileType {
        /// 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 {
                Self::ConfigFile => "CONFIG_FILE",
                Self::ConfigTemplate => "CONFIG_TEMPLATE",
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "CONFIG_FILE" => Some(Self::ConfigFile),
                "CONFIG_TEMPLATE" => Some(Self::ConfigTemplate),
                _ => None,
            }
        }
    }
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct ConfigFileTemplate {
    #[prost(uint64, tag = "1")]
    pub id: u64,
    #[prost(string, tag = "2")]
    pub name: ::prost::alloc::string::String,
    #[prost(string, tag = "3")]
    pub content: ::prost::alloc::string::String,
    #[prost(string, tag = "4")]
    pub format: ::prost::alloc::string::String,
    #[prost(string, tag = "5")]
    pub comment: ::prost::alloc::string::String,
    #[prost(string, tag = "6")]
    pub ctime: ::prost::alloc::string::String,
    #[prost(string, tag = "8")]
    pub mtime: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct WatchConfigFileRequest {
    #[prost(string, tag = "1")]
    pub client_ip: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub service_name: ::prost::alloc::string::String,
    #[prost(message, repeated, tag = "3")]
    pub files: ::prost::alloc::vec::Vec<ConfigFileRelease>,
    #[prost(enumeration = "ConfigClientType", tag = "4")]
    pub client_type: i32,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct ConfigFileExportRequest {
    #[prost(string, tag = "1")]
    pub namespace: ::prost::alloc::string::String,
    #[prost(string, repeated, tag = "2")]
    pub groups: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    #[prost(string, repeated, tag = "3")]
    pub names: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    #[prost(uint64, repeated, tag = "4")]
    pub ids: ::prost::alloc::vec::Vec<u64>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ConfigFilePublishInfo {
    #[prost(string, tag = "1")]
    pub release_name: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub namespace: ::prost::alloc::string::String,
    #[prost(string, tag = "3")]
    pub group: ::prost::alloc::string::String,
    #[prost(string, tag = "4")]
    pub file_name: ::prost::alloc::string::String,
    #[prost(string, tag = "5")]
    pub content: ::prost::alloc::string::String,
    #[prost(string, tag = "6")]
    pub comment: ::prost::alloc::string::String,
    #[prost(string, tag = "7")]
    pub format: ::prost::alloc::string::String,
    #[prost(string, tag = "8")]
    pub release_description: ::prost::alloc::string::String,
    #[prost(map = "string, string", tag = "14")]
    pub labels: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    #[prost(string, tag = "15")]
    pub md5: ::prost::alloc::string::String,
    /// 是否为加密配置文件
    #[prost(bool, tag = "16")]
    pub encrypted: bool,
    /// 加密算法
    #[prost(string, tag = "17")]
    pub encrypt_algo: ::prost::alloc::string::String,
    #[prost(message, optional, tag = "19")]
    pub persistent: ::core::option::Option<ConfigFilePersistent>,
    #[prost(enumeration = "config_file_publish_info::ConfigFileType", tag = "200")]
    pub config_type: i32,
    /// 如果是配置模板，还需要添加占位符对应的 value 值匹配信息
    #[prost(map = "string, message", tag = "201")]
    pub placeholder_value_map: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        PlaceholderValue,
    >,
}
/// Nested message and enum types in `ConfigFilePublishInfo`.
pub mod config_file_publish_info {
    /// 文件类型
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum ConfigFileType {
        /// 普通配置文件
        ConfigFile = 0,
        /// 配置模板
        ConfigTemplate = 1,
    }
    impl ConfigFileType {
        /// 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 {
                Self::ConfigFile => "CONFIG_FILE",
                Self::ConfigTemplate => "CONFIG_TEMPLATE",
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "CONFIG_FILE" => Some(Self::ConfigFile),
                "CONFIG_TEMPLATE" => Some(Self::ConfigTemplate),
                _ => None,
            }
        }
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ConfigFileGroupRequest {
    #[prost(string, tag = "1")]
    pub revision: ::prost::alloc::string::String,
    #[prost(message, optional, tag = "2")]
    pub config_file_group: ::core::option::Option<ConfigFileGroup>,
    /// 配置标签
    #[prost(map = "string, string", tag = "12")]
    pub client_labels: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    #[prost(enumeration = "ConfigClientType", tag = "13")]
    pub client_type: i32,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ConfigDiscoverFilter {
    /// pole.io 自定义信息
    #[prost(message, optional, tag = "1")]
    pub caller: ::core::option::Option<Caller>,
    /// 客户端公钥，用于加密返回的配置 encrypted_key 字段
    #[prost(string, tag = "2")]
    pub public_key: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ConfigDiscoverRequest {
    #[prost(
        enumeration = "config_discover_request::ConfigDiscoverRequestType",
        tag = "1"
    )]
    pub r#type: i32,
    #[prost(message, optional, tag = "2")]
    pub file: ::core::option::Option<ConfigFile>,
    #[prost(string, tag = "3")]
    pub revision: ::prost::alloc::string::String,
    /// pole.io 自定义信息
    #[prost(message, optional, tag = "500")]
    pub filter: ::core::option::Option<ConfigDiscoverFilter>,
}
/// Nested message and enum types in `ConfigDiscoverRequest`.
pub mod config_discover_request {
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum ConfigDiscoverRequestType {
        Unknown = 0,
        ConfigFile = 1,
        ConfigFileNames = 2,
        ConfigFileGroups = 3,
    }
    impl ConfigDiscoverRequestType {
        /// 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 {
                Self::Unknown => "UNKNOWN",
                Self::ConfigFile => "CONFIG_FILE",
                Self::ConfigFileNames => "CONFIG_FILE_NAMES",
                Self::ConfigFileGroups => "CONFIG_FILE_GROUPS",
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "UNKNOWN" => Some(Self::Unknown),
                "CONFIG_FILE" => Some(Self::ConfigFile),
                "CONFIG_FILE_NAMES" => Some(Self::ConfigFileNames),
                "CONFIG_FILE_GROUPS" => Some(Self::ConfigFileGroups),
                _ => None,
            }
        }
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ConfigDiscoverResponse {
    #[prost(uint32, tag = "1")]
    pub code: u32,
    #[prost(string, tag = "2")]
    pub info: ::prost::alloc::string::String,
    #[prost(string, tag = "3")]
    pub revision: ::prost::alloc::string::String,
    #[prost(
        enumeration = "config_discover_response::ConfigDiscoverResponseType",
        tag = "4"
    )]
    pub r#type: i32,
    #[prost(message, optional, tag = "5")]
    pub file: ::core::option::Option<ConfigFileRelease>,
    #[prost(message, repeated, tag = "6")]
    pub file_names: ::prost::alloc::vec::Vec<ConfigFileRelease>,
    #[prost(message, repeated, tag = "7")]
    pub file_groups: ::prost::alloc::vec::Vec<ConfigFileGroup>,
}
/// Nested message and enum types in `ConfigDiscoverResponse`.
pub mod config_discover_response {
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum ConfigDiscoverResponseType {
        Unknown = 0,
        ConfigFile = 1,
        ConfigFileNames = 2,
        ConfigFileGroups = 3,
    }
    impl ConfigDiscoverResponseType {
        /// 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 {
                Self::Unknown => "UNKNOWN",
                Self::ConfigFile => "CONFIG_FILE",
                Self::ConfigFileNames => "CONFIG_FILE_NAMES",
                Self::ConfigFileGroups => "CONFIG_FILE_GROUPS",
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "UNKNOWN" => Some(Self::Unknown),
                "CONFIG_FILE" => Some(Self::ConfigFile),
                "CONFIG_FILE_NAMES" => Some(Self::ConfigFileNames),
                "CONFIG_FILE_GROUPS" => Some(Self::ConfigFileGroups),
                _ => None,
            }
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum ConfigFileSupportedClient {
    /// 配置文件仅能被SDK拉取
    ClientSdk = 0,
    /// 配置文件仅能被Agent拉取
    ClientAgent = 1,
    /// 配置文件可以被SDK及Agent同时拉取
    ClientAll = 2,
}
impl ConfigFileSupportedClient {
    /// 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 {
            Self::ClientSdk => "CLIENT_SDK",
            Self::ClientAgent => "CLIENT_AGENT",
            Self::ClientAll => "CLIENT_ALL",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "CLIENT_SDK" => Some(Self::ClientSdk),
            "CLIENT_AGENT" => Some(Self::ClientAgent),
            "CLIENT_ALL" => Some(Self::ClientAll),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum ConfigClientType {
    Sdk = 0,
    Agent = 1,
}
impl ConfigClientType {
    /// 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 {
            Self::Sdk => "SDK",
            Self::Agent => "Agent",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "SDK" => Some(Self::Sdk),
            "Agent" => Some(Self::Agent),
            _ => None,
        }
    }
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct Response {
    #[prost(uint32, tag = "1")]
    pub code: u32,
    #[prost(string, tag = "2")]
    pub info: ::prost::alloc::string::String,
    #[prost(message, optional, tag = "3")]
    pub data: ::core::option::Option<::prost_types::Any>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchWriteResponse {
    #[prost(uint32, tag = "1")]
    pub code: u32,
    #[prost(string, tag = "2")]
    pub info: ::prost::alloc::string::String,
    #[prost(uint32, tag = "3")]
    pub size: u32,
    #[prost(message, repeated, tag = "4")]
    pub responses: ::prost::alloc::vec::Vec<Response>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchQueryResponse {
    #[prost(uint32, tag = "1")]
    pub code: u32,
    #[prost(string, tag = "2")]
    pub info: ::prost::alloc::string::String,
    #[prost(uint32, tag = "3")]
    pub amount: u32,
    #[prost(uint32, tag = "4")]
    pub size: u32,
    #[prost(message, repeated, tag = "5")]
    pub data: ::prost::alloc::vec::Vec<::prost_types::Any>,
}
/// Generated client implementations.
pub mod config_grpc_client {
    #![allow(
        unused_variables,
        dead_code,
        missing_docs,
        clippy::wildcard_imports,
        clippy::let_unit_value,
    )]
    use tonic::codegen::*;
    use tonic::codegen::http::Uri;
    #[derive(Debug, Clone)]
    pub struct ConfigGrpcClient<T> {
        inner: tonic::client::Grpc<T>,
    }
    impl ConfigGrpcClient<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> ConfigGrpcClient<T>
    where
        T: tonic::client::GrpcService<tonic::body::Body>,
        T::Error: Into<StdError>,
        T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
        <T::ResponseBody as Body>::Error: Into<StdError> + std::marker::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,
        ) -> ConfigGrpcClient<InterceptedService<T, F>>
        where
            F: tonic::service::Interceptor,
            T::ResponseBody: Default,
            T: tonic::codegen::Service<
                http::Request<tonic::body::Body>,
                Response = http::Response<
                    <T as tonic::client::GrpcService<tonic::body::Body>>::ResponseBody,
                >,
            >,
            <T as tonic::codegen::Service<
                http::Request<tonic::body::Body>,
            >>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
        {
            ConfigGrpcClient::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
        }
        /// 创建配置
        pub async fn create_config_file(
            &mut self,
            request: impl tonic::IntoRequest<super::ConfigFile>,
        ) -> std::result::Result<tonic::Response<super::Response>, tonic::Status> {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/v1.ConfigGRPC/CreateConfigFile",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("v1.ConfigGRPC", "CreateConfigFile"));
            self.inner.unary(req, path, codec).await
        }
        /// 更新配置
        pub async fn update_config_file(
            &mut self,
            request: impl tonic::IntoRequest<super::ConfigFile>,
        ) -> std::result::Result<tonic::Response<super::Response>, tonic::Status> {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/v1.ConfigGRPC/UpdateConfigFile",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("v1.ConfigGRPC", "UpdateConfigFile"));
            self.inner.unary(req, path, codec).await
        }
        /// 发布配置
        pub async fn publish_config_file(
            &mut self,
            request: impl tonic::IntoRequest<super::ConfigFileRelease>,
        ) -> std::result::Result<tonic::Response<super::Response>, tonic::Status> {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/v1.ConfigGRPC/PublishConfigFile",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("v1.ConfigGRPC", "PublishConfigFile"));
            self.inner.unary(req, path, codec).await
        }
        /// 统一发现接口
        pub async fn discover(
            &mut self,
            request: impl tonic::IntoStreamingRequest<
                Message = super::ConfigDiscoverRequest,
            >,
        ) -> std::result::Result<
            tonic::Response<tonic::codec::Streaming<super::ConfigDiscoverResponse>>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static("/v1.ConfigGRPC/Discover");
            let mut req = request.into_streaming_request();
            req.extensions_mut().insert(GrpcMethod::new("v1.ConfigGRPC", "Discover"));
            self.inner.streaming(req, path, codec).await
        }
    }
}
/// Generated server implementations.
pub mod config_grpc_server {
    #![allow(
        unused_variables,
        dead_code,
        missing_docs,
        clippy::wildcard_imports,
        clippy::let_unit_value,
    )]
    use tonic::codegen::*;
    /// Generated trait containing gRPC methods that should be implemented for use with ConfigGrpcServer.
    #[async_trait]
    pub trait ConfigGrpc: std::marker::Send + std::marker::Sync + 'static {
        /// 创建配置
        async fn create_config_file(
            &self,
            request: tonic::Request<super::ConfigFile>,
        ) -> std::result::Result<tonic::Response<super::Response>, tonic::Status>;
        /// 更新配置
        async fn update_config_file(
            &self,
            request: tonic::Request<super::ConfigFile>,
        ) -> std::result::Result<tonic::Response<super::Response>, tonic::Status>;
        /// 发布配置
        async fn publish_config_file(
            &self,
            request: tonic::Request<super::ConfigFileRelease>,
        ) -> std::result::Result<tonic::Response<super::Response>, tonic::Status>;
        /// Server streaming response type for the Discover method.
        type DiscoverStream: tonic::codegen::tokio_stream::Stream<
                Item = std::result::Result<super::ConfigDiscoverResponse, tonic::Status>,
            >
            + std::marker::Send
            + 'static;
        /// 统一发现接口
        async fn discover(
            &self,
            request: tonic::Request<tonic::Streaming<super::ConfigDiscoverRequest>>,
        ) -> std::result::Result<tonic::Response<Self::DiscoverStream>, tonic::Status>;
    }
    #[derive(Debug)]
    pub struct ConfigGrpcServer<T> {
        inner: Arc<T>,
        accept_compression_encodings: EnabledCompressionEncodings,
        send_compression_encodings: EnabledCompressionEncodings,
        max_decoding_message_size: Option<usize>,
        max_encoding_message_size: Option<usize>,
    }
    impl<T> ConfigGrpcServer<T> {
        pub fn new(inner: T) -> Self {
            Self::from_arc(Arc::new(inner))
        }
        pub fn from_arc(inner: Arc<T>) -> Self {
            Self {
                inner,
                accept_compression_encodings: Default::default(),
                send_compression_encodings: Default::default(),
                max_decoding_message_size: None,
                max_encoding_message_size: None,
            }
        }
        pub fn with_interceptor<F>(
            inner: T,
            interceptor: F,
        ) -> InterceptedService<Self, F>
        where
            F: tonic::service::Interceptor,
        {
            InterceptedService::new(Self::new(inner), interceptor)
        }
        /// Enable decompressing requests with the given encoding.
        #[must_use]
        pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
            self.accept_compression_encodings.enable(encoding);
            self
        }
        /// Compress responses with the given encoding, if the client supports it.
        #[must_use]
        pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
            self.send_compression_encodings.enable(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.max_decoding_message_size = Some(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.max_encoding_message_size = Some(limit);
            self
        }
    }
    impl<T, B> tonic::codegen::Service<http::Request<B>> for ConfigGrpcServer<T>
    where
        T: ConfigGrpc,
        B: Body + std::marker::Send + 'static,
        B::Error: Into<StdError> + std::marker::Send + 'static,
    {
        type Response = http::Response<tonic::body::Body>;
        type Error = std::convert::Infallible;
        type Future = BoxFuture<Self::Response, Self::Error>;
        fn poll_ready(
            &mut self,
            _cx: &mut Context<'_>,
        ) -> Poll<std::result::Result<(), Self::Error>> {
            Poll::Ready(Ok(()))
        }
        fn call(&mut self, req: http::Request<B>) -> Self::Future {
            match req.uri().path() {
                "/v1.ConfigGRPC/CreateConfigFile" => {
                    #[allow(non_camel_case_types)]
                    struct CreateConfigFileSvc<T: ConfigGrpc>(pub Arc<T>);
                    impl<T: ConfigGrpc> tonic::server::UnaryService<super::ConfigFile>
                    for CreateConfigFileSvc<T> {
                        type Response = super::Response;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::ConfigFile>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as ConfigGrpc>::create_config_file(&inner, request).await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = CreateConfigFileSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/v1.ConfigGRPC/UpdateConfigFile" => {
                    #[allow(non_camel_case_types)]
                    struct UpdateConfigFileSvc<T: ConfigGrpc>(pub Arc<T>);
                    impl<T: ConfigGrpc> tonic::server::UnaryService<super::ConfigFile>
                    for UpdateConfigFileSvc<T> {
                        type Response = super::Response;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::ConfigFile>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as ConfigGrpc>::update_config_file(&inner, request).await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = UpdateConfigFileSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/v1.ConfigGRPC/PublishConfigFile" => {
                    #[allow(non_camel_case_types)]
                    struct PublishConfigFileSvc<T: ConfigGrpc>(pub Arc<T>);
                    impl<
                        T: ConfigGrpc,
                    > tonic::server::UnaryService<super::ConfigFileRelease>
                    for PublishConfigFileSvc<T> {
                        type Response = super::Response;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::ConfigFileRelease>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as ConfigGrpc>::publish_config_file(&inner, request)
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = PublishConfigFileSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/v1.ConfigGRPC/Discover" => {
                    #[allow(non_camel_case_types)]
                    struct DiscoverSvc<T: ConfigGrpc>(pub Arc<T>);
                    impl<
                        T: ConfigGrpc,
                    > tonic::server::StreamingService<super::ConfigDiscoverRequest>
                    for DiscoverSvc<T> {
                        type Response = super::ConfigDiscoverResponse;
                        type ResponseStream = T::DiscoverStream;
                        type Future = BoxFuture<
                            tonic::Response<Self::ResponseStream>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<
                                tonic::Streaming<super::ConfigDiscoverRequest>,
                            >,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as ConfigGrpc>::discover(&inner, request).await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = DiscoverSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.streaming(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                _ => {
                    Box::pin(async move {
                        let mut response = http::Response::new(
                            tonic::body::Body::default(),
                        );
                        let headers = response.headers_mut();
                        headers
                            .insert(
                                tonic::Status::GRPC_STATUS,
                                (tonic::Code::Unimplemented as i32).into(),
                            );
                        headers
                            .insert(
                                http::header::CONTENT_TYPE,
                                tonic::metadata::GRPC_CONTENT_TYPE,
                            );
                        Ok(response)
                    })
                }
            }
        }
    }
    impl<T> Clone for ConfigGrpcServer<T> {
        fn clone(&self) -> Self {
            let inner = self.inner.clone();
            Self {
                inner,
                accept_compression_encodings: self.accept_compression_encodings,
                send_compression_encodings: self.send_compression_encodings,
                max_decoding_message_size: self.max_decoding_message_size,
                max_encoding_message_size: self.max_encoding_message_size,
            }
        }
    }
    /// Generated gRPC service name
    pub const SERVICE_NAME: &str = "v1.ConfigGRPC";
    impl<T> tonic::server::NamedService for ConfigGrpcServer<T> {
        const NAME: &'static str = SERVICE_NAME;
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum Code {
    /// base module status codes
    Unknown = 0,
    ExecuteSuccess = 200000,
    DataNoChange = 200001,
    NoNeedUpdate = 200002,
    BadRequest = 400000,
    ParseException = 400001,
    EmptyRequest = 400002,
    BatchSizeOverLimit = 400003,
    InvalidDiscoverResource = 400004,
    InvalidRequestId = 400100,
    InvalidUserName = 400101,
    InvalidUserToken = 400102,
    InvalidParameter = 400103,
    EmptyQueryParameter = 400104,
    InvalidQueryInsParameter = 400105,
    HealthCheckNotOpen = 400140,
    HeartbeatOnDisabledIns = 400141,
    HeartbeatExceedLimit = 400142,
    HeartbeatTypeNotFound = 400143,
    InvalidMetadata = 400150,
    InvalidMatchRule = 400904,
    /// network relative codes
    ServicesExistedMesh = 400170,
    ResourcesExistedMesh = 400171,
    InvalidMeshParameter = 400172,
    ExistedResource = 400201,
    NamespaceExistedServices = 400203,
    ServiceExistedInstances = 400204,
    ServiceExistedRoutings = 400205,
    ServiceExistedRateLimits = 400206,
    ExistReleasedConfig = 400207,
    SameInstanceRequest = 400208,
    ServiceExistedCircuitBreakers = 400209,
    ServiceExistedAlias = 400210,
    NamespaceExistedMeshResources = 400211,
    NamespaceExistedCircuitBreakers = 400212,
    ServiceSubscribedByMeshes = 400213,
    ServiceExistedFluxRateLimits = 400214,
    NamespaceExistedConfigGroups = 400219,
    ClientApiNotOpen = 400401,
    NotFoundResource = 404202,
    Unauthorized = 401000,
    NotAllowedAccess = 401001,
    CmdbNotFindHost = 404001,
    DataConflict = 409000,
    InstanceTooManyRequests = 429001,
    IpRateLimit = 429002,
    ApiRateLimit = 403003,
    ExecuteException = 500000,
    StoreLayerException = 500001,
    CmdbPluginException = 500002,
    HeartbeatException = 500007,
    InstanceRegisTimeout = 500008,
    /// config center status codes
    EncryptConfigFileException = 400809,
    GroupExistActiveRelease = 400810,
    DecryptConfigFileException = 400811,
    /// auth codes
    InvalidUserOwners = 400410,
    InvalidUserId = 400411,
    InvalidUserPassword = 400412,
    InvalidUserGroupOwners = 400420,
    InvalidUserGroupId = 400421,
    InvalidAuthStrategyOwners = 400430,
    InvalidAuthStrategyName = 400431,
    InvalidAuthStrategyId = 400432,
    InvalidPrincipalType = 400440,
    UserExisted = 400215,
    UserGroupExisted = 400216,
    AuthStrategyRuleExisted = 400217,
    SubAccountExisted = 400218,
    NotFoundUser = 400312,
    NotFoundOwnerUser = 400313,
    NotFoundUserGroup = 400314,
    NotFoundAuthStrategyRule = 400315,
    NotAllowModifyDefaultStrategyPrincipal = 400508,
    NotAllowModifyOwnerDefaultStrategy = 400509,
    EmptyAutToken = 401002,
    TokenDisabled = 401003,
    TokenNotExisted = 401004,
    AuthTokenForbidden = 403001,
    OperationRoleForbidden = 403002,
}
impl Code {
    /// 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 {
            Self::Unknown => "Unknown",
            Self::ExecuteSuccess => "ExecuteSuccess",
            Self::DataNoChange => "DataNoChange",
            Self::NoNeedUpdate => "NoNeedUpdate",
            Self::BadRequest => "BadRequest",
            Self::ParseException => "ParseException",
            Self::EmptyRequest => "EmptyRequest",
            Self::BatchSizeOverLimit => "BatchSizeOverLimit",
            Self::InvalidDiscoverResource => "InvalidDiscoverResource",
            Self::InvalidRequestId => "InvalidRequestID",
            Self::InvalidUserName => "InvalidUserName",
            Self::InvalidUserToken => "InvalidUserToken",
            Self::InvalidParameter => "InvalidParameter",
            Self::EmptyQueryParameter => "EmptyQueryParameter",
            Self::InvalidQueryInsParameter => "InvalidQueryInsParameter",
            Self::HealthCheckNotOpen => "HealthCheckNotOpen",
            Self::HeartbeatOnDisabledIns => "HeartbeatOnDisabledIns",
            Self::HeartbeatExceedLimit => "HeartbeatExceedLimit",
            Self::HeartbeatTypeNotFound => "HeartbeatTypeNotFound",
            Self::InvalidMetadata => "InvalidMetadata",
            Self::InvalidMatchRule => "InvalidMatchRule",
            Self::ServicesExistedMesh => "ServicesExistedMesh",
            Self::ResourcesExistedMesh => "ResourcesExistedMesh",
            Self::InvalidMeshParameter => "InvalidMeshParameter",
            Self::ExistedResource => "ExistedResource",
            Self::NamespaceExistedServices => "NamespaceExistedServices",
            Self::ServiceExistedInstances => "ServiceExistedInstances",
            Self::ServiceExistedRoutings => "ServiceExistedRoutings",
            Self::ServiceExistedRateLimits => "ServiceExistedRateLimits",
            Self::ExistReleasedConfig => "ExistReleasedConfig",
            Self::SameInstanceRequest => "SameInstanceRequest",
            Self::ServiceExistedCircuitBreakers => "ServiceExistedCircuitBreakers",
            Self::ServiceExistedAlias => "ServiceExistedAlias",
            Self::NamespaceExistedMeshResources => "NamespaceExistedMeshResources",
            Self::NamespaceExistedCircuitBreakers => "NamespaceExistedCircuitBreakers",
            Self::ServiceSubscribedByMeshes => "ServiceSubscribedByMeshes",
            Self::ServiceExistedFluxRateLimits => "ServiceExistedFluxRateLimits",
            Self::NamespaceExistedConfigGroups => "NamespaceExistedConfigGroups",
            Self::ClientApiNotOpen => "ClientAPINotOpen",
            Self::NotFoundResource => "NotFoundResource",
            Self::Unauthorized => "Unauthorized",
            Self::NotAllowedAccess => "NotAllowedAccess",
            Self::CmdbNotFindHost => "CMDBNotFindHost",
            Self::DataConflict => "DataConflict",
            Self::InstanceTooManyRequests => "InstanceTooManyRequests",
            Self::IpRateLimit => "IPRateLimit",
            Self::ApiRateLimit => "APIRateLimit",
            Self::ExecuteException => "ExecuteException",
            Self::StoreLayerException => "StoreLayerException",
            Self::CmdbPluginException => "CMDBPluginException",
            Self::HeartbeatException => "HeartbeatException",
            Self::InstanceRegisTimeout => "InstanceRegisTimeout",
            Self::EncryptConfigFileException => "EncryptConfigFileException",
            Self::GroupExistActiveRelease => "GroupExistActiveRelease",
            Self::DecryptConfigFileException => "DecryptConfigFileException",
            Self::InvalidUserOwners => "InvalidUserOwners",
            Self::InvalidUserId => "InvalidUserID",
            Self::InvalidUserPassword => "InvalidUserPassword",
            Self::InvalidUserGroupOwners => "InvalidUserGroupOwners",
            Self::InvalidUserGroupId => "InvalidUserGroupID",
            Self::InvalidAuthStrategyOwners => "InvalidAuthStrategyOwners",
            Self::InvalidAuthStrategyName => "InvalidAuthStrategyName",
            Self::InvalidAuthStrategyId => "InvalidAuthStrategyID",
            Self::InvalidPrincipalType => "InvalidPrincipalType",
            Self::UserExisted => "UserExisted",
            Self::UserGroupExisted => "UserGroupExisted",
            Self::AuthStrategyRuleExisted => "AuthStrategyRuleExisted",
            Self::SubAccountExisted => "SubAccountExisted",
            Self::NotFoundUser => "NotFoundUser",
            Self::NotFoundOwnerUser => "NotFoundOwnerUser",
            Self::NotFoundUserGroup => "NotFoundUserGroup",
            Self::NotFoundAuthStrategyRule => "NotFoundAuthStrategyRule",
            Self::NotAllowModifyDefaultStrategyPrincipal => {
                "NotAllowModifyDefaultStrategyPrincipal"
            }
            Self::NotAllowModifyOwnerDefaultStrategy => {
                "NotAllowModifyOwnerDefaultStrategy"
            }
            Self::EmptyAutToken => "EmptyAutToken",
            Self::TokenDisabled => "TokenDisabled",
            Self::TokenNotExisted => "TokenNotExisted",
            Self::AuthTokenForbidden => "AuthTokenForbidden",
            Self::OperationRoleForbidden => "OperationRoleForbidden",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "Unknown" => Some(Self::Unknown),
            "ExecuteSuccess" => Some(Self::ExecuteSuccess),
            "DataNoChange" => Some(Self::DataNoChange),
            "NoNeedUpdate" => Some(Self::NoNeedUpdate),
            "BadRequest" => Some(Self::BadRequest),
            "ParseException" => Some(Self::ParseException),
            "EmptyRequest" => Some(Self::EmptyRequest),
            "BatchSizeOverLimit" => Some(Self::BatchSizeOverLimit),
            "InvalidDiscoverResource" => Some(Self::InvalidDiscoverResource),
            "InvalidRequestID" => Some(Self::InvalidRequestId),
            "InvalidUserName" => Some(Self::InvalidUserName),
            "InvalidUserToken" => Some(Self::InvalidUserToken),
            "InvalidParameter" => Some(Self::InvalidParameter),
            "EmptyQueryParameter" => Some(Self::EmptyQueryParameter),
            "InvalidQueryInsParameter" => Some(Self::InvalidQueryInsParameter),
            "HealthCheckNotOpen" => Some(Self::HealthCheckNotOpen),
            "HeartbeatOnDisabledIns" => Some(Self::HeartbeatOnDisabledIns),
            "HeartbeatExceedLimit" => Some(Self::HeartbeatExceedLimit),
            "HeartbeatTypeNotFound" => Some(Self::HeartbeatTypeNotFound),
            "InvalidMetadata" => Some(Self::InvalidMetadata),
            "InvalidMatchRule" => Some(Self::InvalidMatchRule),
            "ServicesExistedMesh" => Some(Self::ServicesExistedMesh),
            "ResourcesExistedMesh" => Some(Self::ResourcesExistedMesh),
            "InvalidMeshParameter" => Some(Self::InvalidMeshParameter),
            "ExistedResource" => Some(Self::ExistedResource),
            "NamespaceExistedServices" => Some(Self::NamespaceExistedServices),
            "ServiceExistedInstances" => Some(Self::ServiceExistedInstances),
            "ServiceExistedRoutings" => Some(Self::ServiceExistedRoutings),
            "ServiceExistedRateLimits" => Some(Self::ServiceExistedRateLimits),
            "ExistReleasedConfig" => Some(Self::ExistReleasedConfig),
            "SameInstanceRequest" => Some(Self::SameInstanceRequest),
            "ServiceExistedCircuitBreakers" => Some(Self::ServiceExistedCircuitBreakers),
            "ServiceExistedAlias" => Some(Self::ServiceExistedAlias),
            "NamespaceExistedMeshResources" => Some(Self::NamespaceExistedMeshResources),
            "NamespaceExistedCircuitBreakers" => {
                Some(Self::NamespaceExistedCircuitBreakers)
            }
            "ServiceSubscribedByMeshes" => Some(Self::ServiceSubscribedByMeshes),
            "ServiceExistedFluxRateLimits" => Some(Self::ServiceExistedFluxRateLimits),
            "NamespaceExistedConfigGroups" => Some(Self::NamespaceExistedConfigGroups),
            "ClientAPINotOpen" => Some(Self::ClientApiNotOpen),
            "NotFoundResource" => Some(Self::NotFoundResource),
            "Unauthorized" => Some(Self::Unauthorized),
            "NotAllowedAccess" => Some(Self::NotAllowedAccess),
            "CMDBNotFindHost" => Some(Self::CmdbNotFindHost),
            "DataConflict" => Some(Self::DataConflict),
            "InstanceTooManyRequests" => Some(Self::InstanceTooManyRequests),
            "IPRateLimit" => Some(Self::IpRateLimit),
            "APIRateLimit" => Some(Self::ApiRateLimit),
            "ExecuteException" => Some(Self::ExecuteException),
            "StoreLayerException" => Some(Self::StoreLayerException),
            "CMDBPluginException" => Some(Self::CmdbPluginException),
            "HeartbeatException" => Some(Self::HeartbeatException),
            "InstanceRegisTimeout" => Some(Self::InstanceRegisTimeout),
            "EncryptConfigFileException" => Some(Self::EncryptConfigFileException),
            "GroupExistActiveRelease" => Some(Self::GroupExistActiveRelease),
            "DecryptConfigFileException" => Some(Self::DecryptConfigFileException),
            "InvalidUserOwners" => Some(Self::InvalidUserOwners),
            "InvalidUserID" => Some(Self::InvalidUserId),
            "InvalidUserPassword" => Some(Self::InvalidUserPassword),
            "InvalidUserGroupOwners" => Some(Self::InvalidUserGroupOwners),
            "InvalidUserGroupID" => Some(Self::InvalidUserGroupId),
            "InvalidAuthStrategyOwners" => Some(Self::InvalidAuthStrategyOwners),
            "InvalidAuthStrategyName" => Some(Self::InvalidAuthStrategyName),
            "InvalidAuthStrategyID" => Some(Self::InvalidAuthStrategyId),
            "InvalidPrincipalType" => Some(Self::InvalidPrincipalType),
            "UserExisted" => Some(Self::UserExisted),
            "UserGroupExisted" => Some(Self::UserGroupExisted),
            "AuthStrategyRuleExisted" => Some(Self::AuthStrategyRuleExisted),
            "SubAccountExisted" => Some(Self::SubAccountExisted),
            "NotFoundUser" => Some(Self::NotFoundUser),
            "NotFoundOwnerUser" => Some(Self::NotFoundOwnerUser),
            "NotFoundUserGroup" => Some(Self::NotFoundUserGroup),
            "NotFoundAuthStrategyRule" => Some(Self::NotFoundAuthStrategyRule),
            "NotAllowModifyDefaultStrategyPrincipal" => {
                Some(Self::NotAllowModifyDefaultStrategyPrincipal)
            }
            "NotAllowModifyOwnerDefaultStrategy" => {
                Some(Self::NotAllowModifyOwnerDefaultStrategy)
            }
            "EmptyAutToken" => Some(Self::EmptyAutToken),
            "TokenDisabled" => Some(Self::TokenDisabled),
            "TokenNotExisted" => Some(Self::TokenNotExisted),
            "AuthTokenForbidden" => Some(Self::AuthTokenForbidden),
            "OperationRoleForbidden" => Some(Self::OperationRoleForbidden),
            _ => None,
        }
    }
}
/// 同一服务下限流规则集合
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct RateLimit {
    /// 限流规则唯一标识
    #[prost(string, tag = "1")]
    pub id: ::prost::alloc::string::String,
    /// 限流规则名称
    #[prost(string, tag = "2")]
    pub name: ::prost::alloc::string::String,
    /// 限流规则所属服务名
    #[prost(string, tag = "3")]
    pub service: ::prost::alloc::string::String,
    /// 限流规则所属命名空间
    #[prost(string, tag = "4")]
    pub namespace: ::prost::alloc::string::String,
    /// 限流规则优先级，0值最高
    #[prost(uint32, tag = "5")]
    pub priority: u32,
    #[prost(enumeration = "rate_limit::Type", tag = "7")]
    pub r#type: i32,
    /// 限流规则集合
    #[prost(message, repeated, tag = "8")]
    pub rules: ::prost::alloc::vec::Vec<LimitTrigger>,
    /// 限流规则汇总的revision信息
    #[prost(string, tag = "9")]
    pub revision: ::prost::alloc::string::String,
    /// 是否停用该限流规则，默认启用
    #[prost(bool, tag = "11")]
    pub disable: bool,
    /// 限流上报方式，同时支持按固定周期上报，以及达到配额百分比后上报
    #[prost(message, optional, tag = "12")]
    pub report: ::core::option::Option<Report>,
    /// 分布式限流服务集群
    #[prost(message, optional, tag = "16")]
    pub cluster: ::core::option::Option<RateLimitCluster>,
    /// 限流规则创建时间
    #[prost(string, tag = "20")]
    pub ctime: ::prost::alloc::string::String,
    /// 限流规则修改时间
    #[prost(string, tag = "21")]
    pub mtime: ::prost::alloc::string::String,
    /// 限流规则标签数据
    #[prost(map = "string, string", tag = "22")]
    pub metadata: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    /// 操作标志位
    #[prost(bool, tag = "30")]
    pub editable: bool,
    #[prost(bool, tag = "31")]
    pub deleteable: bool,
}
/// Nested message and enum types in `RateLimit`.
pub mod rate_limit {
    /// 限流类型
    /// global全局限流(默认)或者local单机限流
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum Type {
        Global = 0,
        Local = 1,
    }
    impl Type {
        /// 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 {
                Self::Global => "GLOBAL",
                Self::Local => "LOCAL",
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "GLOBAL" => Some(Self::Global),
                "LOCAL" => Some(Self::Local),
                _ => None,
            }
        }
    }
}
/// 单个限流规则信息
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct LimitTrigger {
    /// 限流规则名
    #[prost(string, tag = "1")]
    pub name: ::prost::alloc::string::String,
    /// 被调接口名
    #[prost(message, optional, tag = "2")]
    pub method: ::core::option::Option<MatchString>,
    #[prost(enumeration = "limit_trigger::Resource", tag = "3")]
    pub resource: i32,
    /// 被调的参数过滤条件，满足过滤条件才进入限流规则
    #[prost(message, repeated, tag = "4")]
    pub arguments: ::prost::alloc::vec::Vec<MatchArgument>,
    /// 限流阈值
    /// 可以有多个粒度的配置（比如同时针对秒级，分钟级，天级），匹配一个则进行限流
    /// 全局限流模式下，该值为服务配额总量；单机限流模式下，该值为单个节点能处理的配额量
    #[prost(message, repeated, tag = "5")]
    pub amounts: ::prost::alloc::vec::Vec<Amount>,
    /// 最大排队时长，单位秒
    #[prost(uint32, tag = "6")]
    pub max_queue_delay: u32,
    /// amount for concurrency rate-limit
    #[prost(message, optional, tag = "7")]
    pub concurrency_amount: ::core::option::Option<ConcurrencyAmount>,
    /// fallback configuration
    #[prost(message, optional, tag = "8")]
    pub custom_response: ::core::option::Option<CustomResponse>,
    /// 通配符是否合并计算，默认分开计数
    #[prost(bool, tag = "9")]
    pub regex_combine: bool,
    #[prost(enumeration = "limit_trigger::FailoverType", tag = "10")]
    pub failover: i32,
    /// 限流动作，和 resource 配合决定插件名称
    #[prost(string, tag = "11")]
    pub action: ::prost::alloc::string::String,
    /// 是否停用该限流规则，默认启用
    #[prost(bool, tag = "12")]
    pub disable: bool,
    #[prost(enumeration = "limit_trigger::AmountMode", tag = "14")]
    pub amount_mode: i32,
}
/// Nested message and enum types in `LimitTrigger`.
pub mod limit_trigger {
    /// 限流资源
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum Resource {
        /// 针对QPS进行限流
        Qps = 0,
        /// 针对并发数进行限流
        Concurrency = 1,
        /// 针对系统资源进行限流
        System = 2,
    }
    impl Resource {
        /// 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 {
                Self::Qps => "QPS",
                Self::Concurrency => "CONCURRENCY",
                Self::System => "SYSTEM",
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "QPS" => Some(Self::Qps),
                "CONCURRENCY" => Some(Self::Concurrency),
                "SYSTEM" => Some(Self::System),
                _ => None,
            }
        }
    }
    /// 与限流集群连接失败时降级模式
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum FailoverType {
        /// 降级成本地阈值
        FailoverLocal = 0,
        /// 降级成直接通过
        FailoverPass = 1,
    }
    impl FailoverType {
        /// 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 {
                Self::FailoverLocal => "FAILOVER_LOCAL",
                Self::FailoverPass => "FAILOVER_PASS",
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "FAILOVER_LOCAL" => Some(Self::FailoverLocal),
                "FAILOVER_PASS" => Some(Self::FailoverPass),
                _ => None,
            }
        }
    }
    /// 限流阈值模
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum AmountMode {
        /// 总体阈值
        GlobalTotal = 0,
        /// 单机均摊阈值
        ShareEqually = 1,
    }
    impl AmountMode {
        /// 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 {
                Self::GlobalTotal => "GLOBAL_TOTAL",
                Self::ShareEqually => "SHARE_EQUALLY",
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "GLOBAL_TOTAL" => Some(Self::GlobalTotal),
                "SHARE_EQUALLY" => Some(Self::ShareEqually),
                _ => None,
            }
        }
    }
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct MatchArgument {
    #[prost(enumeration = "match_argument::Type", tag = "1")]
    pub r#type: i32,
    /// header key or query key
    #[prost(string, tag = "2")]
    pub key: ::prost::alloc::string::String,
    /// header value or query value
    #[prost(message, optional, tag = "3")]
    pub value: ::core::option::Option<MatchString>,
}
/// Nested message and enum types in `MatchArgument`.
pub mod match_argument {
    /// label type for gateway request
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum Type {
        /// custom arguments
        Custom = 0,
        /// method, match the http post/get/put/delete or grpc method
        Method = 1,
        /// header, match the http header, dubbo attachment, grpc header
        Header = 2,
        /// query, match the http query, dubbo argument
        Query = 3,
        /// caller service
        CallerService = 4,
        /// caller host ip
        CallerIp = 5,
        /// caller instance metadata
        CallerMetadata = 6,
    }
    impl Type {
        /// 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 {
                Self::Custom => "CUSTOM",
                Self::Method => "METHOD",
                Self::Header => "HEADER",
                Self::Query => "QUERY",
                Self::CallerService => "CALLER_SERVICE",
                Self::CallerIp => "CALLER_IP",
                Self::CallerMetadata => "CALLER_METADATA",
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "CUSTOM" => Some(Self::Custom),
                "METHOD" => Some(Self::Method),
                "HEADER" => Some(Self::Header),
                "QUERY" => Some(Self::Query),
                "CALLER_SERVICE" => Some(Self::CallerService),
                "CALLER_IP" => Some(Self::CallerIp),
                "CALLER_METADATA" => Some(Self::CallerMetadata),
                _ => None,
            }
        }
    }
}
/// concurrency rate-limit amount config
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct ConcurrencyAmount {
    #[prost(uint32, tag = "1")]
    pub max_amount: u32,
}
/// custom response text when limited
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CustomResponse {
    #[prost(string, tag = "1")]
    pub code: ::prost::alloc::string::String,
    #[prost(map = "string, string", tag = "2")]
    pub headers: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    #[prost(string, tag = "3")]
    pub body: ::prost::alloc::string::String,
}
/// 分布式限流服务集群
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct RateLimitCluster {
    #[prost(string, tag = "1")]
    pub service: ::prost::alloc::string::String,
    /// 限流规则所属命名空间
    #[prost(string, tag = "2")]
    pub namespace: ::prost::alloc::string::String,
}
/// 限流配额
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct Amount {
    /// 时间周期内的最大配额数
    #[prost(uint32, tag = "1")]
    pub max_amount: u32,
    /// 配额生效的时间周期，必须大于等于1s
    #[prost(message, optional, tag = "2")]
    pub valid_duration: ::core::option::Option<::prost_types::Duration>,
    /// 请求统计精度
    #[prost(uint32, tag = "3")]
    pub precision: u32,
    /// 可选，起始限流阈值，爬坡起始值
    #[prost(uint32, tag = "4")]
    pub start_amount: u32,
    /// 可选，最小限流阈值，降低时最小值
    #[prost(uint32, tag = "5")]
    pub min_amount: u32,
}
/// 限流上报方式
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct Report {
    /// 配额固定上报周期，单位毫秒
    #[prost(message, optional, tag = "1")]
    pub interval: ::core::option::Option<::prost_types::Duration>,
    /// 使用了百分之多少配额后启动一次实时上报，值范围(0,100\]
    #[prost(uint32, tag = "2")]
    pub amount_percent: u32,
}
/// configuration root for route
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct RouteRule {
    #[prost(string, tag = "1")]
    pub id: ::prost::alloc::string::String,
    /// route rule name
    #[prost(string, tag = "2")]
    pub name: ::prost::alloc::string::String,
    /// namespace namingspace of routing rules
    #[prost(string, tag = "3")]
    pub namespace: ::prost::alloc::string::String,
    /// Enable this router
    #[prost(bool, tag = "4")]
    pub enable: bool,
    /// Router type
    #[prost(enumeration = "RoutePolicy", tag = "5")]
    pub route_policy: i32,
    /// Routing configuration for router
    #[prost(message, optional, tag = "6")]
    pub routing_config: ::core::option::Option<::prost_types::Any>,
    /// revision routing version
    #[prost(string, tag = "7")]
    pub revision: ::prost::alloc::string::String,
    /// ctime create time of the rules
    #[prost(string, tag = "8")]
    pub ctime: ::prost::alloc::string::String,
    /// mtime modify time of the rules
    #[prost(string, tag = "9")]
    pub mtime: ::prost::alloc::string::String,
    /// etime enable time of the rules
    #[prost(string, tag = "10")]
    pub etime: ::prost::alloc::string::String,
    /// priority rules priority
    #[prost(uint32, tag = "11")]
    pub priority: u32,
    /// description simple description rules
    #[prost(string, tag = "12")]
    pub description: ::prost::alloc::string::String,
    /// 路由规则标签数据
    #[prost(map = "string, string", tag = "21")]
    pub metadata: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    /// 操作标志位
    #[prost(bool, tag = "30")]
    pub editable: bool,
    #[prost(bool, tag = "31")]
    pub deleteable: bool,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct MetadataFailover {
    /// failover_range metadata route bottom type
    #[prost(enumeration = "metadata_failover::FailoverRange", tag = "1")]
    pub failover_range: i32,
    /// only use to failover_range == OTHER_KEYS
    #[prost(map = "string, string", tag = "2")]
    pub labels: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
}
/// Nested message and enum types in `MetadataFailover`.
pub mod metadata_failover {
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum FailoverRange {
        /// ALL return all instances
        All = 0,
        /// OTHERS retuen without thie labels instances
        Others = 1,
        /// OTHER_KEYS return other instances which match keys
        OtherKeys = 2,
    }
    impl FailoverRange {
        /// 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 {
                Self::All => "ALL",
                Self::Others => "OTHERS",
                Self::OtherKeys => "OTHER_KEYS",
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "ALL" => Some(Self::All),
                "OTHERS" => Some(Self::Others),
                "OTHER_KEYS" => Some(Self::OtherKeys),
                _ => None,
            }
        }
    }
}
/// MetadataRoutingConfig metadata routing configuration
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct MetadataRoutingConfig {
    /// service
    #[prost(string, tag = "1")]
    pub service: ::prost::alloc::string::String,
    /// namespace
    #[prost(string, tag = "2")]
    pub namespace: ::prost::alloc::string::String,
    #[prost(map = "string, string", tag = "3")]
    pub labels: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    /// When metadata not found, it will fall back to the
    #[prost(message, optional, tag = "4")]
    pub failover: ::core::option::Option<MetadataFailover>,
}
/// NearbyRoutingConfig routing configuration
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct NearbyRoutingConfig {
    /// 被调服务名，支持\*，代表全部服务
    #[prost(string, tag = "1")]
    pub service: ::prost::alloc::string::String,
    /// 被调命名空间
    #[prost(string, tag = "2")]
    pub namespace: ::prost::alloc::string::String,
    /// 默认就近级别
    #[prost(enumeration = "nearby_routing_config::LocationLevel", tag = "3")]
    pub match_level: i32,
    /// 最大就近级别
    #[prost(enumeration = "nearby_routing_config::LocationLevel", tag = "4")]
    pub max_match_level: i32,
    /// 是否强制就近
    #[prost(bool, tag = "5")]
    pub strict_nearby: bool,
}
/// Nested message and enum types in `NearbyRoutingConfig`.
pub mod nearby_routing_config {
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum LocationLevel {
        /// 未知就近级别，等同于未定义级别
        Unknown = 0,
        /// 机房就近级别
        Campus = 1,
        /// 可用区就近级别
        Zone = 2,
        /// 地域就近级别
        Region = 3,
        /// 全局就近级别
        All = 4,
    }
    impl LocationLevel {
        /// 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 {
                Self::Unknown => "UNKNOWN",
                Self::Campus => "CAMPUS",
                Self::Zone => "ZONE",
                Self::Region => "REGION",
                Self::All => "ALL",
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "UNKNOWN" => Some(Self::Unknown),
                "CAMPUS" => Some(Self::Campus),
                "ZONE" => Some(Self::Zone),
                "REGION" => Some(Self::Region),
                "ALL" => Some(Self::All),
                _ => None,
            }
        }
    }
}
/// CustomRoute routing configuration
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CustomRoute {
    /// source source info
    /// deprecated_filed  only for compatible to the old version server
    #[prost(message, optional, tag = "1")]
    pub caller: ::core::option::Option<custom_route::ServiceKey>,
    /// destination destinations info
    /// deprecated_filed  only for compatible to the old version server
    #[prost(message, optional, tag = "2")]
    pub callee: ::core::option::Option<custom_route::ServiceKey>,
    /// rule route chain
    #[prost(message, repeated, tag = "3")]
    pub rules: ::prost::alloc::vec::Vec<CustomRouteRule>,
}
/// Nested message and enum types in `CustomRoute`.
pub mod custom_route {
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
    pub struct ServiceKey {
        /// service service name
        #[prost(string, tag = "1")]
        pub service: ::prost::alloc::string::String,
        /// namespace namespace of service
        #[prost(string, tag = "2")]
        pub namespace: ::prost::alloc::string::String,
    }
}
/// SubRuleRouting sub routing configuration
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CustomRouteRule {
    /// sub routing rule name
    #[prost(string, tag = "1")]
    pub name: ::prost::alloc::string::String,
    /// Master Control Service Example Tag or Request Label
    /// Value supports regular matching
    #[prost(message, optional, tag = "2")]
    pub arguments: ::core::option::Option<TrafficMatchRule>,
    /// destination destinations info
    #[prost(message, repeated, tag = "3")]
    pub destinations: ::prost::alloc::vec::Vec<DestinationGroup>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct SourceService {
    /// Main tuning service and namespace
    #[prost(string, tag = "1")]
    pub service: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub namespace: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct DestinationService {
    /// Main tuning service and namespace
    #[prost(string, tag = "1")]
    pub service: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub namespace: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DestinationGroup {
    /// Templated service and namespace
    #[prost(string, tag = "1")]
    pub service: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub namespace: ::prost::alloc::string::String,
    /// Templated service example label
    /// Value supports regular matching
    #[prost(map = "string, message", tag = "3")]
    pub labels: ::std::collections::HashMap<::prost::alloc::string::String, MatchString>,
    /// According to the service name and service instance Metadata Filter the
    /// qualified service instance subset Service instance subset can set priority
    /// and weight Priority: integer, range \[0, 9\], the highest priority is 0
    /// Weight: Integer
    /// Press priority routing, if there is high priority, low priority will not
    /// use If there is a subset of the same priority, then assign by weight
    /// Priority and weight can be not set / set up one / set two
    /// If the section is set priority, some are not set, it is considered that the
    /// priority is not set. If the part is set, some is not set, it is considered
    /// that the weight is not set to 0 If you have no weight, you think the weight
    /// is the same
    #[prost(uint32, tag = "4")]
    pub priority: u32,
    #[prost(uint32, tag = "5")]
    pub weight: u32,
    /// Forward requests to proxy service
    #[prost(string, tag = "6")]
    pub transfer: ::prost::alloc::string::String,
    /// Whether to isolate the SET, after isolation, no traffic will be allocated
    #[prost(bool, tag = "7")]
    pub isolate: bool,
    /// name desition name
    #[prost(string, tag = "8")]
    pub name: ::prost::alloc::string::String,
}
/// TrafficMatchRule 流量匹配规则
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TrafficMatchRule {
    /// 流量匹配规则，判断哪些流量需要进入泳道
    #[prost(message, repeated, tag = "1")]
    pub arguments: ::prost::alloc::vec::Vec<SourceMatch>,
    /// 随机百分比流量匹配, 1-100, 表示百分之几的流量会被匹配到, 默认值为 100
    #[prost(uint32, tag = "3")]
    pub random_percent: u32,
    #[prost(enumeration = "traffic_match_rule::TrafficMatchMode", tag = "4")]
    pub match_mode: i32,
}
/// Nested message and enum types in `TrafficMatchRule`.
pub mod traffic_match_rule {
    /// 多个 SourceMatch 之间的判断关系
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum TrafficMatchMode {
        /// 与模式
        And = 0,
        /// 或模式
        Or = 1,
    }
    impl TrafficMatchMode {
        /// 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 {
                Self::And => "AND",
                Self::Or => "OR",
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "AND" => Some(Self::And),
                "OR" => Some(Self::Or),
                _ => None,
            }
        }
    }
}
/// SourceMatch
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct SourceMatch {
    #[prost(enumeration = "source_match::Type", tag = "1")]
    pub r#type: i32,
    /// header key or query key
    #[prost(string, tag = "2")]
    pub key: ::prost::alloc::string::String,
    /// header value or query value
    #[prost(message, optional, tag = "3")]
    pub value: ::core::option::Option<MatchString>,
}
/// Nested message and enum types in `SourceMatch`.
pub mod source_match {
    /// label type for gateway request
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum Type {
        /// custom arguments
        Custom = 0,
        /// method, match the http post/get/put/delete or grpc method
        Method = 1,
        /// header, match the http header, dubbo attachment, grpc header
        Header = 2,
        /// query, match the http query, dubbo argument
        Query = 3,
        /// caller host ip
        CallerIp = 4,
        /// path, math the http url
        Path = 5,
        /// cookie match http cookie
        Cookie = 6,
        /// indicate the caller instance metadata
        CallerMetadata = 7,
    }
    impl Type {
        /// 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 {
                Self::Custom => "CUSTOM",
                Self::Method => "METHOD",
                Self::Header => "HEADER",
                Self::Query => "QUERY",
                Self::CallerIp => "CALLER_IP",
                Self::Path => "PATH",
                Self::Cookie => "COOKIE",
                Self::CallerMetadata => "CALLER_METADATA",
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "CUSTOM" => Some(Self::Custom),
                "METHOD" => Some(Self::Method),
                "HEADER" => Some(Self::Header),
                "QUERY" => Some(Self::Query),
                "CALLER_IP" => Some(Self::CallerIp),
                "PATH" => Some(Self::Path),
                "COOKIE" => Some(Self::Cookie),
                "CALLER_METADATA" => Some(Self::CallerMetadata),
                _ => None,
            }
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum RoutePolicy {
    /// Route by rule rule => RuleRoutingConfig
    RulePolicy = 0,
    /// Route by destination metadata ==> MetadataRoutingConfig
    MetadataPolicy = 1,
    /// Route by Nearby rule => NearByRoutingConfig
    NearbyPolicy = 2,
}
impl RoutePolicy {
    /// 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 {
            Self::RulePolicy => "RulePolicy",
            Self::MetadataPolicy => "MetadataPolicy",
            Self::NearbyPolicy => "NearbyPolicy",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "RulePolicy" => Some(Self::RulePolicy),
            "MetadataPolicy" => Some(Self::MetadataPolicy),
            "NearbyPolicy" => Some(Self::NearbyPolicy),
            _ => None,
        }
    }
}
/// 流量入口
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TrafficEntry {
    /// 标记流量入口类型
    /// type == "pole.io/gateway/spring-cloud-gateway", 则 selector 为
    /// ServiceGatewaySelector type == "pole.io/service, 则 selector 为
    /// ServiceSelector
    #[prost(string, tag = "1")]
    pub r#type: ::prost::alloc::string::String,
    #[prost(message, optional, tag = "2")]
    pub selector: ::core::option::Option<::prost_types::Any>,
}
/// 微服务网关入口定义
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ServiceGatewaySelector {
    #[prost(string, tag = "1")]
    pub namespace: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub service: ::prost::alloc::string::String,
    /// 决定要不要部份
    #[prost(map = "string, message", tag = "3")]
    pub labels: ::std::collections::HashMap<::prost::alloc::string::String, MatchString>,
}
/// 普通服务入口定义
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ServiceSelector {
    #[prost(string, tag = "1")]
    pub namespace: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub service: ::prost::alloc::string::String,
    /// 决定要不要部份
    #[prost(map = "string, message", tag = "3")]
    pub labels: ::std::collections::HashMap<::prost::alloc::string::String, MatchString>,
}
/// 泳道组实体定义
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct LaneGroup {
    /// 泳道组 ID
    #[prost(string, tag = "1")]
    pub id: ::prost::alloc::string::String,
    /// 泳道组名称
    #[prost(string, tag = "2")]
    pub name: ::prost::alloc::string::String,
    /// 泳道组内的流量入口信息
    #[prost(message, repeated, tag = "3")]
    pub entries: ::prost::alloc::vec::Vec<TrafficEntry>,
    /// 在泳道组内的服务列表信息
    #[prost(message, repeated, tag = "4")]
    pub destinations: ::prost::alloc::vec::Vec<DestinationGroup>,
    /// 泳道组描述信息
    #[prost(string, tag = "7")]
    pub revision: ::prost::alloc::string::String,
    /// 泳道组描述信息
    #[prost(string, tag = "8")]
    pub description: ::prost::alloc::string::String,
    /// 泳道组的创建时间
    #[prost(string, tag = "9")]
    pub ctime: ::prost::alloc::string::String,
    /// 泳道组的更新时间
    #[prost(string, tag = "10")]
    pub mtime: ::prost::alloc::string::String,
    /// 泳道组内的流量入口信息
    #[prost(message, repeated, tag = "11")]
    pub rules: ::prost::alloc::vec::Vec<LaneRule>,
    /// 泳道组标签信息
    #[prost(map = "string, string", tag = "12")]
    pub metadata: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    /// 操作标志位
    #[prost(bool, tag = "20")]
    pub editable: bool,
    #[prost(bool, tag = "21")]
    pub deleteable: bool,
}
/// 泳道规则
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct LaneRule {
    #[prost(string, tag = "1")]
    pub id: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub name: ::prost::alloc::string::String,
    /// 所属泳道组的名称
    #[prost(string, tag = "3")]
    pub group_name: ::prost::alloc::string::String,
    /// 流量匹配规则
    #[prost(message, optional, tag = "4")]
    pub traffic_match_rule: ::core::option::Option<TrafficMatchRule>,
    /// 保存这个泳道的默认实例标签
    #[prost(string, tag = "5")]
    pub default_label_value: ::prost::alloc::string::String,
    /// 泳道规则是否启用
    #[prost(bool, tag = "6")]
    pub enable: bool,
    #[prost(enumeration = "lane_rule::LaneMatchMode", tag = "7")]
    pub match_mode: i32,
    /// revision routing version
    #[prost(string, tag = "8")]
    pub revision: ::prost::alloc::string::String,
    /// ctime create time of the rules
    #[prost(string, tag = "9")]
    pub ctime: ::prost::alloc::string::String,
    /// mtime modify time of the rules
    #[prost(string, tag = "10")]
    pub mtime: ::prost::alloc::string::String,
    /// etime enable time of the rules
    #[prost(string, tag = "11")]
    pub etime: ::prost::alloc::string::String,
    /// priority rules priority
    #[prost(uint32, tag = "12")]
    pub priority: u32,
    /// description simple description rules
    #[prost(string, tag = "13")]
    pub description: ::prost::alloc::string::String,
    /// 属于该泳道的实例标签KEY，不填默认为lane
    #[prost(string, tag = "14")]
    pub label_key: ::prost::alloc::string::String,
}
/// Nested message and enum types in `LaneRule`.
pub mod lane_rule {
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum LaneMatchMode {
        /// 严格匹配模式
        Strict = 0,
        /// 宽松匹配模式
        Permissive = 1,
    }
    impl LaneMatchMode {
        /// 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 {
                Self::Strict => "STRICT",
                Self::Permissive => "PERMISSIVE",
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "STRICT" => Some(Self::Strict),
                "PERMISSIVE" => Some(Self::Permissive),
                _ => None,
            }
        }
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Client {
    /// client ip
    #[prost(string, tag = "1")]
    pub host: ::prost::alloc::string::String,
    /// client type
    #[prost(enumeration = "client::ClientType", tag = "2")]
    pub r#type: i32,
    /// client version
    #[prost(string, tag = "3")]
    pub version: ::prost::alloc::string::String,
    /// location 客户端地址位置
    #[prost(message, optional, tag = "4")]
    pub location: ::core::option::Option<Location>,
    /// client id
    #[prost(string, tag = "5")]
    pub id: ::prost::alloc::string::String,
    /// stat 监控数据上报信息
    #[prost(message, repeated, tag = "6")]
    pub stat: ::prost::alloc::vec::Vec<StatInfo>,
    /// creation time
    #[prost(string, tag = "7")]
    pub ctime: ::prost::alloc::string::String,
    /// modify time
    #[prost(string, tag = "8")]
    pub mtime: ::prost::alloc::string::String,
}
/// Nested message and enum types in `Client`.
pub mod client {
    /// client type
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum ClientType {
        Unknown = 0,
        Sdk = 1,
        Agent = 2,
    }
    impl ClientType {
        /// 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 {
                Self::Unknown => "UNKNOWN",
                Self::Sdk => "SDK",
                Self::Agent => "AGENT",
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "UNKNOWN" => Some(Self::Unknown),
                "SDK" => Some(Self::Sdk),
                "AGENT" => Some(Self::Agent),
                _ => None,
            }
        }
    }
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct StatInfo {
    /// target ip
    #[prost(string, tag = "1")]
    pub target: ::prost::alloc::string::String,
    /// target port
    #[prost(uint32, tag = "2")]
    pub port: u32,
    /// api path
    #[prost(string, tag = "3")]
    pub path: ::prost::alloc::string::String,
    /// metrics protocol
    #[prost(string, tag = "4")]
    pub protocol: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct LoginRequest {
    #[prost(string, tag = "1")]
    pub owner: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub name: ::prost::alloc::string::String,
    #[prost(string, tag = "3")]
    pub password: ::prost::alloc::string::String,
    #[prost(map = "string, string", tag = "4")]
    pub options: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct LoginResponse {
    #[prost(string, tag = "1")]
    pub user_id: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub name: ::prost::alloc::string::String,
    #[prost(string, tag = "3")]
    pub role: ::prost::alloc::string::String,
    #[prost(string, tag = "4")]
    pub owner_id: ::prost::alloc::string::String,
    #[prost(string, tag = "5")]
    pub token: ::prost::alloc::string::String,
    #[prost(map = "string, string", tag = "6")]
    pub options: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct User {
    #[prost(string, tag = "1")]
    pub id: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub name: ::prost::alloc::string::String,
    #[prost(string, tag = "3")]
    pub password: ::prost::alloc::string::String,
    #[prost(string, tag = "4")]
    pub owner: ::prost::alloc::string::String,
    #[prost(string, tag = "5")]
    pub source: ::prost::alloc::string::String,
    #[prost(string, tag = "6")]
    pub auth_token: ::prost::alloc::string::String,
    #[prost(bool, tag = "7")]
    pub token_enable: bool,
    #[prost(string, tag = "8")]
    pub comment: ::prost::alloc::string::String,
    #[prost(string, tag = "9")]
    pub ctime: ::prost::alloc::string::String,
    #[prost(string, tag = "10")]
    pub mtime: ::prost::alloc::string::String,
    #[prost(string, tag = "11")]
    pub user_type: ::prost::alloc::string::String,
    #[prost(string, tag = "12")]
    pub mobile: ::prost::alloc::string::String,
    #[prost(string, tag = "13")]
    pub email: ::prost::alloc::string::String,
    #[prost(map = "string, string", tag = "14")]
    pub metadata: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct ModifyUserPassword {
    #[prost(string, tag = "1")]
    pub id: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub old_password: ::prost::alloc::string::String,
    #[prost(string, tag = "3")]
    pub new_password: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UserGroupRelation {
    #[prost(string, tag = "1")]
    pub group_id: ::prost::alloc::string::String,
    #[prost(message, repeated, tag = "2")]
    pub users: ::prost::alloc::vec::Vec<User>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UserGroup {
    #[prost(string, tag = "1")]
    pub id: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub name: ::prost::alloc::string::String,
    #[prost(string, tag = "3")]
    pub owner: ::prost::alloc::string::String,
    #[prost(string, tag = "4")]
    pub auth_token: ::prost::alloc::string::String,
    #[prost(bool, tag = "5")]
    pub token_enable: bool,
    #[prost(string, tag = "6")]
    pub comment: ::prost::alloc::string::String,
    #[prost(string, tag = "7")]
    pub ctime: ::prost::alloc::string::String,
    #[prost(string, tag = "8")]
    pub mtime: ::prost::alloc::string::String,
    #[prost(message, optional, tag = "9")]
    pub relation: ::core::option::Option<UserGroupRelation>,
    #[prost(uint32, tag = "10")]
    pub user_count: u32,
    #[prost(string, tag = "11")]
    pub source: ::prost::alloc::string::String,
    #[prost(map = "string, string", tag = "12")]
    pub metadata: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ModifyUserGroup {
    #[prost(string, tag = "1")]
    pub id: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub owner: ::prost::alloc::string::String,
    #[prost(string, tag = "3")]
    pub name: ::prost::alloc::string::String,
    #[prost(string, tag = "4")]
    pub auth_token: ::prost::alloc::string::String,
    #[prost(bool, tag = "5")]
    pub token_enable: bool,
    #[prost(string, tag = "6")]
    pub comment: ::prost::alloc::string::String,
    #[prost(message, optional, tag = "7")]
    pub add_relations: ::core::option::Option<UserGroupRelation>,
    #[prost(message, optional, tag = "8")]
    pub remove_relations: ::core::option::Option<UserGroupRelation>,
    #[prost(map = "string, string", tag = "9")]
    pub metadata: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    #[prost(string, tag = "10")]
    pub source: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Role {
    #[prost(string, tag = "1")]
    pub id: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub name: ::prost::alloc::string::String,
    #[prost(string, tag = "4")]
    pub owner: ::prost::alloc::string::String,
    #[prost(string, tag = "5")]
    pub source: ::prost::alloc::string::String,
    #[prost(bool, tag = "6")]
    pub default_role: bool,
    #[prost(map = "string, string", tag = "7")]
    pub metadata: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    #[prost(string, tag = "8")]
    pub comment: ::prost::alloc::string::String,
    #[prost(string, tag = "9")]
    pub ctime: ::prost::alloc::string::String,
    #[prost(string, tag = "10")]
    pub mtime: ::prost::alloc::string::String,
    #[prost(message, repeated, tag = "20")]
    pub users: ::prost::alloc::vec::Vec<User>,
    #[prost(message, repeated, tag = "21")]
    pub user_groups: ::prost::alloc::vec::Vec<UserGroup>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct Principal {
    #[prost(string, tag = "1")]
    pub id: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub name: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Principals {
    #[prost(message, repeated, tag = "1")]
    pub users: ::prost::alloc::vec::Vec<Principal>,
    #[prost(message, repeated, tag = "2")]
    pub groups: ::prost::alloc::vec::Vec<Principal>,
    #[prost(message, repeated, tag = "3")]
    pub roles: ::prost::alloc::vec::Vec<Principal>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct StrategyResourceEntry {
    #[prost(string, tag = "1")]
    pub id: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub namespace: ::prost::alloc::string::String,
    #[prost(string, tag = "3")]
    pub name: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct StrategyResources {
    #[prost(string, tag = "1")]
    pub strategy_id: ::prost::alloc::string::String,
    #[prost(message, repeated, tag = "2")]
    pub namespaces: ::prost::alloc::vec::Vec<StrategyResourceEntry>,
    #[prost(message, repeated, tag = "3")]
    pub services: ::prost::alloc::vec::Vec<StrategyResourceEntry>,
    #[prost(message, repeated, tag = "4")]
    pub config_groups: ::prost::alloc::vec::Vec<StrategyResourceEntry>,
    #[prost(message, repeated, tag = "5")]
    pub route_rules: ::prost::alloc::vec::Vec<StrategyResourceEntry>,
    #[prost(message, repeated, tag = "6")]
    pub ratelimit_rules: ::prost::alloc::vec::Vec<StrategyResourceEntry>,
    #[prost(message, repeated, tag = "7")]
    pub circuitbreaker_rules: ::prost::alloc::vec::Vec<StrategyResourceEntry>,
    #[prost(message, repeated, tag = "8")]
    pub faultdetect_rules: ::prost::alloc::vec::Vec<StrategyResourceEntry>,
    #[prost(message, repeated, tag = "9")]
    pub lane_rules: ::prost::alloc::vec::Vec<StrategyResourceEntry>,
    #[prost(message, repeated, tag = "10")]
    pub lossless_rules: ::prost::alloc::vec::Vec<StrategyResourceEntry>,
    #[prost(message, repeated, tag = "11")]
    pub mirror_rules: ::prost::alloc::vec::Vec<StrategyResourceEntry>,
    #[prost(message, repeated, tag = "12")]
    pub security_rules: ::prost::alloc::vec::Vec<StrategyResourceEntry>,
    #[prost(message, repeated, tag = "21")]
    pub users: ::prost::alloc::vec::Vec<StrategyResourceEntry>,
    #[prost(message, repeated, tag = "22")]
    pub user_groups: ::prost::alloc::vec::Vec<StrategyResourceEntry>,
    #[prost(message, repeated, tag = "23")]
    pub roles: ::prost::alloc::vec::Vec<StrategyResourceEntry>,
    #[prost(message, repeated, tag = "24")]
    pub auth_policies: ::prost::alloc::vec::Vec<StrategyResourceEntry>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct StrategyResourceLabel {
    #[prost(string, tag = "1")]
    pub key: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub value: ::prost::alloc::string::String,
    #[prost(string, tag = "3")]
    pub compare_type: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AuthStrategy {
    #[prost(string, tag = "1")]
    pub id: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub name: ::prost::alloc::string::String,
    #[prost(message, optional, tag = "3")]
    pub principals: ::core::option::Option<Principals>,
    #[prost(message, optional, tag = "4")]
    pub resources: ::core::option::Option<StrategyResources>,
    #[prost(enumeration = "AuthAction", tag = "5")]
    pub action: i32,
    #[prost(string, tag = "6")]
    pub comment: ::prost::alloc::string::String,
    #[prost(string, tag = "7")]
    pub owner: ::prost::alloc::string::String,
    #[prost(string, tag = "8")]
    pub ctime: ::prost::alloc::string::String,
    #[prost(string, tag = "9")]
    pub mtime: ::prost::alloc::string::String,
    #[prost(string, tag = "10")]
    pub auth_token: ::prost::alloc::string::String,
    #[prost(bool, tag = "11")]
    pub default_strategy: bool,
    #[prost(map = "string, string", tag = "12")]
    pub metadata: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    #[prost(string, tag = "13")]
    pub source: ::prost::alloc::string::String,
    #[prost(string, repeated, tag = "14")]
    pub functions: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    #[prost(message, repeated, tag = "15")]
    pub resource_labels: ::prost::alloc::vec::Vec<StrategyResourceLabel>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ModifyAuthStrategy {
    #[prost(string, tag = "1")]
    pub id: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub name: ::prost::alloc::string::String,
    #[prost(message, optional, tag = "3")]
    pub add_principals: ::core::option::Option<Principals>,
    #[prost(message, optional, tag = "4")]
    pub remove_principals: ::core::option::Option<Principals>,
    #[prost(message, optional, tag = "5")]
    pub add_resources: ::core::option::Option<StrategyResources>,
    #[prost(message, optional, tag = "6")]
    pub remove_resources: ::core::option::Option<StrategyResources>,
    #[prost(enumeration = "AuthAction", tag = "7")]
    pub action: i32,
    #[prost(string, tag = "8")]
    pub comment: ::prost::alloc::string::String,
    #[prost(string, tag = "9")]
    pub owner: ::prost::alloc::string::String,
    #[prost(map = "string, string", tag = "12")]
    pub metadata: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    #[prost(string, tag = "13")]
    pub source: ::prost::alloc::string::String,
    #[prost(string, repeated, tag = "14")]
    pub functions: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    #[prost(message, repeated, tag = "15")]
    pub resource_labels: ::prost::alloc::vec::Vec<StrategyResourceLabel>,
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum AuthAction {
    /// deprecated_filed 该字段从未使用过
    OnlyRead = 0,
    /// deprecated_filed 使用 ALLOW 进行替代
    ReadWrite = 1,
    Allow = 10,
    Deny = 11,
}
impl AuthAction {
    /// 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 {
            Self::OnlyRead => "ONLY_READ",
            Self::ReadWrite => "READ_WRITE",
            Self::Allow => "ALLOW",
            Self::Deny => "DENY",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "ONLY_READ" => Some(Self::OnlyRead),
            "READ_WRITE" => Some(Self::ReadWrite),
            "ALLOW" => Some(Self::Allow),
            "DENY" => Some(Self::Deny),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum ResourceType {
    Namespaces = 0,
    Services = 1,
    ConfigGroups = 2,
    RouteRules = 3,
    RateLimitRules = 4,
    CircuitBreakerRules = 5,
    FaultDetectRules = 6,
    LaneRules = 7,
    LosslessRules = 8,
    MirrorRules = 9,
    SecurityRules = 10,
    Users = 20,
    UserGroups = 21,
    Roles = 22,
    PolicyRules = 23,
}
impl ResourceType {
    /// 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 {
            Self::Namespaces => "Namespaces",
            Self::Services => "Services",
            Self::ConfigGroups => "ConfigGroups",
            Self::RouteRules => "RouteRules",
            Self::RateLimitRules => "RateLimitRules",
            Self::CircuitBreakerRules => "CircuitBreakerRules",
            Self::FaultDetectRules => "FaultDetectRules",
            Self::LaneRules => "LaneRules",
            Self::LosslessRules => "LosslessRules",
            Self::MirrorRules => "MirrorRules",
            Self::SecurityRules => "SecurityRules",
            Self::Users => "Users",
            Self::UserGroups => "UserGroups",
            Self::Roles => "Roles",
            Self::PolicyRules => "PolicyRules",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "Namespaces" => Some(Self::Namespaces),
            "Services" => Some(Self::Services),
            "ConfigGroups" => Some(Self::ConfigGroups),
            "RouteRules" => Some(Self::RouteRules),
            "RateLimitRules" => Some(Self::RateLimitRules),
            "CircuitBreakerRules" => Some(Self::CircuitBreakerRules),
            "FaultDetectRules" => Some(Self::FaultDetectRules),
            "LaneRules" => Some(Self::LaneRules),
            "LosslessRules" => Some(Self::LosslessRules),
            "MirrorRules" => Some(Self::MirrorRules),
            "SecurityRules" => Some(Self::SecurityRules),
            "Users" => Some(Self::Users),
            "UserGroups" => Some(Self::UserGroups),
            "Roles" => Some(Self::Roles),
            "PolicyRules" => Some(Self::PolicyRules),
            _ => None,
        }
    }
}
/// 流量镜像规则
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TrafficMirror {
    #[prost(string, tag = "1")]
    pub id: ::prost::alloc::string::String,
    /// 流量镜像规则名称
    #[prost(string, tag = "2")]
    pub name: ::prost::alloc::string::String,
    /// 流量镜像规则描述
    #[prost(string, tag = "3")]
    pub description: ::prost::alloc::string::String,
    /// 流量镜像规则集合
    #[prost(message, repeated, tag = "4")]
    pub rules: ::prost::alloc::vec::Vec<MirrorRule>,
    /// 流量镜像规则revision信息
    #[prost(string, tag = "8")]
    pub revision: ::prost::alloc::string::String,
    /// 创建时间
    #[prost(string, tag = "20")]
    pub ctime: ::prost::alloc::string::String,
    /// 修改时间
    #[prost(string, tag = "21")]
    pub mtime: ::prost::alloc::string::String,
    /// 规则资源元数据
    #[prost(map = "string, string", tag = "30")]
    pub metadata: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    /// 操作标志位
    #[prost(bool, tag = "40")]
    pub editable: bool,
    #[prost(bool, tag = "41")]
    pub deleteable: bool,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct MirrorRule {
    /// 源服务
    #[prost(message, optional, tag = "1")]
    pub source: ::core::option::Option<MirrorSource>,
    /// 目标服务
    #[prost(message, optional, tag = "2")]
    pub destination: ::core::option::Option<MirrorDestination>,
    /// 流量镜像百分比，0-100
    #[prost(uint32, tag = "3")]
    pub mirror_percent: u32,
    /// 流量镜像持续时间，默认无限制
    #[prost(message, optional, tag = "4")]
    pub duration: ::core::option::Option<::prost_types::Duration>,
    /// 子规则是否禁用，默认启用
    #[prost(bool, tag = "5")]
    pub disable: bool,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct MirrorSource {
    /// 源服务所在的命名空间
    #[prost(string, tag = "1")]
    pub namespace: ::prost::alloc::string::String,
    /// 源服务名称
    #[prost(string, tag = "2")]
    pub service: ::prost::alloc::string::String,
    /// 流量匹配规则
    #[prost(message, optional, tag = "3")]
    pub traffic_match_rule: ::core::option::Option<TrafficMatchRule>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct MirrorDestination {
    /// 目标服务所在的命名空间
    #[prost(string, tag = "1")]
    pub namespace: ::prost::alloc::string::String,
    /// 目标服务名称
    #[prost(string, tag = "2")]
    pub service: ::prost::alloc::string::String,
    /// 目标服务实例标签选择器
    #[prost(map = "string, message", tag = "3")]
    pub labels: ::std::collections::HashMap<::prost::alloc::string::String, MatchString>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BlockAllowListRule {
    /// unique rule id
    #[prost(string, tag = "1")]
    pub id: ::prost::alloc::string::String,
    /// unique rule name
    #[prost(string, tag = "2")]
    pub name: ::prost::alloc::string::String,
    /// service namespace
    #[prost(string, tag = "4")]
    pub namespace: ::prost::alloc::string::String,
    /// service name
    #[prost(string, tag = "5")]
    pub service: ::prost::alloc::string::String,
    /// rule description
    #[prost(string, tag = "6")]
    pub description: ::prost::alloc::string::String,
    /// rule priority
    #[prost(uint32, tag = "7")]
    pub priority: u32,
    /// block or allow configuration
    #[prost(message, repeated, tag = "12")]
    pub block_allow_config: ::prost::alloc::vec::Vec<BlockAllowConfig>,
    /// ctime create time of the rules
    #[prost(string, tag = "20")]
    pub ctime: ::prost::alloc::string::String,
    /// mtime modify time of the rules
    #[prost(string, tag = "21")]
    pub mtime: ::prost::alloc::string::String,
    /// metadata for block allow list rules
    #[prost(map = "string, string", tag = "30")]
    pub metadata: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    /// rule revision
    #[prost(string, tag = "31")]
    pub revision: ::prost::alloc::string::String,
    /// 规则的权限操作状态
    #[prost(bool, tag = "40")]
    pub editable: bool,
    #[prost(bool, tag = "41")]
    pub deleteable: bool,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BlockAllowConfig {
    /// blocking target api
    #[prost(message, optional, tag = "1")]
    pub api: ::core::option::Option<Api>,
    /// traffic match rule
    #[prost(message, optional, tag = "2")]
    pub traffic_match_rule: ::core::option::Option<TrafficMatchRule>,
    /// block or allow as policy
    #[prost(enumeration = "block_allow_config::BlockAllowPolicy", tag = "3")]
    pub block_allow_policy: i32,
}
/// Nested message and enum types in `BlockAllowConfig`.
pub mod block_allow_config {
    /// block or allow as policy
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum BlockAllowPolicy {
        AllowList = 0,
        BlockList = 1,
    }
    impl BlockAllowPolicy {
        /// 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 {
                Self::AllowList => "ALLOW_LIST",
                Self::BlockList => "BLOCK_LIST",
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "ALLOW_LIST" => Some(Self::AllowList),
                "BLOCK_LIST" => Some(Self::BlockList),
                _ => None,
            }
        }
    }
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct SimpleService {
    #[prost(string, tag = "2")]
    pub name: ::prost::alloc::string::String,
    #[prost(string, tag = "3")]
    pub namespace: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Service {
    #[prost(string, tag = "1")]
    pub id: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub name: ::prost::alloc::string::String,
    #[prost(string, tag = "3")]
    pub namespace: ::prost::alloc::string::String,
    #[prost(map = "string, string", tag = "4")]
    pub metadata: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    #[prost(string, tag = "5")]
    pub ports: ::prost::alloc::string::String,
    #[prost(string, tag = "6")]
    pub business: ::prost::alloc::string::String,
    #[prost(string, tag = "7")]
    pub department: ::prost::alloc::string::String,
    #[prost(string, tag = "8")]
    pub cmdb_mod1: ::prost::alloc::string::String,
    #[prost(string, tag = "9")]
    pub cmdb_mod2: ::prost::alloc::string::String,
    #[prost(string, tag = "10")]
    pub cmdb_mod3: ::prost::alloc::string::String,
    #[prost(string, tag = "11")]
    pub comment: ::prost::alloc::string::String,
    #[prost(string, tag = "12")]
    pub owners: ::prost::alloc::string::String,
    #[prost(string, tag = "13")]
    pub token: ::prost::alloc::string::String,
    #[prost(string, tag = "14")]
    pub ctime: ::prost::alloc::string::String,
    #[prost(string, tag = "15")]
    pub mtime: ::prost::alloc::string::String,
    #[prost(string, tag = "16")]
    pub revision: ::prost::alloc::string::String,
    #[prost(string, repeated, tag = "17")]
    pub export_to: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    #[prost(uint32, tag = "30")]
    pub total_instance_count: u32,
    #[prost(uint32, tag = "31")]
    pub healthy_instance_count: u32,
    #[prost(bool, tag = "40")]
    pub editable: bool,
    #[prost(bool, tag = "41")]
    pub deleteable: bool,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct ServiceAlias {
    #[prost(string, tag = "1")]
    pub service: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub namespace: ::prost::alloc::string::String,
    #[prost(string, tag = "3")]
    pub alias: ::prost::alloc::string::String,
    #[prost(string, tag = "4")]
    pub alias_namespace: ::prost::alloc::string::String,
    #[prost(enumeration = "AliasType", tag = "5")]
    pub r#type: i32,
    #[prost(string, tag = "6")]
    pub owners: ::prost::alloc::string::String,
    #[prost(string, tag = "7")]
    pub comment: ::prost::alloc::string::String,
    #[prost(string, tag = "8")]
    pub service_token: ::prost::alloc::string::String,
    #[prost(string, tag = "9")]
    pub ctime: ::prost::alloc::string::String,
    #[prost(string, tag = "10")]
    pub mtime: ::prost::alloc::string::String,
    #[prost(string, tag = "11")]
    pub id: ::prost::alloc::string::String,
    #[prost(bool, tag = "12")]
    pub editable: bool,
    #[prost(bool, tag = "13")]
    pub deleteable: bool,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Instance {
    #[prost(string, tag = "1")]
    pub id: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub service: ::prost::alloc::string::String,
    #[prost(string, tag = "3")]
    pub namespace: ::prost::alloc::string::String,
    #[prost(string, tag = "4")]
    pub host: ::prost::alloc::string::String,
    #[prost(uint32, tag = "5")]
    pub port: u32,
    #[prost(string, tag = "6")]
    pub protocol: ::prost::alloc::string::String,
    #[prost(string, tag = "7")]
    pub version: ::prost::alloc::string::String,
    #[prost(uint32, tag = "8")]
    pub priority: u32,
    #[prost(uint32, tag = "9")]
    pub weight: u32,
    #[prost(bool, tag = "20")]
    pub enable_health_check: bool,
    #[prost(message, optional, tag = "10")]
    pub health_check: ::core::option::Option<HealthCheck>,
    #[prost(bool, tag = "11")]
    pub healthy: bool,
    #[prost(bool, tag = "12")]
    pub isolate: bool,
    #[prost(message, optional, tag = "13")]
    pub location: ::core::option::Option<Location>,
    #[prost(map = "string, string", tag = "14")]
    pub metadata: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    #[prost(string, tag = "16")]
    pub ctime: ::prost::alloc::string::String,
    #[prost(string, tag = "17")]
    pub mtime: ::prost::alloc::string::String,
    #[prost(string, tag = "18")]
    pub revision: ::prost::alloc::string::String,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct HealthCheck {
    #[prost(enumeration = "health_check::HealthCheckType", tag = "1")]
    pub r#type: i32,
    #[prost(message, optional, tag = "2")]
    pub heartbeat: ::core::option::Option<HeartbeatHealthCheck>,
}
/// Nested message and enum types in `HealthCheck`.
pub mod health_check {
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum HealthCheckType {
        Unknown = 0,
        Heartbeat = 1,
    }
    impl HealthCheckType {
        /// 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 {
                Self::Unknown => "UNKNOWN",
                Self::Heartbeat => "HEARTBEAT",
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "UNKNOWN" => Some(Self::Unknown),
                "HEARTBEAT" => Some(Self::Heartbeat),
                _ => None,
            }
        }
    }
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct HeartbeatHealthCheck {
    #[prost(uint32, tag = "1")]
    pub ttl: u32,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct InstanceLabels {
    #[prost(string, tag = "2")]
    pub namespace: ::prost::alloc::string::String,
    #[prost(string, tag = "3")]
    pub service: ::prost::alloc::string::String,
    #[prost(string, tag = "4")]
    pub service_id: ::prost::alloc::string::String,
    #[prost(map = "string, message", tag = "1")]
    pub labels: ::std::collections::HashMap<::prost::alloc::string::String, StringList>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct ServiceSubscriber {}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum AliasType {
    Default = 0,
    Cl5sid = 1,
}
impl AliasType {
    /// 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 {
            Self::Default => "DEFAULT",
            Self::Cl5sid => "CL5SID",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "DEFAULT" => Some(Self::Default),
            "CL5SID" => Some(Self::Cl5sid),
            _ => None,
        }
    }
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct HeartbeatRecord {
    #[prost(string, tag = "1")]
    pub instance_id: ::prost::alloc::string::String,
    #[prost(int64, tag = "6")]
    pub last_heartbeat_sec: i64,
    #[prost(bool, tag = "7")]
    pub exist: bool,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct InstanceHeartbeat {
    #[prost(string, tag = "1")]
    pub instance_id: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub service: ::prost::alloc::string::String,
    #[prost(string, tag = "3")]
    pub namespace: ::prost::alloc::string::String,
    #[prost(string, tag = "4")]
    pub host: ::prost::alloc::string::String,
    #[prost(uint32, tag = "5")]
    pub port: u32,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct HeartbeatsRequest {
    #[prost(message, repeated, tag = "1")]
    pub heartbeats: ::prost::alloc::vec::Vec<InstanceHeartbeat>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct HeartbeatsResponse {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct GetHeartbeatsRequest {
    #[prost(string, repeated, tag = "1")]
    pub instance_ids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetHeartbeatsResponse {
    #[prost(message, repeated, tag = "1")]
    pub records: ::prost::alloc::vec::Vec<HeartbeatRecord>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct DelHeartbeatsRequest {
    #[prost(string, repeated, tag = "1")]
    pub instance_ids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct DelHeartbeatsResponse {
    #[prost(uint32, tag = "1")]
    pub code: u32,
    #[prost(string, tag = "2")]
    pub info: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ServiceContract {
    /// 契约ID
    #[prost(string, tag = "1")]
    pub id: ::prost::alloc::string::String,
    /// 契约名称
    /// deprecated, use type field
    #[prost(string, tag = "2")]
    pub name: ::prost::alloc::string::String,
    /// 所属命名空间
    #[prost(string, tag = "3")]
    pub namespace: ::prost::alloc::string::String,
    /// 所属服务名称
    #[prost(string, tag = "4")]
    pub service: ::prost::alloc::string::String,
    /// 协议，http/grpc/dubbo/thrift
    #[prost(string, tag = "5")]
    pub protocol: ::prost::alloc::string::String,
    /// 契约版本
    #[prost(string, tag = "6")]
    pub version: ::prost::alloc::string::String,
    /// 信息摘要
    #[prost(string, tag = "7")]
    pub revision: ::prost::alloc::string::String,
    /// 额外描述
    #[prost(string, tag = "8")]
    pub content: ::prost::alloc::string::String,
    /// 接口描述信息
    #[prost(message, repeated, tag = "9")]
    pub interfaces: ::prost::alloc::vec::Vec<InterfaceDescriptor>,
    /// 创建时间
    #[prost(string, tag = "10")]
    pub ctime: ::prost::alloc::string::String,
    /// 更新时间
    #[prost(string, tag = "11")]
    pub mtime: ::prost::alloc::string::String,
    /// 接口状态，Offline/Online
    #[prost(string, tag = "12")]
    pub status: ::prost::alloc::string::String,
    /// 类型
    #[prost(string, tag = "14")]
    pub r#type: ::prost::alloc::string::String,
    /// 标签
    #[prost(map = "string, string", tag = "15")]
    pub metadata: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    /// 内容摘要
    #[prost(string, tag = "16")]
    pub content_digest: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct InterfaceDescriptor {
    /// 接口ID
    #[prost(string, tag = "1")]
    pub id: ::prost::alloc::string::String,
    /// 方法名称，对应 http method/ dubbo interface func/grpc service func
    #[prost(string, tag = "2")]
    pub method: ::prost::alloc::string::String,
    /// 接口名称，http path/dubbo interface/grpc service
    #[prost(string, tag = "3")]
    pub path: ::prost::alloc::string::String,
    /// 接口描述信息
    #[prost(string, tag = "4")]
    pub content: ::prost::alloc::string::String,
    /// 创建来源
    #[prost(enumeration = "interface_descriptor::Source", tag = "5")]
    pub source: i32,
    /// 接口信息摘要
    #[prost(string, tag = "6")]
    pub revision: ::prost::alloc::string::String,
    /// 创建时间
    #[prost(string, tag = "7")]
    pub ctime: ::prost::alloc::string::String,
    /// 更新时间
    #[prost(string, tag = "8")]
    pub mtime: ::prost::alloc::string::String,
    /// 接口名称描述信息
    /// deprecated, use type field
    #[prost(string, tag = "9")]
    pub name: ::prost::alloc::string::String,
    /// 所属命名空间
    #[prost(string, tag = "10")]
    pub namespace: ::prost::alloc::string::String,
    /// 所属服务名称
    #[prost(string, tag = "11")]
    pub service: ::prost::alloc::string::String,
    /// 协议，http/grpc/dubbo/thrift
    #[prost(string, tag = "12")]
    pub protocol: ::prost::alloc::string::String,
    /// 契约版本
    #[prost(string, tag = "13")]
    pub version: ::prost::alloc::string::String,
    /// 类型
    #[prost(string, tag = "14")]
    pub r#type: ::prost::alloc::string::String,
    /// 内容摘要
    #[prost(string, tag = "15")]
    pub content_digest: ::prost::alloc::string::String,
}
/// Nested message and enum types in `InterfaceDescriptor`.
pub mod interface_descriptor {
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum Source {
        Unknown = 0,
        Manual = 1,
        Client = 2,
    }
    impl Source {
        /// 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 {
                Self::Unknown => "UNKNOWN",
                Self::Manual => "Manual",
                Self::Client => "Client",
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "UNKNOWN" => Some(Self::Unknown),
                "Manual" => Some(Self::Manual),
                "Client" => Some(Self::Client),
                _ => None,
            }
        }
    }
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct RuleMatcher {
    #[prost(message, optional, tag = "1")]
    pub source: ::core::option::Option<rule_matcher::SourceService>,
    #[prost(message, optional, tag = "2")]
    pub destination: ::core::option::Option<rule_matcher::DestinationService>,
}
/// Nested message and enum types in `RuleMatcher`.
pub mod rule_matcher {
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
    pub struct SourceService {
        #[prost(string, tag = "1")]
        pub service: ::prost::alloc::string::String,
        #[prost(string, tag = "2")]
        pub namespace: ::prost::alloc::string::String,
    }
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
    pub struct DestinationService {
        #[prost(string, tag = "1")]
        pub service: ::prost::alloc::string::String,
        #[prost(string, tag = "2")]
        pub namespace: ::prost::alloc::string::String,
        /// deprecated_filed  using api.path in blockConfig instead
        #[deprecated]
        #[prost(message, optional, tag = "3")]
        pub method: ::core::option::Option<super::MatchString>,
    }
}
/// new specific rule for circuitbreaker config
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CircuitBreakerRule {
    #[prost(string, tag = "1")]
    pub id: ::prost::alloc::string::String,
    /// rule name
    #[prost(string, tag = "2")]
    pub name: ::prost::alloc::string::String,
    /// namespace of rule
    #[prost(string, tag = "3")]
    pub namespace: ::prost::alloc::string::String,
    /// enable this router
    #[prost(bool, tag = "4")]
    pub enable: bool,
    /// revision routing version
    #[prost(string, tag = "5")]
    pub revision: ::prost::alloc::string::String,
    /// ctime create time of the rules
    #[prost(string, tag = "6")]
    pub ctime: ::prost::alloc::string::String,
    /// mtime modify time of the rules
    #[prost(string, tag = "7")]
    pub mtime: ::prost::alloc::string::String,
    /// etime enable time of the rules
    #[prost(string, tag = "8")]
    pub etime: ::prost::alloc::string::String,
    /// description simple description rules
    #[prost(string, tag = "9")]
    pub description: ::prost::alloc::string::String,
    /// the circuitbreaking level
    #[prost(enumeration = "Level", tag = "21")]
    pub level: i32,
    /// match condition for this rule
    #[prost(message, optional, tag = "22")]
    pub rule_matcher: ::core::option::Option<RuleMatcher>,
    /// deprecated_filed error conditions to judge an invocation as an error
    #[deprecated]
    #[prost(message, repeated, tag = "23")]
    pub error_conditions: ::prost::alloc::vec::Vec<ErrorCondition>,
    /// deprecated_filed trigger condition to trigger circuitbreaking
    #[deprecated]
    #[prost(message, repeated, tag = "24")]
    pub trigger_condition: ::prost::alloc::vec::Vec<TriggerCondition>,
    /// the maximum % of an upstream cluster that can be ejected
    #[prost(uint32, tag = "25")]
    pub max_ejection_percent: u32,
    /// recover condition to make resource open to close
    #[prost(message, optional, tag = "26")]
    pub recover_condition: ::core::option::Option<RecoverCondition>,
    /// fault detection enable config
    #[prost(message, optional, tag = "27")]
    pub fault_detect_config: ::core::option::Option<FaultDetectConfig>,
    /// fall back configuration
    #[prost(message, optional, tag = "28")]
    pub fallback_config: ::core::option::Option<FallbackConfig>,
    /// list for block configuration
    #[prost(message, repeated, tag = "29")]
    pub block_configs: ::prost::alloc::vec::Vec<BlockConfig>,
    /// priority rules priority
    #[prost(uint32, tag = "30")]
    pub priority: u32,
    /// 熔断规则标签数据
    #[prost(map = "string, string", tag = "31")]
    pub metadata: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    /// 操作标志位
    #[prost(bool, tag = "40")]
    pub editable: bool,
    #[prost(bool, tag = "41")]
    pub deleteable: bool,
}
/// the condition to judge an input invocation as an error
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct ErrorCondition {
    #[prost(enumeration = "error_condition::InputType", tag = "1")]
    pub input_type: i32,
    #[prost(message, optional, tag = "2")]
    pub condition: ::core::option::Option<MatchString>,
}
/// Nested message and enum types in `ErrorCondition`.
pub mod error_condition {
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum InputType {
        Unknown = 0,
        RetCode = 1,
        Delay = 2,
    }
    impl InputType {
        /// 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 {
                Self::Unknown => "UNKNOWN",
                Self::RetCode => "RET_CODE",
                Self::Delay => "DELAY",
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "UNKNOWN" => Some(Self::Unknown),
                "RET_CODE" => Some(Self::RetCode),
                "DELAY" => Some(Self::Delay),
                _ => None,
            }
        }
    }
}
/// the error condition to trigger circuitbreaking
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TriggerCondition {
    #[prost(enumeration = "trigger_condition::TriggerType", tag = "1")]
    pub trigger_type: i32,
    #[prost(uint32, tag = "2")]
    pub error_count: u32,
    #[prost(uint32, tag = "3")]
    pub error_percent: u32,
    #[prost(uint32, tag = "4")]
    pub interval: u32,
    #[prost(uint32, tag = "5")]
    pub minimum_request: u32,
}
/// Nested message and enum types in `TriggerCondition`.
pub mod trigger_condition {
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum TriggerType {
        Unknown = 0,
        ErrorRate = 1,
        ConsecutiveError = 2,
    }
    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 {
                Self::Unknown => "UNKNOWN",
                Self::ErrorRate => "ERROR_RATE",
                Self::ConsecutiveError => "CONSECUTIVE_ERROR",
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "UNKNOWN" => Some(Self::Unknown),
                "ERROR_RATE" => Some(Self::ErrorRate),
                "CONSECUTIVE_ERROR" => Some(Self::ConsecutiveError),
                _ => None,
            }
        }
    }
}
/// circuitbreaking OPEN status recover
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct RecoverCondition {
    /// seconds from open to half-open
    #[prost(uint32, tag = "1")]
    pub sleep_window: u32,
    /// consecutive success request to recover
    #[prost(uint32, tag = "2")]
    pub consecutive_success: u32,
}
/// fault detect config within circuitbreaking
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct FaultDetectConfig {
    #[prost(bool, tag = "1")]
    pub enable: bool,
}
/// blocking strategy
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BlockConfig {
    #[prost(string, tag = "1")]
    pub name: ::prost::alloc::string::String,
    /// blocking target api
    #[prost(message, optional, tag = "2")]
    pub api: ::core::option::Option<Api>,
    /// conditions to judge an invocation as an error
    #[prost(message, repeated, tag = "3")]
    pub error_conditions: ::prost::alloc::vec::Vec<ErrorCondition>,
    /// trigger condition to trigger circuitbreaking
    #[prost(message, repeated, tag = "4")]
    pub trigger_conditions: ::prost::alloc::vec::Vec<TriggerCondition>,
}
/// fallback config
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FallbackConfig {
    #[prost(bool, tag = "1")]
    pub enable: bool,
    #[prost(message, optional, tag = "2")]
    pub response: ::core::option::Option<FallbackResponse>,
}
/// fallback response
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FallbackResponse {
    #[prost(int32, tag = "1")]
    pub code: i32,
    #[prost(message, repeated, tag = "2")]
    pub headers: ::prost::alloc::vec::Vec<fallback_response::MessageHeader>,
    #[prost(string, tag = "3")]
    pub body: ::prost::alloc::string::String,
}
/// Nested message and enum types in `FallbackResponse`.
pub mod fallback_response {
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
    pub struct MessageHeader {
        #[prost(string, tag = "1")]
        pub key: ::prost::alloc::string::String,
        #[prost(string, tag = "2")]
        pub value: ::prost::alloc::string::String,
    }
}
/// circuitbreaking level
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum Level {
    Unknown = 0,
    /// service level circuitbreaking
    Service = 1,
    /// method level circuitbreaking
    Method = 2,
    /// group level circuitbreaking
    Group = 3,
    /// instance level circuitbreaking
    Instance = 4,
}
impl Level {
    /// 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 {
            Self::Unknown => "UNKNOWN",
            Self::Service => "SERVICE",
            Self::Method => "METHOD",
            Self::Group => "GROUP",
            Self::Instance => "INSTANCE",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "UNKNOWN" => Some(Self::Unknown),
            "SERVICE" => Some(Self::Service),
            "METHOD" => Some(Self::Method),
            "GROUP" => Some(Self::Group),
            "INSTANCE" => Some(Self::Instance),
            _ => None,
        }
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Namespace {
    #[prost(string, tag = "1")]
    pub id: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub name: ::prost::alloc::string::String,
    #[prost(string, tag = "3")]
    pub comment: ::prost::alloc::string::String,
    #[prost(string, tag = "4")]
    pub owners: ::prost::alloc::string::String,
    #[prost(string, tag = "5")]
    pub token: ::prost::alloc::string::String,
    #[prost(string, tag = "6")]
    pub ctime: ::prost::alloc::string::String,
    #[prost(string, tag = "7")]
    pub mtime: ::prost::alloc::string::String,
    #[prost(string, repeated, tag = "8")]
    pub service_export_to: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    #[prost(map = "string, string", tag = "9")]
    pub metadata: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    #[prost(uint32, tag = "20")]
    pub total_service_count: u32,
    #[prost(uint32, tag = "21")]
    pub total_health_instance_count: u32,
    #[prost(uint32, tag = "22")]
    pub total_instance_count: u32,
    #[prost(bool, tag = "30")]
    pub editable: bool,
    #[prost(bool, tag = "31")]
    pub deleteable: bool,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FaultDetector {
    /// fault detect rules for current service
    #[prost(message, repeated, tag = "1")]
    pub rules: ::prost::alloc::vec::Vec<FaultDetectRule>,
    /// total revision for the fault detect rules
    #[prost(string, tag = "2")]
    pub revision: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FaultDetectRule {
    #[prost(string, tag = "1")]
    pub id: ::prost::alloc::string::String,
    /// rule name
    #[prost(string, tag = "2")]
    pub name: ::prost::alloc::string::String,
    /// namespace of rule
    #[prost(string, tag = "3")]
    pub namespace: ::prost::alloc::string::String,
    /// revision routing version
    #[prost(string, tag = "4")]
    pub revision: ::prost::alloc::string::String,
    /// ctime create time of the rules
    #[prost(string, tag = "5")]
    pub ctime: ::prost::alloc::string::String,
    /// mtime modify time of the rules
    #[prost(string, tag = "6")]
    pub mtime: ::prost::alloc::string::String,
    /// description simple description rules
    #[prost(string, tag = "7")]
    pub description: ::prost::alloc::string::String,
    /// detect target
    #[prost(message, optional, tag = "21")]
    pub target_service: ::core::option::Option<fault_detect_rule::DestinationService>,
    /// detect interval
    #[prost(uint32, tag = "22")]
    pub interval: u32,
    /// detect timeout
    #[prost(uint32, tag = "23")]
    pub timeout: u32,
    /// detect port
    #[prost(uint32, tag = "24")]
    pub port: u32,
    #[prost(enumeration = "fault_detect_rule::Protocol", tag = "25")]
    pub protocol: i32,
    /// http detect config
    #[prost(message, optional, tag = "26")]
    pub http_config: ::core::option::Option<HttpProtocolConfig>,
    /// tcp detect config
    #[prost(message, optional, tag = "27")]
    pub tcp_config: ::core::option::Option<TcpProtocolConfig>,
    /// udp detect config
    #[prost(message, optional, tag = "28")]
    pub udp_config: ::core::option::Option<UdpProtocolConfig>,
    /// priority rules priority
    #[prost(uint32, tag = "29")]
    pub priority: u32,
    /// 探测规则标签数据
    #[prost(map = "string, string", tag = "30")]
    pub metadata: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    /// extend info, put some custom info to display in console
    #[prost(map = "string, string", tag = "31")]
    pub extend_info: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    /// 操作标志位
    #[prost(bool, tag = "40")]
    pub editable: bool,
    #[prost(bool, tag = "41")]
    pub deleteable: bool,
}
/// Nested message and enum types in `FaultDetectRule`.
pub mod fault_detect_rule {
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
    pub struct DestinationService {
        #[prost(string, tag = "1")]
        pub service: ::prost::alloc::string::String,
        #[prost(string, tag = "2")]
        pub namespace: ::prost::alloc::string::String,
        /// deprecated_filed  use api.path instead
        #[deprecated]
        #[prost(message, optional, tag = "3")]
        pub method: ::core::option::Option<super::MatchString>,
        #[prost(message, optional, tag = "4")]
        pub api: ::core::option::Option<super::Api>,
    }
    /// detect protocol
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum Protocol {
        Unknown = 0,
        Http = 1,
        Tcp = 2,
        Udp = 3,
    }
    impl Protocol {
        /// 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 {
                Self::Unknown => "UNKNOWN",
                Self::Http => "HTTP",
                Self::Tcp => "TCP",
                Self::Udp => "UDP",
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "UNKNOWN" => Some(Self::Unknown),
                "HTTP" => Some(Self::Http),
                "TCP" => Some(Self::Tcp),
                "UDP" => Some(Self::Udp),
                _ => None,
            }
        }
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct HttpProtocolConfig {
    #[prost(string, tag = "1")]
    pub method: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub url: ::prost::alloc::string::String,
    #[prost(message, repeated, tag = "3")]
    pub headers: ::prost::alloc::vec::Vec<http_protocol_config::MessageHeader>,
    #[prost(string, tag = "4")]
    pub body: ::prost::alloc::string::String,
}
/// Nested message and enum types in `HttpProtocolConfig`.
pub mod http_protocol_config {
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
    pub struct MessageHeader {
        #[prost(string, tag = "1")]
        pub key: ::prost::alloc::string::String,
        #[prost(string, tag = "2")]
        pub value: ::prost::alloc::string::String,
    }
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TcpProtocolConfig {
    #[prost(string, tag = "1")]
    pub send: ::prost::alloc::string::String,
    #[prost(string, repeated, tag = "2")]
    pub receive: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct UdpProtocolConfig {
    #[prost(string, tag = "1")]
    pub send: ::prost::alloc::string::String,
    #[prost(string, repeated, tag = "2")]
    pub receive: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
/// 优雅上下线规则的模型
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct LosslessRule {
    /// rule id
    #[prost(string, tag = "1")]
    pub id: ::prost::alloc::string::String,
    /// service for rule belongs to
    #[prost(string, tag = "2")]
    pub service: ::prost::alloc::string::String,
    /// namespace for rule belongs to
    #[prost(string, tag = "3")]
    pub namespace: ::prost::alloc::string::String,
    /// revision routing version
    #[prost(string, tag = "4")]
    pub revision: ::prost::alloc::string::String,
    /// ctime create time of the rules
    #[prost(string, tag = "5")]
    pub ctime: ::prost::alloc::string::String,
    /// mtime modify time of the rules
    #[prost(string, tag = "6")]
    pub mtime: ::prost::alloc::string::String,
    /// configuration for lossless online
    #[prost(message, optional, tag = "7")]
    pub lossless_online: ::core::option::Option<LosslessOnline>,
    /// configuration for lossless offline
    #[prost(message, optional, tag = "8")]
    pub lossless_offline: ::core::option::Option<LosslessOffline>,
    /// rule labels
    #[prost(map = "string, string", tag = "9")]
    pub metadata: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    /// 操作标志位
    #[prost(bool, tag = "30")]
    pub editable: bool,
    #[prost(bool, tag = "31")]
    pub deleteable: bool,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct LosslessOnline {
    /// configuration for delayRegister
    #[prost(message, optional, tag = "1")]
    pub delay_register: ::core::option::Option<DelayRegister>,
    /// configuration for warmup
    #[prost(message, optional, tag = "2")]
    pub warmup: ::core::option::Option<Warmup>,
    /// configuration for readiness probe
    #[prost(message, optional, tag = "3")]
    pub readiness: ::core::option::Option<Readiness>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct DelayRegister {
    /// enable delay registry
    #[prost(bool, tag = "1")]
    pub enable: bool,
    /// delay register strategy
    #[prost(enumeration = "delay_register::DelayStrategy", tag = "2")]
    pub strategy: i32,
    /// delay register time by second, active when strategy == DELAY_BY_TIME
    #[prost(int32, tag = "3")]
    pub interval_second: i32,
    /// protocol to do health check, default http, active when strategy == DELAY_BY_HEALTH_CHECK
    #[prost(string, tag = "4")]
    pub health_check_protocol: ::prost::alloc::string::String,
    /// method to do health check, default GET, active when strategy == DELAY_BY_HEALTH_CHECK
    #[prost(string, tag = "5")]
    pub health_check_method: ::prost::alloc::string::String,
    /// path to do health check, no default value, active when strategy == DELAY_BY_HEALTH_CHECK
    #[prost(string, tag = "6")]
    pub health_check_path: ::prost::alloc::string::String,
    /// health check interval second, default is 30, active when strategy == DELAY_BY_HEALTH_CHECK
    #[prost(string, tag = "7")]
    pub health_check_interval_second: ::prost::alloc::string::String,
}
/// Nested message and enum types in `DelayRegister`.
pub mod delay_register {
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum DelayStrategy {
        /// register instance after delay specific time
        DelayByTime = 0,
        /// register instance until health check successfully
        DelayByHealthCheck = 1,
    }
    impl DelayStrategy {
        /// 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 {
                Self::DelayByTime => "DELAY_BY_TIME",
                Self::DelayByHealthCheck => "DELAY_BY_HEALTH_CHECK",
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "DELAY_BY_TIME" => Some(Self::DelayByTime),
                "DELAY_BY_HEALTH_CHECK" => Some(Self::DelayByHealthCheck),
                _ => None,
            }
        }
    }
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct Warmup {
    /// enable warmup
    #[prost(bool, tag = "1")]
    pub enable: bool,
    /// total warmup interval by second
    #[prost(int32, tag = "2")]
    pub interval_second: i32,
    /// warmup stop when most of the instances in service are in warmup status
    #[prost(bool, tag = "3")]
    pub enable_overload_protection: bool,
    /// the threshold to active overload protection, default is 50, threshld = sum(WarmupInstances)/sum(AllInstances)\*100
    #[prost(int32, tag = "4")]
    pub overload_protection_threshold: i32,
    /// curvature for warmup register, default is 1
    #[prost(int32, tag = "5")]
    pub curvature: i32,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct Readiness {
    /// enable /readiness expose
    #[prost(bool, tag = "1")]
    pub enable: bool,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct LosslessOffline {
    /// enable /offline expose
    #[prost(bool, tag = "1")]
    pub enable: bool,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DiscoverFilter {
    #[prost(bool, tag = "1")]
    pub only_healthy_instance: bool,
    /// pole.io 自定义信息
    #[prost(message, optional, tag = "100")]
    pub caller: ::core::option::Option<Caller>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DiscoverRequest {
    #[prost(enumeration = "discover_request::DiscoverRequestType", tag = "1")]
    pub r#type: i32,
    #[prost(message, optional, tag = "2")]
    pub service: ::core::option::Option<Service>,
    #[prost(message, optional, tag = "30")]
    pub filter: ::core::option::Option<DiscoverFilter>,
}
/// Nested message and enum types in `DiscoverRequest`.
pub mod discover_request {
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum DiscoverRequestType {
        Unknown = 0,
        /// 拉起命名空间列表
        Namespaces = 1,
        /// 服务列表
        Services = 2,
        /// 服务实例列表
        Instance = 3,
        /// 服务契约列表
        ServiceContracts = 4,
        /// 限流规则
        RateLimit = 20,
        /// 熔断规则
        CircuitBreaker = 21,
        /// 故障检测规则
        FaultDetector = 22,
        /// 自定义路由规则
        CustomRouteRule = 23,
        /// 就近路由规则
        NearbyRouteRule = 24,
        /// 泳道规则
        Lane = 25,
        /// 无损上下线规则
        Lossless = 26,
        /// 服务黑白名单规则
        BlockAllowRule = 27,
        /// 服务订阅视图
        ServiceSubscribers = 50,
    }
    impl DiscoverRequestType {
        /// 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 {
                Self::Unknown => "UNKNOWN",
                Self::Namespaces => "NAMESPACES",
                Self::Services => "SERVICES",
                Self::Instance => "INSTANCE",
                Self::ServiceContracts => "SERVICE_CONTRACTS",
                Self::RateLimit => "RATE_LIMIT",
                Self::CircuitBreaker => "CIRCUIT_BREAKER",
                Self::FaultDetector => "FAULT_DETECTOR",
                Self::CustomRouteRule => "CUSTOM_ROUTE_RULE",
                Self::NearbyRouteRule => "NEARBY_ROUTE_RULE",
                Self::Lane => "LANE",
                Self::Lossless => "LOSSLESS",
                Self::BlockAllowRule => "BLOCK_ALLOW_RULE",
                Self::ServiceSubscribers => "SERVICE_SUBSCRIBERS",
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "UNKNOWN" => Some(Self::Unknown),
                "NAMESPACES" => Some(Self::Namespaces),
                "SERVICES" => Some(Self::Services),
                "INSTANCE" => Some(Self::Instance),
                "SERVICE_CONTRACTS" => Some(Self::ServiceContracts),
                "RATE_LIMIT" => Some(Self::RateLimit),
                "CIRCUIT_BREAKER" => Some(Self::CircuitBreaker),
                "FAULT_DETECTOR" => Some(Self::FaultDetector),
                "CUSTOM_ROUTE_RULE" => Some(Self::CustomRouteRule),
                "NEARBY_ROUTE_RULE" => Some(Self::NearbyRouteRule),
                "LANE" => Some(Self::Lane),
                "LOSSLESS" => Some(Self::Lossless),
                "BLOCK_ALLOW_RULE" => Some(Self::BlockAllowRule),
                "SERVICE_SUBSCRIBERS" => Some(Self::ServiceSubscribers),
                _ => None,
            }
        }
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DiscoverResponse {
    #[prost(uint32, tag = "1")]
    pub code: u32,
    #[prost(string, tag = "2")]
    pub info: ::prost::alloc::string::String,
    #[prost(enumeration = "discover_response::DiscoverResponseType", tag = "3")]
    pub r#type: i32,
    /// 服务
    #[prost(message, optional, tag = "4")]
    pub service: ::core::option::Option<Service>,
    /// 服务真实名称
    #[prost(message, optional, tag = "5")]
    pub alias_for: ::core::option::Option<Service>,
    /// 命名空间列表
    #[prost(message, repeated, tag = "6")]
    pub namespaces: ::prost::alloc::vec::Vec<Namespace>,
    /// 服务列表
    #[prost(message, repeated, tag = "7")]
    pub services: ::prost::alloc::vec::Vec<Service>,
    /// 服务实例列表
    #[prost(message, repeated, tag = "8")]
    pub instances: ::prost::alloc::vec::Vec<Instance>,
    /// 服务契约
    #[prost(message, repeated, tag = "9")]
    pub service_contracts: ::prost::alloc::vec::Vec<ServiceContract>,
    /// 限流规则
    #[prost(message, repeated, tag = "20")]
    pub rate_limit: ::prost::alloc::vec::Vec<RateLimit>,
    /// 熔断规则
    #[prost(message, repeated, tag = "21")]
    pub circuit_breaker: ::prost::alloc::vec::Vec<CircuitBreakerRule>,
    /// 故障检测规则
    #[prost(message, optional, tag = "22")]
    pub fault_detector: ::core::option::Option<FaultDetector>,
    /// 全链路灰度泳道
    #[prost(message, repeated, tag = "23")]
    pub lanes: ::prost::alloc::vec::Vec<LaneGroup>,
    /// 自定义路由规则内容
    #[prost(message, repeated, tag = "24")]
    pub custom_route_rules: ::prost::alloc::vec::Vec<RouteRule>,
    /// 就近路由规则内容
    #[prost(message, repeated, tag = "25")]
    pub nearby_route_rules: ::prost::alloc::vec::Vec<RouteRule>,
    /// 无损上下线规则内容
    #[prost(message, repeated, tag = "26")]
    pub lossless_rules: ::prost::alloc::vec::Vec<LosslessRule>,
    /// 服务黑白名单鉴权规则
    #[prost(message, repeated, tag = "27")]
    pub block_allow_list_rule: ::prost::alloc::vec::Vec<BlockAllowListRule>,
}
/// Nested message and enum types in `DiscoverResponse`.
pub mod discover_response {
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum DiscoverResponseType {
        Unknown = 0,
        /// 拉起命名空间列表
        Namespaces = 1,
        /// 服务列表
        Services = 2,
        /// 服务实例列表
        Instance = 3,
        /// 服务契约列表
        ServiceContracts = 4,
        /// 限流规则
        RateLimit = 20,
        /// 熔断规则
        CircuitBreaker = 21,
        /// 故障检测规则
        FaultDetector = 22,
        /// 自定义路由规则
        CustomRouteRule = 23,
        /// 就近路由规则
        NearbyRouteRule = 24,
        /// 泳道规则
        Lane = 25,
        /// 无损上下线规则
        Lossless = 26,
        /// 服务黑白名单规则
        BlockAllowRule = 27,
        /// 服务订阅视图
        ServiceSubscribers = 50,
    }
    impl DiscoverResponseType {
        /// 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 {
                Self::Unknown => "UNKNOWN",
                Self::Namespaces => "NAMESPACES",
                Self::Services => "SERVICES",
                Self::Instance => "INSTANCE",
                Self::ServiceContracts => "SERVICE_CONTRACTS",
                Self::RateLimit => "RATE_LIMIT",
                Self::CircuitBreaker => "CIRCUIT_BREAKER",
                Self::FaultDetector => "FAULT_DETECTOR",
                Self::CustomRouteRule => "CUSTOM_ROUTE_RULE",
                Self::NearbyRouteRule => "NEARBY_ROUTE_RULE",
                Self::Lane => "LANE",
                Self::Lossless => "LOSSLESS",
                Self::BlockAllowRule => "BLOCK_ALLOW_RULE",
                Self::ServiceSubscribers => "SERVICE_SUBSCRIBERS",
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "UNKNOWN" => Some(Self::Unknown),
                "NAMESPACES" => Some(Self::Namespaces),
                "SERVICES" => Some(Self::Services),
                "INSTANCE" => Some(Self::Instance),
                "SERVICE_CONTRACTS" => Some(Self::ServiceContracts),
                "RATE_LIMIT" => Some(Self::RateLimit),
                "CIRCUIT_BREAKER" => Some(Self::CircuitBreaker),
                "FAULT_DETECTOR" => Some(Self::FaultDetector),
                "CUSTOM_ROUTE_RULE" => Some(Self::CustomRouteRule),
                "NEARBY_ROUTE_RULE" => Some(Self::NearbyRouteRule),
                "LANE" => Some(Self::Lane),
                "LOSSLESS" => Some(Self::Lossless),
                "BLOCK_ALLOW_RULE" => Some(Self::BlockAllowRule),
                "SERVICE_SUBSCRIBERS" => Some(Self::ServiceSubscribers),
                _ => None,
            }
        }
    }
}
/// Generated client implementations.
pub mod discover_grpc_client {
    #![allow(
        unused_variables,
        dead_code,
        missing_docs,
        clippy::wildcard_imports,
        clippy::let_unit_value,
    )]
    use tonic::codegen::*;
    use tonic::codegen::http::Uri;
    #[derive(Debug, Clone)]
    pub struct DiscoverGrpcClient<T> {
        inner: tonic::client::Grpc<T>,
    }
    impl DiscoverGrpcClient<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> DiscoverGrpcClient<T>
    where
        T: tonic::client::GrpcService<tonic::body::Body>,
        T::Error: Into<StdError>,
        T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
        <T::ResponseBody as Body>::Error: Into<StdError> + std::marker::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,
        ) -> DiscoverGrpcClient<InterceptedService<T, F>>
        where
            F: tonic::service::Interceptor,
            T::ResponseBody: Default,
            T: tonic::codegen::Service<
                http::Request<tonic::body::Body>,
                Response = http::Response<
                    <T as tonic::client::GrpcService<tonic::body::Body>>::ResponseBody,
                >,
            >,
            <T as tonic::codegen::Service<
                http::Request<tonic::body::Body>,
            >>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
        {
            DiscoverGrpcClient::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
        }
        /// 客户端上报
        pub async fn report_client(
            &mut self,
            request: impl tonic::IntoRequest<super::Client>,
        ) -> std::result::Result<tonic::Response<super::Response>, tonic::Status> {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/v1.DiscoverGRPC/ReportClient",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("v1.DiscoverGRPC", "ReportClient"));
            self.inner.unary(req, path, codec).await
        }
        /// 被调方注册服务实例
        pub async fn register_instance(
            &mut self,
            request: impl tonic::IntoRequest<super::Instance>,
        ) -> std::result::Result<tonic::Response<super::Response>, tonic::Status> {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/v1.DiscoverGRPC/RegisterInstance",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("v1.DiscoverGRPC", "RegisterInstance"));
            self.inner.unary(req, path, codec).await
        }
        /// 被调方反注册服务实例
        pub async fn deregister_instance(
            &mut self,
            request: impl tonic::IntoRequest<super::Instance>,
        ) -> std::result::Result<tonic::Response<super::Response>, tonic::Status> {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/v1.DiscoverGRPC/DeregisterInstance",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("v1.DiscoverGRPC", "DeregisterInstance"));
            self.inner.unary(req, path, codec).await
        }
        /// 统一发现接口
        pub async fn discover(
            &mut self,
            request: impl tonic::IntoStreamingRequest<Message = super::DiscoverRequest>,
        ) -> std::result::Result<
            tonic::Response<tonic::codec::Streaming<super::DiscoverResponse>>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static("/v1.DiscoverGRPC/Discover");
            let mut req = request.into_streaming_request();
            req.extensions_mut().insert(GrpcMethod::new("v1.DiscoverGRPC", "Discover"));
            self.inner.streaming(req, path, codec).await
        }
        /// 被调方批量上报心跳
        pub async fn heartbeat(
            &mut self,
            request: impl tonic::IntoStreamingRequest<Message = super::HeartbeatsRequest>,
        ) -> std::result::Result<
            tonic::Response<tonic::codec::Streaming<super::HeartbeatsResponse>>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/v1.DiscoverGRPC/Heartbeat",
            );
            let mut req = request.into_streaming_request();
            req.extensions_mut().insert(GrpcMethod::new("v1.DiscoverGRPC", "Heartbeat"));
            self.inner.streaming(req, path, codec).await
        }
        /// 上报服务契约
        pub async fn report_service_contract(
            &mut self,
            request: impl tonic::IntoRequest<super::ServiceContract>,
        ) -> std::result::Result<tonic::Response<super::Response>, tonic::Status> {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/v1.DiscoverGRPC/ReportServiceContract",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("v1.DiscoverGRPC", "ReportServiceContract"));
            self.inner.unary(req, path, codec).await
        }
    }
}
/// Generated server implementations.
pub mod discover_grpc_server {
    #![allow(
        unused_variables,
        dead_code,
        missing_docs,
        clippy::wildcard_imports,
        clippy::let_unit_value,
    )]
    use tonic::codegen::*;
    /// Generated trait containing gRPC methods that should be implemented for use with DiscoverGrpcServer.
    #[async_trait]
    pub trait DiscoverGrpc: std::marker::Send + std::marker::Sync + 'static {
        /// 客户端上报
        async fn report_client(
            &self,
            request: tonic::Request<super::Client>,
        ) -> std::result::Result<tonic::Response<super::Response>, tonic::Status>;
        /// 被调方注册服务实例
        async fn register_instance(
            &self,
            request: tonic::Request<super::Instance>,
        ) -> std::result::Result<tonic::Response<super::Response>, tonic::Status>;
        /// 被调方反注册服务实例
        async fn deregister_instance(
            &self,
            request: tonic::Request<super::Instance>,
        ) -> std::result::Result<tonic::Response<super::Response>, tonic::Status>;
        /// Server streaming response type for the Discover method.
        type DiscoverStream: tonic::codegen::tokio_stream::Stream<
                Item = std::result::Result<super::DiscoverResponse, tonic::Status>,
            >
            + std::marker::Send
            + 'static;
        /// 统一发现接口
        async fn discover(
            &self,
            request: tonic::Request<tonic::Streaming<super::DiscoverRequest>>,
        ) -> std::result::Result<tonic::Response<Self::DiscoverStream>, tonic::Status>;
        /// Server streaming response type for the Heartbeat method.
        type HeartbeatStream: tonic::codegen::tokio_stream::Stream<
                Item = std::result::Result<super::HeartbeatsResponse, tonic::Status>,
            >
            + std::marker::Send
            + 'static;
        /// 被调方批量上报心跳
        async fn heartbeat(
            &self,
            request: tonic::Request<tonic::Streaming<super::HeartbeatsRequest>>,
        ) -> std::result::Result<tonic::Response<Self::HeartbeatStream>, tonic::Status>;
        /// 上报服务契约
        async fn report_service_contract(
            &self,
            request: tonic::Request<super::ServiceContract>,
        ) -> std::result::Result<tonic::Response<super::Response>, tonic::Status>;
    }
    #[derive(Debug)]
    pub struct DiscoverGrpcServer<T> {
        inner: Arc<T>,
        accept_compression_encodings: EnabledCompressionEncodings,
        send_compression_encodings: EnabledCompressionEncodings,
        max_decoding_message_size: Option<usize>,
        max_encoding_message_size: Option<usize>,
    }
    impl<T> DiscoverGrpcServer<T> {
        pub fn new(inner: T) -> Self {
            Self::from_arc(Arc::new(inner))
        }
        pub fn from_arc(inner: Arc<T>) -> Self {
            Self {
                inner,
                accept_compression_encodings: Default::default(),
                send_compression_encodings: Default::default(),
                max_decoding_message_size: None,
                max_encoding_message_size: None,
            }
        }
        pub fn with_interceptor<F>(
            inner: T,
            interceptor: F,
        ) -> InterceptedService<Self, F>
        where
            F: tonic::service::Interceptor,
        {
            InterceptedService::new(Self::new(inner), interceptor)
        }
        /// Enable decompressing requests with the given encoding.
        #[must_use]
        pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
            self.accept_compression_encodings.enable(encoding);
            self
        }
        /// Compress responses with the given encoding, if the client supports it.
        #[must_use]
        pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
            self.send_compression_encodings.enable(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.max_decoding_message_size = Some(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.max_encoding_message_size = Some(limit);
            self
        }
    }
    impl<T, B> tonic::codegen::Service<http::Request<B>> for DiscoverGrpcServer<T>
    where
        T: DiscoverGrpc,
        B: Body + std::marker::Send + 'static,
        B::Error: Into<StdError> + std::marker::Send + 'static,
    {
        type Response = http::Response<tonic::body::Body>;
        type Error = std::convert::Infallible;
        type Future = BoxFuture<Self::Response, Self::Error>;
        fn poll_ready(
            &mut self,
            _cx: &mut Context<'_>,
        ) -> Poll<std::result::Result<(), Self::Error>> {
            Poll::Ready(Ok(()))
        }
        fn call(&mut self, req: http::Request<B>) -> Self::Future {
            match req.uri().path() {
                "/v1.DiscoverGRPC/ReportClient" => {
                    #[allow(non_camel_case_types)]
                    struct ReportClientSvc<T: DiscoverGrpc>(pub Arc<T>);
                    impl<T: DiscoverGrpc> tonic::server::UnaryService<super::Client>
                    for ReportClientSvc<T> {
                        type Response = super::Response;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::Client>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as DiscoverGrpc>::report_client(&inner, request).await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = ReportClientSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/v1.DiscoverGRPC/RegisterInstance" => {
                    #[allow(non_camel_case_types)]
                    struct RegisterInstanceSvc<T: DiscoverGrpc>(pub Arc<T>);
                    impl<T: DiscoverGrpc> tonic::server::UnaryService<super::Instance>
                    for RegisterInstanceSvc<T> {
                        type Response = super::Response;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::Instance>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as DiscoverGrpc>::register_instance(&inner, request)
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = RegisterInstanceSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/v1.DiscoverGRPC/DeregisterInstance" => {
                    #[allow(non_camel_case_types)]
                    struct DeregisterInstanceSvc<T: DiscoverGrpc>(pub Arc<T>);
                    impl<T: DiscoverGrpc> tonic::server::UnaryService<super::Instance>
                    for DeregisterInstanceSvc<T> {
                        type Response = super::Response;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::Instance>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as DiscoverGrpc>::deregister_instance(&inner, request)
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = DeregisterInstanceSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/v1.DiscoverGRPC/Discover" => {
                    #[allow(non_camel_case_types)]
                    struct DiscoverSvc<T: DiscoverGrpc>(pub Arc<T>);
                    impl<
                        T: DiscoverGrpc,
                    > tonic::server::StreamingService<super::DiscoverRequest>
                    for DiscoverSvc<T> {
                        type Response = super::DiscoverResponse;
                        type ResponseStream = T::DiscoverStream;
                        type Future = BoxFuture<
                            tonic::Response<Self::ResponseStream>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<
                                tonic::Streaming<super::DiscoverRequest>,
                            >,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as DiscoverGrpc>::discover(&inner, request).await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = DiscoverSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.streaming(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/v1.DiscoverGRPC/Heartbeat" => {
                    #[allow(non_camel_case_types)]
                    struct HeartbeatSvc<T: DiscoverGrpc>(pub Arc<T>);
                    impl<
                        T: DiscoverGrpc,
                    > tonic::server::StreamingService<super::HeartbeatsRequest>
                    for HeartbeatSvc<T> {
                        type Response = super::HeartbeatsResponse;
                        type ResponseStream = T::HeartbeatStream;
                        type Future = BoxFuture<
                            tonic::Response<Self::ResponseStream>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<
                                tonic::Streaming<super::HeartbeatsRequest>,
                            >,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as DiscoverGrpc>::heartbeat(&inner, request).await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = HeartbeatSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.streaming(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/v1.DiscoverGRPC/ReportServiceContract" => {
                    #[allow(non_camel_case_types)]
                    struct ReportServiceContractSvc<T: DiscoverGrpc>(pub Arc<T>);
                    impl<
                        T: DiscoverGrpc,
                    > tonic::server::UnaryService<super::ServiceContract>
                    for ReportServiceContractSvc<T> {
                        type Response = super::Response;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::ServiceContract>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as DiscoverGrpc>::report_service_contract(
                                        &inner,
                                        request,
                                    )
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = ReportServiceContractSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                _ => {
                    Box::pin(async move {
                        let mut response = http::Response::new(
                            tonic::body::Body::default(),
                        );
                        let headers = response.headers_mut();
                        headers
                            .insert(
                                tonic::Status::GRPC_STATUS,
                                (tonic::Code::Unimplemented as i32).into(),
                            );
                        headers
                            .insert(
                                http::header::CONTENT_TYPE,
                                tonic::metadata::GRPC_CONTENT_TYPE,
                            );
                        Ok(response)
                    })
                }
            }
        }
    }
    impl<T> Clone for DiscoverGrpcServer<T> {
        fn clone(&self) -> Self {
            let inner = self.inner.clone();
            Self {
                inner,
                accept_compression_encodings: self.accept_compression_encodings,
                send_compression_encodings: self.send_compression_encodings,
                max_decoding_message_size: self.max_decoding_message_size,
                max_encoding_message_size: self.max_encoding_message_size,
            }
        }
    }
    /// Generated gRPC service name
    pub const SERVICE_NAME: &str = "v1.DiscoverGRPC";
    impl<T> tonic::server::NamedService for DiscoverGrpcServer<T> {
        const NAME: &'static str = SERVICE_NAME;
    }
}
/// Generated client implementations.
pub mod pole_heartbeat_grpc_client {
    #![allow(
        unused_variables,
        dead_code,
        missing_docs,
        clippy::wildcard_imports,
        clippy::let_unit_value,
    )]
    use tonic::codegen::*;
    use tonic::codegen::http::Uri;
    #[derive(Debug, Clone)]
    pub struct PoleHeartbeatGrpcClient<T> {
        inner: tonic::client::Grpc<T>,
    }
    impl PoleHeartbeatGrpcClient<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> PoleHeartbeatGrpcClient<T>
    where
        T: tonic::client::GrpcService<tonic::body::Body>,
        T::Error: Into<StdError>,
        T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
        <T::ResponseBody as Body>::Error: Into<StdError> + std::marker::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,
        ) -> PoleHeartbeatGrpcClient<InterceptedService<T, F>>
        where
            F: tonic::service::Interceptor,
            T::ResponseBody: Default,
            T: tonic::codegen::Service<
                http::Request<tonic::body::Body>,
                Response = http::Response<
                    <T as tonic::client::GrpcService<tonic::body::Body>>::ResponseBody,
                >,
            >,
            <T as tonic::codegen::Service<
                http::Request<tonic::body::Body>,
            >>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
        {
            PoleHeartbeatGrpcClient::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
        }
        /// 批量获取心跳记录
        pub async fn batch_get_heartbeat(
            &mut self,
            request: impl tonic::IntoRequest<super::GetHeartbeatsRequest>,
        ) -> std::result::Result<
            tonic::Response<super::GetHeartbeatsResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/v1.PoleHeartbeatGRPC/BatchGetHeartbeat",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("v1.PoleHeartbeatGRPC", "BatchGetHeartbeat"));
            self.inner.unary(req, path, codec).await
        }
        /// 批量删除心跳记录
        pub async fn batch_del_heartbeat(
            &mut self,
            request: impl tonic::IntoRequest<super::DelHeartbeatsRequest>,
        ) -> std::result::Result<
            tonic::Response<super::DelHeartbeatsResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/v1.PoleHeartbeatGRPC/BatchDelHeartbeat",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("v1.PoleHeartbeatGRPC", "BatchDelHeartbeat"));
            self.inner.unary(req, path, codec).await
        }
    }
}
/// Generated server implementations.
pub mod pole_heartbeat_grpc_server {
    #![allow(
        unused_variables,
        dead_code,
        missing_docs,
        clippy::wildcard_imports,
        clippy::let_unit_value,
    )]
    use tonic::codegen::*;
    /// Generated trait containing gRPC methods that should be implemented for use with PoleHeartbeatGrpcServer.
    #[async_trait]
    pub trait PoleHeartbeatGrpc: std::marker::Send + std::marker::Sync + 'static {
        /// 批量获取心跳记录
        async fn batch_get_heartbeat(
            &self,
            request: tonic::Request<super::GetHeartbeatsRequest>,
        ) -> std::result::Result<
            tonic::Response<super::GetHeartbeatsResponse>,
            tonic::Status,
        >;
        /// 批量删除心跳记录
        async fn batch_del_heartbeat(
            &self,
            request: tonic::Request<super::DelHeartbeatsRequest>,
        ) -> std::result::Result<
            tonic::Response<super::DelHeartbeatsResponse>,
            tonic::Status,
        >;
    }
    #[derive(Debug)]
    pub struct PoleHeartbeatGrpcServer<T> {
        inner: Arc<T>,
        accept_compression_encodings: EnabledCompressionEncodings,
        send_compression_encodings: EnabledCompressionEncodings,
        max_decoding_message_size: Option<usize>,
        max_encoding_message_size: Option<usize>,
    }
    impl<T> PoleHeartbeatGrpcServer<T> {
        pub fn new(inner: T) -> Self {
            Self::from_arc(Arc::new(inner))
        }
        pub fn from_arc(inner: Arc<T>) -> Self {
            Self {
                inner,
                accept_compression_encodings: Default::default(),
                send_compression_encodings: Default::default(),
                max_decoding_message_size: None,
                max_encoding_message_size: None,
            }
        }
        pub fn with_interceptor<F>(
            inner: T,
            interceptor: F,
        ) -> InterceptedService<Self, F>
        where
            F: tonic::service::Interceptor,
        {
            InterceptedService::new(Self::new(inner), interceptor)
        }
        /// Enable decompressing requests with the given encoding.
        #[must_use]
        pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
            self.accept_compression_encodings.enable(encoding);
            self
        }
        /// Compress responses with the given encoding, if the client supports it.
        #[must_use]
        pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
            self.send_compression_encodings.enable(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.max_decoding_message_size = Some(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.max_encoding_message_size = Some(limit);
            self
        }
    }
    impl<T, B> tonic::codegen::Service<http::Request<B>> for PoleHeartbeatGrpcServer<T>
    where
        T: PoleHeartbeatGrpc,
        B: Body + std::marker::Send + 'static,
        B::Error: Into<StdError> + std::marker::Send + 'static,
    {
        type Response = http::Response<tonic::body::Body>;
        type Error = std::convert::Infallible;
        type Future = BoxFuture<Self::Response, Self::Error>;
        fn poll_ready(
            &mut self,
            _cx: &mut Context<'_>,
        ) -> Poll<std::result::Result<(), Self::Error>> {
            Poll::Ready(Ok(()))
        }
        fn call(&mut self, req: http::Request<B>) -> Self::Future {
            match req.uri().path() {
                "/v1.PoleHeartbeatGRPC/BatchGetHeartbeat" => {
                    #[allow(non_camel_case_types)]
                    struct BatchGetHeartbeatSvc<T: PoleHeartbeatGrpc>(pub Arc<T>);
                    impl<
                        T: PoleHeartbeatGrpc,
                    > tonic::server::UnaryService<super::GetHeartbeatsRequest>
                    for BatchGetHeartbeatSvc<T> {
                        type Response = super::GetHeartbeatsResponse;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::GetHeartbeatsRequest>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as PoleHeartbeatGrpc>::batch_get_heartbeat(
                                        &inner,
                                        request,
                                    )
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = BatchGetHeartbeatSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/v1.PoleHeartbeatGRPC/BatchDelHeartbeat" => {
                    #[allow(non_camel_case_types)]
                    struct BatchDelHeartbeatSvc<T: PoleHeartbeatGrpc>(pub Arc<T>);
                    impl<
                        T: PoleHeartbeatGrpc,
                    > tonic::server::UnaryService<super::DelHeartbeatsRequest>
                    for BatchDelHeartbeatSvc<T> {
                        type Response = super::DelHeartbeatsResponse;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::DelHeartbeatsRequest>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as PoleHeartbeatGrpc>::batch_del_heartbeat(
                                        &inner,
                                        request,
                                    )
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = BatchDelHeartbeatSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                _ => {
                    Box::pin(async move {
                        let mut response = http::Response::new(
                            tonic::body::Body::default(),
                        );
                        let headers = response.headers_mut();
                        headers
                            .insert(
                                tonic::Status::GRPC_STATUS,
                                (tonic::Code::Unimplemented as i32).into(),
                            );
                        headers
                            .insert(
                                http::header::CONTENT_TYPE,
                                tonic::metadata::GRPC_CONTENT_TYPE,
                            );
                        Ok(response)
                    })
                }
            }
        }
    }
    impl<T> Clone for PoleHeartbeatGrpcServer<T> {
        fn clone(&self) -> Self {
            let inner = self.inner.clone();
            Self {
                inner,
                accept_compression_encodings: self.accept_compression_encodings,
                send_compression_encodings: self.send_compression_encodings,
                max_decoding_message_size: self.max_decoding_message_size,
                max_encoding_message_size: self.max_encoding_message_size,
            }
        }
    }
    /// Generated gRPC service name
    pub const SERVICE_NAME: &str = "v1.PoleHeartbeatGRPC";
    impl<T> tonic::server::NamedService for PoleHeartbeatGrpcServer<T> {
        const NAME: &'static str = SERVICE_NAME;
    }
}