Enum AlertMessage 

pub enum AlertMessage {
    Heartbeat,
}

Variants

Heartbeat

Send a heartbeat to the backend API Returns ws_url in response for ConfigManager to connect WebSocket

Trait Implementations

impl Clone for AlertMessage

fn clone(&self) -> AlertMessage

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for AlertMessage

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

Formats the value using the given formatter.

impl FactoryLifecycleHooks<(), AlertMessage> for AlertsFactoryHooks

fn on_factory_started<'life0, 'async_trait>( &'life0 self, _factory: ActorRef<FactoryMessage<(), AlertMessage>>, ) -> Pin<Box<dyn Future<Output = Result<(), ActorProcessingErr>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Called when the factory has completed it’s startup routine but PRIOR to processing any messages. Just before this point, the factory is ready to accept and process requests and all workers are started.

fn on_factory_stopped<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), ActorProcessingErr>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Called when the factory has completed it’s shutdown routine but PRIOR to fully exiting and notifying any relevant supervisors. Just prior to this call the factory has processed its last message and will process no more messages.

fn on_factory_draining<'life0, 'async_trait>( &'life0 self, _factory: ActorRef<FactoryMessage<(), AlertMessage>>, ) -> Pin<Box<dyn Future<Output = Result<(), ActorProcessingErr>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Called when the factory has received a signal to drain requests and exit after draining has completed.