Struct ClientBroker 

pub struct ClientBroker<T> { /* private fields */ }

Implementations

impl<T> ClientBroker<T>

where T: Debug + Send + 'static + DeserializeOwned + Sync + Clone + Serialize,

pub fn init( network_topology: StdArc<NetworkTopology>, container_state: StdArc<AtomicUsize>, container_state_notify: StdArc<Notify>, ) -> Self

Initializes the ClientBroker with the network topology, container state, and state notification mechanism.

Arguments

• network_topology - A reference-counted arc for network connections.
• container_state - Atomic state of the container lifecycle.
• container_state_notify - State notification for component updates.

pub async fn handle_message(&self, message: ClientBrokerMessage<T>)

pub async fn forward_shutdown(&mut self, message: T)

pub async fn shutdown(&mut self)

Trait Implementations

impl<T> Drop for ClientBroker<T>

fn drop(&mut self)

Executes the destructor for this type.