pipebase 0.2.0

A tokio based runtime library for data integration app
Documentation
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
pub use crate::collect::*;
pub use crate::common::*;
pub use crate::context::*;
pub use crate::error::*;
pub use crate::export::*;
pub use crate::listen::*;
pub use crate::map::*;
pub use crate::poll::*;
pub use crate::select::*;
pub use crate::stream::*;
pub use crate::{
    channel, collect_context, collector, config, cstore, error_handler, exporter, join_pipes,
    listener, mapper, pipe_channels, poller, run_cstore, run_error_handler, run_pipe, selector,
    streamer, subscribe_error_handler,
};
pub use pipederive::*;