consul-api 0.0.6-pre

// The content of this file is generated by 'scanner/main.go'.
// Do not modify it manually.
// Manual changes may cause issues with the program's operation.
// If modifications are needed, please do so through the program's logic.

use base64::{engine::general_purpose::STANDARD, Engine as _};
use serde::{Deserialize, Serialize};

#[derive(Debug, Copy, Clone, Serialize, Deserialize, Eq, PartialEq)]
pub enum MeshGatewayMode {
    /// MeshGatewayModeDefault represents no specific mode and should
    /// be used to indicate that a different layer of the configuration
    /// chain should take precedence
    #[serde(rename = "")]
    Default,

    /// MeshGatewayModeNone represents that the Upstream Connect connections
    /// should be direct and not flow through a mesh gateway.
    #[serde(rename = "none")]
    None,

    /// MeshGatewayModeLocal represents that the Upstream Connect connections
    /// should be made to a mesh gateway in the local datacenter.
    #[serde(rename = "local")]
    Local,

    /// MeshGatewayModeRemote represents that the Upstream Connect connections
    /// should be made to a mesh gateway in a remote datacenter.
    #[serde(rename = "remote")]
    Remote,
}

impl Default for MeshGatewayMode {
    fn default() -> Self {
        Self::Default
    }
}

impl ::core::fmt::Display for MeshGatewayMode {
    fn fmt(&self, f: &mut ::core::fmt::Formatter) -> ::core::fmt::Result {
        match self {
            Self::Default => write!(f, ""),
            Self::None => write!(f, "none"),
            Self::Local => write!(f, "local"),
            Self::Remote => write!(f, "remote"),
        }
    }
}

// TODO 不清楚为何会返回 “Default”，但又不在定义中，所以暂时用字符串代替这个定义
// #[derive(Debug, Copy, Clone, Serialize, Deserialize, Eq, PartialEq)]
// pub enum ProxyMode {
//     /// ProxyModeDefault represents no specific mode and should
//     /// be used to indicate that a different layer of the configuration
//     /// chain should take precedence
//     #[serde(rename = "")]
//     Default,

//     /// ProxyModeTransparent represents that inbound and outbound application
//     /// traffic is being captured and redirected through the proxy.
//     #[serde(rename = "transparent")]
//     Transparent,

//     /// ProxyModeDirect represents that the proxy's listeners must be dialed directly
//     /// by the local application and other proxies.
//     #[serde(rename = "direct")]
//     Direct,
// }

// impl Default for ProxyMode {
//     fn default() -> Self {
//         Self::Default
//     }
// }

// impl ::core::fmt::Display for ProxyMode {
//     fn fmt(&self, f: &mut ::core::fmt::Formatter) -> ::core::fmt::Result {
//         match self {
//             Self::Default => write!(f, ""),
//             Self::Transparent => write!(f, "transparent"),
//             Self::Direct => write!(f, "direct"),
//         }
//     }
// }

#[derive(Debug, Copy, Clone, Serialize, Deserialize, Eq, PartialEq)]
pub enum LogSinkType {
    #[serde(rename = "")]
    Default,
    #[serde(rename = "file")]
    File,
    #[serde(rename = "stderr")]
    StdErr,
    #[serde(rename = "stdout")]
    StdOut,
}

impl Default for LogSinkType {
    fn default() -> Self {
        Self::Default
    }
}

impl ::core::fmt::Display for LogSinkType {
    fn fmt(&self, f: &mut ::core::fmt::Formatter) -> ::core::fmt::Result {
        match self {
            Self::Default => write!(f, ""),
            Self::File => write!(f, "file"),
            Self::StdErr => write!(f, "stderr"),
            Self::StdOut => write!(f, "stdout"),
        }
    }
}

#[derive(Debug, Copy, Clone, Serialize, Deserialize, Eq, PartialEq)]
pub enum Health {
    /// HealthAny is special, and is used as a wild card,
    /// not as a specific state.
    #[serde(rename = "any")]
    Any,
    #[serde(rename = "passing")]
    Passing,
    #[serde(rename = "warning")]
    Warning,
    #[serde(rename = "critical")]
    Critical,
    #[serde(rename = "maintenance")]
    Maintenance,
}

impl Default for Health {
    fn default() -> Self {
        Self::Any
    }
}

impl From<&str> for Health {
    fn from(s: &str) -> Self {
        match s {
            _ => Self::Any,
            "passing" => Self::Passing,
            "warning" => Self::Warning,
            "critical" => Self::Critical,
            "maintenance" => Self::Maintenance,
        }
    }
}

impl ::core::fmt::Display for Health {
    fn fmt(&self, f: &mut ::core::fmt::Formatter) -> ::core::fmt::Result {
        match self {
            Self::Any => write!(f, "any"),
            Self::Passing => write!(f, "passing"),
            Self::Warning => write!(f, "warning"),
            Self::Critical => write!(f, "critical"),
            Self::Maintenance => write!(f, "maintenance"),
        }
    }
}

#[derive(Debug, Copy, Clone, Serialize, Deserialize, Eq, PartialEq)]
pub enum GatewayServiceKind {
    #[serde(rename = "")]
    Unknown,
    #[serde(rename = "destination")]
    Destination,
    #[serde(rename = "service")]
    Service,
}

impl Default for GatewayServiceKind {
    fn default() -> Self {
        Self::Unknown
    }
}

impl ::core::fmt::Display for GatewayServiceKind {
    fn fmt(&self, f: &mut ::core::fmt::Formatter) -> ::core::fmt::Result {
        match self {
            Self::Unknown => write!(f, ""),
            Self::Destination => write!(f, "destination"),
            Self::Service => write!(f, "service"),
        }
    }
}

#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct Base64Payload(pub(crate) String);

impl Base64Payload {
    pub fn to_vec(&self) -> Vec<u8> {
        STANDARD.decode(&self.0).unwrap()
    }
}

#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct ACLLink {
    #[serde(rename = "ID")]
    pub id: String,

    #[serde(rename = "Name")]
    pub name: String,

}

/// AgentWeights represent optional weights for a service
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct AgentWeights {
    #[serde(rename = "Passing")]
    pub passing: isize,

    #[serde(rename = "Warning")]
    pub warning: isize,

}

