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 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

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 hash_key(&self) -> String

Generates a unique hash key for this upstream configuration Used for caching and comparison purposes

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

pub fn validate(&self, name: &str) -> 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)

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 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.