tempest 0.1.0

Realtime message handling framework inspired by Apache Storm and built with Actix
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

pub mod common;
pub mod metric;
pub mod pipeline;
pub mod rt;
pub mod source;
pub mod task;
pub mod topology;

pub(crate) mod service;

// Base imports for implementing Topology & Task's
pub mod prelude {
    pub use crate::metric::{self, MetricLogLevel, MetricTarget};
    pub use crate::pipeline::Pipeline;
    pub use crate::rt::{self, run};
    pub use crate::source::{Msg, SourceMsg};
    pub use crate::task;
    pub use crate::topology::{Topology, TopologyBuilder, TopologyFailurePolicy, TopologyOptions};
}

pub use actix;
pub use config;