infinyon / fluvio-demo-apps-rust
Mysql Change Data Capture Demo App for Fluvio Streaming Platform
☆14Updated last year
Related projects ⓘ
Alternatives and complementary repositories for fluvio-demo-apps-rust
- Deadlock free Mutexes.☆15Updated last year
- Advanced futures library☆16Updated 2 weeks ago
- A type erased wrapper around some key-value storages to provide common operations(redis, sled, hashmaps)☆23Updated last year
- Queue futures to run concurrently, in the order they're spawned, and with global and group limits.☆57Updated this week
- Adapters between hyper 0.14-1.0, http-body 0.4-1.0, and tower-service 0.3.☆11Updated 11 months ago
- Asynchronous signal handling☆15Updated last month
- A "blazingly" fast key-value pair database without bloat written in rust☆19Updated 11 months ago
- Message bus - enables async communication between different parts of application using messages☆23Updated 3 weeks ago
- Simple Rust triggers that allows triggering a one time event in another task/thread☆22Updated 2 years ago
- A rust crate with various helpers for writing production-ready servers in rust using async-std☆18Updated 4 years ago
- native Rust implementation of Kafka protocol and api☆14Updated last year
- cross-platform Rust API for memory mapped IO☆41Updated 6 months ago
- Idiomatic Async Prometheus Query (PromQL) Client for Rust.☆20Updated 4 years ago
- A multi layered configuration loader and zero-boilerplate configuration parser.☆28Updated 3 years ago
- Rust interface for the WebRTC Voice-Activity-Module☆23Updated 4 years ago
- Extension traits for reporting failed unwraps to a tracing::Subscriber.☆10Updated 8 months ago
- ☆21Updated 2 years ago
- Fluvio DuckDB Integration☆19Updated last year
- WRite Ahead Logging for distributed applications.☆30Updated 2 years ago
- A version for futures::FuturesUnordered that multiplexes Streams☆25Updated last week
- Thread-safe clone-on-write container for fast concurrent writing and reading.☆49Updated last year
- Avrow is a pure Rust implementation of the avro specification https://avro.apache.org/docs/current/spec.html with Serde support.☆28Updated 2 years ago
- Rust client library for ClickHouse☆16Updated last year
- AtomicRingBuffer is a constant-size almost lock-free ring buffer with low memory overhead in Rust☆38Updated 7 months ago
- Drpc-Correct, high performance, robust, easy use Remote invocation framework☆35Updated 10 months ago
- Ruskel generates skeletonized outlines of Rust crates.☆16Updated last month
- axum::ws with type safe messages☆21Updated 6 months ago