/// AgentService represents a service known to the agent
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct AgentService {
    #[serde(rename = "ID")]
    pub id: String,

    #[serde(rename = "Service")]
    pub service: String,

    #[serde(rename = "Tags")]
    pub tags: Vec<String>,

    #[serde(rename = "Meta")]
    pub meta: ::std::collections::HashMap<String, String>,

    #[serde(rename = "Port")]
    pub port: u16,

    #[serde(rename = "Address")]
    pub address: String,

    #[serde(rename = "SocketPath")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub socket_path: Option<String>,

    #[serde(rename = "TaggedAddresses")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub tagged_addresses: Option<::std::collections::HashMap<String, ServiceAddress>>,

    #[serde(rename = "Weights")]
    pub weights: AgentWeights,

    #[serde(rename = "EnableTagOverride")]
    pub enable_tag_override: bool,

    #[serde(rename = "CreateIndex")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub create_index: Option<u64>,

    #[serde(rename = "ModifyIndex")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub modify_index: Option<u64>,

    #[serde(rename = "ContentHash")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub content_hash: Option<String>,

    #[serde(rename = "Proxy")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub proxy: Option<AgentServiceConnectProxyConfig>,

    #[serde(rename = "Connect")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub connect: Option<AgentServiceConnect>,

    /// NOTE: If we ever set the ContentHash outside of singular service lookup then we may need
    /// to include the Namespace in the hash. When we do, then we are in for lots of fun with tests.
    /// For now though, ignoring it works well enough.
    #[serde(rename = "Namespace")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub namespace: Option<String>,

    #[serde(rename = "Partition")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub partition: Option<String>,

    /// Datacenter is only ever returned and is ignored if presented.
    #[serde(rename = "Datacenter")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub datacenter: Option<String>,

    #[cfg(feature = "enterprise")]
    #[serde(rename = "Locality")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub locality: Option<Locality>,

}

/// AgentServiceChecksInfo returns information about a Service and its checks
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct AgentServiceChecksInfo {
    #[serde(rename = "AggregatedStatus")]
    pub aggregated_status: Health,

    #[serde(rename = "Service")]
    pub service: AgentService,

    #[serde(rename = "Checks")]
    pub checks: HealthChecks,

}

/// AgentServiceConnect represents the Connect configuration of a service.
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct AgentServiceConnect {
    #[serde(rename = "Native")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub native: Option<bool>,

    #[serde(rename = "SidecarService")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub sidecar_service: Option<Box<AgentServiceRegistration>>,

}

/// AgentServiceConnectProxyConfig is the proxy configuration in a connect-proxy
/// ServiceDefinition or response.
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct AgentServiceConnectProxyConfig {
    #[serde(rename = "EnvoyExtensions")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub envoy_extensions: Option<Vec<EnvoyExtension>>,

    #[serde(rename = "DestinationServiceName")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub destination_service_name: Option<String>,

    #[serde(rename = "DestinationServiceID")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub destination_service_id: Option<String>,

    #[serde(rename = "LocalServiceAddress")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub local_service_address: Option<String>,

    #[serde(rename = "LocalServicePort")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub local_service_port: Option<u16>,

    #[serde(rename = "LocalServiceSocketPath")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub local_service_socket_path: Option<String>,

    #[serde(rename = "Mode")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub mode: Option<String>,

    #[serde(rename = "TransparentProxy")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub transparent_proxy: Option<TransparentProxyConfig>,

    #[serde(rename = "Upstreams")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub upstreams: Option<Vec<Upstream>>,

    #[serde(rename = "MeshGateway")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub mesh_gateway: Option<MeshGatewayConfig>,

    #[serde(rename = "Expose")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub expose: Option<ExposeConfig>,

    #[serde(rename = "AccessLogs")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub access_logs: Option<AccessLogsConfig>,

}

/// AgentServiceRegistration is used to register a new service
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct AgentServiceRegistration {
    #[serde(rename = "Kind")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub kind: Option<String>,

    #[serde(rename = "ID")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub id: Option<String>,

    #[serde(rename = "Name")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub name: Option<String>,

    #[serde(rename = "Tags")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub tags: Option<Vec<String>>,

    #[serde(rename = "Port")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub port: Option<u16>,

    #[serde(rename = "Address")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub address: Option<String>,

    #[serde(rename = "SocketPath")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub socket_path: Option<String>,

    #[serde(rename = "TaggedAddresses")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub tagged_addresses: Option<::std::collections::HashMap<String, ServiceAddress>>,

    #[serde(rename = "EnableTagOverride")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub enable_tag_override: Option<bool>,

    #[serde(rename = "Meta")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub meta: Option<::std::collections::HashMap<String, String>>,

    #[serde(rename = "Weights")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub weights: Option<AgentWeights>,

    #[serde(rename = "Check")]
    pub check: AgentServiceCheck,

    #[serde(rename = "Checks")]
    pub checks: AgentServiceChecks,

    #[serde(rename = "Proxy")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub proxy: Option<AgentServiceConnectProxyConfig>,

    #[serde(rename = "Connect")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub connect: Option<AgentServiceConnect>,

    #[serde(rename = "Namespace")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub namespace: Option<String>,

    #[serde(rename = "Partition")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub partition: Option<String>,

    #[cfg(feature = "enterprise")]
    #[serde(rename = "Locality")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub locality: Option<Locality>,

}

/// AgentServiceCheck is used to define a node or service level check
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct AgentServiceCheck {
    #[serde(rename = "CheckID")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub check_id: Option<String>,

    #[serde(rename = "Name")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub name: Option<String>,

    #[serde(rename = "Args")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub args: Option<Vec<String>>,

    #[serde(rename = "DockerContainerID")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub docker_container_id: Option<String>,

    #[serde(rename = "Shell")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub shell: Option<String>,

    #[serde(rename = "Interval")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub interval: Option<String>,

    #[serde(rename = "Timeout")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub timeout: Option<String>,

    #[serde(rename = "TTL")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub ttl: Option<String>,

    #[serde(rename = "HTTP")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub http: Option<String>,

    #[serde(rename = "Header")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub header: Option<::std::collections::HashMap<String, Vec<String>>>,

    #[serde(rename = "Method")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub method: Option<String>,

    #[serde(rename = "Body")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub body: Option<String>,

    #[serde(rename = "TCP")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub tcp: Option<String>,

    #[serde(rename = "TCPUseTLS")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub tcp_use_tls: Option<bool>,

    #[serde(rename = "UDP")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub udp: Option<String>,

    #[serde(rename = "Status")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub status: Option<String>,

    #[serde(rename = "Notes")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub notes: Option<String>,

    #[serde(rename = "TLSServerName")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub tls_server_name: Option<String>,

    #[serde(rename = "TLSSkipVerify")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub tls_skip_verify: Option<bool>,

    #[serde(rename = "GRPC")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub grpc: Option<String>,

    #[serde(rename = "GRPCUseTLS")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub grpc_use_tls: Option<bool>,

    #[serde(rename = "H2PING")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub h2_ping: Option<String>,

    #[serde(rename = "H2PingUseTLS")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub h2_ping_use_tls: Option<bool>,

    #[serde(rename = "AliasNode")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub alias_node: Option<String>,

    #[serde(rename = "AliasService")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub alias_service: Option<String>,

    #[serde(rename = "SuccessBeforePassing")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub success_before_passing: Option<isize>,

    #[serde(rename = "FailuresBeforeWarning")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub failures_before_warning: Option<isize>,

    #[serde(rename = "FailuresBeforeCritical")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub failures_before_critical: Option<isize>,

    /// In Consul 0.7 and later, checks that are associated with a service
    /// may also contain this optional DeregisterCriticalServiceAfter field,
    /// which is a timeout in the same Go time format as Interval and TTL. If
    /// a check is in the critical state for more than this configured value,
    /// then its associated service (and all of its associated checks) will
    /// automatically be deregistered.
    #[serde(rename = "DeregisterCriticalServiceAfter")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub deregister_critical_service_after: Option<String>,

}

