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
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.