Struct StreamService 

pub struct StreamService {
    pub name: String,
    pub backends: Vec<SocketAddr>,
    /* 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

Implementations

impl StreamService

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

Create a new stream service

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.