pub type AgentServiceChecks = Vec<AgentServiceCheck>;


/// QueryOptions are used to parameterize a query
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct QueryOptions {
    /// Namespace overrides the `default` namespace
    /// Note: Namespaces are available only in Consul Enterprise
    #[serde(rename = "Namespace")]
    pub namespace: String,

    /// Partition overrides the `default` partition
    /// Note: Partitions are available only in Consul Enterprise
    #[serde(rename = "Partition")]
    pub partition: String,

    /// SamenessGroup is used find the SamenessGroup in the given
    /// Partition and will find the failover order for the Service
    /// from the SamenessGroup Members, with the given Partition being
    /// the first member.
    /// Note: SamenessGroups are available only in Consul Enterprise
    #[serde(rename = "SamenessGroup")]
    pub sameness_group: String,

    /// Providing a datacenter overwrites the DC provided
    /// by the Config
    #[serde(rename = "Datacenter")]
    pub datacenter: String,

    /// Providing a peer name in the query option
    #[serde(rename = "Peer")]
    pub peer: String,

    /// AllowStale allows any Consul server (non-leader) to service
    /// a read. This allows for lower latency and higher throughput
    #[serde(rename = "AllowStale")]
    pub allow_stale: bool,

    /// RequireConsistent forces the read to be fully consistent.
    /// This is more expensive but prevents ever performing a stale
    /// read.
    #[serde(rename = "RequireConsistent")]
    pub require_consistent: bool,

    /// UseCache requests that the agent cache results locally. See
    /// https://www.consul.io/api/features/caching.html for more details on the
    /// semantics.
    #[serde(rename = "UseCache")]
    pub use_cache: bool,

    /// MaxAge limits how old a cached value will be returned if UseCache is true.
    /// If there is a cached response that is older than the MaxAge, it is treated
    /// as a cache miss and a new fetch invoked. If the fetch fails, the error is
    /// returned. Clients that wish to allow for stale results on error can set
    /// StaleIfError to a longer duration to change this behavior. It is ignored
    /// if the endpoint supports background refresh caching. See
    /// https://www.consul.io/api/features/caching.html for more details.
    #[serde(rename = "MaxAge")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub max_age: Option<String>,

    /// StaleIfError specifies how stale the client will accept a cached response
    /// if the servers are unavailable to fetch a fresh one. Only makes sense when
    /// UseCache is true and MaxAge is set to a lower, non-zero value. It is
    /// ignored if the endpoint supports background refresh caching. See
    /// https://www.consul.io/api/features/caching.html for more details.
    #[serde(rename = "StaleIfError")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub stale_if_error: Option<String>,

    /// WaitIndex is used to enable a blocking query. Waits
    /// until the timeout or the next index is reached
    #[serde(rename = "WaitIndex")]
    pub wait_index: u64,

    /// WaitHash is used by some endpoints instead of WaitIndex to perform blocking
    /// on state based on a hash of the response rather than a monotonic index.
    /// This is required when the state being blocked on is not stored in Raft, for
    /// example agent-local proxy configuration.
    #[serde(rename = "WaitHash")]
    pub wait_hash: String,

    /// WaitTime is used to bound the duration of a wait.
    /// Defaults to that of the Config, but can be overridden.
    #[serde(rename = "WaitTime")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub wait_time: Option<String>,

    /// Token is used to provide a per-request ACL token
    /// which overrides the agent's default token.
    #[serde(rename = "Token")]
    pub token: String,

    /// Near is used to provide a node name that will sort the results
    /// in ascending order based on the estimated round trip time from
    /// that node. Setting this to "_agent" will use the agent's node
    /// for the sort.
    #[serde(rename = "Near")]
    pub near: String,

    /// NodeMeta is used to filter results by nodes with the given
    /// metadata key/value pairs. Currently, only one key/value pair can
    /// be provided for filtering.
    #[serde(rename = "NodeMeta")]
    pub node_meta: ::std::collections::HashMap<String, String>,

    /// RelayFactor is used in keyring operations to cause responses to be
    /// relayed back to the sender through N other random nodes. Must be
    /// a value from 0 to 5 (inclusive).
    #[serde(rename = "RelayFactor")]
    pub relay_factor: u8,

    /// LocalOnly is used in keyring list operation to force the keyring
    /// query to only hit local servers (no WAN traffic).
    #[serde(rename = "LocalOnly")]
    pub local_only: bool,

    /// Connect filters prepared query execution to only include Connect-capable
    /// services. This currently affects prepared query execution.
    #[serde(rename = "Connect")]
    pub connect: bool,

    /// Filter requests filtering data prior to it being returned. The string
    /// is a go-bexpr compatible expression.
    #[serde(rename = "Filter")]
    pub filter: String,

    /// MergeCentralConfig returns a service definition merged with the
    /// proxy-defaults/global and service-defaults/:service config entries.
    /// This can be used to ensure a full service definition is returned in the response
    /// especially when the service might not be written into the catalog that way.
    #[serde(rename = "MergeCentralConfig")]
    pub merge_central_config: bool,

    /// Global is used to request information from all datacenters. Currently only
    /// used for operator usage requests.
    #[serde(rename = "Global")]
    pub global: bool,

}

