A tiny Kafka client library with producer and consumer functionalities.
Rust bindings for the Listen Notes Podcast API
Proc macros for the karga load testing framework
A small, flexible load-testing framework for Rust
Input/output connectors for Pulse — integrates with external systems such as Kafka, Arrow, and Parquet.
AWS S3 sink connector for the faucet-stream ecosystem
Wire-level types shared by the Akribes SDK and core (events, values, AST shapes, errors).
Pure‑Rust client for Apache Kafka 4.0+ – drop‑in replacement for librdkafka, powered by Tokio and zero‑copy buffers.
Core runtime and dataflow engine for Pulse — defines execution graph, operators, and streaming primitives.
Built-in operators and combinators for Pulse dataflows — map, filter, join, window, and custom processing logic.
State management utilities for Pulse — provides windowing, aggregations, and persistent operator state.
Universal Data Broker — a Rust gRPC broker over multiple databases (Postgres, MySQL, SQLite, MongoDB, ClickHouse, Cassandra, MSSQL, Redis, Qdrant, S3, Neo4j, …) with per-tenant RLS, 2PC, sagas, and CDC.