Struct ProbeActor 

pub(crate) struct ProbeActor {
    pub(crate) config: ActorConfig,
    pub(crate) mailbox_tx: Sender<Message>,
    pub(crate) mailbox_rx: Option<Receiver<Message>>,
    pub(crate) metrics: Arc<ActorMetrics>,
    pub(crate) starts: Arc<AtomicU64>,
    pub(crate) crash_remaining: Arc<AtomicU64>,
}

Fields

config: ActorConfig

mailbox_tx: Sender<Message>

mailbox_rx: Option<Receiver<Message>>

metrics: Arc<ActorMetrics>

starts: Arc<AtomicU64>

crash_remaining: Arc<AtomicU64>

Implementations

impl ProbeActor

pub(crate) fn new( name: &str, starts: Arc<AtomicU64>, crash_remaining: Arc<AtomicU64>, ) -> Self

Trait Implementations

impl Actor for ProbeActor

fn id(&self) -> String

Return this actor’s unique WID identifier.

fn name(&self) -> &str

Return this actor’s human-readable name.

fn state(&self) -> ActorState

Return the current lifecycle state.

fn metrics(&self) -> Arc<ActorMetrics>

Return a reference to this actor’s metrics.

fn mailbox(&self) -> Sender<Message>

Return a sender handle to this actor’s mailbox.

fn handle_message<'life0, 'async_trait>( &'life0 mut self, _msg: Message, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Called with each incoming message from the mailbox.

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

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

Drive the actor’s main loop.

fn is_protected(&self) -> bool

Return whether this actor is protected from external kill commands.

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

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

Called once after the actor is created, before the message loop starts.

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

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

Called on heartbeat tick; default implementation is a no-op.

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

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

Called once just before the actor loop exits.