/// HealthCheck is used to represent a single check
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct HealthCheck {
    #[serde(rename = "Node")]
    pub node: String,

    #[serde(rename = "CheckID")]
    pub check_id: String,

    #[serde(rename = "Name")]
    pub name: String,

    #[serde(rename = "Status")]
    pub status: String,

    #[serde(rename = "Notes")]
    pub notes: String,

    #[serde(rename = "Output")]
    pub output: String,

    #[serde(rename = "ServiceID")]
    pub service_id: String,

    #[serde(rename = "ServiceName")]
    pub service_name: String,

    #[serde(rename = "ServiceTags")]
    pub service_tags: Vec<String>,

    #[serde(rename = "Type")]
    pub r#type: String,

    #[serde(rename = "Namespace")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub namespace: Option<String>,

    #[serde(rename = "Partition")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub partition: Option<String>,

    #[serde(rename = "ExposedPort")]
    pub exposed_port: u16,

    #[serde(rename = "Definition")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub definition: Option<HealthCheckDefinition>,

    #[serde(rename = "CreateIndex")]
    pub create_index: u64,

    #[serde(rename = "ModifyIndex")]
    pub modify_index: u64,

}

pub type HealthChecks = Vec<HealthCheck>;


/// NamespaceACLConfig is the Namespace specific ACL configuration container
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct NamespaceACLConfig {
    /// PolicyDefaults is the list of policies that should be used for the parent authorizer
    /// of all tokens in the associated namespace.
    #[serde(rename = "PolicyDefaults")]
    pub policy_defaults: Vec<ACLLink>,

    /// RoleDefaults is the list of roles that should be used for the parent authorizer
    /// of all tokens in the associated namespace.
    #[serde(rename = "RoleDefaults")]
    pub role_defaults: Vec<ACLLink>,

}

/// UserEventParam is used to parameterize a user event
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct UserEvent {
    /// ID of the user event. Automatically generated.
    #[serde(rename = "ID")]
    pub id: String,

    /// Name of the event
    #[serde(rename = "Name")]
    pub name: String,

    /// Optional payload
    #[serde(rename = "Payload")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub payload: Option<Base64Payload>,

    /// NodeFilter is a regular expression to filter on nodes
    #[serde(rename = "NodeFilter")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub node_filter: Option<String>,

    /// ServiceFilter is a regular expression to filter on services
    #[serde(rename = "ServiceFilter")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub service_filter: Option<String>,

    /// TagFilter is a regular expression to filter on tags of a service,
    /// must be provided with ServiceFilter
    #[serde(rename = "TagFilter")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub tag_filter: Option<String>,

    /// Version of the user event. Automatically generated.
    #[serde(rename = "Version")]
    pub version: isize,

    /// LTime is the lamport time. Automatically generated.
    #[serde(rename = "LTime")]
    pub l_time: u64,

}

/// CheckDefinition is used to JSON decode the Check definitions
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct CheckDefinition {
    #[serde(rename = "ID")]
    pub id: String,

    #[serde(rename = "Name")]
    pub name: String,

    #[serde(rename = "Notes")]
    pub notes: String,

    #[serde(rename = "ServiceID")]
    pub service_id: String,

    #[serde(rename = "Token")]
    pub token: String,

    #[serde(rename = "Status")]
    pub status: String,

    /// Copied fields from CheckType without the fields
    /// already present in CheckDefinition:
    ///
    ///   ID (CheckID), Name, Status, Notes
    #[serde(rename = "ScriptArgs")]
    pub script_args: Vec<String>,

    #[serde(rename = "HTTP")]
    pub http: String,

    #[serde(rename = "H2PING")]
    pub h2_ping: String,

    #[serde(rename = "H2PingUseTLS")]
    pub h2_ping_use_tls: bool,

    #[serde(rename = "Header")]
    pub header: ::std::collections::HashMap<String, Vec<String>>,

    #[serde(rename = "Method")]
    pub method: String,

    #[serde(rename = "Body")]
    pub body: String,

    #[serde(rename = "DisableRedirects")]
    pub disable_redirects: bool,

    #[serde(rename = "TCP")]
    pub tcp: String,

    #[serde(rename = "TCPUseTLS")]
    pub tcp_use_tls: bool,

    #[serde(rename = "UDP")]
    pub udp: String,

    #[serde(rename = "Interval")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub interval: Option<String>,

    #[serde(rename = "DockerContainerID")]
    pub docker_container_id: String,

    #[serde(rename = "Shell")]
    pub shell: String,

    #[serde(rename = "GRPC")]
    pub grpc: String,

    #[serde(rename = "GRPCUseTLS")]
    pub grpc_use_tls: bool,

    #[serde(rename = "OSService")]
    pub os_service: String,

    #[serde(rename = "TLSServerName")]
    pub tls_server_name: String,

    #[serde(rename = "TLSSkipVerify")]
    pub tls_skip_verify: bool,

    #[serde(rename = "AliasNode")]
    pub alias_node: String,

    #[serde(rename = "AliasService")]
    pub alias_service: String,

    #[serde(rename = "Timeout")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub timeout: Option<String>,

    #[serde(rename = "TTL")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub ttl: Option<String>,

    #[serde(rename = "SuccessBeforePassing")]
    pub success_before_passing: isize,

    #[serde(rename = "FailuresBeforeWarning")]
    pub failures_before_warning: isize,

    #[serde(rename = "FailuresBeforeCritical")]
    pub failures_before_critical: isize,

    #[serde(rename = "DeregisterCriticalServiceAfter")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub deregister_critical_service_after: Option<String>,

    #[serde(rename = "OutputMaxSize")]
    pub output_max_size: isize,

}

