polaris_specification/

v1.rs

// This file is @generated by prost-build.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Location {
    #[prost(message, optional, tag = "1")]
    pub region: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub zone: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "3")]
    pub campus: ::core::option::Option<::prost::alloc::string::String>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct MatchString {
    #[prost(enumeration = "match_string::MatchStringType", tag = "1")]
    pub r#type: i32,
    #[prost(message, optional, tag = "2")]
    pub value: ::core::option::Option<::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 {
                MatchStringType::Exact => "EXACT",
                MatchStringType::Regex => "REGEX",
                MatchStringType::NotEquals => "NOT_EQUALS",
                MatchStringType::In => "IN",
                MatchStringType::NotIn => "NOT_IN",
                MatchStringType::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 {
                ValueType::Text => "TEXT",
                ValueType::Parameter => "PARAMETER",
                ValueType::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,
            }
        }
    }
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct StringList {
    #[prost(string, repeated, tag = "1")]
    pub values: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
/// 汇总查询数据
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::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,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::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统一数据结构
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::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>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Service {
    #[prost(message, optional, tag = "1")]
    pub name: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub namespace: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(map = "string, string", tag = "3")]
    pub metadata: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    #[prost(message, optional, tag = "4")]
    pub ports: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "5")]
    pub business: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "6")]
    pub department: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "7")]
    pub cmdb_mod1: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "8")]
    pub cmdb_mod2: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "9")]
    pub cmdb_mod3: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "10")]
    pub comment: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "11")]
    pub owners: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "12")]
    pub token: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "13")]
    pub ctime: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "14")]
    pub mtime: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "15")]
    pub revision: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "16")]
    pub platform_id: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "17")]
    pub total_instance_count: ::core::option::Option<u32>,
    #[prost(message, optional, tag = "18")]
    pub healthy_instance_count: ::core::option::Option<u32>,
    #[prost(message, repeated, tag = "19")]
    pub user_ids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    #[prost(message, repeated, tag = "20")]
    pub group_ids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    #[prost(message, repeated, tag = "22")]
    pub remove_user_ids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    #[prost(message, repeated, tag = "23")]
    pub remove_group_ids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "21")]
    pub id: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "24")]
    pub editable: ::core::option::Option<bool>,
    #[prost(message, repeated, tag = "25")]
    pub export_to: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "26")]
    pub deleteable: ::core::option::Option<bool>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ServiceAlias {
    #[prost(message, optional, tag = "1")]
    pub service: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub namespace: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "3")]
    pub alias: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "4")]
    pub alias_namespace: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(enumeration = "AliasType", tag = "5")]
    pub r#type: i32,
    #[prost(message, optional, tag = "6")]
    pub owners: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "7")]
    pub comment: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "8")]
    pub service_token: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "9")]
    pub ctime: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "10")]
    pub mtime: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "11")]
    pub id: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "12")]
    pub editable: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "13")]
    pub deleteable: ::core::option::Option<bool>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Instance {
    #[prost(message, optional, tag = "1")]
    pub id: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub service: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "3")]
    pub namespace: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "21")]
    pub vpc_id: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "4")]
    pub host: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "5")]
    pub port: ::core::option::Option<u32>,
    #[prost(message, optional, tag = "6")]
    pub protocol: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "7")]
    pub version: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "8")]
    pub priority: ::core::option::Option<u32>,
    #[prost(message, optional, tag = "9")]
    pub weight: ::core::option::Option<u32>,
    #[prost(message, optional, tag = "20")]
    pub enable_health_check: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "10")]
    pub health_check: ::core::option::Option<HealthCheck>,
    #[prost(message, optional, tag = "11")]
    pub healthy: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "12")]
    pub isolate: ::core::option::Option<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(message, optional, tag = "15")]
    pub logic_set: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "16")]
    pub ctime: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "17")]
    pub mtime: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "18")]
    pub revision: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "19")]
    pub service_token: ::core::option::Option<::prost::alloc::string::String>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::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 {
                HealthCheckType::Unknown => "UNKNOWN",
                HealthCheckType::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,
            }
        }
    }
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct HeartbeatHealthCheck {
    #[prost(message, optional, tag = "1")]
    pub ttl: ::core::option::Option<u32>,
}
#[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 {
            AliasType::Default => "DEFAULT",
            AliasType::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,
        }
    }
}
/// 单个熔断规则定义
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CircuitBreaker {
    /// deprecated
    #[prost(message, optional, tag = "1")]
    pub id: ::core::option::Option<::prost::alloc::string::String>,
    /// 规则版本
    /// deprecated
    #[prost(message, optional, tag = "2")]
    pub version: ::core::option::Option<::prost::alloc::string::String>,
    /// 规则名
    /// deprecated
    #[prost(message, optional, tag = "3")]
    pub name: ::core::option::Option<::prost::alloc::string::String>,
    /// 规则命名空间
    /// deprecated
    #[prost(message, optional, tag = "4")]
    pub namespace: ::core::option::Option<::prost::alloc::string::String>,
    /// 规则所属服务
    #[prost(message, optional, tag = "5")]
    pub service: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "6")]
    pub service_namespace: ::core::option::Option<::prost::alloc::string::String>,
    /// 熔断规则可以分为被调规则和主调规则
    /// 被调规则针对所有的指定主调生效，假如不指定则对所有的主调生效
    /// 主调规则为当前主调方的规则，假如不指定则针对所有被调生效
    /// deprecated
    #[prost(message, repeated, tag = "7")]
    pub inbounds: ::prost::alloc::vec::Vec<CbRule>,
    /// deprecated
    #[prost(message, repeated, tag = "8")]
    pub outbounds: ::prost::alloc::vec::Vec<CbRule>,
    /// deprecated
    #[prost(message, optional, tag = "9")]
    pub token: ::core::option::Option<::prost::alloc::string::String>,
    /// deprecated
    #[prost(message, optional, tag = "10")]
    pub owners: ::core::option::Option<::prost::alloc::string::String>,
    /// 业务
    /// deprecated
    #[prost(message, optional, tag = "11")]
    pub business: ::core::option::Option<::prost::alloc::string::String>,
    /// 部门
    /// deprecated
    #[prost(message, optional, tag = "12")]
    pub department: ::core::option::Option<::prost::alloc::string::String>,
    /// 规则描述
    /// deprecated
    #[prost(message, optional, tag = "13")]
    pub comment: ::core::option::Option<::prost::alloc::string::String>,
    /// deprecated
    #[prost(message, optional, tag = "14")]
    pub ctime: ::core::option::Option<::prost::alloc::string::String>,
    /// deprecated
    #[prost(message, optional, tag = "15")]
    pub mtime: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "16")]
    pub revision: ::core::option::Option<::prost::alloc::string::String>,
    /// circuitbreaker rules for current service
    #[prost(message, repeated, tag = "21")]
    pub rules: ::prost::alloc::vec::Vec<CircuitBreakerRule>,
}
/// 主调匹配规则
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SourceMatcher {
    /// 主调命名空间以及服务名，可以为*，代表全匹配
    #[prost(message, optional, tag = "1")]
    pub service: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub namespace: ::core::option::Option<::prost::alloc::string::String>,
    /// 可选，主调业务标签，用于匹配是否使用该熔断规则，可放置用户的接口信息等
    #[prost(map = "string, message", tag = "3")]
    pub labels: ::std::collections::HashMap<::prost::alloc::string::String, MatchString>,
}
/// 熔断恢复配置
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct RecoverConfig {
    /// 触发熔断后到半开状态之间的等待间隔
    #[prost(message, optional, tag = "1")]
    pub sleep_window: ::core::option::Option<::prost_types::Duration>,
    /// 半开后，最多重试多少次恢复
    #[prost(message, optional, tag = "2")]
    pub max_retry_after_half_open: ::core::option::Option<u32>,
    /// 半开后放量的最大百分比
    #[prost(message, repeated, tag = "3")]
    pub request_rate_after_half_open: ::prost::alloc::vec::Vec<u32>,
    /// 熔断器半开到关闭所必须的最少成功率，默认100%
    #[prost(message, optional, tag = "4")]
    pub success_rate_to_close: ::core::option::Option<u32>,
    /// 半开后最大放量数（用户不配置最大百分比时默认使用该配置）
    #[prost(message, optional, tag = "5")]
    pub request_count_after_half_open: ::core::option::Option<u32>,
    #[prost(enumeration = "recover_config::OutlierDetectWhen", tag = "6")]
    pub outlier_detect_when: i32,
}
/// Nested message and enum types in `RecoverConfig`.
pub mod recover_config {
    /// 主动探测配置
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum OutlierDetectWhen {
        /// 不开启监控探测
        Never = 0,
        /// 只有在熔断恢复时才开启健康探测
        OnRecover = 1,
        /// 一直开启健康探测
        Always = 2,
    }
    impl OutlierDetectWhen {
        /// 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 {
                OutlierDetectWhen::Never => "NEVER",
                OutlierDetectWhen::OnRecover => "ON_RECOVER",
                OutlierDetectWhen::Always => "ALWAYS",
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "NEVER" => Some(Self::Never),
                "ON_RECOVER" => Some(Self::OnRecover),
                "ALWAYS" => Some(Self::Always),
                _ => None,
            }
        }
    }
}
/// 熔断策略
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CbPolicy {
    #[prost(message, optional, tag = "1")]
    pub error_rate: ::core::option::Option<cb_policy::ErrRateConfig>,
    #[prost(message, optional, tag = "2")]
    pub slow_rate: ::core::option::Option<cb_policy::SlowRateConfig>,
    /// 熔断的决策周期，多久触发一次熔断决策
    #[prost(message, optional, tag = "3")]
    pub judge_duration: ::core::option::Option<::prost_types::Duration>,
    /// 最大熔断比例，超过多少比例后不会继续熔断
    #[prost(message, optional, tag = "4")]
    pub max_ejection_percent: ::core::option::Option<u32>,
    #[prost(message, optional, tag = "5")]
    pub consecutive: ::core::option::Option<cb_policy::ConsecutiveErrConfig>,
}
/// Nested message and enum types in `CbPolicy`.
pub mod cb_policy {
    /// 错误率熔断配置
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct ErrRateConfig {
        /// 是否启用错误率配置
        #[prost(message, optional, tag = "1")]
        pub enable: ::core::option::Option<bool>,
        /// 触发错误率熔断的最低请求阈值
        #[prost(message, optional, tag = "2")]
        pub request_volume_threshold: ::core::option::Option<u32>,
        /// 可选。触发保持状态的错误率阈值，假如不配置，则默认不会进入Preserved状态
        #[prost(message, optional, tag = "3")]
        pub error_rate_to_preserved: ::core::option::Option<u32>,
        /// 触发熔断的错误率阈值
        #[prost(message, optional, tag = "4")]
        pub error_rate_to_open: ::core::option::Option<u32>,
        #[prost(message, repeated, tag = "5")]
        pub specials: ::prost::alloc::vec::Vec<err_rate_config::SpecialConfig>,
    }
    /// Nested message and enum types in `ErrRateConfig`.
    pub mod err_rate_config {
        /// 错误码相关特定配置
        #[allow(clippy::derive_partial_eq_without_eq)]
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct SpecialConfig {
            /// 熔断关心的错误类型，用户可以自己定义
            #[prost(message, optional, tag = "1")]
            pub r#type: ::core::option::Option<::prost::alloc::string::String>,
            #[prost(message, repeated, tag = "2")]
            pub error_codes: ::prost::alloc::vec::Vec<i64>,
            #[prost(message, optional, tag = "3")]
            pub error_rate_to_preserved: ::core::option::Option<u32>,
            #[prost(message, optional, tag = "4")]
            pub error_rate_to_open: ::core::option::Option<u32>,
        }
    }
    /// 慢调用率熔断策略配置
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct SlowRateConfig {
        /// 是否启用慢调用率配置
        #[prost(message, optional, tag = "1")]
        pub enable: ::core::option::Option<bool>,
        /// 最大响应时间，超过该时间属于慢调用请求
        #[prost(message, optional, tag = "2")]
        pub max_rt: ::core::option::Option<::prost_types::Duration>,
        /// 可选。触发保持状态的超时率阈值，假如不配置，则默认不会进入Preserved状态
        #[prost(message, optional, tag = "3")]
        pub slow_rate_to_preserved: ::core::option::Option<u32>,
        /// 触发熔断的超时率阈值
        #[prost(message, optional, tag = "4")]
        pub slow_rate_to_open: ::core::option::Option<u32>,
    }
    /// 连续错误数熔断配置
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct ConsecutiveErrConfig {
        /// 是否启用连续错误数配置
        #[prost(message, optional, tag = "1")]
        pub enable: ::core::option::Option<bool>,
        /// 连续错误数阈值，进入Preserved状态
        #[prost(message, optional, tag = "2")]
        pub consecutive_error_to_preserved: ::core::option::Option<u32>,
        /// 连续错误数阈值，进入Open状态
        #[prost(message, optional, tag = "3")]
        pub consecutive_error_to_open: ::core::option::Option<u32>,
    }
}
/// 目标set的规则
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DestinationSet {
    /// 被调命名空间以及服务名，可以为*，代表全匹配
    #[prost(message, optional, tag = "1")]
    pub service: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub namespace: ::core::option::Option<::prost::alloc::string::String>,
    /// 可选，SUBSET标识
    #[prost(map = "string, message", tag = "3")]
    pub metadata: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        MatchString,
    >,
    #[prost(enumeration = "destination_set::Resource", tag = "4")]
    pub resource: i32,
    #[prost(enumeration = "destination_set::Type", tag = "5")]
    pub r#type: i32,
    #[prost(enumeration = "destination_set::Scope", tag = "6")]
    pub scope: i32,
    /// 熔断数据度量周期
    /// 所有的阈值指标按此周期进行统计
    #[prost(message, optional, tag = "7")]
    pub metric_window: ::core::option::Option<::prost_types::Duration>,
    /// 熔断数据统计精度，决定数据度量的最小周期
    /// 度量滑窗的步长=window/precision
    #[prost(message, optional, tag = "8")]
    pub metric_precision: ::core::option::Option<u32>,
    /// 熔断数据上报周期，对分布式熔断有效
    #[prost(message, optional, tag = "9")]
    pub update_interval: ::core::option::Option<::prost_types::Duration>,
    /// 触发熔断后恢复配置
    #[prost(message, optional, tag = "10")]
    pub recover: ::core::option::Option<RecoverConfig>,
    /// 熔断策略
    #[prost(message, optional, tag = "11")]
    pub policy: ::core::option::Option<CbPolicy>,
    /// 被调的接口信息，指定哪些接口会使用该规则
    #[prost(message, optional, tag = "12")]
    pub method: ::core::option::Option<MatchString>,
    /// 返回码，指定哪些返回码会使用该规则
    #[prost(message, repeated, tag = "13")]
    pub error_codes: ::prost::alloc::vec::Vec<i64>,
}
/// Nested message and enum types in `DestinationSet`.
pub mod destination_set {
    /// 需要进行熔断的资源
    /// 支持SUBSET（子集群），以及INSTANCE（单个实例），默认为SUBSET
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum Resource {
        /// 针对实例分组进行熔断
        Subset = 0,
        /// 针对实例进行熔断
        Instance = 1,
    }
    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 {
                Resource::Subset => "SUBSET",
                Resource::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 {
                "SUBSET" => Some(Self::Subset),
                "INSTANCE" => Some(Self::Instance),
                _ => None,
            }
        }
    }
    /// 熔断决策类型，支持GLOBAL（分布式决策）以及LOCAL(本地决策），默认GLOBAL
    /// 当指定为GLOBAL时，则会定期上报统计数据并根据汇总数据进行熔断决策
    #[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 {
                Type::Global => "GLOBAL",
                Type::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,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum Scope {
        /// 触发熔断条件，扩散熔断所有接口
        All = 0,
        /// 触发熔断条件，只熔断当前接口
        Current = 1,
    }
    impl Scope {
        /// 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 {
                Scope::All => "ALL",
                Scope::Current => "CURRENT",
            }
        }
        /// 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),
                "CURRENT" => Some(Self::Current),
                _ => None,
            }
        }
    }
}
/// 具体熔断规则
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CbRule {
    /// 如果匹配Source规则，按照Destination进行熔断
    /// 多个Source之间的关系为或
    #[prost(message, repeated, tag = "1")]
    pub sources: ::prost::alloc::vec::Vec<SourceMatcher>,
    #[prost(message, repeated, tag = "2")]
    pub destinations: ::prost::alloc::vec::Vec<DestinationSet>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::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 {
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, PartialEq, ::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,
    }
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, PartialEq, ::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
#[allow(clippy::derive_partial_eq_without_eq)]
#[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
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::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 {
                InputType::Unknown => "UNKNOWN",
                InputType::RetCode => "RET_CODE",
                InputType::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
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::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 {
                TriggerType::Unknown => "UNKNOWN",
                TriggerType::ErrorRate => "ERROR_RATE",
                TriggerType::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
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::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
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FaultDetectConfig {
    #[prost(bool, tag = "1")]
    pub enable: bool,
}
/// blocking strategy
#[allow(clippy::derive_partial_eq_without_eq)]
#[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
#[allow(clippy::derive_partial_eq_without_eq)]
#[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
#[allow(clippy::derive_partial_eq_without_eq)]
#[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 {
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, PartialEq, ::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 {
            Level::Unknown => "UNKNOWN",
            Level::Service => "SERVICE",
            Level::Method => "METHOD",
            Level::Group => "GROUP",
            Level::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,
        }
    }
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ConfigRelease {
    #[prost(message, optional, tag = "1")]
    pub service: ::core::option::Option<Service>,
    #[prost(message, optional, tag = "2")]
    pub ctime: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "3")]
    pub mtime: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "4")]
    pub circuit_breaker: ::core::option::Option<CircuitBreaker>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ConfigWithService {
    #[prost(message, repeated, tag = "1")]
    pub services: ::prost::alloc::vec::Vec<Service>,
    #[prost(message, optional, tag = "2")]
    pub circuit_breaker: ::core::option::Option<CircuitBreaker>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[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,
    >,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::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,
}
/// 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 {
                Source::Unknown => "UNKNOWN",
                Source::Manual => "Manual",
                Source::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,
            }
        }
    }
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ConfigFileGroup {
    #[prost(message, optional, tag = "1")]
    pub id: ::core::option::Option<u64>,
    #[prost(message, optional, tag = "2")]
    pub name: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "3")]
    pub namespace: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "4")]
    pub comment: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "5")]
    pub create_time: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "6")]
    pub create_by: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "7")]
    pub modify_time: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "8")]
    pub modify_by: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "9")]
    pub file_count: ::core::option::Option<u64>,
    #[prost(message, repeated, tag = "10")]
    pub user_ids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    #[prost(message, repeated, tag = "11")]
    pub group_ids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    #[prost(message, repeated, tag = "13")]
    pub remove_user_ids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    #[prost(message, repeated, tag = "14")]
    pub remove_group_ids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "15")]
    pub editable: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "16")]
    pub owner: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "17")]
    pub business: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "18")]
    pub department: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(map = "string, string", tag = "19")]
    pub metadata: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    /// 删除操作标志位
    #[prost(message, optional, tag = "20")]
    pub deleteable: ::core::option::Option<bool>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ConfigFile {
    #[prost(message, optional, tag = "1")]
    pub id: ::core::option::Option<u64>,
    #[prost(message, optional, tag = "2")]
    pub name: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "3")]
    pub namespace: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "4")]
    pub group: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "5")]
    pub content: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "6")]
    pub format: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "7")]
    pub comment: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "8")]
    pub status: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, repeated, tag = "9")]
    pub tags: ::prost::alloc::vec::Vec<ConfigFileTag>,
    #[prost(message, optional, tag = "10")]
    pub create_time: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "11")]
    pub create_by: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "12")]
    pub modify_time: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "13")]
    pub modify_by: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "14")]
    pub release_time: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "15")]
    pub release_by: ::core::option::Option<::prost::alloc::string::String>,
    /// 是否为加密配置文件
    #[prost(message, optional, tag = "16")]
    pub encrypted: ::core::option::Option<bool>,
    /// 加密算法
    #[prost(message, optional, tag = "17")]
    pub encrypt_algo: ::core::option::Option<::prost::alloc::string::String>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ConfigFileTag {
    #[prost(message, optional, tag = "1")]
    pub key: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub value: ::core::option::Option<::prost::alloc::string::String>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ConfigFileRelease {
    #[prost(message, optional, tag = "1")]
    pub id: ::core::option::Option<u64>,
    #[prost(message, optional, tag = "2")]
    pub name: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "3")]
    pub namespace: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "4")]
    pub group: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "5")]
    pub file_name: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "6")]
    pub content: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "7")]
    pub comment: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "8")]
    pub md5: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "9")]
    pub version: ::core::option::Option<u64>,
    #[prost(message, optional, tag = "10")]
    pub create_time: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "11")]
    pub create_by: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "12")]
    pub modify_time: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "13")]
    pub modify_by: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, repeated, tag = "14")]
    pub tags: ::prost::alloc::vec::Vec<ConfigFileTag>,
    /// 当前生效配置
    #[prost(message, optional, tag = "15")]
    pub active: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "16")]
    pub format: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "17")]
    pub release_description: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "18")]
    pub release_type: ::core::option::Option<::prost::alloc::string::String>,
    /// 配置灰度发布时需要匹配的客户端标签信息
    #[prost(message, repeated, tag = "19")]
    pub beta_labels: ::prost::alloc::vec::Vec<ClientLabel>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ConfigFileReleaseHistory {
    #[prost(message, optional, tag = "1")]
    pub id: ::core::option::Option<u64>,
    #[prost(message, optional, tag = "2")]
    pub name: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "3")]
    pub namespace: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "4")]
    pub group: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "5")]
    pub file_name: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "6")]
    pub content: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "7")]
    pub format: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "8")]
    pub comment: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "9")]
    pub md5: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "10")]
    pub r#type: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "11")]
    pub status: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, repeated, tag = "12")]
    pub tags: ::prost::alloc::vec::Vec<ConfigFileTag>,
    #[prost(message, optional, tag = "13")]
    pub create_time: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "14")]
    pub create_by: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "15")]
    pub modify_time: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "16")]
    pub modify_by: ::core::option::Option<::prost::alloc::string::String>,
    /// 配置发布失败的原因
    #[prost(message, optional, tag = "17")]
    pub reason: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "18")]
    pub release_description: ::core::option::Option<::prost::alloc::string::String>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ConfigFileTemplate {
    #[prost(message, optional, tag = "1")]
    pub id: ::core::option::Option<u64>,
    #[prost(message, optional, tag = "2")]
    pub name: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "3")]
    pub content: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "4")]
    pub format: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "5")]
    pub comment: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "6")]
    pub create_time: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "7")]
    pub create_by: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "8")]
    pub modify_time: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "9")]
    pub modify_by: ::core::option::Option<::prost::alloc::string::String>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ClientConfigFileInfo {
    #[prost(message, optional, tag = "1")]
    pub namespace: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub group: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "3")]
    pub file_name: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "4")]
    pub content: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "5")]
    pub version: ::core::option::Option<u64>,
    #[prost(message, optional, tag = "6")]
    pub md5: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, repeated, tag = "7")]
    pub tags: ::prost::alloc::vec::Vec<ConfigFileTag>,
    /// 是否为加密配置文件
    #[prost(message, optional, tag = "8")]
    pub encrypted: ::core::option::Option<bool>,
    /// 公钥，用于加密数据密钥
    #[prost(message, optional, tag = "9")]
    pub public_key: ::core::option::Option<::prost::alloc::string::String>,
    /// 配置文件版本名称
    #[prost(message, optional, tag = "10")]
    pub name: ::core::option::Option<::prost::alloc::string::String>,
    /// 配置文件的发布时间
    #[prost(message, optional, tag = "11")]
    pub release_time: ::core::option::Option<::prost::alloc::string::String>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ClientWatchConfigFileRequest {
    #[prost(message, optional, tag = "1")]
    pub client_ip: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub service_name: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, repeated, tag = "3")]
    pub watch_files: ::prost::alloc::vec::Vec<ClientConfigFileInfo>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ConfigFileExportRequest {
    #[prost(message, optional, tag = "1")]
    pub namespace: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, repeated, tag = "2")]
    pub groups: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    #[prost(message, repeated, tag = "3")]
    pub names: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ConfigFilePublishInfo {
    #[prost(message, optional, tag = "1")]
    pub release_name: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub namespace: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "3")]
    pub group: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "4")]
    pub file_name: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "5")]
    pub content: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "6")]
    pub comment: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "7")]
    pub format: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "8")]
    pub release_description: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "11")]
    pub create_by: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "13")]
    pub modify_by: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, repeated, tag = "14")]
    pub tags: ::prost::alloc::vec::Vec<ConfigFileTag>,
    #[prost(message, optional, tag = "15")]
    pub md5: ::core::option::Option<::prost::alloc::string::String>,
    /// 是否为加密配置文件
    #[prost(message, optional, tag = "16")]
    pub encrypted: ::core::option::Option<bool>,
    /// 加密算法
    #[prost(message, optional, tag = "17")]
    pub encrypt_algo: ::core::option::Option<::prost::alloc::string::String>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ConfigFileGroupRequest {
    #[prost(message, optional, tag = "1")]
    pub revision: ::core::option::Option<::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,
    >,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[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 config_file: ::core::option::Option<ClientConfigFileInfo>,
    #[prost(string, tag = "3")]
    pub revision: ::prost::alloc::string::String,
}
/// 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 {
                ConfigDiscoverRequestType::Unknown => "UNKNOWN",
                ConfigDiscoverRequestType::ConfigFile => "CONFIG_FILE",
                ConfigDiscoverRequestType::ConfigFileNames => "CONFIG_FILE_Names",
                ConfigDiscoverRequestType::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,
            }
        }
    }
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[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 config_file: ::core::option::Option<ClientConfigFileInfo>,
    #[prost(message, repeated, tag = "6")]
    pub config_file_names: ::prost::alloc::vec::Vec<ClientConfigFileInfo>,
    #[prost(message, repeated, tag = "7")]
    pub config_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 {
                ConfigDiscoverResponseType::Unknown => "UNKNOWN",
                ConfigDiscoverResponseType::ConfigFile => "CONFIG_FILE",
                ConfigDiscoverResponseType::ConfigFileNames => "CONFIG_FILE_Names",
                ConfigDiscoverResponseType::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,
            }
        }
    }
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Client {
    #[prost(message, optional, tag = "1")]
    pub host: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(enumeration = "client::ClientType", tag = "2")]
    pub r#type: i32,
    #[prost(message, optional, tag = "3")]
    pub version: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "4")]
    pub location: ::core::option::Option<Location>,
    #[prost(message, optional, tag = "5")]
    pub id: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, repeated, tag = "6")]
    pub stat: ::prost::alloc::vec::Vec<StatInfo>,
    #[prost(message, optional, tag = "7")]
    pub ctime: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "8")]
    pub mtime: ::core::option::Option<::prost::alloc::string::String>,
}
/// Nested message and enum types in `Client`.
pub mod client {
    #[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 {
                ClientType::Unknown => "UNKNOWN",
                ClientType::Sdk => "SDK",
                ClientType::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,
            }
        }
    }
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct StatInfo {
    #[prost(message, optional, tag = "1")]
    pub target: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub port: ::core::option::Option<u32>,
    #[prost(message, optional, tag = "3")]
    pub path: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "4")]
    pub protocol: ::core::option::Option<::prost::alloc::string::String>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DiscoverFilter {
    #[prost(bool, tag = "1")]
    pub only_healthy_instance: bool,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[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,
        Instance = 1,
        Cluster = 2,
        Routing = 3,
        RateLimit = 4,
        CircuitBreaker = 5,
        Services = 6,
        Namespaces = 12,
        FaultDetector = 13,
        Lane = 100,
        /// 自定义路由规则
        CustomRouteRule = 101,
        /// 就近路由规则
        NearbyRouteRule = 102,
        /// 无损上下线规则
        Lossless = 103,
        /// 服务黑白名单规则
        BlockAllowRule = 104,
    }
    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 {
                DiscoverRequestType::Unknown => "UNKNOWN",
                DiscoverRequestType::Instance => "INSTANCE",
                DiscoverRequestType::Cluster => "CLUSTER",
                DiscoverRequestType::Routing => "ROUTING",
                DiscoverRequestType::RateLimit => "RATE_LIMIT",
                DiscoverRequestType::CircuitBreaker => "CIRCUIT_BREAKER",
                DiscoverRequestType::Services => "SERVICES",
                DiscoverRequestType::Namespaces => "NAMESPACES",
                DiscoverRequestType::FaultDetector => "FAULT_DETECTOR",
                DiscoverRequestType::Lane => "LANE",
                DiscoverRequestType::CustomRouteRule => "CUSTOM_ROUTE_RULE",
                DiscoverRequestType::NearbyRouteRule => "NEARBY_ROUTE_RULE",
                DiscoverRequestType::Lossless => "LOSSLESS",
                DiscoverRequestType::BlockAllowRule => "BLOCK_ALLOW_RULE",
            }
        }
        /// 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),
                "INSTANCE" => Some(Self::Instance),
                "CLUSTER" => Some(Self::Cluster),
                "ROUTING" => Some(Self::Routing),
                "RATE_LIMIT" => Some(Self::RateLimit),
                "CIRCUIT_BREAKER" => Some(Self::CircuitBreaker),
                "SERVICES" => Some(Self::Services),
                "NAMESPACES" => Some(Self::Namespaces),
                "FAULT_DETECTOR" => Some(Self::FaultDetector),
                "LANE" => Some(Self::Lane),
                "CUSTOM_ROUTE_RULE" => Some(Self::CustomRouteRule),
                "NEARBY_ROUTE_RULE" => Some(Self::NearbyRouteRule),
                "LOSSLESS" => Some(Self::Lossless),
                "BLOCK_ALLOW_RULE" => Some(Self::BlockAllowRule),
                _ => None,
            }
        }
    }
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Namespace {
    #[prost(message, optional, tag = "1")]
    pub name: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub comment: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "3")]
    pub owners: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "4")]
    pub token: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "5")]
    pub ctime: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "6")]
    pub mtime: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "7")]
    pub total_service_count: ::core::option::Option<u32>,
    #[prost(message, optional, tag = "8")]
    pub total_health_instance_count: ::core::option::Option<u32>,
    #[prost(message, optional, tag = "9")]
    pub total_instance_count: ::core::option::Option<u32>,
    #[prost(message, repeated, tag = "10")]
    pub user_ids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    #[prost(message, repeated, tag = "11")]
    pub group_ids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    #[prost(message, repeated, tag = "13")]
    pub remove_user_ids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    #[prost(message, repeated, tag = "14")]
    pub remove_group_ids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "12")]
    pub id: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "15")]
    pub editable: ::core::option::Option<bool>,
    #[prost(message, repeated, tag = "16")]
    pub service_export_to: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    #[prost(map = "string, string", tag = "17")]
    pub metadata: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    #[prost(message, optional, tag = "18")]
    pub deleteable: ::core::option::Option<bool>,
}
/// 规则所属服务以及命名空间
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Routing {
    #[prost(message, optional, tag = "1")]
    pub service: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub namespace: ::core::option::Option<::prost::alloc::string::String>,
    /// 每个服务可以配置多条入站或者出站规则
    /// 对于每个请求，从上到下依次匹配，若命中则终止
    #[prost(message, repeated, tag = "3")]
    pub inbounds: ::prost::alloc::vec::Vec<Route>,
    #[prost(message, repeated, tag = "4")]
    pub outbounds: ::prost::alloc::vec::Vec<Route>,
    #[prost(message, optional, tag = "5")]
    pub ctime: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "6")]
    pub mtime: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "7")]
    pub revision: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "8")]
    pub service_token: ::core::option::Option<::prost::alloc::string::String>,
    /// route rules for current service
    #[prost(message, repeated, tag = "21")]
    pub rules: ::prost::alloc::vec::Vec<RouteRule>,
}
/// deprecated: only for compatible to the old version server
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Route {
    /// 如果匹配Source规则，按照Destination路由
    /// 多个Source之间的关系为或
    #[prost(message, repeated, tag = "1")]
    pub sources: ::prost::alloc::vec::Vec<Source>,
    #[prost(message, repeated, tag = "2")]
    pub destinations: ::prost::alloc::vec::Vec<Destination>,
    /// extendInfo 用于承载一些额外信息
    /// case 1: 升级到 v2 版本时，记录对应到 v2 版本的 id 信息
    #[prost(map = "string, string", tag = "3")]
    pub extend_info: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
}
/// deprecated: only for compatible to the old version server
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Source {
    /// 主调方服务以及命名空间
    #[prost(message, optional, tag = "1")]
    pub service: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub namespace: ::core::option::Option<::prost::alloc::string::String>,
    /// 主调方服务实例标签或者请求标签
    /// value支持正则匹配
    #[prost(map = "string, message", tag = "3")]
    pub metadata: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        MatchString,
    >,
}
/// deprecated: only for compatible to the old version server
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Destination {
    /// 被调方服务以及命名空间
    #[prost(message, optional, tag = "1")]
    pub service: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub namespace: ::core::option::Option<::prost::alloc::string::String>,
    /// 被调方服务实例标签
    /// value支持正则匹配
    #[prost(map = "string, message", tag = "3")]
    pub metadata: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        MatchString,
    >,
    /// 根据服务名和服务实例metadata筛选符合条件的服务实例子集
    /// 服务实例子集可以设置优先级和权重
    /// 优先级：整型，范围\[0, 9\]，最高优先级为0
    /// 权重：整型
    /// 先按优先级路由，如果存在高优先级，不会使用低优先级
    /// 如果存在优先级相同的子集，再按权重分配
    /// 优先级和权重可以都不设置/设置一个/设置两个
    /// 如果部分设置优先级，部分没有设置，认为没有设置的优先级最低
    /// 如果部分设置权重，部分没有设置，认为没有设置的权重为0
    /// 如果全部没有设置权重，认为权重相同
    #[prost(message, optional, tag = "4")]
    pub priority: ::core::option::Option<u32>,
    #[prost(message, optional, tag = "5")]
    pub weight: ::core::option::Option<u32>,
    /// 将请求转发到代理服务
    #[prost(message, optional, tag = "6")]
    pub transfer: ::core::option::Option<::prost::alloc::string::String>,
    /// 是否对该set执行隔离，隔离后，不会再分配流量
    #[prost(message, optional, tag = "7")]
    pub isolate: ::core::option::Option<bool>,
    /// 实例分组名
    #[prost(message, optional, tag = "8")]
    pub name: ::core::option::Option<::prost::alloc::string::String>,
}
/// configuration root for route
#[allow(clippy::derive_partial_eq_without_eq)]
#[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 = "RoutingPolicy", tag = "5")]
    pub routing_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,
    /// extendInfo 用于承载一些额外信息
    /// case 1: 升级到 v2 版本时，记录对应到 v1 版本的 id 信息
    /// deprecated_filed only for compatible to the old version server
    #[prost(map = "string, string", tag = "20")]
    pub extend_info: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::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,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[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 {
                FailoverRange::All => "ALL",
                FailoverRange::Others => "OTHERS",
                FailoverRange::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
#[allow(clippy::derive_partial_eq_without_eq)]
#[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
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::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 {
                LocationLevel::Unknown => "UNKNOWN",
                LocationLevel::Campus => "CAMPUS",
                LocationLevel::Zone => "ZONE",
                LocationLevel::Region => "REGION",
                LocationLevel::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,
            }
        }
    }
}
/// RuleRoutingConfig routing configuration
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct RuleRoutingConfig {
    /// source source info
    /// deprecated_filed  only for compatible to the old version server
    #[deprecated]
    #[prost(message, repeated, tag = "1")]
    pub sources: ::prost::alloc::vec::Vec<SourceService>,
    /// destination destinations info
    /// deprecated_filed  only for compatible to the old version server
    #[deprecated]
    #[prost(message, repeated, tag = "2")]
    pub destinations: ::prost::alloc::vec::Vec<DestinationGroup>,
    /// rule route chain
    #[prost(message, repeated, tag = "3")]
    pub rules: ::prost::alloc::vec::Vec<SubRuleRouting>,
}
/// SubRuleRouting sub routing configuration
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SubRuleRouting {
    /// sub routing rule name
    #[prost(string, tag = "1")]
    pub name: ::prost::alloc::string::String,
    /// source source info
    #[prost(message, repeated, tag = "2")]
    pub sources: ::prost::alloc::vec::Vec<SourceService>,
    /// destination destinations info
    #[prost(message, repeated, tag = "3")]
    pub destinations: ::prost::alloc::vec::Vec<DestinationGroup>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::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,
    /// Master Control Service Example Tag or Request Label
    /// Value supports regular matching
    #[prost(message, repeated, tag = "3")]
    pub arguments: ::prost::alloc::vec::Vec<SourceMatch>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[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,
}
/// SourceMatch
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::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 {
                Type::Custom => "CUSTOM",
                Type::Method => "METHOD",
                Type::Header => "HEADER",
                Type::Query => "QUERY",
                Type::CallerIp => "CALLER_IP",
                Type::Path => "PATH",
                Type::Cookie => "COOKIE",
                Type::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 RoutingPolicy {
    /// Route by rule rule => RuleRoutingConfig
    RulePolicy = 0,
    /// Route by destination metadata ==> MetadataRoutingConfig
    MetadataPolicy = 1,
    /// Route by Nearby rule => NearByRoutingConfig
    NearbyPolicy = 2,
}
impl RoutingPolicy {
    /// 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 {
            RoutingPolicy::RulePolicy => "RulePolicy",
            RoutingPolicy::MetadataPolicy => "MetadataPolicy",
            RoutingPolicy::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,
        }
    }
}
/// 同一服务下限流规则集合
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct RateLimit {
    /// 限流规则集合
    #[prost(message, repeated, tag = "1")]
    pub rules: ::prost::alloc::vec::Vec<Rule>,
    /// 限流规则汇总的revision信息
    #[prost(message, optional, tag = "2")]
    pub revision: ::core::option::Option<::prost::alloc::string::String>,
}
/// 单个限流规则信息
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Rule {
    /// 限流规则唯一标识
    #[prost(message, optional, tag = "1")]
    pub id: ::core::option::Option<::prost::alloc::string::String>,
    /// 限流规则所属服务名
    #[prost(message, optional, tag = "2")]
    pub service: ::core::option::Option<::prost::alloc::string::String>,
    /// 限流规则所属命名空间
    #[prost(message, optional, tag = "3")]
    pub namespace: ::core::option::Option<::prost::alloc::string::String>,
    /// 可选，SUBSET标识
    #[prost(map = "string, message", tag = "4")]
    pub subset: ::std::collections::HashMap<::prost::alloc::string::String, MatchString>,
    /// 限流规则优先级，0值最高
    #[prost(message, optional, tag = "5")]
    pub priority: ::core::option::Option<u32>,
    #[prost(enumeration = "rule::Resource", tag = "6")]
    pub resource: i32,
    #[prost(enumeration = "rule::Type", tag = "7")]
    pub r#type: i32,
    /// 业务标签集合，通过KV进行匹配，全部匹配才使用该规则
    #[prost(map = "string, message", tag = "8")]
    pub labels: ::std::collections::HashMap<::prost::alloc::string::String, MatchString>,
    /// 限流阈值
    /// 可以有多个粒度的配置（比如同时针对秒级，分钟级，天级），匹配一个则进行限流
    /// 全局限流模式下，该值为服务配额总量；单机限流模式下，该值为单个节点能处理的配额量
    #[prost(message, repeated, tag = "9")]
    pub amounts: ::prost::alloc::vec::Vec<Amount>,
    /// 限流动作，和 resource 配合决定插件名称
    #[prost(message, optional, tag = "10")]
    pub action: ::core::option::Option<::prost::alloc::string::String>,
    /// 是否停用该限流规则，默认启用
    #[prost(message, optional, tag = "11")]
    pub disable: ::core::option::Option<bool>,
    /// 限流上报方式，同时支持按固定周期上报，以及达到配额百分比后上报
    #[prost(message, optional, tag = "12")]
    pub report: ::core::option::Option<Report>,
    /// 限流规则创建时间
    #[prost(message, optional, tag = "13")]
    pub ctime: ::core::option::Option<::prost::alloc::string::String>,
    /// 限流规则修改时间
    #[prost(message, optional, tag = "14")]
    pub mtime: ::core::option::Option<::prost::alloc::string::String>,
    /// 限流规则revision信息
    #[prost(message, optional, tag = "15")]
    pub revision: ::core::option::Option<::prost::alloc::string::String>,
    /// 服务的TOKEN信息，仅用于控制台，discover接口不下发
    #[prost(message, optional, tag = "16")]
    pub service_token: ::core::option::Option<::prost::alloc::string::String>,
    /// 配额调整算法
    #[prost(message, optional, tag = "17")]
    pub adjuster: ::core::option::Option<AmountAdjuster>,
    /// 通配符是否合并计算，默认分开计数
    #[prost(message, optional, tag = "18")]
    pub regex_combine: ::core::option::Option<bool>,
    #[prost(enumeration = "rule::AmountMode", tag = "19")]
    pub amount_mode: i32,
    #[prost(enumeration = "rule::FailoverType", tag = "20")]
    pub failover: i32,
    /// 分布式限流服务集群
    #[prost(message, optional, tag = "21")]
    pub cluster: ::core::option::Option<RateLimitCluster>,
    /// 被调接口名
    #[prost(message, optional, tag = "22")]
    pub method: ::core::option::Option<MatchString>,
    /// 被调的参数过滤条件，满足过滤条件才进入限流规则
    #[prost(message, repeated, tag = "23")]
    pub arguments: ::prost::alloc::vec::Vec<MatchArgument>,
    /// 限流规则名
    #[prost(message, optional, tag = "24")]
    pub name: ::core::option::Option<::prost::alloc::string::String>,
    /// 限流规则启用时间
    #[prost(message, optional, tag = "25")]
    pub etime: ::core::option::Option<::prost::alloc::string::String>,
    /// 最大排队时长，单位秒
    #[prost(message, optional, tag = "26")]
    pub max_queue_delay: ::core::option::Option<u32>,
    /// amount for concurrency rate-limit
    #[prost(message, optional, tag = "27")]
    pub concurrency_amount: ::core::option::Option<ConcurrencyAmount>,
    /// fallback configuration
    #[prost(message, optional, tag = "28")]
    pub custom_response: ::core::option::Option<CustomResponse>,
    /// 限流规则标签数据
    #[prost(map = "string, string", tag = "29")]
    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 `Rule`.
pub mod rule {
    /// 限流资源
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum Resource {
        /// 针对QPS进行限流
        Qps = 0,
        /// 针对并发数进行限流
        Concurrency = 1,
    }
    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 {
                Resource::Qps => "QPS",
                Resource::Concurrency => "CONCURRENCY",
            }
        }
        /// 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),
                _ => None,
            }
        }
    }
    /// 限流类型
    /// 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 {
                Type::Global => "GLOBAL",
                Type::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,
        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 {
                AmountMode::GlobalTotal => "GLOBAL_TOTAL",
                AmountMode::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,
        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 {
                FailoverType::FailoverLocal => "FAILOVER_LOCAL",
                FailoverType::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,
            }
        }
    }
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::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 {
                Type::Custom => "CUSTOM",
                Type::Method => "METHOD",
                Type::Header => "HEADER",
                Type::Query => "QUERY",
                Type::CallerService => "CALLER_SERVICE",
                Type::CallerIp => "CALLER_IP",
                Type::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
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ConcurrencyAmount {
    #[prost(uint32, tag = "1")]
    pub max_amount: u32,
}
/// custom response text when limited
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CustomResponse {
    #[prost(string, tag = "3")]
    pub body: ::prost::alloc::string::String,
}
/// 分布式限流服务集群
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct RateLimitCluster {
    #[prost(message, optional, tag = "1")]
    pub service: ::core::option::Option<::prost::alloc::string::String>,
    /// 限流规则所属命名空间
    #[prost(message, optional, tag = "2")]
    pub namespace: ::core::option::Option<::prost::alloc::string::String>,
}
/// 限流配额
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Amount {
    /// 时间周期内的最大配额数
    #[prost(message, optional, tag = "1")]
    pub max_amount: ::core::option::Option<u32>,
    /// 配额生效的时间周期，必须大于等于1s
    #[prost(message, optional, tag = "2")]
    pub valid_duration: ::core::option::Option<::prost_types::Duration>,
    /// 请求统计精度
    #[prost(message, optional, tag = "3")]
    pub precision: ::core::option::Option<u32>,
    /// 可选，起始限流阈值，爬坡起始值
    #[prost(message, optional, tag = "4")]
    pub start_amount: ::core::option::Option<u32>,
    /// 可选，最小限流阈值，降低时最小值
    #[prost(message, optional, tag = "5")]
    pub min_amount: ::core::option::Option<u32>,
}
/// 限流上报方式
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Report {
    /// 配额固定上报周期，单位毫秒
    #[prost(message, optional, tag = "1")]
    pub interval: ::core::option::Option<::prost_types::Duration>,
    /// 使用了百分之多少配额后启动一次实时上报，值范围(0,100]
    #[prost(message, optional, tag = "2")]
    pub amount_percent: ::core::option::Option<u32>,
}
/// 配额调整算法
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AmountAdjuster {
    #[prost(message, optional, tag = "1")]
    pub climb: ::core::option::Option<ClimbConfig>,
}
/// 限流调整算法Climb相关配置
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ClimbConfig {
    /// 是否开启
    #[prost(message, optional, tag = "1")]
    pub enable: ::core::option::Option<bool>,
    /// 限流数据统计配置
    #[prost(message, optional, tag = "2")]
    pub metric: ::core::option::Option<climb_config::MetricConfig>,
    /// 触发调整策略
    #[prost(message, optional, tag = "3")]
    pub policy: ::core::option::Option<climb_config::TriggerPolicy>,
    /// 限流调整相关参数
    #[prost(message, optional, tag = "4")]
    pub throttling: ::core::option::Option<climb_config::ClimbThrottling>,
}
/// Nested message and enum types in `ClimbConfig`.
pub mod climb_config {
    /// 限流数据统计配置
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct MetricConfig {
        /// 限流数据度量周期，默认60s
        #[prost(message, optional, tag = "1")]
        pub window: ::core::option::Option<::prost_types::Duration>,
        /// 数据统计精度，决定数据度量的最小周期，度量滑窗的步长=window/precision
        #[prost(message, optional, tag = "2")]
        pub precision: ::core::option::Option<u32>,
        /// 上报周期，默认20s
        #[prost(message, optional, tag = "3")]
        pub report_interval: ::core::option::Option<::prost_types::Duration>,
    }
    /// 触发调整的策略
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct TriggerPolicy {
        /// 按错误率阈值调整
        #[prost(message, optional, tag = "1")]
        pub error_rate: ::core::option::Option<trigger_policy::ErrorRate>,
        /// 慢调用进行触发调整
        #[prost(message, optional, tag = "2")]
        pub slow_rate: ::core::option::Option<trigger_policy::SlowRate>,
    }
    /// Nested message and enum types in `TriggerPolicy`.
    pub mod trigger_policy {
        /// 错误率触发调整配置
        #[allow(clippy::derive_partial_eq_without_eq)]
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct ErrorRate {
            /// 是否开启
            #[prost(message, optional, tag = "1")]
            pub enable: ::core::option::Option<bool>,
            /// 触发限流调整的最小的请求数
            #[prost(message, optional, tag = "2")]
            pub request_volume_threshold: ::core::option::Option<u32>,
            /// 触发限流的错误率配置
            #[prost(message, optional, tag = "3")]
            pub error_rate: ::core::option::Option<i32>,
            /// 针对部分错误码，使用额外的错误率统计，可设置多组特殊规则
            #[prost(message, repeated, tag = "4")]
            pub specials: ::prost::alloc::vec::Vec<error_rate::SpecialConfig>,
        }
        /// Nested message and enum types in `ErrorRate`.
        pub mod error_rate {
            /// 特殊错误码触发调整配置
            #[allow(clippy::derive_partial_eq_without_eq)]
            #[derive(Clone, PartialEq, ::prost::Message)]
            pub struct SpecialConfig {
                /// 自定义错误类型
                #[prost(message, optional, tag = "1")]
                pub r#type: ::core::option::Option<::prost::alloc::string::String>,
                /// 特定规则针对的错误码
                #[prost(message, repeated, tag = "2")]
                pub error_codes: ::prost::alloc::vec::Vec<i64>,
                /// 特定规则错误率
                #[prost(message, optional, tag = "3")]
                pub error_rate: ::core::option::Option<i32>,
            }
        }
        /// 慢调用触发调整配置
        #[allow(clippy::derive_partial_eq_without_eq)]
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct SlowRate {
            /// 是否开启
            #[prost(message, optional, tag = "1")]
            pub enable: ::core::option::Option<bool>,
            /// 最大响应时间，超过该响应时间属于慢调用
            #[prost(message, optional, tag = "2")]
            pub max_rt: ::core::option::Option<::prost_types::Duration>,
            /// 慢请求率阈值，达到该阈值进行限流
            #[prost(message, optional, tag = "3")]
            pub slow_rate: ::core::option::Option<i32>,
        }
    }
    /// 爬坡调整相关参数
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct ClimbThrottling {
        /// 冷水位以下区间的下调百分比
        #[prost(message, optional, tag = "1")]
        pub cold_below_tune_down_rate: ::core::option::Option<i32>,
        /// 冷水位以下区间的上调百分比
        #[prost(message, optional, tag = "2")]
        pub cold_below_tune_up_rate: ::core::option::Option<i32>,
        /// 冷水位以上区间的下调百分比
        #[prost(message, optional, tag = "3")]
        pub cold_above_tune_down_rate: ::core::option::Option<i32>,
        /// 冷水位以上区间的上调百分比
        #[prost(message, optional, tag = "4")]
        pub cold_above_tune_up_rate: ::core::option::Option<i32>,
        /// 冷水位以上，超过该百分的请求被限流后进行阈值上调
        #[prost(message, optional, tag = "5")]
        pub limit_threshold_to_tune_up: ::core::option::Option<i32>,
        /// 阈值调整规则的决策间隔
        #[prost(message, optional, tag = "6")]
        pub judge_duration: ::core::option::Option<::prost_types::Duration>,
        /// 阈值上调周期数，连续N个决策间隔都为上调，才执行上调
        #[prost(message, optional, tag = "7")]
        pub tune_up_period: ::core::option::Option<i32>,
        /// 阈值下调周期数，连续N个决策间隔都为下调，才执行下调
        #[prost(message, optional, tag = "8")]
        pub tune_down_period: ::core::option::Option<i32>,
    }
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[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,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[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 {
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, PartialEq, ::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 {
                Protocol::Unknown => "UNKNOWN",
                Protocol::Http => "HTTP",
                Protocol::Tcp => "TCP",
                Protocol::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,
            }
        }
    }
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[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 {
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, PartialEq, ::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,
    }
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::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>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::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>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct LoginRequest {
    #[prost(message, optional, tag = "1")]
    pub owner: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub name: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "3")]
    pub password: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(map = "string, string", tag = "4")]
    pub options: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct LoginResponse {
    #[prost(message, optional, tag = "1")]
    pub user_id: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub name: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "3")]
    pub role: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "4")]
    pub owner_id: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "5")]
    pub token: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(map = "string, string", tag = "6")]
    pub options: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct User {
    #[prost(message, optional, tag = "1")]
    pub id: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub name: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "3")]
    pub password: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "4")]
    pub owner: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "5")]
    pub source: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "6")]
    pub auth_token: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "7")]
    pub token_enable: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "8")]
    pub comment: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "9")]
    pub ctime: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "10")]
    pub mtime: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "11")]
    pub user_type: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "12")]
    pub mobile: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "13")]
    pub email: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(map = "string, string", tag = "14")]
    pub metadata: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ModifyUserPassword {
    #[prost(message, optional, tag = "1")]
    pub id: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub old_password: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "3")]
    pub new_password: ::core::option::Option<::prost::alloc::string::String>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UserGroupRelation {
    #[prost(message, optional, tag = "1")]
    pub group_id: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, repeated, tag = "2")]
    pub users: ::prost::alloc::vec::Vec<User>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UserGroup {
    #[prost(message, optional, tag = "1")]
    pub id: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub name: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "3")]
    pub owner: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "4")]
    pub auth_token: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "5")]
    pub token_enable: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "6")]
    pub comment: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "7")]
    pub ctime: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "8")]
    pub mtime: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "9")]
    pub relation: ::core::option::Option<UserGroupRelation>,
    #[prost(message, optional, tag = "10")]
    pub user_count: ::core::option::Option<u32>,
    #[prost(message, optional, tag = "11")]
    pub source: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(map = "string, string", tag = "12")]
    pub metadata: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ModifyUserGroup {
    #[prost(message, optional, tag = "1")]
    pub id: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub owner: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "3")]
    pub name: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "4")]
    pub auth_token: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "5")]
    pub token_enable: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "6")]
    pub comment: ::core::option::Option<::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(message, optional, tag = "10")]
    pub source: ::core::option::Option<::prost::alloc::string::String>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[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>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Principal {
    #[prost(message, optional, tag = "1")]
    pub id: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub name: ::core::option::Option<::prost::alloc::string::String>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[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>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct StrategyResourceEntry {
    #[prost(message, optional, tag = "1")]
    pub id: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub namespace: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "3")]
    pub name: ::core::option::Option<::prost::alloc::string::String>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct StrategyResources {
    #[prost(message, optional, tag = "1")]
    pub strategy_id: ::core::option::Option<::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 = "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>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::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,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AuthStrategy {
    #[prost(message, optional, tag = "1")]
    pub id: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub name: ::core::option::Option<::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(message, optional, tag = "6")]
    pub comment: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "7")]
    pub owner: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "8")]
    pub ctime: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "9")]
    pub mtime: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "10")]
    pub auth_token: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "11")]
    pub default_strategy: ::core::option::Option<bool>,
    #[prost(map = "string, string", tag = "12")]
    pub metadata: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    #[prost(message, optional, tag = "13")]
    pub source: ::core::option::Option<::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>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ModifyAuthStrategy {
    #[prost(message, optional, tag = "1")]
    pub id: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub name: ::core::option::Option<::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(message, optional, tag = "8")]
    pub comment: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "9")]
    pub owner: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(map = "string, string", tag = "12")]
    pub metadata: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
    #[prost(message, optional, tag = "13")]
    pub source: ::core::option::Option<::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 {
            AuthAction::OnlyRead => "ONLY_READ",
            AuthAction::ReadWrite => "READ_WRITE",
            AuthAction::Allow => "ALLOW",
            AuthAction::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,
    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 {
            ResourceType::Namespaces => "Namespaces",
            ResourceType::Services => "Services",
            ResourceType::ConfigGroups => "ConfigGroups",
            ResourceType::RouteRules => "RouteRules",
            ResourceType::RateLimitRules => "RateLimitRules",
            ResourceType::CircuitBreakerRules => "CircuitBreakerRules",
            ResourceType::FaultDetectRules => "FaultDetectRules",
            ResourceType::LaneRules => "LaneRules",
            ResourceType::Users => "Users",
            ResourceType::UserGroups => "UserGroups",
            ResourceType::Roles => "Roles",
            ResourceType::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),
            "Users" => Some(Self::Users),
            "UserGroups" => Some(Self::UserGroups),
            "Roles" => Some(Self::Roles),
            "PolicyRules" => Some(Self::PolicyRules),
            _ => None,
        }
    }
}
/// 流量入口
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TrafficEntry {
    /// 标记流量入口类型
    /// type == "polarismesh.cn/gateway/spring-cloud-gateway", 则 selector 为
    /// ServiceGatewaySelector type == "polarismesh.cn/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>,
}
/// 微服务网关入口定义
#[allow(clippy::derive_partial_eq_without_eq)]
#[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>,
}
/// 普通服务入口定义
#[allow(clippy::derive_partial_eq_without_eq)]
#[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>,
}
/// 泳道组实体定义
#[allow(clippy::derive_partial_eq_without_eq)]
#[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,
}
/// TrafficMatchRule 流量匹配规则
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TrafficMatchRule {
    /// 流量匹配规则，判断哪些流量需要进入泳道
    #[prost(message, repeated, tag = "4")]
    pub arguments: ::prost::alloc::vec::Vec<SourceMatch>,
    #[prost(enumeration = "traffic_match_rule::TrafficMatchMode", tag = "14")]
    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 {
                TrafficMatchMode::And => "AND",
                TrafficMatchMode::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,
            }
        }
    }
}
/// 泳道规则
#[allow(clippy::derive_partial_eq_without_eq)]
#[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 {
                LaneMatchMode::Strict => "STRICT",
                LaneMatchMode::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,
            }
        }
    }
}
/// 优雅上下线规则的模型
#[allow(clippy::derive_partial_eq_without_eq)]
#[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,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::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>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::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 {
                DelayStrategy::DelayByTime => "DELAY_BY_TIME",
                DelayStrategy::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,
            }
        }
    }
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::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,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Readiness {
    /// enable /readiness expose
    #[prost(bool, tag = "1")]
    pub enable: bool,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct LosslessOffline {
    /// enable /offline expose
    #[prost(bool, tag = "1")]
    pub enable: bool,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[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,
    /// metadata for block allow list rules
    #[prost(map = "string, string", tag = "3")]
    pub metadata: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::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,
    /// rule enable
    #[prost(bool, tag = "8")]
    pub enable: bool,
    /// 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,
    /// block or allow configuration
    #[prost(message, repeated, tag = "12")]
    pub block_allow_config: ::prost::alloc::vec::Vec<BlockAllowConfig>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BlockAllowConfig {
    /// blocking target api
    #[prost(message, optional, tag = "1")]
    pub api: ::core::option::Option<Api>,
    /// arguments to match this config
    #[prost(message, repeated, tag = "2")]
    pub arguments: ::prost::alloc::vec::Vec<block_allow_config::MatchArgument>,
    /// 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 {
    #[allow(clippy::derive_partial_eq_without_eq)]
    #[derive(Clone, PartialEq, ::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<super::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,
            /// header, match the http header, dubbo attachment, grpc header
            Header = 1,
            /// query, match the http query, dubbo argument
            Query = 2,
            /// caller service
            CallerService = 3,
            /// caller host ip
            CallerIp = 4,
            /// caller instance metadata
            CallerMetadata = 5,
            /// caller instance metadata
            CalleeMetadata = 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 {
                    Type::Custom => "CUSTOM",
                    Type::Header => "HEADER",
                    Type::Query => "QUERY",
                    Type::CallerService => "CALLER_SERVICE",
                    Type::CallerIp => "CALLER_IP",
                    Type::CallerMetadata => "CALLER_METADATA",
                    Type::CalleeMetadata => "CALLEE_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),
                    "HEADER" => Some(Self::Header),
                    "QUERY" => Some(Self::Query),
                    "CALLER_SERVICE" => Some(Self::CallerService),
                    "CALLER_IP" => Some(Self::CallerIp),
                    "CALLER_METADATA" => Some(Self::CallerMetadata),
                    "CALLEE_METADATA" => Some(Self::CalleeMetadata),
                    _ => None,
                }
            }
        }
    }
    #[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 {
                BlockAllowPolicy::AllowList => "ALLOW_LIST",
                BlockAllowPolicy::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,
            }
        }
    }
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Response {
    #[prost(message, optional, tag = "1")]
    pub code: ::core::option::Option<u32>,
    #[prost(message, optional, tag = "2")]
    pub info: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "3")]
    pub client: ::core::option::Option<Client>,
    #[prost(message, optional, tag = "4")]
    pub namespace: ::core::option::Option<Namespace>,
    #[prost(message, optional, tag = "5")]
    pub service: ::core::option::Option<Service>,
    #[prost(message, optional, tag = "6")]
    pub instance: ::core::option::Option<Instance>,
    #[prost(message, optional, tag = "7")]
    pub routing: ::core::option::Option<Routing>,
    #[prost(message, optional, tag = "8")]
    pub alias: ::core::option::Option<ServiceAlias>,
    #[prost(message, optional, tag = "9")]
    pub rate_limit: ::core::option::Option<Rule>,
    #[prost(message, optional, tag = "10")]
    pub circuit_breaker: ::core::option::Option<CircuitBreaker>,
    #[prost(message, optional, tag = "11")]
    pub config_release: ::core::option::Option<ConfigRelease>,
    #[prost(message, optional, tag = "19")]
    pub user: ::core::option::Option<User>,
    #[prost(message, optional, tag = "20")]
    pub user_group: ::core::option::Option<UserGroup>,
    #[prost(message, optional, tag = "21")]
    pub auth_strategy: ::core::option::Option<AuthStrategy>,
    #[prost(message, optional, tag = "22")]
    pub relation: ::core::option::Option<UserGroupRelation>,
    #[prost(message, optional, tag = "23")]
    pub login_response: ::core::option::Option<LoginResponse>,
    #[prost(message, optional, tag = "24")]
    pub modify_auth_strategy: ::core::option::Option<ModifyAuthStrategy>,
    #[prost(message, optional, tag = "25")]
    pub modify_user_group: ::core::option::Option<ModifyUserGroup>,
    #[prost(message, optional, tag = "26")]
    pub resources: ::core::option::Option<StrategyResources>,
    #[prost(message, optional, tag = "27")]
    pub option_switch: ::core::option::Option<OptionSwitch>,
    #[prost(message, optional, tag = "28")]
    pub instance_labels: ::core::option::Option<InstanceLabels>,
    #[prost(message, optional, tag = "29")]
    pub data: ::core::option::Option<::prost_types::Any>,
    #[prost(message, optional, tag = "30")]
    pub service_contract: ::core::option::Option<ServiceContract>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchWriteResponse {
    #[prost(message, optional, tag = "1")]
    pub code: ::core::option::Option<u32>,
    #[prost(message, optional, tag = "2")]
    pub info: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "3")]
    pub size: ::core::option::Option<u32>,
    #[prost(message, repeated, tag = "4")]
    pub responses: ::prost::alloc::vec::Vec<Response>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchQueryResponse {
    #[prost(message, optional, tag = "1")]
    pub code: ::core::option::Option<u32>,
    #[prost(message, optional, tag = "2")]
    pub info: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "3")]
    pub amount: ::core::option::Option<u32>,
    #[prost(message, optional, tag = "4")]
    pub size: ::core::option::Option<u32>,
    #[prost(message, repeated, tag = "5")]
    pub namespaces: ::prost::alloc::vec::Vec<Namespace>,
    #[prost(message, repeated, tag = "6")]
    pub services: ::prost::alloc::vec::Vec<Service>,
    #[prost(message, repeated, tag = "7")]
    pub instances: ::prost::alloc::vec::Vec<Instance>,
    #[prost(message, repeated, tag = "8")]
    pub routings: ::prost::alloc::vec::Vec<Routing>,
    #[prost(message, repeated, tag = "9")]
    pub aliases: ::prost::alloc::vec::Vec<ServiceAlias>,
    #[prost(message, repeated, tag = "10")]
    pub rate_limits: ::prost::alloc::vec::Vec<Rule>,
    #[prost(message, repeated, tag = "11")]
    pub config_with_services: ::prost::alloc::vec::Vec<ConfigWithService>,
    #[prost(message, repeated, tag = "18")]
    pub users: ::prost::alloc::vec::Vec<User>,
    #[prost(message, repeated, tag = "19")]
    pub user_groups: ::prost::alloc::vec::Vec<UserGroup>,
    #[prost(message, repeated, tag = "20")]
    pub auth_strategies: ::prost::alloc::vec::Vec<AuthStrategy>,
    #[prost(message, repeated, tag = "21")]
    pub clients: ::prost::alloc::vec::Vec<Client>,
    #[prost(message, repeated, tag = "22")]
    pub data: ::prost::alloc::vec::Vec<::prost_types::Any>,
    #[prost(message, optional, tag = "23")]
    pub summary: ::core::option::Option<Summary>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DiscoverResponse {
    #[prost(message, optional, tag = "1")]
    pub code: ::core::option::Option<u32>,
    #[prost(message, optional, tag = "2")]
    pub info: ::core::option::Option<::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, repeated, tag = "5")]
    pub instances: ::prost::alloc::vec::Vec<Instance>,
    #[prost(message, optional, tag = "6")]
    pub routing: ::core::option::Option<Routing>,
    #[prost(message, optional, tag = "7")]
    pub rate_limit: ::core::option::Option<RateLimit>,
    #[prost(message, optional, tag = "8")]
    pub circuit_breaker: ::core::option::Option<CircuitBreaker>,
    #[prost(message, repeated, tag = "9")]
    pub services: ::prost::alloc::vec::Vec<Service>,
    #[prost(message, repeated, tag = "10")]
    pub namespaces: ::prost::alloc::vec::Vec<Namespace>,
    #[prost(message, optional, tag = "11")]
    pub fault_detector: ::core::option::Option<FaultDetector>,
    #[prost(message, optional, tag = "21")]
    pub alias_for: ::core::option::Option<Service>,
    #[prost(message, repeated, tag = "22")]
    pub lanes: ::prost::alloc::vec::Vec<LaneGroup>,
    /// 自定义路由规则内容
    #[prost(message, repeated, tag = "23")]
    pub custom_route_rules: ::prost::alloc::vec::Vec<RouteRule>,
    /// 就近路由规则内容
    #[prost(message, repeated, tag = "24")]
    pub nearby_route_rules: ::prost::alloc::vec::Vec<RouteRule>,
    /// 无损上下线规则内容
    #[prost(message, repeated, tag = "25")]
    pub lossless_rules: ::prost::alloc::vec::Vec<LosslessRule>,
    /// 服务黑白名单鉴权规则
    #[prost(message, repeated, tag = "26")]
    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,
        Instance = 1,
        Cluster = 2,
        Routing = 3,
        RateLimit = 4,
        CircuitBreaker = 5,
        Services = 6,
        Namespaces = 12,
        FaultDetector = 13,
        Lane = 100,
        /// 自定义路由规则
        CustomRouteRule = 101,
        /// 就近路由规则
        NearbyRouteRule = 102,
        /// 无损上下线规则
        Lossless = 103,
        /// 服务黑白名单规则
        BlockAllowRule = 104,
    }
    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 {
                DiscoverResponseType::Unknown => "UNKNOWN",
                DiscoverResponseType::Instance => "INSTANCE",
                DiscoverResponseType::Cluster => "CLUSTER",
                DiscoverResponseType::Routing => "ROUTING",
                DiscoverResponseType::RateLimit => "RATE_LIMIT",
                DiscoverResponseType::CircuitBreaker => "CIRCUIT_BREAKER",
                DiscoverResponseType::Services => "SERVICES",
                DiscoverResponseType::Namespaces => "NAMESPACES",
                DiscoverResponseType::FaultDetector => "FAULT_DETECTOR",
                DiscoverResponseType::Lane => "LANE",
                DiscoverResponseType::CustomRouteRule => "CUSTOM_ROUTE_RULE",
                DiscoverResponseType::NearbyRouteRule => "NEARBY_ROUTE_RULE",
                DiscoverResponseType::Lossless => "LOSSLESS",
                DiscoverResponseType::BlockAllowRule => "BLOCK_ALLOW_RULE",
            }
        }
        /// 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),
                "INSTANCE" => Some(Self::Instance),
                "CLUSTER" => Some(Self::Cluster),
                "ROUTING" => Some(Self::Routing),
                "RATE_LIMIT" => Some(Self::RateLimit),
                "CIRCUIT_BREAKER" => Some(Self::CircuitBreaker),
                "SERVICES" => Some(Self::Services),
                "NAMESPACES" => Some(Self::Namespaces),
                "FAULT_DETECTOR" => Some(Self::FaultDetector),
                "LANE" => Some(Self::Lane),
                "CUSTOM_ROUTE_RULE" => Some(Self::CustomRouteRule),
                "NEARBY_ROUTE_RULE" => Some(Self::NearbyRouteRule),
                "LOSSLESS" => Some(Self::Lossless),
                "BLOCK_ALLOW_RULE" => Some(Self::BlockAllowRule),
                _ => None,
            }
        }
    }
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct OptionSwitch {
    #[prost(map = "string, string", tag = "1")]
    pub options: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct InstanceLabels {
    #[prost(map = "string, message", tag = "1")]
    pub labels: ::std::collections::HashMap<::prost::alloc::string::String, StringList>,
    #[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,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::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,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::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,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct HeartbeatsRequest {
    #[prost(message, repeated, tag = "1")]
    pub heartbeats: ::prost::alloc::vec::Vec<InstanceHeartbeat>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct HeartbeatsResponse {}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetHeartbeatsRequest {
    #[prost(string, repeated, tag = "1")]
    pub instance_ids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetHeartbeatsResponse {
    #[prost(message, repeated, tag = "1")]
    pub records: ::prost::alloc::vec::Vec<HeartbeatRecord>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DelHeartbeatsRequest {
    #[prost(string, repeated, tag = "1")]
    pub instance_ids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DelHeartbeatsResponse {
    #[prost(uint32, tag = "1")]
    pub code: u32,
    #[prost(string, tag = "2")]
    pub info: ::prost::alloc::string::String,
}
/// Generated client implementations.
pub mod polaris_grpc_client {
    #![allow(unused_variables, dead_code, missing_docs, clippy::let_unit_value)]
    use tonic::codegen::*;
    use tonic::codegen::http::Uri;
    #[derive(Debug, Clone)]
    pub struct PolarisGrpcClient<T> {
        inner: tonic::client::Grpc<T>,
    }
    impl PolarisGrpcClient<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> PolarisGrpcClient<T>
    where
        T: tonic::client::GrpcService<tonic::body::BoxBody>,
        T::Error: Into<StdError>,
        T::ResponseBody: Body<Data = Bytes> + Send + 'static,
        <T::ResponseBody as Body>::Error: Into<StdError> + Send,
    {
        pub fn new(inner: T) -> Self {
            let inner = tonic::client::Grpc::new(inner);
            Self { inner }
        }
        pub fn with_origin(inner: T, origin: Uri) -> Self {
            let inner = tonic::client::Grpc::with_origin(inner, origin);
            Self { inner }
        }
        pub fn with_interceptor<F>(
            inner: T,
            interceptor: F,
        ) -> PolarisGrpcClient<InterceptedService<T, F>>
        where
            F: tonic::service::Interceptor,
            T::ResponseBody: Default,
            T: tonic::codegen::Service<
                http::Request<tonic::body::BoxBody>,
                Response = http::Response<
                    <T as tonic::client::GrpcService<tonic::body::BoxBody>>::ResponseBody,
                >,
            >,
            <T as tonic::codegen::Service<
                http::Request<tonic::body::BoxBody>,
            >>::Error: Into<StdError> + Send + Sync,
        {
            PolarisGrpcClient::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::new(
                        tonic::Code::Unknown,
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/v1.PolarisGRPC/ReportClient",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("v1.PolarisGRPC", "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::new(
                        tonic::Code::Unknown,
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/v1.PolarisGRPC/RegisterInstance",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("v1.PolarisGRPC", "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::new(
                        tonic::Code::Unknown,
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/v1.PolarisGRPC/DeregisterInstance",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("v1.PolarisGRPC", "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::new(
                        tonic::Code::Unknown,
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static("/v1.PolarisGRPC/Discover");
            let mut req = request.into_streaming_request();
            req.extensions_mut().insert(GrpcMethod::new("v1.PolarisGRPC", "Discover"));
            self.inner.streaming(req, path, codec).await
        }
        /// 被调方上报心跳
        pub async fn heartbeat(
            &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::new(
                        tonic::Code::Unknown,
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static("/v1.PolarisGRPC/Heartbeat");
            let mut req = request.into_request();
            req.extensions_mut().insert(GrpcMethod::new("v1.PolarisGRPC", "Heartbeat"));
            self.inner.unary(req, path, codec).await
        }
    }
}
/// Generated client implementations.
pub mod polaris_heartbeat_grpc_client {
    #![allow(unused_variables, dead_code, missing_docs, clippy::let_unit_value)]
    use tonic::codegen::*;
    use tonic::codegen::http::Uri;
    #[derive(Debug, Clone)]
    pub struct PolarisHeartbeatGrpcClient<T> {
        inner: tonic::client::Grpc<T>,
    }
    impl PolarisHeartbeatGrpcClient<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> PolarisHeartbeatGrpcClient<T>
    where
        T: tonic::client::GrpcService<tonic::body::BoxBody>,
        T::Error: Into<StdError>,
        T::ResponseBody: Body<Data = Bytes> + Send + 'static,
        <T::ResponseBody as Body>::Error: Into<StdError> + Send,
    {
        pub fn new(inner: T) -> Self {
            let inner = tonic::client::Grpc::new(inner);
            Self { inner }
        }
        pub fn with_origin(inner: T, origin: Uri) -> Self {
            let inner = tonic::client::Grpc::with_origin(inner, origin);
            Self { inner }
        }
        pub fn with_interceptor<F>(
            inner: T,
            interceptor: F,
        ) -> PolarisHeartbeatGrpcClient<InterceptedService<T, F>>
        where
            F: tonic::service::Interceptor,
            T::ResponseBody: Default,
            T: tonic::codegen::Service<
                http::Request<tonic::body::BoxBody>,
                Response = http::Response<
                    <T as tonic::client::GrpcService<tonic::body::BoxBody>>::ResponseBody,
                >,
            >,
            <T as tonic::codegen::Service<
                http::Request<tonic::body::BoxBody>,
            >>::Error: Into<StdError> + Send + Sync,
        {
            PolarisHeartbeatGrpcClient::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_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::new(
                        tonic::Code::Unknown,
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/v1.PolarisHeartbeatGRPC/BatchHeartbeat",
            );
            let mut req = request.into_streaming_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("v1.PolarisHeartbeatGRPC", "BatchHeartbeat"));
            self.inner.streaming(req, path, codec).await
        }
        /// 批量获取心跳记录
        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::new(
                        tonic::Code::Unknown,
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/v1.PolarisHeartbeatGRPC/BatchGetHeartbeat",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("v1.PolarisHeartbeatGRPC", "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::new(
                        tonic::Code::Unknown,
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/v1.PolarisHeartbeatGRPC/BatchDelHeartbeat",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("v1.PolarisHeartbeatGRPC", "BatchDelHeartbeat"));
            self.inner.unary(req, path, codec).await
        }
    }
}
/// Generated client implementations.
pub mod polaris_service_contract_grpc_client {
    #![allow(unused_variables, dead_code, missing_docs, clippy::let_unit_value)]
    use tonic::codegen::*;
    use tonic::codegen::http::Uri;
    #[derive(Debug, Clone)]
    pub struct PolarisServiceContractGrpcClient<T> {
        inner: tonic::client::Grpc<T>,
    }
    impl PolarisServiceContractGrpcClient<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> PolarisServiceContractGrpcClient<T>
    where
        T: tonic::client::GrpcService<tonic::body::BoxBody>,
        T::Error: Into<StdError>,
        T::ResponseBody: Body<Data = Bytes> + Send + 'static,
        <T::ResponseBody as Body>::Error: Into<StdError> + Send,
    {
        pub fn new(inner: T) -> Self {
            let inner = tonic::client::Grpc::new(inner);
            Self { inner }
        }
        pub fn with_origin(inner: T, origin: Uri) -> Self {
            let inner = tonic::client::Grpc::with_origin(inner, origin);
            Self { inner }
        }
        pub fn with_interceptor<F>(
            inner: T,
            interceptor: F,
        ) -> PolarisServiceContractGrpcClient<InterceptedService<T, F>>
        where
            F: tonic::service::Interceptor,
            T::ResponseBody: Default,
            T: tonic::codegen::Service<
                http::Request<tonic::body::BoxBody>,
                Response = http::Response<
                    <T as tonic::client::GrpcService<tonic::body::BoxBody>>::ResponseBody,
                >,
            >,
            <T as tonic::codegen::Service<
                http::Request<tonic::body::BoxBody>,
            >>::Error: Into<StdError> + Send + Sync,
        {
            PolarisServiceContractGrpcClient::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_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::new(
                        tonic::Code::Unknown,
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/v1.PolarisServiceContractGRPC/ReportServiceContract",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "v1.PolarisServiceContractGRPC",
                        "ReportServiceContract",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        /// 查询服务契约
        pub async fn get_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::new(
                        tonic::Code::Unknown,
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/v1.PolarisServiceContractGRPC/GetServiceContract",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "v1.PolarisServiceContractGRPC",
                        "GetServiceContract",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
    }
}
/// Generated server implementations.
pub mod polaris_grpc_server {
    #![allow(unused_variables, dead_code, missing_docs, clippy::let_unit_value)]
    use tonic::codegen::*;
    /// Generated trait containing gRPC methods that should be implemented for use with PolarisGrpcServer.
    #[async_trait]
    pub trait PolarisGrpc: Send + 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>,
            >
            + Send
            + 'static;
        /// 统一发现接口
        async fn discover(
            &self,
            request: tonic::Request<tonic::Streaming<super::DiscoverRequest>>,
        ) -> std::result::Result<tonic::Response<Self::DiscoverStream>, tonic::Status>;
        /// 被调方上报心跳
        async fn heartbeat(
            &self,
            request: tonic::Request<super::Instance>,
        ) -> std::result::Result<tonic::Response<super::Response>, tonic::Status>;
    }
    #[derive(Debug)]
    pub struct PolarisGrpcServer<T: PolarisGrpc> {
        inner: _Inner<T>,
        accept_compression_encodings: EnabledCompressionEncodings,
        send_compression_encodings: EnabledCompressionEncodings,
        max_decoding_message_size: Option<usize>,
        max_encoding_message_size: Option<usize>,
    }
    struct _Inner<T>(Arc<T>);
    impl<T: PolarisGrpc> PolarisGrpcServer<T> {
        pub fn new(inner: T) -> Self {
            Self::from_arc(Arc::new(inner))
        }
        pub fn from_arc(inner: Arc<T>) -> Self {
            let inner = _Inner(inner);
            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 PolarisGrpcServer<T>
    where
        T: PolarisGrpc,
        B: Body + Send + 'static,
        B::Error: Into<StdError> + Send + 'static,
    {
        type Response = http::Response<tonic::body::BoxBody>;
        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 {
            let inner = self.inner.clone();
            match req.uri().path() {
                "/v1.PolarisGRPC/ReportClient" => {
                    #[allow(non_camel_case_types)]
                    struct ReportClientSvc<T: PolarisGrpc>(pub Arc<T>);
                    impl<T: PolarisGrpc> 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 PolarisGrpc>::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 inner = inner.0;
                        let method = ReportClientSvc(inner);
                        let codec = tonic::codec::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.PolarisGRPC/RegisterInstance" => {
                    #[allow(non_camel_case_types)]
                    struct RegisterInstanceSvc<T: PolarisGrpc>(pub Arc<T>);
                    impl<T: PolarisGrpc> 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 PolarisGrpc>::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 inner = inner.0;
                        let method = RegisterInstanceSvc(inner);
                        let codec = tonic::codec::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.PolarisGRPC/DeregisterInstance" => {
                    #[allow(non_camel_case_types)]
                    struct DeregisterInstanceSvc<T: PolarisGrpc>(pub Arc<T>);
                    impl<T: PolarisGrpc> 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 PolarisGrpc>::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 inner = inner.0;
                        let method = DeregisterInstanceSvc(inner);
                        let codec = tonic::codec::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.PolarisGRPC/Discover" => {
                    #[allow(non_camel_case_types)]
                    struct DiscoverSvc<T: PolarisGrpc>(pub Arc<T>);
                    impl<
                        T: PolarisGrpc,
                    > 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 PolarisGrpc>::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 inner = inner.0;
                        let method = DiscoverSvc(inner);
                        let codec = tonic::codec::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.PolarisGRPC/Heartbeat" => {
                    #[allow(non_camel_case_types)]
                    struct HeartbeatSvc<T: PolarisGrpc>(pub Arc<T>);
                    impl<T: PolarisGrpc> tonic::server::UnaryService<super::Instance>
                    for HeartbeatSvc<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 PolarisGrpc>::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 inner = inner.0;
                        let method = HeartbeatSvc(inner);
                        let codec = tonic::codec::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 {
                        Ok(
                            http::Response::builder()
                                .status(200)
                                .header("grpc-status", "12")
                                .header("content-type", "application/grpc")
                                .body(empty_body())
                                .unwrap(),
                        )
                    })
                }
            }
        }
    }
    impl<T: PolarisGrpc> Clone for PolarisGrpcServer<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,
            }
        }
    }
    impl<T: PolarisGrpc> Clone for _Inner<T> {
        fn clone(&self) -> Self {
            Self(Arc::clone(&self.0))
        }
    }
    impl<T: std::fmt::Debug> std::fmt::Debug for _Inner<T> {
        fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
            write!(f, "{:?}", self.0)
        }
    }
    impl<T: PolarisGrpc> tonic::server::NamedService for PolarisGrpcServer<T> {
        const NAME: &'static str = "v1.PolarisGRPC";
    }
}
/// Generated server implementations.
pub mod polaris_heartbeat_grpc_server {
    #![allow(unused_variables, dead_code, missing_docs, clippy::let_unit_value)]
    use tonic::codegen::*;
    /// Generated trait containing gRPC methods that should be implemented for use with PolarisHeartbeatGrpcServer.
    #[async_trait]
    pub trait PolarisHeartbeatGrpc: Send + Sync + 'static {
        /// Server streaming response type for the BatchHeartbeat method.
        type BatchHeartbeatStream: tonic::codegen::tokio_stream::Stream<
                Item = std::result::Result<super::HeartbeatsResponse, tonic::Status>,
            >
            + Send
            + 'static;
        /// 被调方批量上报心跳
        async fn batch_heartbeat(
            &self,
            request: tonic::Request<tonic::Streaming<super::HeartbeatsRequest>>,
        ) -> std::result::Result<
            tonic::Response<Self::BatchHeartbeatStream>,
            tonic::Status,
        >;
        /// 批量获取心跳记录
        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 PolarisHeartbeatGrpcServer<T: PolarisHeartbeatGrpc> {
        inner: _Inner<T>,
        accept_compression_encodings: EnabledCompressionEncodings,
        send_compression_encodings: EnabledCompressionEncodings,
        max_decoding_message_size: Option<usize>,
        max_encoding_message_size: Option<usize>,
    }
    struct _Inner<T>(Arc<T>);
    impl<T: PolarisHeartbeatGrpc> PolarisHeartbeatGrpcServer<T> {
        pub fn new(inner: T) -> Self {
            Self::from_arc(Arc::new(inner))
        }
        pub fn from_arc(inner: Arc<T>) -> Self {
            let inner = _Inner(inner);
            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 PolarisHeartbeatGrpcServer<T>
    where
        T: PolarisHeartbeatGrpc,
        B: Body + Send + 'static,
        B::Error: Into<StdError> + Send + 'static,
    {
        type Response = http::Response<tonic::body::BoxBody>;
        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 {
            let inner = self.inner.clone();
            match req.uri().path() {
                "/v1.PolarisHeartbeatGRPC/BatchHeartbeat" => {
                    #[allow(non_camel_case_types)]
                    struct BatchHeartbeatSvc<T: PolarisHeartbeatGrpc>(pub Arc<T>);
                    impl<
                        T: PolarisHeartbeatGrpc,
                    > tonic::server::StreamingService<super::HeartbeatsRequest>
                    for BatchHeartbeatSvc<T> {
                        type Response = super::HeartbeatsResponse;
                        type ResponseStream = T::BatchHeartbeatStream;
                        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 PolarisHeartbeatGrpc>::batch_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 inner = inner.0;
                        let method = BatchHeartbeatSvc(inner);
                        let codec = tonic::codec::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.PolarisHeartbeatGRPC/BatchGetHeartbeat" => {
                    #[allow(non_camel_case_types)]
                    struct BatchGetHeartbeatSvc<T: PolarisHeartbeatGrpc>(pub Arc<T>);
                    impl<
                        T: PolarisHeartbeatGrpc,
                    > 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 PolarisHeartbeatGrpc>::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 inner = inner.0;
                        let method = BatchGetHeartbeatSvc(inner);
                        let codec = tonic::codec::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.PolarisHeartbeatGRPC/BatchDelHeartbeat" => {
                    #[allow(non_camel_case_types)]
                    struct BatchDelHeartbeatSvc<T: PolarisHeartbeatGrpc>(pub Arc<T>);
                    impl<
                        T: PolarisHeartbeatGrpc,
                    > 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 PolarisHeartbeatGrpc>::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 inner = inner.0;
                        let method = BatchDelHeartbeatSvc(inner);
                        let codec = tonic::codec::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 {
                        Ok(
                            http::Response::builder()
                                .status(200)
                                .header("grpc-status", "12")
                                .header("content-type", "application/grpc")
                                .body(empty_body())
                                .unwrap(),
                        )
                    })
                }
            }
        }
    }
    impl<T: PolarisHeartbeatGrpc> Clone for PolarisHeartbeatGrpcServer<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,
            }
        }
    }
    impl<T: PolarisHeartbeatGrpc> Clone for _Inner<T> {
        fn clone(&self) -> Self {
            Self(Arc::clone(&self.0))
        }
    }
    impl<T: std::fmt::Debug> std::fmt::Debug for _Inner<T> {
        fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
            write!(f, "{:?}", self.0)
        }
    }
    impl<T: PolarisHeartbeatGrpc> tonic::server::NamedService
    for PolarisHeartbeatGrpcServer<T> {
        const NAME: &'static str = "v1.PolarisHeartbeatGRPC";
    }
}
/// Generated server implementations.
pub mod polaris_service_contract_grpc_server {
    #![allow(unused_variables, dead_code, missing_docs, clippy::let_unit_value)]
    use tonic::codegen::*;
    /// Generated trait containing gRPC methods that should be implemented for use with PolarisServiceContractGrpcServer.
    #[async_trait]
    pub trait PolarisServiceContractGrpc: Send + Sync + 'static {
        /// 上报服务契约
        async fn report_service_contract(
            &self,
            request: tonic::Request<super::ServiceContract>,
        ) -> std::result::Result<tonic::Response<super::Response>, tonic::Status>;
        /// 查询服务契约
        async fn get_service_contract(
            &self,
            request: tonic::Request<super::ServiceContract>,
        ) -> std::result::Result<tonic::Response<super::Response>, tonic::Status>;
    }
    #[derive(Debug)]
    pub struct PolarisServiceContractGrpcServer<T: PolarisServiceContractGrpc> {
        inner: _Inner<T>,
        accept_compression_encodings: EnabledCompressionEncodings,
        send_compression_encodings: EnabledCompressionEncodings,
        max_decoding_message_size: Option<usize>,
        max_encoding_message_size: Option<usize>,
    }
    struct _Inner<T>(Arc<T>);
    impl<T: PolarisServiceContractGrpc> PolarisServiceContractGrpcServer<T> {
        pub fn new(inner: T) -> Self {
            Self::from_arc(Arc::new(inner))
        }
        pub fn from_arc(inner: Arc<T>) -> Self {
            let inner = _Inner(inner);
            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 PolarisServiceContractGrpcServer<T>
    where
        T: PolarisServiceContractGrpc,
        B: Body + Send + 'static,
        B::Error: Into<StdError> + Send + 'static,
    {
        type Response = http::Response<tonic::body::BoxBody>;
        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 {
            let inner = self.inner.clone();
            match req.uri().path() {
                "/v1.PolarisServiceContractGRPC/ReportServiceContract" => {
                    #[allow(non_camel_case_types)]
                    struct ReportServiceContractSvc<T: PolarisServiceContractGrpc>(
                        pub Arc<T>,
                    );
                    impl<
                        T: PolarisServiceContractGrpc,
                    > 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 PolarisServiceContractGrpc>::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 inner = inner.0;
                        let method = ReportServiceContractSvc(inner);
                        let codec = tonic::codec::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.PolarisServiceContractGRPC/GetServiceContract" => {
                    #[allow(non_camel_case_types)]
                    struct GetServiceContractSvc<T: PolarisServiceContractGrpc>(
                        pub Arc<T>,
                    );
                    impl<
                        T: PolarisServiceContractGrpc,
                    > tonic::server::UnaryService<super::ServiceContract>
                    for GetServiceContractSvc<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 PolarisServiceContractGrpc>::get_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 inner = inner.0;
                        let method = GetServiceContractSvc(inner);
                        let codec = tonic::codec::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 {
                        Ok(
                            http::Response::builder()
                                .status(200)
                                .header("grpc-status", "12")
                                .header("content-type", "application/grpc")
                                .body(empty_body())
                                .unwrap(),
                        )
                    })
                }
            }
        }
    }
    impl<T: PolarisServiceContractGrpc> Clone for PolarisServiceContractGrpcServer<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,
            }
        }
    }
    impl<T: PolarisServiceContractGrpc> Clone for _Inner<T> {
        fn clone(&self) -> Self {
            Self(Arc::clone(&self.0))
        }
    }
    impl<T: std::fmt::Debug> std::fmt::Debug for _Inner<T> {
        fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
            write!(f, "{:?}", self.0)
        }
    }
    impl<T: PolarisServiceContractGrpc> tonic::server::NamedService
    for PolarisServiceContractGrpcServer<T> {
        const NAME: &'static str = "v1.PolarisServiceContractGRPC";
    }
}
#[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,
    InvalidNamespaceName = 400110,
    InvalidNamespaceOwners = 400111,
    InvalidNamespaceToken = 400112,
    InvalidServiceName = 400120,
    InvalidServiceOwners = 400121,
    InvalidServiceToken = 400122,
    InvalidServiceMetadata = 400123,
    InvalidServicePorts = 400124,
    InvalidServiceBusiness = 400125,
    InvalidServiceDepartment = 400126,
    InvalidServiceCmdb = 400127,
    InvalidServiceComment = 400128,
    InvalidServiceAliasComment = 400129,
    InvalidInstanceId = 400130,
    InvalidInstanceHost = 400131,
    InvalidInstancePort = 400132,
    InvalidServiceAlias = 400133,
    InvalidNamespaceWithAlias = 400134,
    InvalidServiceAliasOwners = 400135,
    InvalidInstanceProtocol = 400136,
    InvalidInstanceVersion = 400137,
    InvalidInstanceLogicSet = 400138,
    InvalidInstanceIsolate = 400139,
    HealthCheckNotOpen = 400140,
    HeartbeatOnDisabledIns = 400141,
    HeartbeatExceedLimit = 400142,
    HeartbeatTypeNotFound = 400143,
    InvalidMetadata = 400150,
    InvalidRateLimitId = 400151,
    InvalidRateLimitLabels = 400152,
    InvalidRateLimitAmounts = 400153,
    InvalidRateLimitName = 400154,
    InvalidCircuitBreakerId = 400160,
    InvalidCircuitBreakerVersion = 400161,
    InvalidCircuitBreakerName = 400162,
    InvalidCircuitBreakerNamespace = 400163,
    InvalidCircuitBreakerOwners = 400164,
    InvalidCircuitBreakerToken = 400165,
    InvalidCircuitBreakerBusiness = 400166,
    InvalidCircuitBreakerDepartment = 400167,
    InvalidCircuitBreakerComment = 400168,
    CircuitBreakerRuleExisted = 400169,
    InvalidRoutingId = 400700,
    InvalidRoutingPolicy = 400701,
    InvalidRoutingName = 400702,
    InvalidRoutingPriority = 400703,
    InvalidFaultDetectId = 400900,
    InvalidFaultDetectName = 400901,
    InvalidFaultDetectNamespace = 400902,
    FaultDetectRuleExisted = 400903,
    InvalidMatchRule = 400904,
    /// network relative codes
    ServicesExistedMesh = 400170,
    ResourcesExistedMesh = 400171,
    InvalidMeshParameter = 400172,
    /// platform relative codes
    InvalidPlatformId = 400180,
    InvalidPlatformName = 400181,
    InvalidPlatformDomain = 400182,
    InvalidPlatformQps = 400183,
    InvalidPlatformToken = 400184,
    InvalidPlatformOwner = 400185,
    InvalidPlatformDepartment = 400186,
    InvalidPlatformComment = 400187,
    NotFoundPlatform = 400188,
    /// flux relative codes
    InvalidFluxRateLimitId = 400190,
    InvalidFluxRateLimitQps = 400191,
    InvalidFluxRateLimitSetKey = 400192,
    ExistedResource = 400201,
    NotFoundResource = 400202,
    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,
    NotFoundService = 400301,
    NotFoundRouting = 400302,
    NotFoundInstance = 400303,
    NotFoundServiceAlias = 400304,
    NotFoundNamespace = 400305,
    NotFoundSourceService = 400306,
    NotFoundRateLimit = 400307,
    NotFoundCircuitBreaker = 400308,
    NotFoundMasterConfig = 400309,
    NotFoundTagConfig = 400310,
    NotFoundTagConfigOrService = 400311,
    ClientApiNotOpen = 400401,
    NotAllowBusinessService = 400402,
    NotAllowAliasUpdate = 400501,
    NotAllowAliasCreateInstance = 400502,
    NotAllowAliasCreateRouting = 400503,
    NotAllowCreateAliasForAlias = 400504,
    NotAllowAliasCreateRateLimit = 400505,
    NotAllowAliasBindRule = 400506,
    NotAllowDifferentNamespaceBindRule = 400507,
    Unauthorized = 401000,
    NotAllowedAccess = 401001,
    CmdbNotFindHost = 404001,
    DataConflict = 409000,
    InstanceTooManyRequests = 429001,
    IpRateLimit = 429002,
    ApiRateLimit = 403003,
    ExecuteException = 500000,
    StoreLayerException = 500001,
    CmdbPluginException = 500002,
    ParseRoutingException = 500004,
    ParseRateLimitException = 500005,
    ParseCircuitBreakerException = 500006,
    HeartbeatException = 500007,
    InstanceRegisTimeout = 500008,
    /// config center status codes
    InvalidConfigFileGroupName = 400801,
    InvalidConfigFileName = 400802,
    InvalidConfigFileContentLength = 400803,
    InvalidConfigFileFormat = 400804,
    InvalidConfigFileTags = 400805,
    InvalidWatchConfigFileFormat = 400806,
    NotFoundResourceConfigFile = 400807,
    InvalidConfigFileTemplateName = 400808,
    EncryptConfigFileException = 400809,
    GroupExistActiveRelease = 400810,
    DecryptConfigFileException = 400811,
    /// auth codes
    InvalidUserOwners = 400410,
    InvalidUserId = 400411,
    InvalidUserPassword = 400412,
    InvalidUserMobile = 400413,
    InvalidUserEmail = 400414,
    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 {
            Code::Unknown => "Unknown",
            Code::ExecuteSuccess => "ExecuteSuccess",
            Code::DataNoChange => "DataNoChange",
            Code::NoNeedUpdate => "NoNeedUpdate",
            Code::BadRequest => "BadRequest",
            Code::ParseException => "ParseException",
            Code::EmptyRequest => "EmptyRequest",
            Code::BatchSizeOverLimit => "BatchSizeOverLimit",
            Code::InvalidDiscoverResource => "InvalidDiscoverResource",
            Code::InvalidRequestId => "InvalidRequestID",
            Code::InvalidUserName => "InvalidUserName",
            Code::InvalidUserToken => "InvalidUserToken",
            Code::InvalidParameter => "InvalidParameter",
            Code::EmptyQueryParameter => "EmptyQueryParameter",
            Code::InvalidQueryInsParameter => "InvalidQueryInsParameter",
            Code::InvalidNamespaceName => "InvalidNamespaceName",
            Code::InvalidNamespaceOwners => "InvalidNamespaceOwners",
            Code::InvalidNamespaceToken => "InvalidNamespaceToken",
            Code::InvalidServiceName => "InvalidServiceName",
            Code::InvalidServiceOwners => "InvalidServiceOwners",
            Code::InvalidServiceToken => "InvalidServiceToken",
            Code::InvalidServiceMetadata => "InvalidServiceMetadata",
            Code::InvalidServicePorts => "InvalidServicePorts",
            Code::InvalidServiceBusiness => "InvalidServiceBusiness",
            Code::InvalidServiceDepartment => "InvalidServiceDepartment",
            Code::InvalidServiceCmdb => "InvalidServiceCMDB",
            Code::InvalidServiceComment => "InvalidServiceComment",
            Code::InvalidServiceAliasComment => "InvalidServiceAliasComment",
            Code::InvalidInstanceId => "InvalidInstanceID",
            Code::InvalidInstanceHost => "InvalidInstanceHost",
            Code::InvalidInstancePort => "InvalidInstancePort",
            Code::InvalidServiceAlias => "InvalidServiceAlias",
            Code::InvalidNamespaceWithAlias => "InvalidNamespaceWithAlias",
            Code::InvalidServiceAliasOwners => "InvalidServiceAliasOwners",
            Code::InvalidInstanceProtocol => "InvalidInstanceProtocol",
            Code::InvalidInstanceVersion => "InvalidInstanceVersion",
            Code::InvalidInstanceLogicSet => "InvalidInstanceLogicSet",
            Code::InvalidInstanceIsolate => "InvalidInstanceIsolate",
            Code::HealthCheckNotOpen => "HealthCheckNotOpen",
            Code::HeartbeatOnDisabledIns => "HeartbeatOnDisabledIns",
            Code::HeartbeatExceedLimit => "HeartbeatExceedLimit",
            Code::HeartbeatTypeNotFound => "HeartbeatTypeNotFound",
            Code::InvalidMetadata => "InvalidMetadata",
            Code::InvalidRateLimitId => "InvalidRateLimitID",
            Code::InvalidRateLimitLabels => "InvalidRateLimitLabels",
            Code::InvalidRateLimitAmounts => "InvalidRateLimitAmounts",
            Code::InvalidRateLimitName => "InvalidRateLimitName",
            Code::InvalidCircuitBreakerId => "InvalidCircuitBreakerID",
            Code::InvalidCircuitBreakerVersion => "InvalidCircuitBreakerVersion",
            Code::InvalidCircuitBreakerName => "InvalidCircuitBreakerName",
            Code::InvalidCircuitBreakerNamespace => "InvalidCircuitBreakerNamespace",
            Code::InvalidCircuitBreakerOwners => "InvalidCircuitBreakerOwners",
            Code::InvalidCircuitBreakerToken => "InvalidCircuitBreakerToken",
            Code::InvalidCircuitBreakerBusiness => "InvalidCircuitBreakerBusiness",
            Code::InvalidCircuitBreakerDepartment => "InvalidCircuitBreakerDepartment",
            Code::InvalidCircuitBreakerComment => "InvalidCircuitBreakerComment",
            Code::CircuitBreakerRuleExisted => "CircuitBreakerRuleExisted",
            Code::InvalidRoutingId => "InvalidRoutingID",
            Code::InvalidRoutingPolicy => "InvalidRoutingPolicy",
            Code::InvalidRoutingName => "InvalidRoutingName",
            Code::InvalidRoutingPriority => "InvalidRoutingPriority",
            Code::InvalidFaultDetectId => "InvalidFaultDetectID",
            Code::InvalidFaultDetectName => "InvalidFaultDetectName",
            Code::InvalidFaultDetectNamespace => "InvalidFaultDetectNamespace",
            Code::FaultDetectRuleExisted => "FaultDetectRuleExisted",
            Code::InvalidMatchRule => "InvalidMatchRule",
            Code::ServicesExistedMesh => "ServicesExistedMesh",
            Code::ResourcesExistedMesh => "ResourcesExistedMesh",
            Code::InvalidMeshParameter => "InvalidMeshParameter",
            Code::InvalidPlatformId => "InvalidPlatformID",
            Code::InvalidPlatformName => "InvalidPlatformName",
            Code::InvalidPlatformDomain => "InvalidPlatformDomain",
            Code::InvalidPlatformQps => "InvalidPlatformQPS",
            Code::InvalidPlatformToken => "InvalidPlatformToken",
            Code::InvalidPlatformOwner => "InvalidPlatformOwner",
            Code::InvalidPlatformDepartment => "InvalidPlatformDepartment",
            Code::InvalidPlatformComment => "InvalidPlatformComment",
            Code::NotFoundPlatform => "NotFoundPlatform",
            Code::InvalidFluxRateLimitId => "InvalidFluxRateLimitId",
            Code::InvalidFluxRateLimitQps => "InvalidFluxRateLimitQps",
            Code::InvalidFluxRateLimitSetKey => "InvalidFluxRateLimitSetKey",
            Code::ExistedResource => "ExistedResource",
            Code::NotFoundResource => "NotFoundResource",
            Code::NamespaceExistedServices => "NamespaceExistedServices",
            Code::ServiceExistedInstances => "ServiceExistedInstances",
            Code::ServiceExistedRoutings => "ServiceExistedRoutings",
            Code::ServiceExistedRateLimits => "ServiceExistedRateLimits",
            Code::ExistReleasedConfig => "ExistReleasedConfig",
            Code::SameInstanceRequest => "SameInstanceRequest",
            Code::ServiceExistedCircuitBreakers => "ServiceExistedCircuitBreakers",
            Code::ServiceExistedAlias => "ServiceExistedAlias",
            Code::NamespaceExistedMeshResources => "NamespaceExistedMeshResources",
            Code::NamespaceExistedCircuitBreakers => "NamespaceExistedCircuitBreakers",
            Code::ServiceSubscribedByMeshes => "ServiceSubscribedByMeshes",
            Code::ServiceExistedFluxRateLimits => "ServiceExistedFluxRateLimits",
            Code::NamespaceExistedConfigGroups => "NamespaceExistedConfigGroups",
            Code::NotFoundService => "NotFoundService",
            Code::NotFoundRouting => "NotFoundRouting",
            Code::NotFoundInstance => "NotFoundInstance",
            Code::NotFoundServiceAlias => "NotFoundServiceAlias",
            Code::NotFoundNamespace => "NotFoundNamespace",
            Code::NotFoundSourceService => "NotFoundSourceService",
            Code::NotFoundRateLimit => "NotFoundRateLimit",
            Code::NotFoundCircuitBreaker => "NotFoundCircuitBreaker",
            Code::NotFoundMasterConfig => "NotFoundMasterConfig",
            Code::NotFoundTagConfig => "NotFoundTagConfig",
            Code::NotFoundTagConfigOrService => "NotFoundTagConfigOrService",
            Code::ClientApiNotOpen => "ClientAPINotOpen",
            Code::NotAllowBusinessService => "NotAllowBusinessService",
            Code::NotAllowAliasUpdate => "NotAllowAliasUpdate",
            Code::NotAllowAliasCreateInstance => "NotAllowAliasCreateInstance",
            Code::NotAllowAliasCreateRouting => "NotAllowAliasCreateRouting",
            Code::NotAllowCreateAliasForAlias => "NotAllowCreateAliasForAlias",
            Code::NotAllowAliasCreateRateLimit => "NotAllowAliasCreateRateLimit",
            Code::NotAllowAliasBindRule => "NotAllowAliasBindRule",
            Code::NotAllowDifferentNamespaceBindRule => {
                "NotAllowDifferentNamespaceBindRule"
            }
            Code::Unauthorized => "Unauthorized",
            Code::NotAllowedAccess => "NotAllowedAccess",
            Code::CmdbNotFindHost => "CMDBNotFindHost",
            Code::DataConflict => "DataConflict",
            Code::InstanceTooManyRequests => "InstanceTooManyRequests",
            Code::IpRateLimit => "IPRateLimit",
            Code::ApiRateLimit => "APIRateLimit",
            Code::ExecuteException => "ExecuteException",
            Code::StoreLayerException => "StoreLayerException",
            Code::CmdbPluginException => "CMDBPluginException",
            Code::ParseRoutingException => "ParseRoutingException",
            Code::ParseRateLimitException => "ParseRateLimitException",
            Code::ParseCircuitBreakerException => "ParseCircuitBreakerException",
            Code::HeartbeatException => "HeartbeatException",
            Code::InstanceRegisTimeout => "InstanceRegisTimeout",
            Code::InvalidConfigFileGroupName => "InvalidConfigFileGroupName",
            Code::InvalidConfigFileName => "InvalidConfigFileName",
            Code::InvalidConfigFileContentLength => "InvalidConfigFileContentLength",
            Code::InvalidConfigFileFormat => "InvalidConfigFileFormat",
            Code::InvalidConfigFileTags => "InvalidConfigFileTags",
            Code::InvalidWatchConfigFileFormat => "InvalidWatchConfigFileFormat",
            Code::NotFoundResourceConfigFile => "NotFoundResourceConfigFile",
            Code::InvalidConfigFileTemplateName => "InvalidConfigFileTemplateName",
            Code::EncryptConfigFileException => "EncryptConfigFileException",
            Code::GroupExistActiveRelease => "GroupExistActiveRelease",
            Code::DecryptConfigFileException => "DecryptConfigFileException",
            Code::InvalidUserOwners => "InvalidUserOwners",
            Code::InvalidUserId => "InvalidUserID",
            Code::InvalidUserPassword => "InvalidUserPassword",
            Code::InvalidUserMobile => "InvalidUserMobile",
            Code::InvalidUserEmail => "InvalidUserEmail",
            Code::InvalidUserGroupOwners => "InvalidUserGroupOwners",
            Code::InvalidUserGroupId => "InvalidUserGroupID",
            Code::InvalidAuthStrategyOwners => "InvalidAuthStrategyOwners",
            Code::InvalidAuthStrategyName => "InvalidAuthStrategyName",
            Code::InvalidAuthStrategyId => "InvalidAuthStrategyID",
            Code::InvalidPrincipalType => "InvalidPrincipalType",
            Code::UserExisted => "UserExisted",
            Code::UserGroupExisted => "UserGroupExisted",
            Code::AuthStrategyRuleExisted => "AuthStrategyRuleExisted",
            Code::SubAccountExisted => "SubAccountExisted",
            Code::NotFoundUser => "NotFoundUser",
            Code::NotFoundOwnerUser => "NotFoundOwnerUser",
            Code::NotFoundUserGroup => "NotFoundUserGroup",
            Code::NotFoundAuthStrategyRule => "NotFoundAuthStrategyRule",
            Code::NotAllowModifyDefaultStrategyPrincipal => {
                "NotAllowModifyDefaultStrategyPrincipal"
            }
            Code::NotAllowModifyOwnerDefaultStrategy => {
                "NotAllowModifyOwnerDefaultStrategy"
            }
            Code::EmptyAutToken => "EmptyAutToken",
            Code::TokenDisabled => "TokenDisabled",
            Code::TokenNotExisted => "TokenNotExisted",
            Code::AuthTokenForbidden => "AuthTokenForbidden",
            Code::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),
            "InvalidNamespaceName" => Some(Self::InvalidNamespaceName),
            "InvalidNamespaceOwners" => Some(Self::InvalidNamespaceOwners),
            "InvalidNamespaceToken" => Some(Self::InvalidNamespaceToken),
            "InvalidServiceName" => Some(Self::InvalidServiceName),
            "InvalidServiceOwners" => Some(Self::InvalidServiceOwners),
            "InvalidServiceToken" => Some(Self::InvalidServiceToken),
            "InvalidServiceMetadata" => Some(Self::InvalidServiceMetadata),
            "InvalidServicePorts" => Some(Self::InvalidServicePorts),
            "InvalidServiceBusiness" => Some(Self::InvalidServiceBusiness),
            "InvalidServiceDepartment" => Some(Self::InvalidServiceDepartment),
            "InvalidServiceCMDB" => Some(Self::InvalidServiceCmdb),
            "InvalidServiceComment" => Some(Self::InvalidServiceComment),
            "InvalidServiceAliasComment" => Some(Self::InvalidServiceAliasComment),
            "InvalidInstanceID" => Some(Self::InvalidInstanceId),
            "InvalidInstanceHost" => Some(Self::InvalidInstanceHost),
            "InvalidInstancePort" => Some(Self::InvalidInstancePort),
            "InvalidServiceAlias" => Some(Self::InvalidServiceAlias),
            "InvalidNamespaceWithAlias" => Some(Self::InvalidNamespaceWithAlias),
            "InvalidServiceAliasOwners" => Some(Self::InvalidServiceAliasOwners),
            "InvalidInstanceProtocol" => Some(Self::InvalidInstanceProtocol),
            "InvalidInstanceVersion" => Some(Self::InvalidInstanceVersion),
            "InvalidInstanceLogicSet" => Some(Self::InvalidInstanceLogicSet),
            "InvalidInstanceIsolate" => Some(Self::InvalidInstanceIsolate),
            "HealthCheckNotOpen" => Some(Self::HealthCheckNotOpen),
            "HeartbeatOnDisabledIns" => Some(Self::HeartbeatOnDisabledIns),
            "HeartbeatExceedLimit" => Some(Self::HeartbeatExceedLimit),
            "HeartbeatTypeNotFound" => Some(Self::HeartbeatTypeNotFound),
            "InvalidMetadata" => Some(Self::InvalidMetadata),
            "InvalidRateLimitID" => Some(Self::InvalidRateLimitId),
            "InvalidRateLimitLabels" => Some(Self::InvalidRateLimitLabels),
            "InvalidRateLimitAmounts" => Some(Self::InvalidRateLimitAmounts),
            "InvalidRateLimitName" => Some(Self::InvalidRateLimitName),
            "InvalidCircuitBreakerID" => Some(Self::InvalidCircuitBreakerId),
            "InvalidCircuitBreakerVersion" => Some(Self::InvalidCircuitBreakerVersion),
            "InvalidCircuitBreakerName" => Some(Self::InvalidCircuitBreakerName),
            "InvalidCircuitBreakerNamespace" => {
                Some(Self::InvalidCircuitBreakerNamespace)
            }
            "InvalidCircuitBreakerOwners" => Some(Self::InvalidCircuitBreakerOwners),
            "InvalidCircuitBreakerToken" => Some(Self::InvalidCircuitBreakerToken),
            "InvalidCircuitBreakerBusiness" => Some(Self::InvalidCircuitBreakerBusiness),
            "InvalidCircuitBreakerDepartment" => {
                Some(Self::InvalidCircuitBreakerDepartment)
            }
            "InvalidCircuitBreakerComment" => Some(Self::InvalidCircuitBreakerComment),
            "CircuitBreakerRuleExisted" => Some(Self::CircuitBreakerRuleExisted),
            "InvalidRoutingID" => Some(Self::InvalidRoutingId),
            "InvalidRoutingPolicy" => Some(Self::InvalidRoutingPolicy),
            "InvalidRoutingName" => Some(Self::InvalidRoutingName),
            "InvalidRoutingPriority" => Some(Self::InvalidRoutingPriority),
            "InvalidFaultDetectID" => Some(Self::InvalidFaultDetectId),
            "InvalidFaultDetectName" => Some(Self::InvalidFaultDetectName),
            "InvalidFaultDetectNamespace" => Some(Self::InvalidFaultDetectNamespace),
            "FaultDetectRuleExisted" => Some(Self::FaultDetectRuleExisted),
            "InvalidMatchRule" => Some(Self::InvalidMatchRule),
            "ServicesExistedMesh" => Some(Self::ServicesExistedMesh),
            "ResourcesExistedMesh" => Some(Self::ResourcesExistedMesh),
            "InvalidMeshParameter" => Some(Self::InvalidMeshParameter),
            "InvalidPlatformID" => Some(Self::InvalidPlatformId),
            "InvalidPlatformName" => Some(Self::InvalidPlatformName),
            "InvalidPlatformDomain" => Some(Self::InvalidPlatformDomain),
            "InvalidPlatformQPS" => Some(Self::InvalidPlatformQps),
            "InvalidPlatformToken" => Some(Self::InvalidPlatformToken),
            "InvalidPlatformOwner" => Some(Self::InvalidPlatformOwner),
            "InvalidPlatformDepartment" => Some(Self::InvalidPlatformDepartment),
            "InvalidPlatformComment" => Some(Self::InvalidPlatformComment),
            "NotFoundPlatform" => Some(Self::NotFoundPlatform),
            "InvalidFluxRateLimitId" => Some(Self::InvalidFluxRateLimitId),
            "InvalidFluxRateLimitQps" => Some(Self::InvalidFluxRateLimitQps),
            "InvalidFluxRateLimitSetKey" => Some(Self::InvalidFluxRateLimitSetKey),
            "ExistedResource" => Some(Self::ExistedResource),
            "NotFoundResource" => Some(Self::NotFoundResource),
            "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),
            "NotFoundService" => Some(Self::NotFoundService),
            "NotFoundRouting" => Some(Self::NotFoundRouting),
            "NotFoundInstance" => Some(Self::NotFoundInstance),
            "NotFoundServiceAlias" => Some(Self::NotFoundServiceAlias),
            "NotFoundNamespace" => Some(Self::NotFoundNamespace),
            "NotFoundSourceService" => Some(Self::NotFoundSourceService),
            "NotFoundRateLimit" => Some(Self::NotFoundRateLimit),
            "NotFoundCircuitBreaker" => Some(Self::NotFoundCircuitBreaker),
            "NotFoundMasterConfig" => Some(Self::NotFoundMasterConfig),
            "NotFoundTagConfig" => Some(Self::NotFoundTagConfig),
            "NotFoundTagConfigOrService" => Some(Self::NotFoundTagConfigOrService),
            "ClientAPINotOpen" => Some(Self::ClientApiNotOpen),
            "NotAllowBusinessService" => Some(Self::NotAllowBusinessService),
            "NotAllowAliasUpdate" => Some(Self::NotAllowAliasUpdate),
            "NotAllowAliasCreateInstance" => Some(Self::NotAllowAliasCreateInstance),
            "NotAllowAliasCreateRouting" => Some(Self::NotAllowAliasCreateRouting),
            "NotAllowCreateAliasForAlias" => Some(Self::NotAllowCreateAliasForAlias),
            "NotAllowAliasCreateRateLimit" => Some(Self::NotAllowAliasCreateRateLimit),
            "NotAllowAliasBindRule" => Some(Self::NotAllowAliasBindRule),
            "NotAllowDifferentNamespaceBindRule" => {
                Some(Self::NotAllowDifferentNamespaceBindRule)
            }
            "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),
            "ParseRoutingException" => Some(Self::ParseRoutingException),
            "ParseRateLimitException" => Some(Self::ParseRateLimitException),
            "ParseCircuitBreakerException" => Some(Self::ParseCircuitBreakerException),
            "HeartbeatException" => Some(Self::HeartbeatException),
            "InstanceRegisTimeout" => Some(Self::InstanceRegisTimeout),
            "InvalidConfigFileGroupName" => Some(Self::InvalidConfigFileGroupName),
            "InvalidConfigFileName" => Some(Self::InvalidConfigFileName),
            "InvalidConfigFileContentLength" => {
                Some(Self::InvalidConfigFileContentLength)
            }
            "InvalidConfigFileFormat" => Some(Self::InvalidConfigFileFormat),
            "InvalidConfigFileTags" => Some(Self::InvalidConfigFileTags),
            "InvalidWatchConfigFileFormat" => Some(Self::InvalidWatchConfigFileFormat),
            "NotFoundResourceConfigFile" => Some(Self::NotFoundResourceConfigFile),
            "InvalidConfigFileTemplateName" => Some(Self::InvalidConfigFileTemplateName),
            "EncryptConfigFileException" => Some(Self::EncryptConfigFileException),
            "GroupExistActiveRelease" => Some(Self::GroupExistActiveRelease),
            "DecryptConfigFileException" => Some(Self::DecryptConfigFileException),
            "InvalidUserOwners" => Some(Self::InvalidUserOwners),
            "InvalidUserID" => Some(Self::InvalidUserId),
            "InvalidUserPassword" => Some(Self::InvalidUserPassword),
            "InvalidUserMobile" => Some(Self::InvalidUserMobile),
            "InvalidUserEmail" => Some(Self::InvalidUserEmail),
            "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,
        }
    }
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ConfigSimpleResponse {
    #[prost(message, optional, tag = "1")]
    pub code: ::core::option::Option<u32>,
    #[prost(message, optional, tag = "2")]
    pub info: ::core::option::Option<::prost::alloc::string::String>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ConfigResponse {
    #[prost(message, optional, tag = "1")]
    pub code: ::core::option::Option<u32>,
    #[prost(message, optional, tag = "2")]
    pub info: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "3")]
    pub config_file_group: ::core::option::Option<ConfigFileGroup>,
    #[prost(message, optional, tag = "4")]
    pub config_file: ::core::option::Option<ConfigFile>,
    #[prost(message, optional, tag = "5")]
    pub config_file_release: ::core::option::Option<ConfigFileRelease>,
    #[prost(message, optional, tag = "6")]
    pub config_file_release_history: ::core::option::Option<ConfigFileReleaseHistory>,
    #[prost(message, optional, tag = "7")]
    pub config_file_template: ::core::option::Option<ConfigFileTemplate>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ConfigBatchWriteResponse {
    #[prost(message, optional, tag = "1")]
    pub code: ::core::option::Option<u32>,
    #[prost(message, optional, tag = "2")]
    pub info: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "3")]
    pub total: ::core::option::Option<u32>,
    #[prost(message, repeated, tag = "4")]
    pub responses: ::prost::alloc::vec::Vec<ConfigResponse>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ConfigBatchQueryResponse {
    #[prost(message, optional, tag = "1")]
    pub code: ::core::option::Option<u32>,
    #[prost(message, optional, tag = "2")]
    pub info: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "3")]
    pub total: ::core::option::Option<u32>,
    #[prost(message, repeated, tag = "4")]
    pub config_file_groups: ::prost::alloc::vec::Vec<ConfigFileGroup>,
    #[prost(message, repeated, tag = "5")]
    pub config_files: ::prost::alloc::vec::Vec<ConfigFile>,
    #[prost(message, repeated, tag = "6")]
    pub config_file_releases: ::prost::alloc::vec::Vec<ConfigFileRelease>,
    #[prost(message, repeated, tag = "7")]
    pub config_file_release_histories: ::prost::alloc::vec::Vec<
        ConfigFileReleaseHistory,
    >,
    #[prost(message, repeated, tag = "8")]
    pub config_file_templates: ::prost::alloc::vec::Vec<ConfigFileTemplate>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ConfigClientResponse {
    #[prost(message, optional, tag = "1")]
    pub code: ::core::option::Option<u32>,
    #[prost(message, optional, tag = "2")]
    pub info: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "3")]
    pub config_file: ::core::option::Option<ClientConfigFileInfo>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ConfigImportResponse {
    #[prost(message, optional, tag = "1")]
    pub code: ::core::option::Option<u32>,
    #[prost(message, optional, tag = "2")]
    pub info: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, repeated, tag = "3")]
    pub create_config_files: ::prost::alloc::vec::Vec<ConfigFile>,
    #[prost(message, repeated, tag = "4")]
    pub skip_config_files: ::prost::alloc::vec::Vec<ConfigFile>,
    #[prost(message, repeated, tag = "5")]
    pub overwrite_config_files: ::prost::alloc::vec::Vec<ConfigFile>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ConfigExportResponse {
    #[prost(message, optional, tag = "1")]
    pub code: ::core::option::Option<u32>,
    #[prost(message, optional, tag = "2")]
    pub info: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "3")]
    pub data: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ConfigEncryptAlgorithmResponse {
    #[prost(message, optional, tag = "1")]
    pub code: ::core::option::Option<u32>,
    #[prost(message, optional, tag = "2")]
    pub info: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, repeated, tag = "3")]
    pub algorithms: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ConfigClientListResponse {
    #[prost(message, optional, tag = "1")]
    pub code: ::core::option::Option<u32>,
    #[prost(message, optional, tag = "2")]
    pub info: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "3")]
    pub revision: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, tag = "4")]
    pub namespace: ::prost::alloc::string::String,
    #[prost(string, tag = "5")]
    pub group: ::prost::alloc::string::String,
    #[prost(message, repeated, tag = "6")]
    pub config_file_infos: ::prost::alloc::vec::Vec<ClientConfigFileInfo>,
}
/// Generated client implementations.
pub mod polaris_config_grpc_client {
    #![allow(unused_variables, dead_code, missing_docs, clippy::let_unit_value)]
    use tonic::codegen::*;
    use tonic::codegen::http::Uri;
    #[derive(Debug, Clone)]
    pub struct PolarisConfigGrpcClient<T> {
        inner: tonic::client::Grpc<T>,
    }
    impl PolarisConfigGrpcClient<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> PolarisConfigGrpcClient<T>
    where
        T: tonic::client::GrpcService<tonic::body::BoxBody>,
        T::Error: Into<StdError>,
        T::ResponseBody: Body<Data = Bytes> + Send + 'static,
        <T::ResponseBody as Body>::Error: Into<StdError> + Send,
    {
        pub fn new(inner: T) -> Self {
            let inner = tonic::client::Grpc::new(inner);
            Self { inner }
        }
        pub fn with_origin(inner: T, origin: Uri) -> Self {
            let inner = tonic::client::Grpc::with_origin(inner, origin);
            Self { inner }
        }
        pub fn with_interceptor<F>(
            inner: T,
            interceptor: F,
        ) -> PolarisConfigGrpcClient<InterceptedService<T, F>>
        where
            F: tonic::service::Interceptor,
            T::ResponseBody: Default,
            T: tonic::codegen::Service<
                http::Request<tonic::body::BoxBody>,
                Response = http::Response<
                    <T as tonic::client::GrpcService<tonic::body::BoxBody>>::ResponseBody,
                >,
            >,
            <T as tonic::codegen::Service<
                http::Request<tonic::body::BoxBody>,
            >>::Error: Into<StdError> + Send + Sync,
        {
            PolarisConfigGrpcClient::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 get_config_file(
            &mut self,
            request: impl tonic::IntoRequest<super::ClientConfigFileInfo>,
        ) -> std::result::Result<
            tonic::Response<super::ConfigClientResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::new(
                        tonic::Code::Unknown,
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/v1.PolarisConfigGRPC/GetConfigFile",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("v1.PolarisConfigGRPC", "GetConfigFile"));
            self.inner.unary(req, path, codec).await
        }
        /// 创建配置
        pub async fn create_config_file(
            &mut self,
            request: impl tonic::IntoRequest<super::ConfigFile>,
        ) -> std::result::Result<
            tonic::Response<super::ConfigClientResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::new(
                        tonic::Code::Unknown,
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/v1.PolarisConfigGRPC/CreateConfigFile",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("v1.PolarisConfigGRPC", "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::ConfigClientResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::new(
                        tonic::Code::Unknown,
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/v1.PolarisConfigGRPC/UpdateConfigFile",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("v1.PolarisConfigGRPC", "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::ConfigClientResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::new(
                        tonic::Code::Unknown,
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/v1.PolarisConfigGRPC/PublishConfigFile",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("v1.PolarisConfigGRPC", "PublishConfigFile"));
            self.inner.unary(req, path, codec).await
        }
        /// 发布配置
        pub async fn upsert_and_publish_config_file(
            &mut self,
            request: impl tonic::IntoRequest<super::ConfigFilePublishInfo>,
        ) -> std::result::Result<
            tonic::Response<super::ConfigClientResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::new(
                        tonic::Code::Unknown,
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/v1.PolarisConfigGRPC/UpsertAndPublishConfigFile",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new("v1.PolarisConfigGRPC", "UpsertAndPublishConfigFile"),
                );
            self.inner.unary(req, path, codec).await
        }
        /// 订阅配置变更
        pub async fn watch_config_files(
            &mut self,
            request: impl tonic::IntoRequest<super::ClientWatchConfigFileRequest>,
        ) -> std::result::Result<
            tonic::Response<super::ConfigClientResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::new(
                        tonic::Code::Unknown,
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/v1.PolarisConfigGRPC/WatchConfigFiles",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("v1.PolarisConfigGRPC", "WatchConfigFiles"));
            self.inner.unary(req, path, codec).await
        }
        /// 拉取指定配置分组下的配置文件列表
        pub async fn get_config_file_metadata_list(
            &mut self,
            request: impl tonic::IntoRequest<super::ConfigFileGroupRequest>,
        ) -> std::result::Result<
            tonic::Response<super::ConfigClientListResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::new(
                        tonic::Code::Unknown,
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/v1.PolarisConfigGRPC/GetConfigFileMetadataList",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new("v1.PolarisConfigGRPC", "GetConfigFileMetadataList"),
                );
            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::new(
                        tonic::Code::Unknown,
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/v1.PolarisConfigGRPC/Discover",
            );
            let mut req = request.into_streaming_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("v1.PolarisConfigGRPC", "Discover"));
            self.inner.streaming(req, path, codec).await
        }
    }
}
/// Generated server implementations.
pub mod polaris_config_grpc_server {
    #![allow(unused_variables, dead_code, missing_docs, clippy::let_unit_value)]
    use tonic::codegen::*;
    /// Generated trait containing gRPC methods that should be implemented for use with PolarisConfigGrpcServer.
    #[async_trait]
    pub trait PolarisConfigGrpc: Send + Sync + 'static {
        /// 拉取配置
        async fn get_config_file(
            &self,
            request: tonic::Request<super::ClientConfigFileInfo>,
        ) -> std::result::Result<
            tonic::Response<super::ConfigClientResponse>,
            tonic::Status,
        >;
        /// 创建配置
        async fn create_config_file(
            &self,
            request: tonic::Request<super::ConfigFile>,
        ) -> std::result::Result<
            tonic::Response<super::ConfigClientResponse>,
            tonic::Status,
        >;
        /// 更新配置
        async fn update_config_file(
            &self,
            request: tonic::Request<super::ConfigFile>,
        ) -> std::result::Result<
            tonic::Response<super::ConfigClientResponse>,
            tonic::Status,
        >;
        /// 发布配置
        async fn publish_config_file(
            &self,
            request: tonic::Request<super::ConfigFileRelease>,
        ) -> std::result::Result<
            tonic::Response<super::ConfigClientResponse>,
            tonic::Status,
        >;
        /// 发布配置
        async fn upsert_and_publish_config_file(
            &self,
            request: tonic::Request<super::ConfigFilePublishInfo>,
        ) -> std::result::Result<
            tonic::Response<super::ConfigClientResponse>,
            tonic::Status,
        >;
        /// 订阅配置变更
        async fn watch_config_files(
            &self,
            request: tonic::Request<super::ClientWatchConfigFileRequest>,
        ) -> std::result::Result<
            tonic::Response<super::ConfigClientResponse>,
            tonic::Status,
        >;
        /// 拉取指定配置分组下的配置文件列表
        async fn get_config_file_metadata_list(
            &self,
            request: tonic::Request<super::ConfigFileGroupRequest>,
        ) -> std::result::Result<
            tonic::Response<super::ConfigClientListResponse>,
            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>,
            >
            + 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 PolarisConfigGrpcServer<T: PolarisConfigGrpc> {
        inner: _Inner<T>,
        accept_compression_encodings: EnabledCompressionEncodings,
        send_compression_encodings: EnabledCompressionEncodings,
        max_decoding_message_size: Option<usize>,
        max_encoding_message_size: Option<usize>,
    }
    struct _Inner<T>(Arc<T>);
    impl<T: PolarisConfigGrpc> PolarisConfigGrpcServer<T> {
        pub fn new(inner: T) -> Self {
            Self::from_arc(Arc::new(inner))
        }
        pub fn from_arc(inner: Arc<T>) -> Self {
            let inner = _Inner(inner);
            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 PolarisConfigGrpcServer<T>
    where
        T: PolarisConfigGrpc,
        B: Body + Send + 'static,
        B::Error: Into<StdError> + Send + 'static,
    {
        type Response = http::Response<tonic::body::BoxBody>;
        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 {
            let inner = self.inner.clone();
            match req.uri().path() {
                "/v1.PolarisConfigGRPC/GetConfigFile" => {
                    #[allow(non_camel_case_types)]
                    struct GetConfigFileSvc<T: PolarisConfigGrpc>(pub Arc<T>);
                    impl<
                        T: PolarisConfigGrpc,
                    > tonic::server::UnaryService<super::ClientConfigFileInfo>
                    for GetConfigFileSvc<T> {
                        type Response = super::ConfigClientResponse;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::ClientConfigFileInfo>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as PolarisConfigGrpc>::get_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 inner = inner.0;
                        let method = GetConfigFileSvc(inner);
                        let codec = tonic::codec::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.PolarisConfigGRPC/CreateConfigFile" => {
                    #[allow(non_camel_case_types)]
                    struct CreateConfigFileSvc<T: PolarisConfigGrpc>(pub Arc<T>);
                    impl<
                        T: PolarisConfigGrpc,
                    > tonic::server::UnaryService<super::ConfigFile>
                    for CreateConfigFileSvc<T> {
                        type Response = super::ConfigClientResponse;
                        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 PolarisConfigGrpc>::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 inner = inner.0;
                        let method = CreateConfigFileSvc(inner);
                        let codec = tonic::codec::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.PolarisConfigGRPC/UpdateConfigFile" => {
                    #[allow(non_camel_case_types)]
                    struct UpdateConfigFileSvc<T: PolarisConfigGrpc>(pub Arc<T>);
                    impl<
                        T: PolarisConfigGrpc,
                    > tonic::server::UnaryService<super::ConfigFile>
                    for UpdateConfigFileSvc<T> {
                        type Response = super::ConfigClientResponse;
                        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 PolarisConfigGrpc>::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 inner = inner.0;
                        let method = UpdateConfigFileSvc(inner);
                        let codec = tonic::codec::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.PolarisConfigGRPC/PublishConfigFile" => {
                    #[allow(non_camel_case_types)]
                    struct PublishConfigFileSvc<T: PolarisConfigGrpc>(pub Arc<T>);
                    impl<
                        T: PolarisConfigGrpc,
                    > tonic::server::UnaryService<super::ConfigFileRelease>
                    for PublishConfigFileSvc<T> {
                        type Response = super::ConfigClientResponse;
                        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 PolarisConfigGrpc>::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 inner = inner.0;
                        let method = PublishConfigFileSvc(inner);
                        let codec = tonic::codec::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.PolarisConfigGRPC/UpsertAndPublishConfigFile" => {
                    #[allow(non_camel_case_types)]
                    struct UpsertAndPublishConfigFileSvc<T: PolarisConfigGrpc>(
                        pub Arc<T>,
                    );
                    impl<
                        T: PolarisConfigGrpc,
                    > tonic::server::UnaryService<super::ConfigFilePublishInfo>
                    for UpsertAndPublishConfigFileSvc<T> {
                        type Response = super::ConfigClientResponse;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::ConfigFilePublishInfo>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as PolarisConfigGrpc>::upsert_and_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 inner = inner.0;
                        let method = UpsertAndPublishConfigFileSvc(inner);
                        let codec = tonic::codec::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.PolarisConfigGRPC/WatchConfigFiles" => {
                    #[allow(non_camel_case_types)]
                    struct WatchConfigFilesSvc<T: PolarisConfigGrpc>(pub Arc<T>);
                    impl<
                        T: PolarisConfigGrpc,
                    > tonic::server::UnaryService<super::ClientWatchConfigFileRequest>
                    for WatchConfigFilesSvc<T> {
                        type Response = super::ConfigClientResponse;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::ClientWatchConfigFileRequest>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as PolarisConfigGrpc>::watch_config_files(
                                        &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 inner = inner.0;
                        let method = WatchConfigFilesSvc(inner);
                        let codec = tonic::codec::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.PolarisConfigGRPC/GetConfigFileMetadataList" => {
                    #[allow(non_camel_case_types)]
                    struct GetConfigFileMetadataListSvc<T: PolarisConfigGrpc>(
                        pub Arc<T>,
                    );
                    impl<
                        T: PolarisConfigGrpc,
                    > tonic::server::UnaryService<super::ConfigFileGroupRequest>
                    for GetConfigFileMetadataListSvc<T> {
                        type Response = super::ConfigClientListResponse;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::ConfigFileGroupRequest>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as PolarisConfigGrpc>::get_config_file_metadata_list(
                                        &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 inner = inner.0;
                        let method = GetConfigFileMetadataListSvc(inner);
                        let codec = tonic::codec::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.PolarisConfigGRPC/Discover" => {
                    #[allow(non_camel_case_types)]
                    struct DiscoverSvc<T: PolarisConfigGrpc>(pub Arc<T>);
                    impl<
                        T: PolarisConfigGrpc,
                    > 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 PolarisConfigGrpc>::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 inner = inner.0;
                        let method = DiscoverSvc(inner);
                        let codec = tonic::codec::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 {
                        Ok(
                            http::Response::builder()
                                .status(200)
                                .header("grpc-status", "12")
                                .header("content-type", "application/grpc")
                                .body(empty_body())
                                .unwrap(),
                        )
                    })
                }
            }
        }
    }
    impl<T: PolarisConfigGrpc> Clone for PolarisConfigGrpcServer<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,
            }
        }
    }
    impl<T: PolarisConfigGrpc> Clone for _Inner<T> {
        fn clone(&self) -> Self {
            Self(Arc::clone(&self.0))
        }
    }
    impl<T: std::fmt::Debug> std::fmt::Debug for _Inner<T> {
        fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
            write!(f, "{:?}", self.0)
        }
    }
    impl<T: PolarisConfigGrpc> tonic::server::NamedService
    for PolarisConfigGrpcServer<T> {
        const NAME: &'static str = "v1.PolarisConfigGRPC";
    }
}