dagrs 0.8.0

Dagrs follows the concept of Flow-based Programming and is suitable for the execution of multiple tasks with graph-like dependencies. Dagrs has the characteristics of high performance and asynchronous execution. It provides users with a convenient programming interface.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

pub mod connection;
pub mod graph;
pub mod node;
pub mod utils;

pub use connection::{
    in_channel::{InChannels, RecvErr},
    information_packet::Content,
    out_channel::{OutChannels, SendErr},
};
pub use node::*;

pub use async_trait;
pub use graph::*;
pub use tokio;
pub use utils::checkpoint::{
    Checkpoint, CheckpointConfig, CheckpointError, CheckpointId, CheckpointStore,
    FileCheckpointStore, MemoryCheckpointStore, NodeState,
};
pub use utils::{env::EnvVar, output::Output};

#[cfg(feature = "derive")]
pub use dagrs_derive::*;