Struct StreamRegistry 

pub struct StreamRegistry { /* private fields */ }

Registry for L4 stream services

Maps listen ports to services for both TCP and UDP protocols.

Implementations

impl StreamRegistry

pub fn new() -> Self

Create a new empty registry

pub fn register_tcp(&self, port: u16, service: StreamService)

Register a TCP service for a port

pub fn register_udp(&self, port: u16, service: StreamService)

Register a UDP service for a port

pub fn resolve_tcp(&self, port: u16) -> Option<StreamService>

Resolve TCP service for a port

pub fn resolve_udp(&self, port: u16) -> Option<StreamService>

Resolve UDP service for a port

pub fn update_tcp_backends(&self, port: u16, backends: Vec<SocketAddr>)

Update backends for a TCP service

pub fn update_udp_backends(&self, port: u16, backends: Vec<SocketAddr>)

Update backends for a UDP service

pub fn unregister_tcp(&self, port: u16) -> Option<StreamService>

Remove a TCP service

pub fn unregister_udp(&self, port: u16) -> Option<StreamService>

Remove a UDP service

pub fn tcp_count(&self) -> usize

Get count of registered TCP services

pub fn udp_count(&self) -> usize

Get count of registered UDP services

pub fn tcp_ports(&self) -> Vec<u16>

List all registered TCP ports

pub fn udp_ports(&self) -> Vec<u16>

List all registered UDP ports

pub fn list_tcp_services(&self) -> Vec<(u16, StreamService)>

List all registered TCP services with their listen ports.

pub fn list_udp_services(&self) -> Vec<(u16, StreamService)>

List all registered UDP services with their listen ports.

pub fn spawn_health_checker( self: &Arc<Self>, interval: Duration, timeout: Duration, ) -> JoinHandle<()>

Spawn a background health checker that periodically probes all registered TCP backends with a connect-only health check.

UDP backends are not probed (there is no reliable connectionless health check). They remain Unknown and are always considered usable.

The task runs every interval and uses timeout for each probe. Returns a JoinHandle that can be used to cancel the checker.

Trait Implementations

impl Default for StreamRegistry

fn default() -> StreamRegistry

Returns the “default value” for a type.