Struct UpstreamConf 

pub struct UpstreamConf {

    pub addrs: Vec<String>,
    pub discovery: Option<String>,
    pub dns_server: Option<String>,
    pub dns_domain: Option<String>,
    pub dns_search: Option<String>,
    pub update_frequency: Option<Duration>,
    pub algo: Option<String>,
    pub sni: Option<String>,
    pub verify_cert: Option<bool>,
    pub health_check: Option<String>,
    pub ipv4_only: Option<bool>,
    pub enable_tracer: Option<bool>,
    pub enable_backend_stats: Option<bool>,
    pub backend_failure_status_code: Option<String>,
    pub circuit_break_max_consecutive_failures: Option<u32>,
    pub circuit_break_max_failure_percent: Option<u16>,
    pub circuit_break_min_requests_threshold: Option<u64>,
    pub circuit_break_half_open_consecutive_success_threshold: Option<u32>,
    pub circuit_break_open_duration: Option<Duration>,
    pub backend_stats_interval: Option<Duration>,
    pub alpn: Option<String>,
    pub connection_timeout: Option<Duration>,
    pub total_connection_timeout: Option<Duration>,
    pub read_timeout: Option<Duration>,
    pub idle_timeout: Option<Duration>,
    pub write_timeout: Option<Duration>,
    pub tcp_idle: Option<Duration>,
    pub tcp_interval: Option<Duration>,
    pub tcp_user_timeout: Option<Duration>,
    pub tcp_probe_count: Option<usize>,
    pub tcp_recv_buf: Option<ByteSize>,
    pub tcp_fast_open: Option<bool>,
    pub includes: Option<Vec<String>>,
    pub remark: Option<String>,
}

Configuration for an upstream service that handles proxied requests

Fields

addrs: Vec<String>

List of upstream server addresses in format “host:port” or “host:port weight”

discovery: Option<String>

Service discovery mechanism to use (e.g. “dns”, “static”)

dns_server: Option<String>

DNS server for DNS discovery

dns_domain: Option<String>

DNS domain for DNS discovery

dns_search: Option<String>

DNS search for DNS discovery

update_frequency: Option<Duration>

How frequently to update the upstream server list

algo: Option<String>

Load balancing algorithm (e.g. “round_robin”, “hash:cookie”)

sni: Option<String>

Server Name Indication for TLS connections

verify_cert: Option<bool>

Whether to verify upstream TLS certificates

health_check: Option<String>

Health check URL to verify upstream server status

ipv4_only: Option<bool>

Whether to only use IPv4 addresses

enable_tracer: Option<bool>

Enable request tracing

enable_backend_stats: Option<bool>

Enable backend stats

backend_failure_status_code: Option<String>

Failure status codes for backend stats Format: “400,500,502,503,504”

circuit_break_max_consecutive_failures: Option<u32>

Maximum number of consecutive failures required to trip the circuit breaker

circuit_break_max_failure_percent: Option<u16>

Maximum failure rate (percentage, 0 to 100) required to trip the circuit breaker

circuit_break_min_requests_threshold: Option<u64>

Minimum total number of requests (within the statistics window) required before the failure rate is considered significant for circuit breaking. Prevents tripping the breaker when traffic is very low.

circuit_break_half_open_consecutive_success_threshold: Option<u32>

The number of consecutive successes required to reset the circuit breaker to closed.

circuit_break_open_duration: Option<Duration>

The duration of the open state of the circuit breaker.

backend_stats_interval: Option<Duration>

Interval for backend stats, default is 60 seconds

alpn: Option<String>

Application Layer Protocol Negotiation for TLS

connection_timeout: Option<Duration>

Timeout for establishing new connections

total_connection_timeout: Option<Duration>

Total timeout for the entire request/response cycle

read_timeout: Option<Duration>

Timeout for reading response data

idle_timeout: Option<Duration>

Timeout for idle connections in the pool

write_timeout: Option<Duration>

Timeout for writing request data

tcp_idle: Option<Duration>

TCP keepalive idle time

tcp_interval: Option<Duration>

TCP keepalive probe interval

tcp_user_timeout: Option<Duration>

TCP keepalive user timeout

tcp_probe_count: Option<usize>

Number of TCP keepalive probes before connection is dropped

tcp_recv_buf: Option<ByteSize>

TCP receive buffer size

tcp_fast_open: Option<bool>

Enable TCP Fast Open

includes: Option<Vec<String>>

List of included configuration files

remark: Option<String>

Optional description/notes about this upstream

Implementations

impl UpstreamConf

pub fn guess_discovery(&self) -> String

Determines the appropriate service discovery mechanism:

• Returns configured discovery if set
• Returns DNS discovery if any address contains a hostname
• Returns empty string (static discovery) otherwise

Trait Implementations

impl Clone for UpstreamConf

fn clone(&self) -> UpstreamConf

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for UpstreamConf

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for UpstreamConf

fn default() -> UpstreamConf

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for UpstreamConf

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Hash for UpstreamConf

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl Hashable for UpstreamConf

fn hash_key(&self) -> String

impl Serialize for UpstreamConf

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Validate for UpstreamConf

fn validate(&self) -> Result<(), Error>

Validates the upstream configuration:

1. The address list can’t be empty
2. For static discovery, addresses must be valid socket addresses
3. Health check URL must be valid if specified
4. TCP probe count must not exceed maximum (16)