{"repo":"brbtavares/pulse","free":true,"listed":false,"github":"https://github.com/brbtavares/pulse","clone":"git clone https://github.com/brbtavares/pulse.git","description":"Pulse is a tiny real-time data streaming framework (mini Flink/Beam) in Rust. Async (Tokio), pluggable operators, state, and I/O. Fast, modular, local-first.","language":"Rust","stars":13,"topics":["arrow","async","beam","data-streaming","event-time","flink","kafka","parquet","real-time","rocksdb"],"license":"MIT","category":"data-pipelines","readme_excerpt":"Pulse Crate crates.io docs.rs ------------- --------------------------------------------------------------------------- ------------------------------------------------------ pulse-core pulse-state pulse-ops pulse-io Pulse is a tiny, modular, event-time streaming framework (Flink/Beam-like) written in Rust. It focuses on clarity, testability, and a local-first workflow. It supports watermarks, windowing, pluggable state, Prometheus metrics, and a single-binary CLI that runs pipelines from a TOML file. Goals: - Local-first: zero external services required for the common path - Stream processing with event-time and watermarks - Configurable windowing (tumbling/sliding/session) also in CLI - Pluggable state backends (in-memory and optional RocksDB) - File and Parquet I/O, plus optional Kafka - First-class observability (tracing/Prometheus) Local-first vision - Single binary you can run on your laptop or inside a container without standing up a cluster or control plane. - Files-in/files-out by default; opt into Kafka when needed. - Deterministic replay support (EOF watermark) so you can iterate quickly and write golden tests. - Ergonomics first: small, readable codebase; simple config; sensible defaults. Workspace structure - pulse-core : core types/traits, Executor , Record , event-time Watermark , timers, metrics, and config loader - pulse-ops : operators ( Map , Filter , KeyBy , Aggregate , WindowedAggregate ), event-time window helpers - pulse-state : state backends - InMemor","default_branch":null,"files":null,"tree":[],"storefront":"/r/brbtavares","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/brbtavares/pulse/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}