#data-processing #stream-processing #real-time #analytics #async

fluxus-sources

Source components for Fluxus stream processing engine

2 releases

Uses new Rust 2024

new 0.1.3 Apr 24, 2025
0.1.2 Apr 24, 2025

#11 in #data-processing


Used in 5 crates

Apache-2.0

17KB
265 lines

Fluxus Sources

Source components for the Fluxus stream processing engine.

Overview

This crate provides various source implementations for the Fluxus stream processing engine, allowing data to be ingested from different sources.

Key Sources

  • CsvSource - Read data from CSV files.
  • GeneratorSource - Generate data for testing purposes.

Usage

Add this to your Cargo.toml:

[dependencies]
fluxus-sources = "0.1"

Dependencies

~5–13MB
~120K SLoC