Expand description
Callysto is a Rust framework for stream processing, which benefits from Rust’s concurrency model and optimized performance.
Callysto made available with Kafka Streams mentality in Rust. It is for building high-performance distributed system and near real-time data pipelines to process large amounts of events.
Callysto behaves like both stream processing and event processing, sharing similarity with tools such as Faust, Kafka Streams, Apache Spark/Storm/Samza/Flink.
It is built on service oriented model to build microservices.
Re-exports§
pub use futures;
pub use http_types;
pub use nuclei;
pub use rdkafka;
Modules§
- Application builder methods
- Application configuration
- Errors of Callysto
- Methods to interact with Kafka
- Callysto prelude
- Metric implementations to instrument Callysto application
- Sink implementations for streams
- Callysto’s building blocks. All modules are under types.