coerce 0.8.11

Async actor runtime and distributed systems framework
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37

use crate::actor::message::Message;
///
/// Actor events provide the ability to monitor the creation of actors, what types of messages
/// they receive and monitor actors that are stopped.
///
/// This provides the ability to create pluggable actor monitoring without the need to manually
/// implement tracing inside each actor, it can be enabled at system level.
///
/// Applications such as dashboards can be created that can receive events as they happen, rather
/// than having to poll.
///
use crate::actor::{ActorId, BoxedActorRef};

pub mod dispatcher;

pub struct ActorStarted {
    timestamp: u64,
    actor_id: ActorId,
    actor_ref: BoxedActorRef,
}

pub struct ActorStopped {
    timestamp: u64,
    actor_ref: BoxedActorRef,
}

pub struct ActorReceived {
    timestamp: u64,
    actor_ref: BoxedActorRef,
    message_type: &'static str,
}

pub enum ActorEvent {
    Started(ActorStarted),
    Stopped(ActorStopped),
    Received(ActorReceived),
}