-
sea-orm
🐚 An async & dynamic ORM for Rust
-
rdkafka
Rust wrapper for librdkafka
-
foyer
Hybrid cache for Rust
-
cmd_lib
Common rust commandline macros and utils, to write shell script like tasks easily
-
aws-sdk-kinesis
AWS SDK for Amazon Kinesis
-
iggy
persistent message streaming platform written in Rust, supporting QUIC, TCP and HTTP transport protocols, capable of processing millions of messages per second
-
rxrust
Reactive Extensions
-
crc-fast
World's fastest generic CRC16, CRC32, and CRC64 calculator using SIMD. Supplies a C-compatible shared library for use in other languages.
-
madsim
Deterministic Simulator for distributed systems
-
kode-bridge
Modern HTTP Over IPC library for Rust with both client and server support (Unix sockets, Windows named pipes)
-
crb
CRB | Composable Runtime Blocks
-
aws-sdk-dynamodbstreams
AWS SDK for Amazon DynamoDB Streams
-
scirs2-fft
Fast Fourier Transform module for SciRS2 (scirs2-fft)
-
oxc_parser
A collection of JavaScript tools written in Rust
-
vicut
A CLI text processor that uses Vim commands to transform text and extract fields
-
pusherator
Push-based version of Rust iterators
-
dataflow-rs
A lightweight, rule-driven workflow engine for building powerful data processing pipelines and nanoservices in Rust. Extend it with your custom tasks to create robust, maintainable services.
-
mel_spec
Mel spectrograms aligned to the results from the whisper.cpp, pytorch and librosa reference implementations and suited to streaming audio
-
ccstat
Analyze Claude Code usage data from local JSONL files
-
rusty_dumb_tools
A collection of simply tools Rust modules
-
wit_owo
interacting with the Wit.ai API
-
onion-lang
A modern functional programming language with asynchronous execution and lazy evaluation
-
databend-driver
Databend Driver for Rust
-
aws-sdk-kinesisanalyticsv2
AWS SDK for Amazon Kinesis Analytics
-
aws-sdk-kinesisanalytics
AWS SDK for Amazon Kinesis Analytics
-
wavelet
High-performance graph-based stream processing runtime
-
moosicbox_aconverter
Audio converter helper binary
-
rust-rule-engine
blazing-fast Rust rule engine with RETE algorithm, backward chaining inference, and GRL (Grule Rule Language) syntax. Features: forward/backward chaining, pattern matching, unification…
-
mssql-client
High-level async SQL Server client with type-state connection management
-
ractor_actors
actors built with Ractor
-
cesrox
Composable Event Streaming Representation (CESR)
-
nebulous
A globally distributed container orchestrator
-
mockforge-kafka
Kafka protocol support for MockForge
-
bitnet-core
Core BitNet implementation with fundamental data structures and algorithms
-
nu_plugin_nw_ulid
Production-grade ULID (Universally Unique Lexicographically Sortable Identifier) utilities plugin for Nushell with cryptographically secure operations, enterprise-grade security, and streaming support
-
marked-yaml
A simplified YAML structure with provenance spans
-
moosicbox_audio_decoder
MoosicBox Symphomia player package
-
sea-streamer
🌊 The stream processing toolkit for Rust
-
ship162
A real-time AIS data decoder
-
scrolling_window_pattern_matcher
A unified pattern matching library with optional context support and extractor-driven architecture for streaming data processing
-
lowess
(Locally Weighted Scatterplot Smoothing) implementation in Rust
-
micro-http
the async micro http server
-
evento
Event sourcing and CQRS toolkit with SQL persistence, projections, and subscriptions
-
dxlink
trading through tastytrade's API
-
biometal
ARM-native bioinformatics library with streaming architecture and evidence-based optimization
-
fastgeotoolkit
A novel high-performance geospatial analysis framework with advanced route density mapping algorithms
-
fastLowess
High-level, parallel LOWESS smoothing built on top of the lowess crate, with ndarray integration and rayon-based parallelism
-
openrouter-rs
A type-safe OpenRouter Rust SDK
-
spop
parsing HAProxy SPOP (Stream Processing Offload Protocol)
-
redis-oxide
High-performance async Redis client for Rust with automatic cluster support, multiplexing, and advanced features
-
avila-fft
Ultimate performance FFT: SIMD, caching, advanced algorithms, parallel, streaming - Zero dependencies
-
fluxion-stream
Stream combinators with ordering guarantees for async Rust
-
claudius
SDK for the Anthropic API
-
fauxgen
write your own generators in stable rust
-
gst-plugin-hlssink3
GStreamer HLS (HTTP Live Streaming) Plugin
-
hydro_std
Standard library of distributed systems building blocks for Hydro
-
xai-sdk
xAI SDK
-
simdscan
Classify SIMD instructions by ISA extension
-
stft-rs
streaming-friendly, no_std compliant STFT implementation with mel spectrogram support
-
fluvio-stream-model
Fluvio Event Stream Model
-
avila-cli
Ávila CLI Parser - Zero-dependency with config files, env vars, macros, completions, colors, and advanced features
-
fluvio-extension-common
Fluvio extension common
-
trash_parallelism
Azzybana Raccoon's comprehensive parallelism library
-
claude-codes
A tightly typed Rust interface for the Claude Code JSON protocol
-
pidgeon
A robust, thread-safe PID controller library written in Rust
-
fluvio-stream-dispatcher
Fluvio Event Stream access
-
kiru
Fast text chunking for Rust
-
nostr-archive-cursor
iterating over JSON-L archives
-
genson-core
Core library for JSON schema inference using genson-rs
-
fluvio-types
Fluvio common types and objects
-
selexqc
High-performance parallel RNA Capture-SELEX library quality control
-
sentry_arroyo
working with streaming data
-
langextract-rust
extracting structured and grounded information from text using LLMs
-
fiddler-cli
Data Stream processor CLI written in rust
-
bufjson
No frills, low-alloc, low-copy JSON lexer/parser for fast stream-oriented parsing
-
fluvio-package-index
Fluvio Package Index
-
cargo-coupling
A coupling analysis tool for Rust projects - measuring the 'right distance' in your code
-
ptyprocess
work with PTY/TTY on Unix systems
-
fluxion-core
Core traits and types for ordered stream processing
-
tilesort
A sorting algorithm optimized for datasets with pre-sorted contiguous blocks (tiles)
-
threatflux-binary-analysis
Comprehensive binary analysis library with multi-format support, disassembly, and security analysis
-
pulse-ops
Built-in operators and combinators for Pulse dataflows — map, filter, join, window, and custom processing logic
-
oneringbuf
A lock-free single-producer, single-consumer (SPSC) ring buffer with in-place mutability, asynchronous support, and virtual memory optimisation
-
streamweave
Composable, async, stream-first computation in pure Rust
-
mcpproxy
MCP proxy server for remote HTTP endpoints supporting JSON and Server-Sent Events
-
markex
Fast, non-validating markup element extractor (Tag Element, MdRef, MdCodeBlock, MDSection)
-
async-regex
Empower regex with streaming capabilities - high-performance async streaming pattern search using regex for multi-byte pattern matching in data streams
-
fiddler
Data Stream processor written in rust
-
vuo
An asynchronous stream processing library for Rust, built on Actix, providing a rich set of functional operators
-
dapt
serializing and unseralizing unstructured data
-
meilibridge
High-performance PostgreSQL to Meilisearch connector
-
rsp-rs
A RDF Stream Processing engine in Rust, supporting RSP-QL queries with sliding windows and real-time analytics
-
tonbo
Embedded database for serverless and edge runtimes, storing data as Parquet on S3
-
maple-proxy
Lightweight OpenAI-compatible proxy server for Maple/OpenSecret TEE infrastructure
-
fluxion-exec
Async stream subscribers and execution utilities for fluxion
-
allsource-core
High-performance event store core built in Rust
-
runagent
SDK for Rust - Client SDK for interacting with deployed AI agents
-
rs2-stream
A high-performance, production-ready async streaming library for Rust
-
renoir
Reactive Network of Operators In Rust
-
rmcp-agent
that extends langchain-rust with support for Model Context Protocol (MCP) tool integration and streaming tool execution capabilities
-
iks
Fast, easy to use XML parser library for Jabber/XMPP and general XML processing
-
maiko
Lightweight event-driven actor runtime with topic-based pub/sub for Tokio
-
rust-logic-graph
Reasoning engine for distributed backend & AI orchestration. Coordinate services, databases, and AI agents with business rules (GRL).
-
process-stream
Thin wrapper around [
tokio::process] to make it streamable -
modtector
A high-performance modification detection tool in Rust
-
tellaro-query-language
A flexible, human-friendly query language for searching and filtering structured data
-
xyz-convert
Fast Rust implementation of XYZ file fixing and trajectory conversion utilities
-
denet
process monitor
-
versatiles_pipeline
A toolbox for converting, checking and serving map tiles in various formats
-
scripty
your Rust command toolkit for easy command execution and file operations
-
llm-optimizer-processor
Data processing and transformation pipeline
-
callysto
Stream processing framework
-
dash-em
Enterprise-Grade Em-Dash Removal Library — SIMD-Accelerated String Processing
-
llm-cost-ops
Core library for cost operations on LLM deployments
-
fluxion-rx
A reactive stream processing library with ordered semantics, friendly interface, and bullet-proof, state-of-the art test coverage and examples
-
tokio-process-stream
that wraps a tokio::process into a tokio::stream
-
aws_utils_s3
AWS S3 utilities for common operations like listing, uploading, downloading, and deleting objects
-
nano-wal
lightweight Write-Ahead Log (WAL) implementation for append-only operations
-
llm-optimizer-decision
Intelligent decision-making engine
-
transmutation
High-performance document conversion engine for AI/LLM embeddings - 27 formats supported
-
optivorbis
A lossless, format-preserving, two-pass Vorbis optimization and repair library
-
ruvector-tiny-dancer-wasm
WASM bindings for Tiny Dancer neural routing
-
midas_processor
High-performance Rust tool for converting UK Met Office MIDAS weather datasets from BADC-CSV to optimized Parquet format
-
fluvio-spu-schema
Fluvio API for SPU
-
midstreamer-scheduler
Ultra-low-latency real-time task scheduler
-
csv_log_cleaner
Clean CSV files to conform to a type schema by streaming them through small memory buffers using multiple threads and logging data loss
-
proc-heim
running and managing short-lived and long-lived processes using asynchronous API
-
anthropic-sdk-rust
Comprehensive, type-safe Rust SDK for the Anthropic API with streaming, tools, vision, files, and batch processing support
-
tree-parser
An asynchronous Rust library for parsing source code and searching constructs
-
nobom
remove UTF-8 BOM (Byte Order Mark) from stdin and write to stdout
-
anyrepair
A comprehensive Rust crate for repairing LLM responses including JSON, YAML, XML, TOML, CSV, INI, and Markdown with advanced analytics and enterprise features
-
fluvio-sc-schema
Fluvio API for SC
-
pulse-core
Core runtime and dataflow engine for Pulse — defines execution graph, operators, and streaming primitives
-
wingfoil
graph based stream processing framework
-
amadeus
Harmonious distributed data processing & analysis in Rust. parquet postgres aws s3 cloudfront elb json csv logs hadoop hdfs arrow common crawl
-
track-rails
Rust Version of TrackRails Protocol
-
arroyo-udf-common
Common utilities for the Arroyo UDF FFI API
-
monochora
gif to ascii art converter written in rust
-
kira_cdh_compat_fastq_reader
Streaming FASTQ reader compatible with CD-HIT input handling (plain and .gz), safe idiomatic Rust API; sync and async
-
nc2parquet
High-performance NetCDF to Parquet converter with cloud storage support
-
surge-sdk
Rust SDK for Surge.sh API - programmatically manage static site deployments, domains, SSL, and DNS
-
indicator
Abstractions for stream aggregation, we call them
Indicators -
nano-consciousness
High-performance consciousness-inspired AI framework with nanosecond scheduling and temporal processing
-
sea-streamer-socket
🌊 SeaStreamer backend-agnostic Socket API
-
eink-image
converting images to formats optimized for eink displays
-
kotoba-kotobas
KotobaScript - Declarative programming language for frontend applications, extending Jsonnet with React component definitions
-
sfo-io
handling IO operations, providing asynchronous read/write and stream processing capabilities
-
async-read-super-ext
A super extension for tokio::io::AsyncRead
-
arcon
A runtime for writing streaming applications
-
pipeless-ai
An open-source computer vision framework to build and deploy applications in minutes
-
ecad-processor
High-performance multi-metric weather data processor for European Climate Assessment & Dataset (ECA&D) archives with Parquet output
-
spring-stream
Integrate sea-streamer with spring-rs
-
moosicbox_image
MoosicBox image package
-
sea-streamer-redis
🌊 SeaStreamer Redis Backend
-
byteforge
A next-generation byte-level transformer with multi-signal patching and SIMD optimization
-
zeal-sdk
Rust SDK for Zeal Integration Protocol (ZIP)
-
rlink
High performance Stream Processing Framework
-
surfing
parsing JSON objects from text streams
-
fudd
Fun with poker. Named after that most famous of rabbit hunters.
-
oxirs-federate
SERVICE planner and GraphQL stitching for federated SPARQL queries
-
rss_parser
A high-performance, streaming RSS parser for Rust with generic AsyncRead support
-
par-stream
Asynchronous parallel streams analogous to rayon
-
llm-optimizer
Production-ready main service binary for LLM Auto Optimizer
-
xstream-util
A command line tool to split a stream to child processes
-
seq_chunking
SeqCDC (content defined chunking) in pure Rust
-
rusty-tracks
Rust client to connect to DataTracks
-
orchflow-terminal
High-performance terminal I/O management with PTY support, buffering, and stream processing
-
evento-store
A collection of libraries and tools that help you build DDD, CQRS, and event sourcing
-
reifydb-sub-flow
Flow subsystem for stream processing and data flows
-
voice-stream
Voice stream is a real-time audio stream processing with voice activity detection. This library provides a high-level interface for capturing audio input, performing voice detection using Silero VAD…
-
oxirs-stream
Real-time streaming support with Kafka/NATS/MQTT/OPC-UA I/O, RDF Patch, and SPARQL Update delta
-
sea-streamer-file
🌊 SeaStreamer File Backend
-
rusoto_kinesisanalytics
AWS SDK for Rust - Amazon Kinesis Analytics @ 2015-08-14
-
quasor
A high-security AEAD based on a Duplex Sponge construction with SHAKE256, Argon2id, and BLAKE3
-
fukurow-streaming
Real-time streaming processing for Fukurow reasoning engine
-
pyth-benchmark-rs
client for streaming and processing historical OHLC price data from the Pyth Network oracle
-
rangebar-streaming
Real-time streaming engine for range bar processing
-
rusoto_kinesisanalyticsv2
AWS SDK for Rust - Amazon Kinesis Analytics @ 2018-05-23
-
rangebar-cli
Command-line tools for range bar processing and analysis
-
sea-streamer-types
🌊 SeaStreamer Traits & Types
-
syncstate
A global synchronization library built for synchronizing states reliably, incrementally and fast
-
kawadb-broker
High-performance Kafka-compatible message broker
-
wingfoil-python
python bindings for wingfoil - graph based stream processing framework
-
scribe-scaling
High-performance scaling optimizations for large repositories
-
bungee-rs
High level Rust FFI bindings for the Bungee audio time-stretching library
-
malstrom
distributed, stateful stream processing framework written in Rust
-
rspl
A stream processor language
-
cmd_lib_cf
Modified version of cmd_lib with CREATE_NO_WINDOW built in
-
quick-xml-to-json
High-performance conversion of XML to JSON
-
pgparquet
High-performance CLI tool for streaming Parquet files from Google Cloud Storage into PostgreSQL
-
hydroflow_lang
Hydroflow's Surface Syntax implementation
-
hydro_optimize
Automatic decoupling and partitioning
-
fluxus
lightweight stream processing engine written in Rust, designed for efficient real-time data processing and analysis
-
round_pipers
A way to pipe ndarrays using circular buffers
-
hypetrigger
Perform efficient per-frame operations on streaming video
-
fluvio-system-util
Fluvio System components
-
zerovault
Fort-Knox document encryption vault with defense-in-depth security
-
rafka-storage
Storage engine for Rafka message broker
-
springql
Open-source stream processor for IoT devices and in-vehicle computers
-
kvc
Very simple key-value-count tools to go from / to pandas data frames or streaming formats
-
noir-compute
Network of Operators In Rust
-
hyprstream
High-performance metrics storage and query service using Arrow Flight SQL
-
rosu-rate-changer
Rate changer for osu!
-
sea-streamer-stdio
🌊 SeaStreamer Standard I/O Backend
-
rsflow
High-performance Rust flow processing engine
-
sentinel-agent-protocol
Agent protocol and IPC for Sentinel reverse proxy external processors
-
fluxus-api
High-level API for Fluxus stream processing engine
-
hydroflow_cli_integration
hydro_cliintegration for Hydroflow -
iterpipes
Compositional, pipes-style stream processing
-
sea-streamer-examples
🌊 The stream processing toolkit for Rust
-
arkflow
High-performance Rust flow processing engine
-
sea-streamer-kafka
🌊 SeaStreamer Kafka / Redpanda Backend
-
mcprs
Model Context Protocol para Rust - Uma biblioteca unificada para comunicação com diferentes LLMs e APIs de IA
-
fluvio-controlplane
Fluvio control plane API
-
sea-streamer-fuse
Stream processing toolbox
-
rstreams
Async Stream-Processing toolkit with actor model flavor
-
fluvio-runner-local
Fluvio Engine Runner
-
file-hasher
A fast and efficient CLI tool for calculating SHA256, SHA1, and MD5 hashes of files with progress indication and colored output
-
x12pp
A CLI pretty-printer for X12 EDI files
-
d-rs
stream processing utilities for the command line
-
rlink-connector-kafka
High performance Stream Processing Framework
-
arkflow-plugin
High-performance Rust flow processing engine
-
x12-stream-parser
Low-level, iterator-based X12 EDI stream parser
-
rust-stream-ext-concurrent
Concurrent behavior extensions for any futures::stream::Stream objects
-
fluxus-source-gharchive
A Fluxus source component for processing and analyzing GitHub Archive data streams, providing efficient access to historical GitHub event data
-
tamar
A super fast stream processing framework that somewhat mirrors Apache Flink's streaming primitives and is designed for simplicity
-
parallel_reader
reading from a file (or any
Readstream) and processing it by chunks, in parallel -
streamgen
generating streams of data for testing and benchmarking
-
fluvio-storage
Storage for Fluvio platform
-
fluxus-runtime
Runtime implementation for Fluxus stream processing engine
-
hadron-client
The Hadron Rust client library
-
fluxus-utils
components for Fluxus stream processing engine
-
fluxus-sinks
Sink components for Fluxus stream processing engine
-
lonesha256
Rust bindings for the lonesha256 C library
-
malstrom-kafka
Kafka protocol sources and sinks for the Malstrom stream processing framework
-
fluxus-transformers
Transformer components for Fluxus stream processing engine
-
sgdata
Scattered, gathered, immutable, arc-ed data
-
process-events-streaming
Easy to use process with events and data streaming
-
fluxus-sources
Source components for Fluxus stream processing engine
-
rlink-connector-clickhouse
High performance Stream Processing Framework
-
hamlet
Html token definitions for stream processing
-
rlink-connector-elasticsearch
High performance Stream Processing Framework
-
fluxus-sink-telegram
A Telegram sink component for the Fluxus stream processing framework, enabling real-time message delivery to Telegram channels and chats
-
kapacitor-multi-indicator-stream-udf
A multi-indicator stream UDF for Kapacitor
-
callysto-avro
Avro serde for Callysto Stream Processing Framework
-
dfir_datalog_core
Datalog implementation for DFIR
-
hydroflow_datalog_core
Datalog implementation for Hydroflow
Try searching with DuckDuckGo or on crates.io.