atomr-core 0.1.0

Actors, supervision, dispatch, mailboxes, scheduler, FSM, event stream, and coordinated shutdown — the core of the atomr actor runtime.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

//! Lifecycle observer hooks. Enables external crates (e.g.
//! `atomr-telemetry`) to observe actor spawn/stop/dead-letter events
//! without taking a dependency on `atomr-core`'s internals.

use super::path::ActorPath;

/// Implementors are notified whenever actors are spawned or stopped.
/// Methods are called on the actor's task, so they should be cheap and
/// non-blocking.
pub trait SpawnObserver: Send + Sync + 'static {
    fn on_spawn(&self, path: &ActorPath, parent: Option<&ActorPath>, actor_type: &'static str);
    fn on_stop(&self, path: &ActorPath);

    /// Called whenever the mailbox depth is sampled (optional).
    fn on_mailbox_depth(&self, _path: &ActorPath, _depth: u64) {}
}

/// Implementors are notified whenever a `tell` fails because the target
/// actor has stopped. Called on the caller's thread, so implementers
/// should be cheap.
pub trait DeadLetterObserver: Send + Sync + 'static {
    fn on_dead_letter(&self, recipient: &ActorPath, sender: Option<&ActorPath>, message_type: &'static str);
}