/// CheckType is used to create either the CheckMonitor or the CheckTTL.
/// The following types are supported: Script, HTTP, TCP, Docker, TTL, GRPC, Alias, H2PING. Script,
/// HTTP, Docker, TCP, GRPC, and H2PING all require Interval. Only one of the types may
/// to be provided: TTL or Script/Interval or HTTP/Interval or TCP/Interval or
/// Docker/Interval or GRPC/Interval or AliasService or H2PING/Interval.
/// Since types like CheckHTTP and CheckGRPC derive from CheckType, there are
/// helper conversion methods that do the reverse conversion. ie. checkHTTP.CheckType()
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct CheckType {
    #[serde(rename = "CheckID")]
    pub check_id: String,

    #[serde(rename = "Name")]
    pub name: String,

    #[serde(rename = "Status")]
    pub status: String,

    #[serde(rename = "Notes")]
    pub notes: String,

    #[serde(rename = "ScriptArgs")]
    pub script_args: Vec<String>,

    #[serde(rename = "HTTP")]
    pub http: String,

    #[serde(rename = "H2PING")]
    pub h2_ping: String,

    #[serde(rename = "H2PingUseTLS")]
    pub h2_ping_use_tls: bool,

    #[serde(rename = "Header")]
    pub header: ::std::collections::HashMap<String, Vec<String>>,

    #[serde(rename = "Method")]
    pub method: String,

    #[serde(rename = "Body")]
    pub body: String,

    #[serde(rename = "DisableRedirects")]
    pub disable_redirects: bool,

    #[serde(rename = "TCP")]
    pub tcp: String,

    #[serde(rename = "TCPUseTLS")]
    pub tcp_use_tls: bool,

    #[serde(rename = "UDP")]
    pub udp: String,

    #[serde(rename = "Interval")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub interval: Option<String>,

    #[serde(rename = "AliasNode")]
    pub alias_node: String,

    #[serde(rename = "AliasService")]
    pub alias_service: String,

    #[serde(rename = "DockerContainerID")]
    pub docker_container_id: String,

    #[serde(rename = "Shell")]
    pub shell: String,

    #[serde(rename = "GRPC")]
    pub grpc: String,

    #[serde(rename = "GRPCUseTLS")]
    pub grpc_use_tls: bool,

    #[serde(rename = "OSService")]
    pub os_service: String,

    #[serde(rename = "TLSServerName")]
    pub tls_server_name: String,

    #[serde(rename = "TLSSkipVerify")]
    pub tls_skip_verify: bool,

    #[serde(rename = "Timeout")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub timeout: Option<String>,

    #[serde(rename = "TTL")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub ttl: Option<String>,

    #[serde(rename = "SuccessBeforePassing")]
    pub success_before_passing: isize,

    #[serde(rename = "FailuresBeforeWarning")]
    pub failures_before_warning: isize,

    #[serde(rename = "FailuresBeforeCritical")]
    pub failures_before_critical: isize,

    /// Definition fields used when exposing checks through a proxy
    #[serde(rename = "ProxyHTTP")]
    pub proxy_http: String,

    #[serde(rename = "ProxyGRPC")]
    pub proxy_grpc: String,

    /// DeregisterCriticalServiceAfter, if >0, will cause the associated
    /// service, if any, to be deregistered if this check is critical for
    /// longer than this duration.
    #[serde(rename = "DeregisterCriticalServiceAfter")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub deregister_critical_service_after: Option<String>,

    #[serde(rename = "OutputMaxSize")]
    pub output_max_size: isize,

}

pub type CheckTypes = Vec<CheckType>;


/// GatewayService is used to associate gateways with their linked services.
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct GatewayService {
    #[serde(rename = "Gateway")]
    pub gateway: ServiceName,

    #[serde(rename = "Service")]
    pub service: ServiceName,

    #[serde(rename = "GatewayKind")]
    pub gateway_kind: String,

    #[serde(rename = "Port")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub port: Option<u16>,

    #[serde(rename = "Protocol")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub protocol: Option<String>,

    #[serde(rename = "Hosts")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub hosts: Option<Vec<String>>,

    #[serde(rename = "CAFile")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub ca_file: Option<String>,

    #[serde(rename = "CertFile")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub cert_file: Option<String>,

    #[serde(rename = "KeyFile")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub key_file: Option<String>,

    #[serde(rename = "SNI")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub sni: Option<String>,

    #[serde(rename = "FromWildcard")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub from_wildcard: Option<bool>,

    #[serde(rename = "ServiceKind")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub service_kind: Option<GatewayServiceKind>,

    #[serde(rename = "AutoHostRewrite")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub auto_host_rewrite: Option<bool>,

}

/// ConnectAuthorizeRequest is the structure of a request to authorize
/// a connection.
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct ConnectAuthorizeRequest {
    /// Target is the name of the service that is being requested.
    #[serde(rename = "Target")]
    pub target: String,

    /// ClientCertURI is a unique identifier for the requesting client. This
    /// is currently the URI SAN from the TLS client certificate.
    ///
    /// ClientCertSerial is a colon-hex-encoded of the serial number for
    /// the requesting client cert. This is used to check against revocation
    /// lists.
    #[serde(rename = "ClientCertURI")]
    pub client_cert_uri: String,

    #[serde(rename = "ClientCertSerial")]
    pub client_cert_serial: String,

}

/// MeshGatewayConfig controls how Mesh Gateways are configured and used
/// This is a struct to allow for future additions without having more free-hanging
/// configuration items all over the place
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct MeshGatewayConfig {
    /// The Mesh Gateway routing mode
    #[serde(rename = "Mode")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub mode: Option<MeshGatewayMode>,

}

#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct TransparentProxyConfig {
    /// The port of the listener where outbound application traffic is being redirected to.
    #[serde(rename = "OutboundListenerPort")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub outbound_listener_port: Option<u16>,

    /// DialedDirectly indicates whether transparent proxies can dial this proxy instance directly.
    /// The discovery chain is not considered when dialing a service instance directly.
    /// This setting is useful when addressing stateful services, such as a database cluster with a leader node.
    #[serde(rename = "DialedDirectly")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub dialed_directly: Option<bool>,

}

/// AccessLogsConfig contains the associated default settings for all Envoy instances within the datacenter or partition
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct AccessLogsConfig {
    /// Enabled turns off all access logging
    #[serde(rename = "Enabled")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub enabled: Option<bool>,

    /// DisableListenerLogs turns off just listener logs for connections rejected by Envoy because they don't
    /// have a matching listener filter.
    #[serde(rename = "DisableListenerLogs")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub disable_listener_logs: Option<bool>,

    /// Type selects the output for logs: "file", "stderr". "stdout"
    #[serde(rename = "Type")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub r#type: Option<LogSinkType>,

    /// Path is the output file to write logs
    #[serde(rename = "Path")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub path: Option<String>,

    /// The presence of one format string or the other implies the access log string encoding.
    /// Defining Both is invalid.
    #[serde(rename = "JSONFormat")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub json_format: Option<String>,

    #[serde(rename = "TextFormat")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub text_format: Option<String>,

}

