Struct BackendMap 

pub struct BackendMap {
    pub backends: HashMap<ClusterId, BackendList>,
    pub max_failures: usize,
    pub health_check_configs: HashMap<ClusterId, HealthCheckConfig>,
    pub cluster_http2: HashMap<ClusterId, bool>,
}

Fields

backends: HashMap<ClusterId, BackendList>

max_failures: usize

health_check_configs: HashMap<ClusterId, HealthCheckConfig>

cluster_http2: HashMap<ClusterId, bool>

Whether the cluster’s backends speak HTTP/2 (cluster.http2 = true). Mirrors the same backend-capability hint the mux router reads at protocol/mux/router.rs::Router::connect. The health checker uses it to switch the probe wire format from HTTP/1.1 to h2c so an h2c-only backend is not probed with an HTTP/1.1 preface that would always fail.

Implementations

impl BackendMap

pub fn new() -> BackendMap

pub fn set_cluster_http2(&mut self, cluster_id: &str, http2: bool)

Record (or clear) the cluster.http2 backend-capability hint for cluster_id. The health checker reads the resulting map at probe time so the wire format follows what the mux router will use to connect to the same backends.

pub fn set_health_check_config( &mut self, cluster_id: &str, config: Option<HealthCheckConfig>, )

pub fn import_configuration_state( &mut self, backends: &HashMap<ClusterId, Vec<Backend>>, )

pub fn add_backend(&mut self, cluster_id: &str, backend: Backend)

pub fn remove_backend( &mut self, cluster_id: &str, backend_address: &SocketAddr, ) -> Vec<String>

Remove every backend at backend_address from cluster_id and return the list of backend_ids that were dropped. Callers (e.g. Server::remove_backend) iterate over the returned ids to tear down per-backend metrics so the identity used by the runtime (address-keyed) matches the identity used by the metrics layer (id-keyed) — see PR #1252 follow-up review MEDIUM-3.

pub fn close_backend_connection(&mut self, cluster_id: &str, addr: &SocketAddr)

pub fn has_backend(&self, cluster_id: &str, backend: &Backend) -> bool

pub fn backend_from_cluster_id( &mut self, cluster_id: &str, ) -> Result<(Rc<RefCell<Backend>>, TcpStream), BackendError>

pub fn backend_from_cluster_id_with_key( &mut self, cluster_id: &str, key: Option<u64>, ) -> Result<(String, SocketAddr), BackendError>

Select a backend for cluster_id, optionally pinned by an affinity key, and return its (backend_id, address) without opening any connection.

This is the UDP datapath’s selection entry point. Unlike backend_from_cluster_id — which is TCP-specific because it calls Backend::try_connect and hands back a TcpStream — UDP owns its own per-flow connected UdpSocket (created in the shell via socket::udp_connect), so all the map needs to surface is the chosen endpoint identity. key is Some(flow_hash) so HRW/Maglev keep a client flow pinned to one backend; None behaves like the legacy round-robin selection. Fail-open (all-unhealthy ⇒ LB over the full set) is inherited from BackendList::next_available_backend_with_key.

pub fn backend_from_sticky_session( &mut self, cluster_id: &str, sticky_session: &str, ) -> Result<(Rc<RefCell<Backend>>, TcpStream), BackendError>

pub fn set_load_balancing_policy_for_cluster( &mut self, cluster_id: &str, lb_algo: LoadBalancingAlgorithms, metric: Option<LoadMetric>, )

pub fn get_or_create_backend_list_for_cluster( &mut self, cluster_id: &str, ) -> &mut BackendList

Trait Implementations

impl Debug for BackendMap

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

Formats the value using the given formatter.

impl Default for BackendMap

fn default() -> Self

Returns the “default value” for a type.