Struct Fleet 

pub struct Fleet<PlcId> { /* private fields */ }

Multi-PLC pool built from actor-backed Client handles.

Implementations

impl<PlcId> Fleet<PlcId>

where PlcId: Clone + Eq + Hash + Send + Sync + 'static,

pub fn new() -> Self

Creates an empty fleet.

pub async fn connect(&mut self, plc_id: PlcId, addr: &str) -> Result<Client>

Connects and adds one PLC by address.

pub async fn connect_with_route( &mut self, plc_id: PlcId, addr: &str, route: RoutePath, ) -> Result<Client>

Connects and adds one routed PLC by address and route path.

pub fn insert_client(&mut self, plc_id: PlcId, client: Client) -> Option<Client>

Inserts an existing actor client into the fleet.

pub fn client(&self, plc_id: &PlcId) -> Option<Client>

Returns a cloneable client handle for one PLC.

pub fn events(&self) -> Receiver<FleetEvent<PlcId>>

Subscribes to fleet-level connection events.

pub async fn check_health(&self) -> HashMap<PlcId, Result<bool>>

Performs a health check against every PLC currently in the fleet.

pub fn len(&self) -> usize

Returns the number of PLCs in the fleet.

pub fn is_empty(&self) -> bool

Returns true when the fleet has no PLC clients.

Trait Implementations

impl<PlcId: Debug> Debug for Fleet<PlcId>

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

Formats the value using the given formatter.

impl<PlcId> Default for Fleet<PlcId>

where PlcId: Clone + Eq + Hash + Send + Sync + 'static,

fn default() -> Self

Returns the “default value” for a type.