supertrees 0.1.2

Supervision trees for Tokio-based services inspired by Erlang/OTP
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

use std::fmt::Debug;
use std::future::Future;
use std::pin::Pin;

use self::restartable::Restartable;
use crate::{BackoffPolicy, RestartPolicy};

pub mod backoff;
pub mod backoff_policy;
pub mod restartable;
pub mod watcher;

/// A trait representing a worker that can be restarted.
pub trait Worker: Debug + Send + Restartable {
    /// The initialization entrypoint for the worker. This is called when the
    /// worker is started, and can be called an infinite number of times if
    /// indefinite restarts are permitted. Therefore, it should be safe to call
    /// this repeatedly.
    fn init(&self) -> Pin<Box<dyn Future<Output = ()> + Send + 'static>>;

    /// Returns the restart policy for worker.
    fn restart_policy(&self) -> RestartPolicy {
        RestartPolicy::default()
    }

    /// Returns the backoff policy for the worker.
    fn backoff_policy(&self) -> BackoffPolicy {
        BackoffPolicy::default()
    }
}