Struct StreamService 

pub struct StreamService {
    pub name: String,
    pub backends: Vec<SocketAddr>,
    pub config: StreamProxyConfig,
    /* private fields */
}

A resolved stream service with backend addresses and health state

Fields

name: String

Service name (for logging/metrics)

backends: Vec<SocketAddr>

Backend addresses for load balancing

config: StreamProxyConfig

Runtime L4 config (TLS / proxy-protocol / session-timeout / health probe) translated from the endpoint’s stream: block. Drives the health checker’s probe selection (see StreamRegistry::spawn_health_checker).

Implementations

impl StreamService

pub fn new(name: String, backends: Vec<SocketAddr>) -> Self

Create a new stream service

pub fn with_config(self, config: StreamProxyConfig) -> Self

Attach a runtime StreamProxyConfig to this service.

Builder-style; preserves StreamService::new’s 2-arg arity so the existing call sites keep compiling. The config’s health_check drives what the background health checker probes.

pub fn select_backend(&self) -> Option<SocketAddr>

Select next backend using round-robin, skipping unhealthy backends.

Tries up to backends.len() candidates. If all backends are unhealthy, falls back to returning any backend (better than nothing).

pub fn update_backends(&mut self, backends: Vec<SocketAddr>)

Update backend addresses (for scaling events).

New backends start with Unknown health; removed backends are pruned from the health map.

pub async fn set_backend_health(&self, addr: SocketAddr, status: BackendHealth)

Set the health status of a specific backend

pub async fn get_backend_health(&self, addr: SocketAddr) -> BackendHealth

Get the health status of a specific backend

pub fn backend_count(&self) -> usize

Get current backend count

pub async fn healthy_count(&self) -> usize

Get count of healthy (usable) backends

Trait Implementations

impl Clone for StreamService

fn clone(&self) -> StreamService

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamService

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

Formats the value using the given formatter.