/// ConnectProxyConfig describes the configuration needed for any proxy managed
/// or unmanaged. It describes a single logical service's listener and optionally
/// upstreams and sidecar-related config for a single instance. To describe a
/// centralized proxy that routed traffic for multiple services, a different one
/// of these would be needed for each, sharing the same LogicalProxyID.
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct ConnectProxyConfig {
    /// EnvoyExtensions are the list of Envoy extensions configured for the local service.
    #[serde(rename = "EnvoyExtensions")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub envoy_extensions: Option<Vec<EnvoyExtension>>,

    /// DestinationServiceName is required and is the name of the service to accept
    /// traffic for.
    #[serde(rename = "DestinationServiceName")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub destination_service_name: Option<String>,

    /// DestinationServiceID is optional and should only be specified for
    /// "side-car" style proxies where the proxy is in front of just a single
    /// instance of the service. It should be set to the service ID of the instance
    /// being represented which must be registered to the same agent. It's valid to
    /// provide a service ID that does not yet exist to avoid timing issues when
    /// bootstrapping a service with a proxy.
    #[serde(rename = "DestinationServiceID")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub destination_service_id: Option<String>,

    /// LocalServiceAddress is the address of the local service instance. It is
    /// optional and should only be specified for "side-car" style proxies. It will
    /// default to 127.0.0.1 if the proxy is a "side-car" (DestinationServiceID is
    /// set) but otherwise will be ignored.
    #[serde(rename = "LocalServiceAddress")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub local_service_address: Option<String>,

    /// LocalServicePort is the port of the local service instance. It is optional
    /// and should only be specified for "side-car" style proxies. It will default
    /// to the registered port for the instance if the proxy is a "side-car"
    /// (DestinationServiceID is set) but otherwise will be ignored.
    #[serde(rename = "LocalServicePort")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub local_service_port: Option<u16>,

    /// LocalServiceSocketPath is the socket of the local service instance. It is optional
    /// and should only be specified for "side-car" style proxies.
    #[serde(rename = "LocalServiceSocketPath")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub local_service_socket_path: Option<String>,

    /// Mode represents how the proxy's inbound and upstream listeners are dialed.
    #[serde(rename = "Mode")]
    pub mode: String,

    /// Upstreams describes any upstream dependencies the proxy instance should
    /// setup.
    #[serde(rename = "Upstreams")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub upstreams: Option<Upstreams>,

    /// MeshGateway defines the mesh gateway configuration for this upstream
    #[serde(rename = "MeshGateway")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub mesh_gateway: Option<MeshGatewayConfig>,

    /// Expose defines whether checks or paths are exposed through the proxy
    #[serde(rename = "Expose")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub expose: Option<ExposeConfig>,

    /// TransparentProxy defines configuration for when the proxy is in
    /// transparent mode.
    #[serde(rename = "TransparentProxy")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub transparent_proxy: Option<TransparentProxyConfig>,

    /// AccessLogs configures the output and format of Envoy access logs
    #[serde(rename = "AccessLogs")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub access_logs: Option<AccessLogsConfig>,

}

/// Upstream represents a single upstream dependency for a service or proxy. It
/// describes the mechanism used to discover instances to communicate with (the
/// Target) as well as any potential client configuration that may be useful such
/// as load balancer options, timeouts etc.
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct Upstream {
    /// Destination fields are the required ones for determining what this upstream
    /// points to. Depending on DestinationType some other fields below might
    /// further restrict the set of instances allowable.
    ///
    /// DestinationType would be better as an int constant but even with custom
    /// JSON marshallers it causes havoc with all the mapstructure mangling we do
    /// on service definitions in various places.
    #[serde(rename = "DestinationType")]
    pub destination_type: String,

    #[serde(rename = "DestinationNamespace")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub destination_namespace: Option<String>,

    #[serde(rename = "DestinationPartition")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub destination_partition: Option<String>,

    #[serde(rename = "DestinationPeer")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub destination_peer: Option<String>,

    #[serde(rename = "DestinationName")]
    pub destination_name: String,

    /// Datacenter that the service discovery request should be run against. Note
    /// for prepared queries, the actual results might be from a different
    /// datacenter.
    #[serde(rename = "Datacenter")]
    pub datacenter: String,

    /// LocalBindAddress is the ip address a side-car proxy should listen on for
    /// traffic destined for this upstream service. Default if empty is 127.0.0.1.
    #[serde(rename = "LocalBindAddress")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub local_bind_address: Option<String>,

    /// LocalBindPort is the ip address a side-car proxy should listen on for traffic
    /// destined for this upstream service. Required.
    #[serde(rename = "LocalBindPort")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub local_bind_port: Option<u16>,

    /// These are exclusive with LocalBindAddress/LocalBindPort
    #[serde(rename = "LocalBindSocketPath")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub local_bind_socket_path: Option<String>,

    /// This might be represented as an int, but because it's octal outputs can be a bit strange.
    #[serde(rename = "LocalBindSocketMode")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub local_bind_socket_mode: Option<String>,

    /// MeshGateway is the configuration for mesh gateway usage of this upstream
    #[serde(rename = "MeshGateway")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub mesh_gateway: Option<MeshGatewayConfig>,

    /// CentrallyConfigured indicates whether the upstream was defined in a proxy
    /// instance registration or whether it was generated from a config entry.
    #[serde(rename = "CentrallyConfigured")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub centrally_configured: Option<bool>,

}

pub type Upstreams = Vec<Upstream>;


/// ExposeConfig describes HTTP paths to expose through Envoy outside of Connect.
/// Users can expose individual paths and/or all HTTP/GRPC paths for checks.
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct ExposeConfig {
    /// Checks defines whether paths associated with Consul checks will be exposed.
    /// This flag triggers exposing all HTTP and GRPC check paths registered for the service.
    #[serde(rename = "Checks")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub checks: Option<bool>,

    /// Paths is the list of paths exposed through the proxy.
    #[serde(rename = "Paths")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub paths: Option<Vec<ExposePath>>,

}

#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct ExposePath {
    /// ListenerPort defines the port of the proxy's listener for exposed paths.
    #[serde(rename = "ListenerPort")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub listener_port: Option<u16>,

    /// Path is the path to expose through the proxy, ie. "/metrics."
    #[serde(rename = "Path")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub path: Option<String>,

    /// LocalPathPort is the port that the service is listening on for the given path.
    #[serde(rename = "LocalPathPort")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub local_path_port: Option<u16>,

    /// Protocol describes the upstream's service protocol.
    /// Valid values are "http" and "http2", defaults to "http"
    #[serde(rename = "Protocol")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub protocol: Option<String>,

    /// ParsedFromCheck is set if this path was parsed from a registered check
    #[serde(rename = "ParsedFromCheck")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub parsed_from_check: Option<bool>,

}

/// EnvoyExtension has configuration for an extension that patches Envoy resources.
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct EnvoyExtension {
    #[serde(rename = "Name")]
    pub name: String,

    #[serde(rename = "Required")]
    pub required: bool,

    #[serde(rename = "ConsulVersion")]
    pub consul_version: String,

    #[serde(rename = "EnvoyVersion")]
    pub envoy_version: String,

}

