Crate callysto

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

• app
  Application builder methods
• config
  Application configuration
• errors
  Errors of Callysto
• kafka
  Methods to interact with Kafka
• prelude
  Callysto prelude
• sensors
  Metric implementations to instrument Callysto application
• sinks
  Sink implementations for streams
• types
  Callysto’s building blocks. All modules are under types.