aector 0.1.1

Dynamic implementation of the actor model with a smart built-in testing 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

use crate::actor::{Actor, ExitReason};
use crate::actor::Backup;
use crate::supervision::supervision::{SuperVisionAction, SupervisionStrategy};
use crate::supervision::supervision::SuperVisionAction::{Exit, Restart};

/// Implements a simple restart strategy where the supervised actor is instantly restarted unless
/// the actor requested the stop itself, in which case the actor is stopped and removed from
/// the actor system.
pub struct SimpleRestartStrategy {}

impl SimpleRestartStrategy {
    pub fn new() -> Box<Self> {
        Box::new(Self {})
    }
}

impl<S: Send + Clone> SupervisionStrategy<S> for SimpleRestartStrategy {
    fn apply(&mut self, exit_reason: ExitReason, backup: &Backup<S>, actor: &mut Actor<S>) -> SuperVisionAction {
        match exit_reason {
            ExitReason::Kill => {
                println!("ActorSys: actor died on purpose");
                return Exit;
            }
            ExitReason::Restart => {
                println!("ActorSys: actor requested a restart. Restarting actor with initial state and behavior");
                actor.apply_backup(&backup);
                return Restart;
            },
            ExitReason::Error => {
                println!("ActorSys: actor ran into error or triggered restart. Restarting actor with initial state and behavior");
                actor.apply_backup(&backup);
                return Restart;
            }
        }
    }
}