/// ServiceDefinition is used to JSON decode the Service definitions. For
/// documentation on specific fields see NodeService which is better documented.
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct ServiceDefinition {
    #[serde(rename = "ID")]
    pub id: String,

    #[serde(rename = "Name")]
    pub name: String,

    #[serde(rename = "Tags")]
    pub tags: Vec<String>,

    #[serde(rename = "Address")]
    pub address: String,

    #[serde(rename = "TaggedAddresses")]
    pub tagged_addresses: ::std::collections::HashMap<String, ServiceAddress>,

    #[serde(rename = "Meta")]
    pub meta: ::std::collections::HashMap<String, String>,

    #[serde(rename = "Port")]
    pub port: u16,

    #[serde(rename = "SocketPath")]
    pub socket_path: String,

    #[serde(rename = "Check")]
    pub check: CheckType,

    #[serde(rename = "Checks")]
    pub checks: CheckTypes,

    #[serde(rename = "Weights")]
    pub weights: Weights,

    #[serde(rename = "Token")]
    pub token: String,

    #[serde(rename = "EnableTagOverride")]
    pub enable_tag_override: bool,

    #[cfg(feature = "enterprise")]
    #[serde(rename = "Locality")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub locality: Option<Locality>,

    /// Proxy is the configuration set for Kind = connect-proxy. It is mandatory in
    /// that case and an error to be set for any other kind. This config is part of
    /// a proxy service definition. ProxyConfig may be a more natural name here, but
    /// it's confusing for the UX because one of the fields in ConnectProxyConfig is
    /// also called just "Config"
    #[serde(rename = "Proxy")]
    pub proxy: ConnectProxyConfig,

    #[serde(rename = "Connect")]
    pub connect: Box<ServiceConnect>,

}

#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct WriteRequest {
    /// Token is the ACL token ID. If not provided, the 'anonymous'
    /// token is assumed for backwards compatibility.
    #[serde(rename = "Token")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub token: Option<String>,

}

/// RegisterRequest is used for the Catalog.Register endpoint
/// to register a node as providing a service. If no service
/// is provided, the node is registered.
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct RegisterRequest {
    #[serde(rename = "Datacenter")]
    pub datacenter: String,

    #[serde(rename = "ID")]
    pub id: String,

    #[serde(rename = "Node")]
    pub node: String,

    #[serde(rename = "Address")]
    pub address: String,

    #[serde(rename = "TaggedAddresses")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub tagged_addresses: Option<::std::collections::HashMap<String, String>>,

    #[serde(rename = "NodeMeta")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub node_meta: Option<::std::collections::HashMap<String, String>>,

    #[serde(rename = "Service")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub service: Option<NodeService>,

    #[serde(rename = "Check")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub check: Option<HealthCheck>,

    #[serde(rename = "Checks")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub checks: Option<HealthChecks>,

    #[cfg(feature = "enterprise")]
    #[serde(rename = "Locality")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub locality: Option<Locality>,

    /// SkipNodeUpdate can be used when a register request is intended for
    /// updating a service and/or checks, but doesn't want to overwrite any
    /// node information if the node is already registered. If the node
    /// doesn't exist, it will still be created, but if the node exists, any
    /// node portion of this update will not apply.
    #[serde(rename = "SkipNodeUpdate")]
    pub skip_node_update: bool,

    /// Token is the ACL token ID. If not provided, the 'anonymous'
    /// token is assumed for backwards compatibility.
    #[serde(rename = "Token")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub token: Option<String>,


}

/// DeregisterRequest is used for the Catalog.Deregister endpoint to
/// deregister a service, check, or node (only one should be provided).
/// If ServiceID or CheckID are not provided, the entire node is deregistered.
/// If a ServiceID is provided, any associated Checks with that service
/// are also deregistered.
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct DeregisterRequest {
    #[serde(rename = "Datacenter")]
    pub datacenter: String,

    #[serde(rename = "Node")]
    pub node: String,

    #[serde(rename = "ServiceID")]
    pub service_id: String,

    #[serde(rename = "CheckID")]
    pub check_id: String,

    /// Token is the ACL token ID. If not provided, the 'anonymous'
    /// token is assumed for backwards compatibility.
    #[serde(rename = "Token")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub token: Option<String>,


}

/// Used to return information about a node
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct Node {
    #[serde(rename = "ID")]
    pub id: String,

    #[serde(rename = "Node")]
    pub node: String,

    #[serde(rename = "Address")]
    pub address: String,

    #[serde(rename = "Datacenter")]
    pub datacenter: String,

    #[serde(rename = "Partition")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub partition: Option<String>,

    #[serde(rename = "TaggedAddresses")]
    pub tagged_addresses: ::std::collections::HashMap<String, String>,

    #[serde(rename = "Meta")]
    pub meta: ::std::collections::HashMap<String, String>,

    #[cfg(feature = "enterprise")]
    #[serde(rename = "Locality")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub locality: Option<Locality>,

}

/// ServiceNode represents a node that is part of a service. ID, Address,
/// TaggedAddresses, and NodeMeta are node-related fields that are always empty
/// in the state store and are filled in on the way out by parseServiceNodes().
/// This is also why PartialClone() skips them, because we know they are blank
/// already so it would be a waste of time to copy them.
/// This is somewhat complicated when the address is really a unix domain socket; technically that
/// will override the address field, but in practice the two use cases should not overlap.
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct ServiceNode {
    #[serde(rename = "ID")]
    pub id: String,

    #[serde(rename = "Node")]
    pub node: String,

    #[serde(rename = "Address")]
    pub address: String,

    #[serde(rename = "Datacenter")]
    pub datacenter: String,

    #[serde(rename = "TaggedAddresses")]
    pub tagged_addresses: ::std::collections::HashMap<String, String>,

    #[serde(rename = "NodeMeta")]
    pub node_meta: ::std::collections::HashMap<String, String>,

    #[serde(rename = "ServiceKind")]
    pub service_kind: String,

    #[serde(rename = "ServiceID")]
    pub service_id: String,

    #[serde(rename = "ServiceName")]
    pub service_name: String,

    #[serde(rename = "ServiceTags")]
    pub service_tags: Vec<String>,

    #[serde(rename = "ServiceAddress")]
    pub service_address: String,

    #[serde(rename = "ServiceTaggedAddresses")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub service_tagged_addresses: Option<::std::collections::HashMap<String, ServiceAddress>>,

    #[serde(rename = "ServiceWeights")]
    pub service_weights: Weights,

    #[serde(rename = "ServiceMeta")]
    pub service_meta: ::std::collections::HashMap<String, String>,

    #[serde(rename = "ServicePort")]
    pub service_port: u16,

    #[serde(rename = "ServiceSocketPath")]
    pub service_socket_path: String,

    #[serde(rename = "ServiceEnableTagOverride")]
    pub service_enable_tag_override: bool,

    #[serde(rename = "ServiceProxy")]
    pub service_proxy: ConnectProxyConfig,

    #[serde(rename = "ServiceConnect")]
    pub service_connect: Box<ServiceConnect>,

    #[cfg(feature = "enterprise")]
    #[serde(rename = "ServiceLocality")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub service_locality: Option<Locality>,

}

