mm1-test-rt 0.7.23

An Erlang-style actor runtime for Rust.
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
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113

use std::collections::{HashMap, HashSet};
use std::sync::Arc;

use futures::future::BoxFuture;
use futures::stream::FuturesUnordered;
use mm1_address::address::Address;
use mm1_address::pool::Lease as AddressLease;
use mm1_address::subnet::NetAddress;
use tokio::sync::{Mutex, Notify, mpsc};

mod actor_fn;
mod context;
pub mod event;
pub mod query;
mod runtime;

#[derive(Debug, thiserror::Error)]
pub enum RuntimeError {
    #[error("no actor: {}", _0)]
    NoActor(Address),
    #[error("duplicate: {}", _0)]
    Duplicate(Address),
}

#[derive(Debug, Clone)]
pub struct TestRuntime<R> {
    queries_tx: mpsc::UnboundedSender<Query<R>>,
    shared:     Arc<Mutex<RuntimeShared<R>>>,
}

#[derive(derive_more::Debug)]
pub struct Event<R, K> {
    #[debug(skip)]
    runtime: Arc<Mutex<RuntimeShared<R>>>,

    pub kind: K,
}

#[derive(Debug)]
pub enum EventKind<R> {
    Done(ActorTaskOutcome),
    Query(Query<R>),
}

#[derive(derive_more::Debug)]
pub struct TestContext<R> {
    task_key:      TaskKey,
    queries_tx:    mpsc::UnboundedSender<Query<R>>,
    address_lease: Option<AddressLease>,
}

#[derive(Debug, Clone, Copy, PartialEq, Eq, PartialOrd, Ord, Hash)]
pub struct TaskKey {
    pub actor:   Address,
    pub context: Address,
}

#[derive(Debug, derive_more::From)]
pub enum Query<R> {
    InitDone(query::InitDone),
    Spawn(query::Spawn<R>),
    Start(query::Start<R>),
    Recv(query::Recv),
    RecvClose(query::RecvClose),
    Fork(query::Fork<R>),
    ForkRun(query::ForkRun),
    Quit(query::Quit),
    Tell(query::Tell),
    Watch(query::Watch),
    Unwatch(query::Unwatch),
    Link(query::Link),
    Unlink(query::Unlink),
    SetTrapExit(query::SetTrapExit),
    Exit(query::Exit),
    Kill(query::Kill),
    BindNetAddress(query::Bind<NetAddress>),
}

#[derive(derive_more::Debug)]
struct RuntimeShared<R> {
    queries_rx: mpsc::UnboundedReceiver<Query<R>>,
    tasks:      FuturesUnordered<BoxFuture<'static, ActorTaskOutcome>>,
    entries:    HashMap<Address, ActorEntry>,
}

#[derive(derive_more::Debug)]
struct ActorEntry {
    forks: HashSet<Address>,

    #[debug(skip)]
    actor_canceled: Arc<Notify>,

    #[debug(skip)]
    actor_done: Arc<Notify>,
}

#[derive(Debug)]
pub enum ActorTaskOutcome {
    Main(MainActorOutcome),
    Fork(ForkTaskOutcome),
}

#[derive(Debug)]
pub struct MainActorOutcome {
    pub address:       Address,
    pub address_lease: Option<AddressLease>,
}

#[derive(Debug)]
pub struct ForkTaskOutcome {
    pub task_key:      TaskKey,
    pub address_lease: Option<AddressLease>,
}