maiko 0.3.1

Lightweight event-driven actor runtime with topic-based pub/sub for Tokio
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13

use std::sync::Arc;

use crate::{ActorId, Envelope, OverflowPolicy};

pub(crate) enum MonitoringEvent<E, T> {
    EventDispatched(Arc<Envelope<E>>, Arc<T>, ActorId),
    EventDelivered(Arc<Envelope<E>>, Arc<T>, ActorId),
    EventHandled(Arc<Envelope<E>>, Arc<T>, ActorId),
    Overflow(Arc<Envelope<E>>, Arc<T>, ActorId, OverflowPolicy),
    ActorRegistered(ActorId),
    ActorStopped(ActorId),
    Error(Arc<str>, ActorId),
}