/// Weights represent the weight used by DNS for a given status
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct Weights {
    #[serde(rename = "Passing")]
    pub passing: isize,

    #[serde(rename = "Warning")]
    pub warning: isize,

}

/// Specifies weights for the service.
/// Default is {"Passing": 1, "Warning": 1}.
/// Learn more: https://developer.hashicorp.com/consul/api-docs/agent/service#weights
impl Default for Weights {
    fn default() -> Self {
        Self {
            passing: 1,
            warning: 1,
        }
    }
}


/// Type to hold a address and port of a service
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct ServiceAddress {
    #[serde(rename = "Address")]
    pub address: String,

    #[serde(rename = "Port")]
    pub port: u16,

}

/// NodeService is a service provided by a node
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct NodeService {
    #[serde(rename = "ID")]
    pub id: String,

    #[serde(rename = "Service")]
    pub service: String,

    #[serde(rename = "Tags")]
    pub tags: Vec<String>,

    #[serde(rename = "Address")]
    pub address: String,

    #[serde(rename = "TaggedAddresses")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub tagged_addresses: Option<::std::collections::HashMap<String, ServiceAddress>>,

    #[serde(rename = "Meta")]
    pub meta: ::std::collections::HashMap<String, String>,

    #[serde(rename = "Port")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub port: Option<u16>,

    #[serde(rename = "SocketPath")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub socket_path: Option<String>,

    #[serde(rename = "Weights")]
    pub weights: Weights,

    #[serde(rename = "EnableTagOverride")]
    pub enable_tag_override: bool,

    #[cfg(feature = "enterprise")]
    #[serde(rename = "Locality")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub locality: Option<Locality>,

    /// Proxy is the configuration set for Kind = connect-proxy. It is mandatory in
    /// that case and an error to be set for any other kind. This config is part of
    /// a proxy service definition. ProxyConfig may be a more natural name here, but
    /// it's confusing for the UX because one of the fields in ConnectProxyConfig is
    /// also called just "Config"
    #[serde(rename = "Proxy")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub proxy: Option<ConnectProxyConfig>,

    /// Connect are the Connect settings for a service. This is purposely NOT
    /// a pointer so that we never have to nil-check this.
    #[serde(rename = "Connect")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub connect: Option<Box<ServiceConnect>>,

}

/// PeeringServiceMeta is read-only information provided from an exported peer.
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct PeeringServiceMeta {
    #[serde(rename = "SNI")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub sni: Option<Vec<String>>,

    #[serde(rename = "SpiffeID")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub spiffe_id: Option<Vec<String>>,

    #[serde(rename = "Protocol")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub protocol: Option<String>,

}

/// ServiceConnect are the shared Connect settings between all service
/// definitions from the agent to the state store.
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct ServiceConnect {
    /// Native is true when this service can natively understand Connect.
    #[serde(rename = "Native")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub native: Option<bool>,

    /// SidecarService is a nested Service Definition to register at the same time.
    /// It's purely a convenience mechanism to allow specifying a sidecar service
    /// along with the application service definition. It's nested nature allows
    /// all of the fields to be defaulted which can reduce the amount of
    /// boilerplate needed to register a sidecar service separately, but the end
    /// result is identical to just making a second service registration via any
    /// other means.
    #[serde(rename = "SidecarService")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub sidecar_service: Option<Box<ServiceDefinition>>,

    #[serde(rename = "PeerMeta")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub peer_meta: Option<PeeringServiceMeta>,

}

/// NodeServices represents services provided by Node.
/// Services is a map of service IDs to services.
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct NodeServices {
    #[serde(rename = "Node")]
    pub node: Node,

    #[serde(rename = "Services")]
    pub services: ::std::collections::HashMap<String, NodeService>,

}

#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct HealthCheckDefinition {
    #[serde(rename = "HTTP")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub http: Option<String>,

    #[serde(rename = "TLSServerName")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub tls_server_name: Option<String>,

    #[serde(rename = "TLSSkipVerify")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub tls_skip_verify: Option<bool>,

    #[serde(rename = "Header")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub header: Option<::std::collections::HashMap<String, Vec<String>>>,

    #[serde(rename = "Method")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub method: Option<String>,

    #[serde(rename = "Body")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub body: Option<String>,

    #[serde(rename = "DisableRedirects")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub disable_redirects: Option<bool>,

    #[serde(rename = "TCP")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub tcp: Option<String>,

    #[serde(rename = "TCPUseTLS")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub tcp_use_tls: Option<bool>,

    #[serde(rename = "UDP")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub udp: Option<String>,

    #[serde(rename = "H2PING")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub h2_ping: Option<String>,

    #[serde(rename = "OSService")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub os_service: Option<String>,

    #[serde(rename = "H2PingUseTLS")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub h2_ping_use_tls: Option<bool>,

    #[serde(rename = "Interval")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub interval: Option<String>,

    #[serde(rename = "OutputMaxSize")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub output_max_size: Option<usize>,

    #[serde(rename = "Timeout")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub timeout: Option<String>,

    #[serde(rename = "DeregisterCriticalServiceAfter")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub deregister_critical_service_after: Option<String>,

    #[serde(rename = "ScriptArgs")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub script_args: Option<Vec<String>>,

    #[serde(rename = "DockerContainerID")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub docker_container_id: Option<String>,

    #[serde(rename = "Shell")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub shell: Option<String>,

    #[serde(rename = "GRPC")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub grpc: Option<String>,

    #[serde(rename = "GRPCUseTLS")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub grpc_use_tls: Option<bool>,

    #[serde(rename = "AliasNode")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub alias_node: Option<String>,

    #[serde(rename = "AliasService")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub alias_service: Option<String>,

    #[serde(rename = "TTL")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub ttl: Option<String>,

}

/// CheckServiceNode is used to provide the node, its service
/// definition, as well as a HealthCheck that is associated.
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct CheckServiceNode {
    #[serde(rename = "Node")]
    pub node: Node,

    #[serde(rename = "Service")]
    pub service: NodeService,

    #[serde(rename = "Checks")]
    pub checks: HealthChecks,

}

#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct ServiceName {
    #[serde(rename = "Name")]
    pub name: String,

}

/// Locality identifies where a given entity is running.
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct Locality {
    /// Region is region the zone belongs to.
    #[serde(rename = "Region")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub region: Option<String>,

    /// Zone is the zone the entity is running in.
    #[serde(rename = "Zone")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub zone: Option<String>,

}