Struct HyperionContainer 

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

Implementations

impl<T> HyperionContainer<T>

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

pub fn create<A>( component_archetype: A, container_state: StdArc<AtomicUsize>, container_state_notify: StdArc<Notify>, client_broker: ClientBroker<T>, main_rx: Receiver<T>, server_rx: Receiver<T>, heartbeat_config: Option<HeartbeatConfig>, container_name: String, timeout_handler: Option<Box<dyn HeartbeatTimeoutHandler>>, missed_handler: Option<Box<dyn HeartbeatMissedHandler>>, ) -> Self

where A: Run<Message = T> + Send + 'static + Sync + Debug,

pub async fn run(&mut self)

HyperionContainer main loop