callysto/
lib.rs

1//!
2//! Callysto is a Rust framework for stream processing,
3//! which benefits from Rust's concurrency model and
4//! optimized performance.
5//!
6//! Callysto made available with Kafka Streams mentality in Rust.
7//! It is for building high-performance distributed system and near real-time data
8//! pipelines to process large amounts of events.
9//!
10//! Callysto behaves like both stream processing and event processing,
11//! sharing similarity with tools such as Faust, Kafka Streams, Apache Spark/Storm/Samza/Flink.
12//!
13//! It is built on service oriented model to build microservices.
14
15#![allow(unused_imports)]
16#![allow(dead_code)]
17#![allow(unused_must_use)]
18#![allow(unused)]
19#![allow(incomplete_features)]
20#![doc(
21    html_logo_url = "https://raw.githubusercontent.com/vertexclique/callysto/master/art/callysto_logo.png"
22)]
23// Force missing implementations
24// #![warn(missing_docs)]
25// #![warn(missing_debug_implementations)]
26// Doc generation experimental features
27#![cfg_attr(feature = "docs", feature(doc_cfg))]
28
29/// Application builder methods
30///
31/// # Example
32/// ```rust,no_run
33/// use callysto::prelude::*;
34///
35/// let mut app = Callysto::new();
36/// app.with_name("example-app");
37/// app.run();
38/// ```
39pub mod app;
40/// Application configuration
41pub mod config;
42/// Errors of Callysto
43pub mod errors;
44/// Methods to interact with Kafka
45pub mod kafka;
46/// Metric implementations to instrument Callysto application
47pub mod sensors;
48/// Sink implementations for streams
49pub mod sinks;
50/// Callysto's building blocks. All modules are under types.
51pub mod types;
52
53mod runtime;
54mod stores;
55
56/// Reexport of Futures
57pub use futures;
58/// Reexport of http_types
59pub use http_types;
60/// Reexport of nuclei
61pub use nuclei;
62/// Reexport of rdkafka
63pub use rdkafka;
64
65/// Callysto prelude
66pub mod prelude {
67    pub use super::app::*;
68    pub use super::config::*;
69    pub use super::errors::*;
70    pub use super::http_types::{
71        Request as CWebRequest, Response as CWebResponse, Result as CWebResult,
72    };
73    pub use super::kafka::prelude::*;
74    pub use super::rdkafka::*;
75    pub use super::sinks::*;
76    pub use super::types::prelude::*;
77    pub use super::types::table::*;
78}
callysto/lib.rs

callysto/
lib.rs
