-
tokio
An event-driven, non-blocking I/O platform for writing asynchronous I/O backed applications
-
h2
An HTTP/2 client and server
-
scc
A collection of high-performance asynchronous/concurrent containers with both asynchronous and synchronous interfaces
-
futures
streams featuring zero allocations, composability, and iterator-like interfaces
-
rdkafka
Rust wrapper for librdkafka
-
deadpool
Dead simple async pool
-
tokio-rustls
Asynchronous TLS/SSL streams for Tokio using Rustls
-
lapin
AMQP client library
-
mlua
High level bindings to Lua 5.5/5.4/5.3/5.2/5.1 (including LuaJIT) and Luau with async/await features and support of writing native Lua modules in Rust
-
futures-lite
Futures, streams, and async I/O combinators
-
mio
Lightweight non-blocking I/O
-
futures-timer
Timeouts for futures
-
interprocess
communication toolkit
-
yrs
High performance implementation of the Yjs CRDT
-
pollster
Synchronously block the thread until a future completes
-
blocking
A thread pool for isolating blocking I/O in async programs
-
polling
Portable interface to epoll, kqueue, event ports, and IOCP
-
axum-server
High level server designed to be used with axum framework
-
futures-concurrency
Structured concurrency operations for async Rust
-
tokio-serial
A serial port implementation for tokio
-
tokio-cron-scheduler
Schedule tasks on tokio using cron-like annotation, at an instant or repeat them at a fixed duration. Tasks can optionally be persisted using PostgreSQL or Nats.
-
ractor
A actor framework for Rust
-
tracing-actix-web
Structured logging middleware for actix-web
-
async-compression
Adaptors between compression crates and Rust's modern asynchronous IO types
-
async-openai
OpenAI
-
openraft
Advanced Raft consensus
-
tower-sessions
🥠 Sessions as a
towerandaxummiddleware -
tower-lsp-server
Language Server Protocol implementation based on Tower
-
minus
An asynchronous data feedable terminal paging library for Rust
-
bb8
Full-featured async (tokio-based) connection pool (like r2d2)
-
kameo
Fault-tolerant Async Actors Built on Tokio
-
rxrust
Reactive Extensions
-
io-uring
The low-level
io_uringuserspace interface for Rust -
async-process
Async interface for working with processes
-
gix-packetline-blocking
A duplicate of
gix-packetlinewith theblocking-iofeature pre-selected -
tokio-retry2
Extensible, asynchronous retry behaviors for futures/tokio
-
apalis
extensible and multithreaded background task processing for Rust
-
process-wrap
Wrap a Command, to spawn processes in a group or session or job etc
-
tokio-retry
Extensible, asynchronous retry behaviours for futures/tokio
-
keycloak
Admin REST API
-
remoc
🦑 Remote multiplexed objects, channels, observable collections and RPC making remote interactions seamless. Provides multiple remote channels and RPC over TCP, TLS or any other transport.
-
miow
A zero overhead I/O library for Windows, focusing on IOCP and async I/O abstractions
-
eventsource-stream
A basic building block for building an Eventsource from a Stream of bytes
-
specta
Easily export your Rust types to other languages
-
paho-mqtt
The Official Eclipse Paho MQTT Rust Client Library. This is a wrapper around the Paho C library
-
wfaas
Workflow-as-a-Service engine for managing multi-step operations
-
tor-rtcompat
Compatibility layer for asynchronous runtimes, used by Tor
-
compio
Completion based async runtime
-
pty-process
spawn commands attached to a pty
-
backon
Make retry like a built-in feature provided by Rust
-
async-native-tls
Native TLS using futures
-
idb
A futures based crate for interacting with IndexedDB on browsers using webassembly
-
fang
Background job processing library for Rust
-
futures-buffered
future concurrency primitives with emphasis on performance and low memory usage
-
salvo-serde-util
serde util for salvo
-
thingbuf
I'm at the buffer pool. I'm at the MPSC channel. I'm at the combination MPSC channel and buffer pool.
-
async-task
Task abstraction for building executors
-
capnp-futures
async serialization for Cap'n Proto messages
-
stream-download
streaming content to a local cache
-
tokio-rusqlite
Asynchronous handle for rusqlite library
-
aws-smithy-async
Async runtime agnostic abstractions for smithy-rs
-
tokio-graceful-shutdown
perform a graceful shutdown on a Tokio based service
-
nmrs
NetworkManager over D-Bus
-
dptree
An asynchronous event dispatch mechanism for Rust
-
duroxide
Durable code execution framework for Rust
-
gix-actor
A way to identify git actors
-
magnetar-driver
Apache Pulsar client driver for Rust. Public façade — re-exports the sans-io core plus the selected runtime engine. Imported as
magnetar. -
monoio
A thread per core runtime based on iouring
-
async-broadcast
Async broadcast channels
-
rsmq_async
Async RSMQ port to rust. RSMQ is a simple redis queue system that works in any redis v2.4+. It contains the same methods as the original one in https://github.com/smrchy/rsmq
-
eyeball
Add observability to your Rust types!
-
asynk-strim
Lightweight stream generator library
-
mq-bridge
An asynchronous message bridging library connecting Kafka, MQTT, AMQP, NATS, MongoDB, HTTP, and more
-
tokio-tun
Asynchronous allocation of TUN/TAP devices using tokio
-
claude-agent-sdk-rs
Rust SDK for Claude Code CLI with bidirectional streaming, hooks, custom tools, and plugin support - 100% feature parity with Python SDK
-
adk-tool
Tool system for Rust Agent Development Kit (ADK-Rust) agents (FunctionTool, MCP, Google Search)
-
async-graphql-parser
GraphQL query parser for async-graphql
-
async-shutdown
one-stop solution for async graceful shutdown
-
rustls-connector
Connector similar to openssl or native-tls for rustls
-
ntex-h2
An HTTP/2 client and server
-
containerd-shim
containerd shim extension
-
ipc-queue
FIFO queue described in fortanix-sgx-abi used for asynchronous usercalls
-
poll-promise
Poll the result of an async operation in a game or immediate mode GUI
-
async-lsp
Asynchronous Language Server Protocol (LSP) framework based on tower
-
iroh-docs
Iroh sync
-
peekable
Buffered peek for
Readand async readers (tokio, futures): inspect incoming bytes without consuming them. Useful for protocol detection, length-prefixed framing, and header inspection. -
async_cell
A Cell<Option<T>> that you can await on
-
crb
CRB | Composable Runtime Blocks
-
syslog-rs
A native Rust implementation of the glibc/libc/windows syslog client and windows native log for logging
-
fastcgi-client
Runtime-agnostic Fastcgi client implemented for Rust
-
exponential-backoff
An exponential backoff generator with jitter
-
pharos
Observer pattern which generates a futures 0.3 stream of events
-
tokio-graceful
util for graceful shutdown of tokio applications
-
aqueue
fast speed thread safe async execute queue
-
mio-serial
A serial port implementation for mio
-
actix-rt
Tokio-based single-threaded async runtime for the Actix ecosystem
-
pi-async-rt
Based on future (MVP), a universal asynchronous runtime and tool used to provide a foundation for the outside world
-
tokio-process-tools
Correctness-focused async subprocess orchestration for Tokio: bounded output, multi-consumer streams, output detection, guaranteed cleanup and graceful termination
-
manual_future
A future that must be manually completed, similar to Java's CompletableFuture
-
apalis-redis
Background task processing for rust using apalis and redis
-
rusty_falcon
Rust bindings for CrowdStrike Falcon API
-
ahp
Agent Host Protocol SDK — transport-agnostic client, reducers, and JSON-RPC plumbing
-
trait-variant
working with impl traits in Rust
-
vertigo
Reactive Real-DOM library with SSR for Rust
-
tokio-rate-limit
High-performance, lock-free rate limiting library with pluggable algorithms and Axum middleware
-
rsactor
Efficient In-Process Actor Model Implementation for Rust
-
ruststream
Async messaging framework for Rust: broker-agnostic traits, router, codecs, and a conformance harness for broker authors
-
scoped-futures
imposing upper bounds on Future lifetimes
-
deno_unsync
A collection of adapters to make working with Tokio single-threaded runtimes easier
-
kube-lease-manager
Ergonomic and reliable leader election using Kubernetes Lease API
-
shmipc
Shared memory IPC for Rust
-
tinyagents
A recursive language-model (RLM) harness for Rust
-
switchy_async
Switchy Async runtime package
-
want
Detect when another Future wants a result
-
rust-parallel
Fast command line app in rust/tokio to run commands in parallel. Similar interface to GNU parallel or xargs.
-
async-recursion
Recursion for async functions
-
greentic-runner-host
Host runtime shim for Greentic runner: config, pack loading, activity handling
-
flo_binding
Declarative binding library for Rust
-
graphile_worker
High performance Rust/PostgreSQL job queue (also suitable for getting jobs generated by PostgreSQL triggers/functions out into a different work queue)
-
turnkeeper
An asynchronous, recurring job scheduler for Tokio with support for CRON, interval, and weekday/time schedules, plus retries, cancellation, and observability
-
rocketmq-rust
Unofficial Rust implementation of Apache RocketMQ
-
faucet-source-rest
REST API source connector for the faucet-stream ecosystem
-
hibana
Choreography-derived runtime enforcement kernel for no_std Rust multiparty protocols
-
ntex-io-uring
The low-level
io_uringuserspace interface for Rust -
taskvisor
In-process Tokio task supervisor with retries, graceful shutdown, reliable final outcomes, and per-key admission control
-
futures-signals
Zero cost FRP signals using the futures crate
-
iroh-quinn-udp
UDP sockets with ECN information for the QUIC transport protocol
-
ws_stream_tungstenite
Provide AsyncRead/AsyncWrite over Tungstenite WebSockets
-
lamellar
asynchronous tasking runtime for HPC systems developed in RUST
-
tor-rpcbase
Low level functionality for Arti's RPC service
-
job-orchestrator
Asynchronous job orchestrator for managing and routing payloads between services and computing resources with quota tracking
-
opencode_rs
Rust SDK for OpenCode (HTTP-first hybrid with SSE streaming)
-
libublk
building linux block device in userspace
-
rivetkit-client-protocol
Client protocol types for RivetKit
-
async-scoped
Spawn scoped (non 'static) asynchronous futures for async_std and tokio runtimes
-
kompact
Kompics component model combined with the Actor model
-
stackfuture
wrapper around futures that stores the wrapped future in space provided by the caller
-
s3util-rs
Tools for managing Amazon S3 objects and buckets
-
zookeeper-client
ZooKeeper async client
-
crosstown_bus
Event Bus with RabbitMQ for Rust
-
tokio-io-timeout
Tokio wrappers which apply timeouts to IO operations
-
kcpserver
fast kcp server frame
-
tigerbeetle-unofficial
Safe high level async bindings to tigerbeetle client library
-
rho-sdk
Embeddable, headless agent runtime for Rho
-
claude-code-agent-sdk
Rust SDK for Claude Code CLI with bidirectional streaming, hooks, custom tools, and plugin support
-
gix-mailmap
gitoxide project for parsing mailmap files
-
uni-xervo
Unified Rust runtime for local and remote embedding (dense, learned-sparse, multi-vector), reranking, generation, NLP, OCR, document extraction, and transcription
-
shove
Async tasks via pubsub on steroids. Comes with built-in support for complex queue configurations, audit logs, autoscaling consumer groups and more.
-
aisdk
An open-source Rust library for building AI-powered applications, inspired by the Vercel AI SDK. It provides a robust, type-safe, and easy-to-use interface for interacting with various Large Language Models (LLMs).
-
async_cache
Async refresh cache
-
ai-agents-state
State machine for AI Agents framework
-
safina
Safe async runtime
-
cxx-async
interoperability between C++ coroutines and asynchronous Rust
-
async-executor
Async executor
-
async_singleflight
Async singleflight
-
net-mesh
High-performance, schema-agnostic, backend-agnostic event bus
-
adk-runner
Agent execution runtime for Rust Agent Development Kit (ADK-Rust) agents
-
nadis
NASA Redis 基础层(client/commands/pipeline/lock;兼容 RedisProxy 五件套)
-
samsa
Rust-native Kafka/Redpanda protocol and client implementation
-
kafka
Rust client for Apache Kafka
-
prism-mcp-rs
Dual-era Rust SDK for stateless MCP 2026 and interoperable MCP 2025 clients and servers
-
upc
USB packet channel (UPC): provides a reliable, packet-based transport over USB
-
asynchronous-codec
encoding and decoding frames using
async/await -
pinky-swear
Futures and async/await-ready Promises
-
actify
An intuitive actor model with minimal boilerplate
-
submap
B-Tree map for pub/sub services
-
oxios
Agent OS — Agent Operating System powered by oxicode-sdk
-
persway-tokio
Sway layout and focus helper daemon that adds spiral and stack-main autotiling plus opacity and window renaming
-
fundamentum-edge-daemon
The supported way to access Fundamentum's ecosystem from linux devices
-
peace
zero stress automation
-
unicycle
A scheduler for driving a large number of futures
-
rocketmq-runtime
Unofficial Rust implementation of Apache RocketMQ
-
agentledger-runtime
Runtime reliability layer for Agent Harness stacks
-
google-plusdomains1
A complete library to interact with plusDomains (protocol v1)
-
tinyplace
Rust SDK for agents to interact with tiny.place — the agent-to-agent social network
-
magi-core
LLM-agnostic multi-perspective analysis system inspired by MAGI
-
oly
Run interactive CLIs and AI agents like managed services with persistent PTY sessions
-
tracing-otel-extra
Bootstrap utilities for tracing and OpenTelemetry integration
-
gql_client
Minimal GraphQL client for Rust
-
openrouter_api
client library for the OpenRouter API
-
async-walkdir
Asynchronous directory traversal for Rust
-
triggered
Triggers for one time events between tasks and threads
-
async-flow
Async abstractions for flow-based programming (FBP)
-
tower-fallback
A Tower service combinator that sends requests to a first service, then retries processing on a second fallback service if the first service errors
-
futuresdr
An Experimental Async SDR Runtime for Heterogeneous Architectures
-
tokio-io-utility
Some helper functions for tokio::io
-
agent_oxide
Agent Oxide — a modular agent framework for Rust (ReAct engine, LLM providers, tools, sandbox, persistence, skills, NOOA ergonomics)
-
better-logger
Flexible sync/async logger with console, file, and HTTP output
-
async-openai-compat
OpenAI
-
uds-fork
A unix domain socket crate that supports abstract addresses, fd-passing, seqpacket and windows unix stream sockets
-
go-lib
rust native goroutines
-
backhopper-cli
Command-line interface for backhopper
-
qml-rs
QML background job processing
-
synchronized-writer
A tiny implement for synchronously writing data
-
futures-util
Common utilities and extension traits for the futures-rs library
-
keyring-lib
High-level, asynchronous API for keyring-rs, a cross-platform Rust library to manage credentials
-
mako-engine
Event-sourced process engine for German energy market communication (MaKo)
-
wg
Golang like WaitGroup implementation for sync/async Rust
-
kestrel-timer
High-performance async timer library based on Hierarchical Timing Wheel algorithm
-
executor-core
A zero-cost task executor abstraction layer for Rust async runtimes
-
afast
A high-performance web backend framework for Rust. Auto generate client code (js, ts, kt, rs).
-
genai-rs
client library for Google's Generative AI (Gemini) API with streaming, function calling, and multi-turn conversations
-
ringline
Async I/O runtime with io_uring (Linux) and mio (cross-platform) backends
-
adaptive-timeout
Adaptive timeout computation based on observed latency percentiles
-
llm-kernel
Foundation library for Rust AI-native apps — provider catalog, LLM client, MCP server, search, telemetry, and safety
-
faucet-sink-csv
CSV file sink connector for the faucet-stream ecosystem
-
nvoken
Rust SDK for the nvoken durable agent runtime
-
containerd-client
GRPC bindings to containerd APIs
-
signal-hook-tokio
Tokio support for signal-hook
-
rust-tokio-supervisor
tokio supervisor with declarative task supervision, restart policy, shutdown coordination, and observability
-
harness-rs-tools-browser
Interactive headless-browser tool (browser) for harness-rs agents — a persistent Chrome DevTools Protocol session that can click, type, select, scroll and wait, returns an accessibility-style…
-
greentic-session
Greentic multi-tenant session manager with in-memory and Redis backends
-
mml-lib
Emacs MIME message Meta Language (MML)
-
rustpython-ruff_python_parser
Unofficial fork for RustPython
-
agentx-adk-core
Core traits and types for Rust Agent Development Kit (ADK-Rust) agents, tools, sessions, and events
-
axum-extra
Extra utilities for axum
-
lashlang
compact CodeAct language for model-authored REPL blocks in the lash agent runtime
-
celers-metrics
Prometheus metrics and observability for CeleRS
-
motosan-agent-loop
Standalone ReAct agent loop — LlmClient + Engine with no platform dependencies
-
iii-sdk
SDK for III Engine - a platform for building distributed applications
-
workflow-graph-queue
Queue traits, in-memory backends, and DAG scheduler for workflow-graph
-
pingora-timeout
Highly efficient async timer and timeout system for Tokio runtimes
-
agnostic
abstraction layer for any async runtime
-
csm-rs
Async Rust client for the HPE Cray Shasta CSM (Cray System Management) API
-
hannibal
A small actor library
-
bat-markets
Futures-first headless Rust exchange engine with honest Binance/Bybit/MEXC linear futures support
-
adk-core
Core traits and types for Rust Agent Development Kit (ADK-Rust) agents, tools, sessions, and events
-
spawns
Async runtime agnostic thread context task spawner for Rust
-
kdbplus
Dual q/kdb+ interface for API to build a shared library and an IPC client
-
qubit-retry
Retry module, providing a feature-complete, type-safe retry management system with support for multiple delay strategies and event listeners
-
camel-component-cxf
CXF/SOAP component for rust-camel via Java bridge
-
acktor
Pure-Rust actor framework built on top of the Tokio async runtime
-
jerrycan-jobs
Background job engine for the jerrycan framework: at-least-once queues, retries + dead-letter, cron, run_at, over a Postgres store. https://jerrycan.cc
-
runtara-core
Core execution engine for runtara - manages instances, checkpoints, signals, and durable sleep
-
busybody
Service Container and Dependency injector crate
-
apis
Reactive, session-oriented, asynchronous process-calculus framework
-
axum-limit
Production-oriented rate limiting for Axum via extractors, with pluggable algorithms, storage backends, and dynamic quotas
-
filebuffer
Fast and simple file reading
-
stateforward-hsm
A hierarchical state machine runtime for Rust
-
gcs-rsync
rsync support for gcs with higher perf than gsutil rsync
-
tokio-stream
work with
Streamandtokio -
genawaiter
Stackless generators on stable Rust
-
voip-ms
Async client for the VoIP.ms REST API
-
apalis-sqlite
Background task processing for rust using apalis and sqlite
-
theseus-mlua
High level bindings to Lua 5.4/5.3/5.2/5.1 (including LuaJIT) and Luau with async/await features and support of writing native Lua modules in Rust. Fork with added Factorio Lua support
-
zai-rs
Type-safe async Rust SDK for Zhipu AI (BigModel) APIs
-
takanawa-http
Tokio and reqwest HTTP range downloader for Takanawa
-
gardal
A WIP performance-focused token-bucket rate limiting and throttling library
-
ginepro
A client-side gRPC channel implementation for tonic
-
bytes-handoff
Incremental async byte ingestion and bounded owned write handoff
-
agents
Facade crate for building typed Rust agents
-
wontopos
— long-term memory for AI agents. Pure semantic retrieval, identical recall in every language, ~100× lower LLM bill.
-
next-gen
Safe generators on stable Rust
-
ya-gcp
APIs for using Google Cloud Platform services
-
mm1-address
An Erlang-style actor runtime for Rust
-
async-io
Async I/O and timers
-
some_executor
A trait for libraries that abstract over any executor
-
vcs-git
Automate Git from Rust: a typed, async wrapper that drives the real git CLI with its exact behavior, config, and credentials
-
cc-sdk
Rust SDK for Claude Code CLI with full interactive capabilities
-
agy-bridge
Async Rust bridge and native runtime for the Google Antigravity SDK
-
xio-rs
A nonblocking IO dispatcher, FS change notifications, async data processing
-
aggligator
Aggregates multiple links (TCP or similar) into one connection having their combined bandwidth and provides resiliency against failure of individual links
-
rl-core
Core logic for a token-bucket rate-limiter
-
procmachines
State machines in the procedural style
-
certsd
automated, asynchronous LE certificate issuer
-
apcore
Build once, invoke by code or AI — with schema, ACL, approval, and audit enforced at every call
-
wp-core-connectors
Core connector registry and sink runtimes for WarpParse
-
partial-io
Helpers to test partial, interrupted and would-block I/O operations, with support for property-based testing through proptest and quickcheck
-
mlb-api
Endpoints for MLB's public Statcast API
-
stakker
A lightweight low-level single-threaded actor runtime
-
ractor_actors
actors built with Ractor
-
tokio-task-pool
Task pool for Tokio Runtime
-
mobc
A generic connection pool with async/await support
-
obzenflow-fsm
Async-first Finite State Machine library inspired by Akka (Classic) FSM
-
tipsy
Cross-platform IPC for Tokio
-
fvm_actor_utils
Utils for authoring native actors for the Filecoin Virtual Machine
-
dagx
A minimal, type-safe, runtime-agnostic async DAG (Directed Acyclic Graph) executor with compile-time cycle prevention and true parallel execution
-
cmd-proc
Process command builder with capture support
-
horsie-actor
Event-sourced actor runtime with durable journaling
-
lsp-server-tokio
An async-first LSP server infrastructure crate using Tokio
-
events
Async manual-reset and auto-reset event primitives
-
edge-ws
Async +
no_std+ no-alloc implementation of the Websockets protocol -
swiftide-docker-executor
A docker executor for swiftide agent tools
-
rust-tg-bot-raw
Pure Telegram Bot API types and methods for Rust -- a faithful port of python-telegram-bot's core layer
-
litchee
Async, builder-pattern Rust client for the Lichess API: full endpoint coverage, NDJSON streaming, and OAuth2 PKCE ('Log in with Lichess')
-
budget-warden
Policy-based protection for scarce external API budgets
-
blockstore
An IPLD blockstore capable of holding arbitrary data indexed by CID
-
tirea-extension-permission
Tool-level permission policies and user-approval gating for tirea agents
-
ghost_actor
GhostActor makes it simple, ergonomic, and idiomatic to implement async / concurrent code using an Actor model
-
postmodern
Postgres-backed job queue with transaction-based locking
-
rrq-runner
RRQ runner runtime for Rust
-
tokio-zookeeper
Asynchronous client library for interacting with Apache ZooKeeper
-
windmark
An elegant and highly performant async Gemini server framework
-
parallax-pipeline
Parallax: a Rust-native streaming pipeline engine with zero-copy multi-process support
-
tokio-muxt
Timer for a limited set of events that multiplexes over a single tokio Sleep instance
-
async-openai-thinking
Fork of async-openai 0.41.3 adding reasoning_content (thinking tokens) to chat completion responses/deltas (DeepSeek, Qwen, etc.)
-
asyncapi-rust
AsyncAPI 3.0 specification generation for Rust WebSockets and async protocols
-
proc-daemon
High-performance async daemon framework for Rust services: cross-platform signal handling, graceful shutdown, subsystem lifecycle management, hot-reload config, and structured logging. Tokio-first.
-
web-task
The simplest way to run async tasks on the web
-
tokio-smoltcp
An asynchronous wrapper for smoltcp
-
future-queue
Adapters to manage a queue of futures, where each future can have a different weight
-
trusty-agents-common
Stable agent-plugin surface (ToolExecutor, AgentPlugin, ToolResult) shared by trusty-agents and external agent crates
-
govee
Async Rust library for controlling Govee smart lighting devices via cloud and local LAN APIs
-
task-local
storage for asynchronous tasks
-
futures-bounded
bounding futures in size and time
-
rigtest
Runtime library for the cargo-rigtest test framework
-
dynify
Add dyn compatible variant to your async trait
-
llm-kit-provider
Provider interface and traits for the LLM Kit - defines the contract for implementing AI model providers
-
activitystreams-vocabulary
ActivityStreams 2.0 Vocabulary data structures
-
product-os-async-executor
Product OS : Async Executor provides a set of tools to handle async execution generically so that the desired async library (e.g. tokio, smol) to be used can be chosen at compile time.
-
tower-resilience-circuitbreaker
A circuit breaker middleware for Tower services
-
mikrotik-rs
Asynchronous Rust library for interfacing with MikroTik routers
-
elegant-departure
simplify graceful shutdown
-
agent-works
Batteries-included Agent toolbox built on agent-base
-
qbice
The Query-Based Incremental Computation Engine
-
kicad-ipc-rs
Rust client library for the KiCad IPC API (async-first)
-
mailfred
Process emails as an HTTP server
-
timer-lib
A feature-rich Rust library for creating and managing timers
-
liteq
High-performance job queue library for Rust using Redis with auto-retry, connection pooling, async handlers, and multi-consumer fair distribution
-
task-killswitch
Abort all tokio tasks at once
-
fluvio-future
I/O futures for Fluvio project
-
stateset-jobs
Background job scheduler for StateSet iCommerce — cron, interval, and event-driven job execution with retry and backoff
-
jaeb
snapshot-driven event bus
-
tower-lsp-f
Language Server Protocol implementation based on Tower
-
runledger-tui
Read-only terminal UI for monitoring Runledger jobs and workflows
-
bubbletea-rs
The fun, functional, and stateful way to build terminal apps in Rust
-
relaycast
Rust SDK for RelayCast - multi-agent coordination platform
-
rust-elm
Elm Architecture for Rust: composable reducers, pure effects, async runtime
-
async-dropper
The least-worst ad-hoc implementation of AsyncDrop as a Derive macro
-
wavelet
High-performance graph-based stream processing runtime
-
firmware-controller
Controller (actor) macro to decouple interactions between components, supporting both embassy (no_std) and tokio (std) backends
-
mq-bridge-app
A message queue bridge application written in Rust, designed to connect different messaging systems like RabbitMQ, Kafka, and NATS
-
rust-multipart-rfc7578_2
multipart/form-data (RFC7578)
-
async-event
An efficient async condition variable for lock-free algorithms
-
ri-agent-graph
Run 9 agents at once — graph-based agent orchestration for Rust with parallel fan-out (up to 16 nodes), fan-in joins, checkpointing, interrupt/resume, and event streaming
-
gitr
Async typed git CLI wrapper for agents and automation
-
kumo
An async web crawling framework for Rust - Scrapy for Rust
-
axocoatl-cli
Command-line interface for the Axocoatl agentic AI framework
-
afaster
High-performance Rust backend framework template with 25+ built-in business modules (WeChat ecosystem, OAuth2, push notifications, storage, payments, etc.). 🚀
-
async-ringbuf
Async SPSC FIFO ring buffer
-
yoagent-state
Durable state and lineage for long-running agents
-
es-replay
Event Sourcing and CQRS library with WASM support
-
manager_handlers
A microservice manager implementation that creates HTTP-accessible handlers with configurable replicas. Handlers communicate via an internal bus, enabling collaborative request processing in a distributed architecture.
-
telnyx
Async Rust SDK for the Telnyx API — messaging, voice / Call Control, phone numbers, SIP trunking, and Ed25519 webhook verification
-
postage
An async channel library
-
discro
DISCRete Observables for asynchronous Functional Reactive Programming (FRP)
-
agentsdk
A lean, OpenAI-compatible AI SDK for Rust
-
mio-aio
POSIX AIO bindings for mio
-
futures-batch
An adaptor that chunks up elements and flushes them after a timeout or when the buffer is full. (Formerly known as tokio-batch.)
-
service-daemon
A declarative Rust framework for automatic service management, event-driven triggers, and compile-time dependency injection
-
nmp-core
NMP kernel substrate: actor runtime, state, capabilities, action registry, snapshots, and protocol extension seams
-
slop-futures
Async and concurrent execution utilities for SLOP
-
ps-promise
Promise-like owned futures
-
mpi-sys
Message Passing Interface bindings for Rust
-
serviceless
actor model in rust, like actix
-
tmq
ZeroMQ bindings for Tokio
-
nagisa
Rust 的 QQ 机器人框架,支持 OneBot v11 和 Milky
-
bombay-behavior
Pure, statically typed actor behavior primitives
-
agentwerk
A minimal Rust crate that gives any application agentic capabilities
-
hackrf-nusb
Rust-native half-duplex HackRF driver built on nusb
-
openrouter2
Typed async and blocking reqwest clients for the OpenRouter API
-
bkash-rs
Idiomatic async-first Rust client for the bKash Payment Gateway API
-
agent-harness-rs
Agent loop harness with local and sandbox tool runtimes, context management, and MCP support
-
sdre-stubborn-io
Forked from https://github.com/craftytrickster/stubborn-io. io traits/structs that automatically recover from potential disconnections/interruptions.
-
codex-helper
A Rust-based local helper / proxy for Codex CLI traffic with multi-provider routing, usage-aware switching, filtering, and session helpers
-
atman-daemon
atman headless daemon — Unix socket + HTTP SSE server for the atman AI coding agent
-
gyre
A lock-free asynchronous ring buffer inspired by the LMAX Disruptor
-
razorpay-api
An async, typed Rust client for the Razorpay payments API
-
murmer
A distributed actor framework for Rust
-
compio-runtime
High-level runtime for compio
-
libsync
Synchronise stuff
-
aws_utils_sqs
AWS SQS utilities for Rust
-
claude-api
Type-safe Rust client for the Anthropic API
-
aion-worker
Rust remote-worker SDK for executing Aion activities over the gRPC worker protocol
-
timeweb-rs
Async Rust SDK for the Timeweb Cloud API
-
aimdb-tokio-adapter
Tokio runtime adapter for AimDB - full-featured std async runtime support
-
future_form
Abstractions over Send and !Send futures
-
stigmer-runner-host
Embed the Stigmer runner as a manager-mode subprocess over its stdin/stdout JSON IPC
-
rzmq
High performance, CPU and memory efficient, fully asynchronous, safe pure-Rust implementation of ZeroMQ (ØMQ) messaging with io_uring and TCP Cork acceleration on Linux
-
idiolect-indexer
Firehose consumer for dev.idiolect.* records, built on top of tapped. Decodes commits into AnyRecord and dispatches them through a RecordHandler.
-
disintegrate
build event-sourced applications
-
aoc_leaderbot_lib
Support library for aoc_leaderbot, an Advent of Code leaderboard-watching bot
-
coclai
Ergonomic Rust wrapper for codex app-server with runtime safety and release gates
-
leptos-next-metadata
Next.js-style metadata management for Leptos v0.8+ with type-safe APIs, blazing-fast OG image generation, and AI-assisted development. Part of the Cloud Shuttle ecosystem.
-
rust-okx
Async Rust client for the OKX v5 REST API
-
s3tui
TUI application for multiple s3 account operations
-
ads_client
An asynchronous, non-blocking ADS client
-
pool-mod
Generic object and connection pooling. Async-safe with min/max sizing, idle timeouts, max-lifetime enforcement, validation-on-borrow, and health-check callbacks. Works for database connections…
-
atomr-agents-retriever
Retriever zoo: Vector, BM25, MultiQuery, ContextualCompression, ParentDocument, Ensemble-RRF, SelfQuery, EmbeddingsFilter, TimeWeighted
-
ic-timers
Observable and recovery-aware timers for Internet Computer canisters
-
enki-next
Enki's Rust agent runtime, workflow engine, and shared core abstractions
-
a3s-lane
Lane-based priority command queue for async task scheduling with reliability, scalability, and observability features
-
tcrm-monitor
Task dependency management and execution library with parallel processing, real-time monitoring, and runtime control
-
pipex
A powerful functional pipeline macro for Rust combining sync, async, parallel, and streaming operations with extensible error handling
-
worterbuch
A message broker / database hybrid
-
service-async
A Service like tower in async style
-
ag-ui-rs
Server-side Rust primitives for the AG-UI protocol
-
ave-actors-actor
Ave actor model
-
async-graphql-actix-web
async-graphql for actix-web
-
ate
Distributed immutable data store with strong encryption and authentication
-
keri-core
Core library for the Key Event Receipt Infrastructure
-
connection-pool
A high-performance, generic async connection pool for Rust with background cleanup and comprehensive logging
-
auto-di
Ergonomic async-aware automatic dependency injection for Rust
-
kube-coordinate
Kubernetes leader election using the coordination.k8s.io API
-
gmf
A runtime-agnostic, high-performance gRPC server framework using thread-per-core architecture
-
yazi-macro
Yazi macros
-
kameo_actors
actors for kameo
-
google-places-api
Unofficial Google Places API for rust
-
telers
An asynchronous framework for Telegram Bot API written in Rust
-
rig-compose
Composable agent kernel: stateless skills, transport-agnostic tools, registry-driven agents, signal-routing coordinator. Companion crate for rig.
-
strides
Async-first terminal UI spinners and progress bars
-
kathputli
Minimal typed-mailbox actor framework over Tokio — actors respond to messages like puppets to strings
-
reactio
Low-Latency Event Driven Nonblocking Reactor Pattern
-
mini_exercism
Minimalistic Rust library to interact with the Exercism.org APIs
-
gmqtt-client
MQTTv5 client
-
ferro-queue
Background job queue system for Ferro framework
-
spider_agent
A concurrent-safe multimodal agent for web automation and research
-
tsoracle-paxos-toolkit
Reusable OmniPaxos glue: RocksDB storage, lifecycle helpers, test fakes
-
futures-locks
Futures-aware lock primitives
-
outl-ws
Workspace bootstrap for embedders: open a workspace directory with locks, actor resolution, and per-page shard registration
-
stof
Data Runtime. JSON that runs.
-
patharg
Treat "-" (hyphen/dash) arguments as stdin/stdout
-
dataloader
Facebook's DataLoader using async-await
-
bob-adapters
Adapter implementations for Bob Agent Framework ports
-
cf-gears-event-broker
Event Broker: Ingest/Delivery/Dispatcher composite module (deployment-topology skeleton)
-
futures-signals-ext
Extension to futures-signals: MutableOption with combinators, spawning, predicate driven selections from SignalVec
-
enact-core
Core agent runtime for Enact - Graph-Native AI agents
-
async_py
calling Python code asynchronously using pyo3 or rustpython
-
frankenlab
Deterministic testing harness for async Rust: record, replay, and minimize concurrency bugs
-
futures-rx
Rx implementations for the futures crate
-
rinf-router
Router and handler framework for RINF-based Flutter <> Rust apps
-
blackbox-recorder
Local flight recorder and debugger for AI-agent runs: PTY capture, SQLite traces, redacted export
-
supervised
Typed supervision for long-lived Tokio services
-
phi-core
effective agent loop with tool execution and event streaming
-
anyspawn
A generic task spawner compatible with any async runtime
-
boxxkite-client
Rust client for a hosted boxxkite control-plane (sandboxes, exec, files, audit log, human takeover)
-
camel-component-seda
SEDA component for rust-camel (asynchronous in-memory staging)
-
activitystreams
A set of core types and traits for activitystreams data
-
execution-policy
Closure-first, runtime-light reliability policies (retry, timeout, circuit breaking, bounded concurrency, retry budgets) for any async Rust operation
-
async-cuda
Async CUDA for Rust
-
akribes-sdk
Rust client SDK for the Akribes workflow server
-
workflow-graph-server
Embeddable Axum API server for workflow-graph
-
futures-rustls
Asynchronous TLS/SSL streams for futures using Rustls
-
oxide_core
Rust engine primitives for Oxide (store, snapshot streams, error model, optional persistence)
-
call-agent
A multimodal chat API library with tool support, OpenAI API compatible
-
rdma-io
Safe async Rust bindings for RDMA programming over libibverbs and librdmacm
-
niblits
Token-aware, multi-format text chunking library with language-aware semantic splitting
-
otherone-agent
Agent 循环驱动 — 核心 Agent 主循环，支持流式和非流式响应
-
solti-exec
Execution backends and host process controls for the Solti SDK
-
rskit-messaging
Message broker abstractions, registry, middleware, and in-memory adapter
-
servo-devtools
A component of the servo web-engine
-
native_messaging
Cross-platform Rust native messaging host for browser extensions (Chrome & Firefox), with async helpers and manifest installer
-
rxr
Reactive extensions for event-driven applications
-
tasklet
An asynchronous task scheduling library
-
adk-skill
AgentSkills parser, index, and runtime injection helpers for ADK-Rust
-
tower-sessions-ext
A maintained fork of tower-sessions-ext, providing session middleware for tower and axum
-
rdkafka-sys
Native bindings to the librdkafka library
-
flourish
Convenient and full-featured signals for Rust
-
camunda-orchestration-sdk
Ergonomic Rust SDK for the Camunda 8 Orchestration Cluster REST API
-
strev
Event-driven pub/sub messaging library with compile-time ack safety
-
calimero-utils-actix
Core Calimero infrastructure and tools
-
hermesmq
Raft-replicated message queue with priority, rate limiting, and push/pull delivery
-
cloud_terrastodon_azure_resource_types
Generated enum for Azure resource types for use in the Cloud Terrastodon project
-
rustfs-kafka-async
Async Kafka client built on tokio
-
chromist
Rust browser automation via the Chrome DevTools Protocol
-
osd-core
OpenSequenceDiagrams core - A sequence diagram parser and SVG renderer
-
mercs2_vehicle
Mercenaries 2 reimpl — vehicle actors + custom raycast drive model + command-ring transport + camera modes. Exe is the oracle (docs/reverse_engineer/vehicle_code_map.md).
-
async-usercalls
An interface for asynchronous usercalls in SGX enclaves. This is an SGX-only crate, you should compile it with the
x86_64-fortanix-unknown-sgxtarget -
futures-byteorder
A modern async byteorder library for the smol/futures-lite ecosystem
-
futures-executor
Executors for asynchronous tasks based on the futures-rs library
-
alpaca-trade
Rust client for the Alpaca Trading HTTP API
-
tools_interface
Abstractions of serveral Wikipedia/Wikimedia/Wikidata-related tools
-
tokio-pipe
Asynchronous pipe(2) library using tokio
-
transform-stream
Lightweight async stream wrapper
-
clockworker
A single-threaded async executor with EEVDF-based fair scheduling and pluggable task schedulers
-
aimds-response
Adaptive response layer with meta-learning for AIMDS threat mitigation
-
phi-tools
General-purpose Agent toolset — local shell, file operations, and browser automation
-
j4rs
j4rs stands for 'Java for Rust' and allows effortless calls to Java code, from Rust
-
oneringbuf
A lock-free single-producer, single-consumer (SPSC) ring buffer with in-place mutability, asynchronous support, and virtual memory optimisation
-
actix
Actor framework for Rust
-
atomr-agents-skill
Skills: bundled instruction+tool+sub-agent capabilities
-
rustix-uring
The low-level
io_uringuserspace interface for Rust -
lash-runtime
Durable agent runtime for Rust: sessions, turns, tools, plugins. Embeddable facade over lash-core.
-
future_deque
Deque collections for managing groups of futures
-
shivya-mind
Bit-packed VSA (MAP-B) memory engine with power-law decay and surprise-driven episodic segmentation
-
fq
A fast and simple ring-buffer-based single-producer, single-consumer queue with no dependencies. You can use this to write Rust programs with low-latency message passing.
-
ryu-realtime
Room-keyed realtime fan-out primitive for Ryu: a transport-agnostic RoomRegistry mapping room_id -> a per-room tokio actor that owns isolated ephemeral state (presence map + idle clock)…
-
interlink-mcp
Cryptographically-authenticated, cross-machine agent-to-agent chat for Claude Code, over MCP
-
async_executors
Implements Spawn, SpawnLocal and SpawnHandle for commonly used executors
-
dark-std
asynchronous containers build on tokio. It uses a read-write separation design borrowed from Golang
-
elizaos-plugin-cron
elizaOS Cron Plugin - scheduled job management
-
cel-context
Portable context snapshots for AI agents. Normalize any stream into reusable elements and point-in-time snapshots.
-
edgee
Rust SDK for the Edgee AI Gateway
-
shared_http_body
creating shareable HTTP bodies that can be cloned and consumed by multiple consumers
-
reactor-trait
A collection of traits to define a common interface across reactors
-
tokio-events
A modern, type-safe async event bus for Rust applications
-
containerd-shim-protos
TTRPC bindings for containerd shim interfaces
-
pravah
Typed, stepwise agentic information flows for Rust
-
mcmc-rs
Minimal rust client for memcached
-
aether-lang
A general-purpose, dynamically typed programming language with automatic memory management
-
est
Extensions for the rust Standard library and Tokio
-
ferric-fred
A strongly-typed async Rust client for the FRED (Federal Reserve Economic Data) API
-
aion-integration-acp
The first-party Agent Client Protocol (ACP) adapter for Aion: implements the aion-integrations AgentHarness trait against any ACP agent subprocess over newline-delimited JSON-RPC 2.0 stdio
-
evno
A high-performance event bus for asynchronous tasks and event-driven systems
-
async-rx
functions for async reactive programming
-
events_once
Efficient oneshot events (channels) with support for single-threaded events, object embedding, event pools and event lakes
-
cacheable
两级缓存门面(L1 moka + L2 Redis 三防 + #[cached]/#[cache_invalidate])
-
wiremocket
Websocket mocking to test Rust applications
-
tor-rtmock
Testing mock support for tor-rtcomapt
-
linemux
providing asynchronous, multiplexed tailing for (namely log) files
-
tros
Your tros from tarantool TX thread to tokio(..and others!)
-
cellos-cortex
Bridge between CellOS execution cells and the Cortex doctrine layer — DoctrineAuthorityPolicy, CortexCellRunner, CellosLedgerEmitter
-
ollama-oxide
integrating with Ollama's native API, providing low-level inference and high-level conveniences
-
greyhound-bus
Broadcast bus for Rust: fire-and-forget, partitioned, replay-from-cursor, and acknowledged delivery in one crate
-
delite-core
The sqlite of durable agent execution — crash-recoverable AI agents with exactly-once semantics. Zero dependencies.
-
tachyonix
A very fast asynchronous, multi-producer, single-consumer bounded channel
-
lsp-max-lsif
LSIF export and conformance for lsp-max
-
wechat-minapp
微信小程序和服务号服务端API SDK
-
gem-rs
that serves as a wrapper around the Google Gemini API, providing support for streaming
-
folk-plugin-grpc
gRPC plugin for Folk — unary server + client (call upstreams from PHP) via tonic
-
reqsign-http-send-reqwest
Reqwest-based HTTP client implementation for reqsign
-
langshell
Rust SDK for building stateful, capability-scoped LangShell runtimes
-
cs2-gsi
Counter-Strike 2 Game State Integration listener — receive game state pushes, emit typed events
-
systemdaemon
System daemon building blocks. Designed for but not limited to systemd.
-
everruns-provider
Provider/LLM abstraction foundation shared by Everruns core and provider crates
-
completion_stage
Push-based futures for Rust similar to Java's CompletionStage
-
c-ares-resolver
An asynchronous DNS resolver, backed by c-ares
-
test_executors
async executors for testing
-
rspl
A stream processor language
-
async-sleep
Async Sleep
-
tokio-hrtime
Hires timers for tokio
-
async-notify
A general version async Notify, like
tokioNotify but can work with any async runtime -
shape-ext-python
Shape Python language runtime extension
-
openraft-surrealkv
key-value store built on top of OpenRaft, designed for learning and experimentation with Raft consensus algorithm
-
mlua-flow-ir
flow.ir async runtime + mlua binding — re-exports flow-ir-core (Pure Rust sync core) and adds AsyncDispatcher + eval_async + Lua module
-
conogram
An async wrapper for Telegram Bot API
-
memory_stash
In-memory cache with policies
-
twilight-http-ratelimiting
Discord REST API ratelimiter implementations for the Twilight ecosystem
-
gloo-worker
Convenience crate for working with Web Workers
-
monzo-lib
async Monzo client in pure rust
-
maybe-once
A singleton. Maybe.
-
faucet-auth
Shared, single-flight authentication providers (OAuth2, token-endpoint) for faucet-stream connectors
-
terrier
Tenacious async retries for Rust: bounded backoff with decorrelated jitter until it succeeds or the budget says stop
-
feder-runtime-server
Runnable server runtime for Feder on standard operating systems
-
delay_timer
Time-manager of delayed tasks. Like crontab, but synchronous asynchronous tasks are possible, and dynamic add/cancel/remove is supported.
-
lockable
offers hash map, hash set and cache data structures where individual entries can be locked
-
pubnub
SDK for Rust
-
ahp-ws
WebSocket transport adapter for the Agent Host Protocol SDK
-
tokio-tasks
Task management for tokio
-
zizq
Official Rust Client for the Zizq Job Queue
-
crossflow
Reactive programming and workflow engine in bevy
-
async-global-executor
A global executor built on top of async-executor and async-io
-
lunarbase-pmm-v2-client
Network-independent LunarBase reducer and realtime client runtime
-
with-async-context
managing contextual data across async tasks
-
asynq
reliable & efficient distributed task queue in Rust, inspired by hibiken/asynq
-
twilight-standby
filter wait for filtered incoming events for the Twilight ecosystem
-
mkv-element
A Matroska/WebM element reader and writer
-
branchforge
Graph-first Rust runtime for durable LLM agents
-
tokio-memq
high-performance in-memory async message queue
-
axum-apcore
Axum integration for the apcore AI-Perceivable Core ecosystem
-
async-ffi
FFI-compatible
Futures -
ferro-blob-store
Async content-addressed blob-store trait + in-memory and filesystem backends. Foundation crate for ferro-oci-server, ferro-maven-layout, ferro-cargo-registry-server.
-
actor12
A lightweight actor framework for Rust with async support
-
plexor-core
Core library for the rust implementation of the Plexo distributed system architecture, providing the fundamental Plexus, Neuron, Codec, and Axon abstractions
-
lmrc-docker
Docker client library for the LMRC Stack - ergonomic fluent APIs for containers, images, networks, volumes, and registry management
-
aselect
Opinionated replacement for tokio::select!, avoiding certain pitfalls
-
kafko
In-process log with Kafka-like semantics: topics, partitions, offset-based reads, replay, retention
-
cortexai-crew
Multi-agent crew orchestration for Cortex: parallel execution, delegation and coordination
-
fin-stream
Real-time market data streaming primitives — 100K+ ticks/second ingestion pipeline
-
a3s-boot
Adapter-first modular Rust web framework for A3S inspired by Nest.js
-
tokio-go
Run async closures on reusable profile-dedicated Tokio runtimes
-
some_global_executor
Reference thread-per-core executor for the some_executor crate
-
ckanaction
featuring an API wrapper of the CKAN Action v3 API
-
rocketmq-remoting
Apache rocketmq remoting
-
fossic
Event-sourced substrate for the Lattica local-first tooling ecosystem. Consumers emit events to per-project stores; a central hub aggregates them for unified observability. Optional at the individual-consumer level…
-
oxicode-ai
Unified LLM API — multi-provider streaming interface for AI coding assistants
-
room-cli
Multi-user chat room for agent/human coordination over Unix domain sockets
-
dbuff
Double-buffered state with async command chains, streaming, and keyed task pools for ratatui applications
-
rust-tg-bot-ext
Application framework for Telegram bots -- handlers, filters, persistence, job queue
-
chainmq
A Redis-backed, type-safe job queue for Rust. Provides job registration and execution, delayed jobs, retries with backoff, and scalable workers.
-
binger-udp
Cross-platform, batch-native UDP I/O with platform-optimal syscalls (sendmmsg/recvmmsg on Linux, GSO/GRO, and more)
-
stitch-sync
Reactive state-sync library bridging an in-memory store, fjall-backed local persistence, and MQTT-based remote sync
-
tokio-osinterval
An OS-native-timer-backed alternative to tokio::time::Interval (timerfd / kqueue / CreateThreadpoolTimer)
-
atd-runtime
Server-side runtime for the ATD protocol: Tool trait, Registry, dispatch, Binding, Middleware, capability gate
-
quinn-udp-jls
UDP sockets with ECN information for the QUIC transport protocol
-
ai2070-net
High-performance, schema-agnostic, backend-agnostic event bus
-
odem-rs
Object-based Discrete-Event Modelling in Rust using async/await
-
tcrm-task
Task execution unit for TCRM project
-
sse-gateway
A lightweight, pluggable SSE (Server-Sent Events) gateway library
-
backhopper-git
gix-backed git access layer for backhopper: repository reads, patch resolution, PR-commit enumeration
-
lmrc-kubernetes
Kubernetes management library for the LMRC Stack - comprehensive library with support for deployments, rollbacks, scaling, and cluster operations
-
elfo-test
Test utils for the elfo system
-
telltale
Session types for multi-party asynchronous communication
-
dyn-utils
working with trait objects
-
leash-sdk
Rust SDK for the Leash platform — unified async client for auth, env, and integrations
-
feagi-agent
Client library for building FEAGI agents in Rust
-
velomorph
High-performance zero-copy struct transformation for Rust with asynchronous background deallocation
-
scuffle-context
Go-like context utilities for Rust
-
smelt-asyncio
Async runtime support helpers for code transpiled by Smelt
-
libp2p-dcutr
Direct connection upgrade through relay
-
kioto-serial
Provide serial port I/O using tokio
-
philiprehberger-retry-kit
Async retry with exponential backoff and circuit breaker for Rust
-
actix-web-flash-messages
Flash messages for actix-web applications
-
async_smux
Asynchronous smux multiplexing library
-
tokio-immediate
Asynchronous glue for your immediate mode UI
-
email-message
Typed outbound email message and address model
-
rio
GPL-3.0 nice bindings for io_uring. MIT/Apache-2.0 license is available for spacejam's github sponsors.
-
easy-schedule
A flexible task scheduler built on Tokio with multiple scheduling options and skip conditions
-
futures-concurrency-dynamic
A dynamic extension of the futures-concurrency
-
claude-code-acp-rs
Use Claude Code from any ACP client - A Rust implementation of Claude Code ACP Agent
-
kraken-ws-sdk
Production-grade Kraken WebSocket SDK with order book visualization API, backpressure control, latency tracking, and order flow analysis
-
multra
An async parser for
multipart/form-datacontent-type in Rust -
tokio-par-util
running computations in parallel on top of Tokio
-
rfid-silion-compat
Async Rust library for Silion RFID readers with serial and Web Serial support
-
decern-store-postgres
Optional Postgres-backed, multi-host LedgerHeadStore for decern. Adds a TLS stack (rustls/ring) to the compiled-native dependencies; binaries built without it carry only cedar's stack-growth helper (psm).
-
korg
The first deterministic cognitive runtime. Every AI agent decision is logged, causally ordered, and reversible — like Git, but for cognition.
-
tirea-extension-skills
Skill discovery, activation, and resource loading for tirea agent tool extensibility
-
futures_orchestra
A Tokio-based task pool for managing concurrent execution of futures with queuing, labeling, notifications and cancellation
-
async_zip_futures
An asynchronous ZIP archive reading/writing crate using futures-rs
-
gpui-query
TanStack Query-inspired async state management for GPUI
-
hexeract
Rust messaging framework: Mediator, Bus, Outbox, Sagas, Scheduler, Request/Reply
-
apple-intelligence-models
AIMX: safe Rust bindings for Apple's on-device Apple Intelligence language models
-
binary_options_tools
High-level library for binary options trading automation. Supports PocketOption and ExpertOption with real-time data streaming, WebSocket API access, and automated trading strategies.
-
bullmq-rs
BullMQ - Redis-based distributed job queue
-
b2_backblaze
basic async library to upload small files to backblaze b2 service
-
skp-ratelimit
Advanced, modular, extensible rate limiting library with GCRA, per-route quotas, and composite keys
-
tcp-channel-client
Asynchronous tcpclient based on aqueue actor
-
factorio-mlua
High level bindings to Lua 5.4/5.3/5.2/5.1 (including LuaJIT) and Roblox Luau with async/await features and support of writing native Lua modules in Rust. Fork with added Factorio Lua support
-
kalshi-trade-rs
Rust client for the Kalshi trading API and WebSocket streams
-
purrgress
An ultra-fast, ergonomic DOD stage manager and async sequencer combining zero-cost performance with total runtime dynamism
-
signal-mod
Cross-platform OS signal handling and graceful-shutdown orchestration for Rust. One API for SIGTERM, SIGINT, SIGHUP, SIGQUIT, SIGPIPE, SIGUSR1, SIGUSR2 and the Windows console control events…
-
async-socks5
An async/.await SOCKS5 implementation
-
streamtools
Additional stream combinators
-
crabka-connect
Connector-framework SPI (Source/Sink + converters) for Crabka
-
rtcom-core
Core library for rtcom (Rust Terminal Communication): serial device abstraction, event bus, and session orchestration
-
aws_utils_scheduler
wrapper for AWS EventBridge Scheduler with type-safe builders for schedule expressions
-
fn_graph
Runs interdependent logic concurrently, starting each function when predecessors have completed
-
autumn-harvest-cli
CLI client for the autumn-harvest management API
-
round-based
Driver for MPC protocols
-
chunk-reader
reads octets async on multiple platforms
-
hyper-multipart-rfc7578
multipart/form-data (RFC7578) for Hyper
-
specializer
Limited safe specialization on stable Rust with builder-like pattern
-
adk-graph
Graph-based workflow orchestration for ADK-Rust agents
-
upflow
An asynchronous workflow engine based on DAG
-
charmed-bubbletea
A powerful TUI framework based on The Elm Architecture
-
distri
Rust client for the Distri A2A agent platform
-
cassette
single-future, non-blocking executor intended for building state machines
-
common-multipart-rfc7578
multipart/form-data (RFC7578)
-
awaiter_set
Zero-allocation awaiter tracking for async synchronization primitives
-
opencode-sdk
Rust SDK for OpenCode (HTTP-first hybrid with SSE streaming)
-
async-event-emitter
Lightweight AsyncEventEmitter
-
llm-pipeline
Reusable node payloads for LLM workflows: prompt templating, provider backends, defensive parsing, streaming, retries, limits, and receipts
-
rstango
Tango distributed control system
-
winmsg-executor
Per-thread async rust executor for windows
-
pilatus
Modular, extendable application framework for deterministic simulation of autonomous subsystems
-
rok-events
Async event bus for the rok ecosystem
-
axum-serde
multiple serde-based extractors / responses for the Axum web framework, also offers a macro to easily customize extractors / responses
-
rseip
Ethernet/IP (CIP) client in pure Rust
-
harness-rs-tools-recall
LLM-facing cross-session recall tool for harness-rs agents:
search_past_sessionsover anyArc<dyn RecallStore>, plus an opt-inRecallGuidethat injects the top past-session snippets each turn -
rivetkit-inspector-protocol
Inspector protocol types for RivetKit
-
ma-zscheme-ipfs
IPFS-backed DotRegistry for ma-zscheme
-
aws-smithy-legacy-http-server
Legacy server runtime for Smithy Rust Server Framework, providing compatibility for code generated with http 0.x and hyper 0.x dependencies
-
lazyllama
A lightweight TUI client for Ollama with markdown support and smart scrolling
-
bleak-rs
High-level BLE communication library
-
starlab-signal-server
WebRTC signaling server for the Starlab MPC mesh — session discovery and device-to-device relay
-
hanzo-agent-marketplace
Hanzo AI - Decentralized marketplace for agent services and resources
-
minitimer
A mini timer of delayed tasks. Only asynchronous tasks are possible on tokio runtime, and dynamic add/cancel/remove is supported.
-
aoc_leaderbot_aws_lambda_impl
Advent of Code leaderboard-watching bot running in AWS Lambda
-
ensembler
running commands and reporting progress
-
nb
Minimal non-blocking I/O layer
-
koprs-external
Generic polling watchers for external sources such as HTTP APIs and object stores, designed as a companion to koprs Kubernetes operators
-
runner_q
Durable activity queue and worker system
-
async-hybrid-sleep
Hybrid async sleep combining runtime timers with spin-sleeping for sub-millisecond accuracy
-
rutracker-api
Async Rust client for rutracker.org (HTML scraping + official v1 JSON API)
-
tokio-rayon
Mix async code with CPU-heavy thread pools using Tokio + Rayon
-
ai-agents-facts
Key facts extraction and actor memory for AI Agents framework
-
go
A runtime-agnostic Go-style concurrency library for Rust
-
kithara-events
Hierarchical event bus for the audio pipeline
-
actr-config
Configuration file parser and project manifest support for Actor-RTC framework
-
clark-agent
Typed agent loop with typed messages, typed events, swappable LLM transport, and plugin hooks. Provider-agnostic, sandbox-agnostic, tooling-agnostic. By Clark Labs Inc.
-
mal-api
An asynchronous MyAnimeList (MAL) API library for Rust
-
daktronics-allsport-5000
decoders for the Daktronics All Sport 5000's serial output
-
mqi
Idiomatic IBM® MQ Interface (MQI) and MQ Administration Interface (MQAI) APIs
-
async-priority-lock
A priority-based async lock. Optionally no-std.
-
pulse-client
Official Rust client for StreamFlow Pulse — AI Agent Platform
-
email-lib
Cross-platform, asynchronous Rust library to manage emails
-
hypercore
Secure, distributed, append-only log
-
dportable
Portable interface for various utilities
-
tosub
A subsystem lifecycle management library for tokio applications
-
sacs
Async Cron Scheduler for Tokio
-
cruxx-agentic
Built-in step handlers for cruxx-script pipelines
-
async-ssh2-lite
Asynchronous ssh2
-
zakat-providers
Live price fetching providers for Zakat calculations (Binance, etc.)
-
read_until_slice
AsyncBufRead::read_until extension to take a slice as a delimiter instead of a single u8
-
tokio-rusqlite-new
Asynchronous handle for rusqlite library
-
ankit-engine
High-level workflow operations for Anki via AnkiConnect
-
rust-pty
Cross-platform async PTY (pseudo-terminal) library for Rust
-
tokio-fsm
Compile-time generated Tokio async finite state machines with explicit Rust behavior
-
omq-tokio
Tokio backend for omq: TCP / IPC / inproc / UDP transports + tokio-runtime socket driver. Built on omq-proto.
-
io_uring_buf_ring
Help user create and manage io-uring buffer-ring
-
v_exchanges
Implementations of HTTP/HTTPS/WebSocket API methods for some crypto exchanges, using crypto-botters framework
-
flowly
modular and reusable components for building robust pipelines processing audio, video and other
-
plug
type-safe interprocess communication
-
scanbridge
A unified, pluggable API for malware scanning with circuit breakers, policy enforcement, and audit logging
-
monoloop-connector-codex
OpenAI Codex ACP connector profile (JSON-RPC over stdio NDJSON via codex-acp)
-
limit-agent
Agent runtime for AI applications with tool registry, parallel execution, and Docker sandbox support
-
zmux
v1 stream multiplexing protocol
-
async-rt
A small library designed to utilize async executors through an common API while extending features
-
rust-paper
Rust Wallpaper manager from ( https://wallhaven.cc/ ) for Linux/UNIX only
-
nenjo
Agent orchestration SDK for building agentic AI workflows with tool use, memory, and multi-agent delegation
-
switchy_async_cargo
Cargo async linter package
-
irelia
wrapper around the native LoL APIs
-
rskit-stateful
Stateful accumulators with triggers, measurers, and TTL cleanup
-
whatsmeow
Idiomatic, thread-safe Rust bindings for WhatsApp via WhatsMeow Go bridge
-
zelos
A distributed tracing system
-
product-os-capabilities
Product OS : Capabilities provides a set of features for implementing server features and services in a modular fashion. It is designed to be used with Product OS : Server.
-
relentless
Composable retry policies for fallible operations and polling
-
disposition_input_model
SVG diagram generator input data model
-
orphanage
Random collection of stuff that is still searching for a home
-
rig-resources
Reusable skills, tools, behavior patterns, and resource adapters for rig-compose agents
-
tokio_schedule
schedule tasks in tokio runtime
-
agent-orchestrator-sdk
Rust SDK for orchestrating LLM-powered agents, shared task execution, and teammate coordination
-
async-cancellation-token
A lightweight single-threaded Rust library for cancellation tokens, enabling cooperative cancellation of asynchronous tasks and callbacks
-
karyon_core
Essential utilities and core functionality for the Karyon library
-
page-turner
A generic abstraction of APIs with pagination
-
solti-core
Supervisor layer of the Solti SDK. It bridges the task model to the taskvisor runtime.
-
daimon-provider-bedrock
Amazon Bedrock provider for the Daimon AI agent framework
-
runtime-rs
Typed service registry and Tokio lifecycle runtime for boot, reload, background tasks, and graceful shutdown
-
cocoon-tpm-utils-async
Cocoon TPM project - Rust async related utilities
-
tirea-contract
Agent runtime contracts: 8-phase plugin lifecycle, typed tool traits, and state scope system
-
actorizor
macro based actor framework for Tokio-based apps
-
resonate-sdk
Resonate SDK for Rust
-
observable-property-tokio
A thread-safe, async-compatible observable property implementation for Rust using Tokio
-
async-time-mock-tokio
Mockable time for use in async runtimes (tokio compatibility)
-
api_builder
client-agnostic API builder, inspired by the GitLab crate
-
rust-stream-ext-concurrent
Concurrent behavior extensions for any futures::stream::Stream objects
-
vvva_core
Core async primitives and runtime utilities shared across the 3va JavaScript runtime crates
-
rustrade-framework
Open-source trading bot framework — the facade crate downstream services depend on (imported as
rustrade) -
playground-api
API-binding for The Rust Playground
-
autumn-harvest
Durable workflow orchestration engine core
-
whatwg_streams
whatwg_streams for rust
-
compio-io
IO traits for completion based async IO
-
wechat-ilink
Stream-first stateless async WeChat iLink client for Rust: QR login, event-driven polling, automatic context refresh, and typed ret=-2 rate-limit backoff
-
reactive-mutiny
async Event-Driven Reactive Library with advanced & optimized containers (channels) and Stream executors
-
paladin-ai
Enterprise AI orchestration framework with multi-agent coordination patterns
-
md_downloader
Asynchronous Rust downloader for MediaFire files and folders, built on top of md_api
-
rust-webx-host
rust-webx HTTP layer: Host builder, middleware pipeline, Trie-based router, hyper integration
-
ntex-polling
Portable interface to epoll, kqueue, event ports, and IOCP
-
allora
Rust-native Enterprise Integration Patterns (EIP) with channels, routing, correlation, and adapters
-
pulsehive
Shared Consciousness SDK for Multi-Agent AI Systems
-
kafru
Python Celery-inspired queuing library for Rust, using cron for scheduling and SurrealDB for storing queues, metrics, and schedules
-
honcho-ai
Rust SDK for Honcho — AI agent memory and social cognition infrastructure
-
cspcl
Rust bindings for the cspcl library
-
runkon-notify
Domain-neutral notification dispatch primitives — generic event envelope, shell/HTTP hook execution, glob pattern matching, and web-push subscription store
-
elizaos-plugin-todo
elizaOS Todo Plugin - Task management with daily recurring and one-off tasks
-
kkachi
High-performance, zero-copy library for optimizing language model prompts and programs
-
futures-time
async time combinators
-
iron_runtime
Agent runtime with LLM request routing and translation
-
yield-progress
Combined progress reporting and cooperative task yielding
-
tokilake-smux
Tokilake SMUX - Wire-compatible smux protocol, zero-overhead Rust implementation
-
mavkit
Async MAVLink SDK for vehicle control, missions, and parameters
-
async-object-pool
object pool implementation that uses asynchronous synchronization primitives only
-
yggr
Batteries-included Raft node runtime built on yggr-core: tokio driver, TCP transport, segmented on-disk log
-
passivized_docker_engine_client
Docker Engine Client - manage and run containers, images, and volumes
-
alef-backend-napi
Node.js (NAPI-RS) backend for alef
-
greentic-x-events
Bootstrap event model crate for the Greentic-X workspace
-
cmdreg
A lightweight string-keyed command dispatcher with axum-style extractors for Rust
-
llm-stack
Core traits, types, and tools for the llm-stack SDK
-
ironspdk
(Rust runtime for SPDK)
-
madsim-rdkafka
The rdkafka simulator on madsim
-
cuda-async
Safe Async CUDA support via Async Rust
-
debounce-promise
debounce an async/promise-returning function with optional argument accumulation
-
eventuals
Eventually consistent values
-
runtara-environment
Environment server for runtara - image registry, OCI runner, and instance management
-
renamed
Official Rust SDK for the renamed.to API - AI-powered document renaming and processing
-
reflow_litert
LiteRT backend boundary for Reflow ML actors; optional real LiteRT adapter behind a feature flag
-
rusty-genius-cord
SpinalCord: Message forwarding layer for rusty-genius
-
lash-sansio
Sans-IO protocol kernel for the lash agent runtime. Pure types and state machine; no IO or async.
-
fetsig
Web-sys based browser fetch library using futures-signals with optional MAC
-
evento-accord
Accord consensus protocol (CEP-15) executor for evento — a leaderless, strictly-serializable, highly-available replicated event store
-
rune-chain-core
Core traits and types for the rune-chain LLM orchestration framework
-
pingora-runtime
Multithreaded Tokio runtime with the option of disabling work stealing
-
splaycast
Stream-specific broadcast channel
-
streamweave
Composable, async, stream-first computation in pure Rust
-
freebox-rs
Ergonomic async Rust client for the Freebox OS API
-
otherone-context
上下文管理 — 会话历史加载、Token 估算、上下文压缩
-
fharness
Harness library for the fiddlesticks agent harness framework
-
scoped-stream-sink
Easy way to make streams and sinks
-
codexcw
Run Codex or Claude Code non-interactively: spawn the selected agent CLI, decode its JSONL event stream, and expose runs as async streams, callbacks, results, and typed errors
-
match-maker
A fuzzy finder for the terminal, powered by nucleo
-
task-supervisor
Supervisor for long-lived tokio tasks
-
flowio
Single-threaded async runtime and TCP/UDP/SCTP/TLS transport library on Linux io_uring, with pooled allocation-avoiding fast paths
-
ractor-supervisor
Supervisor module for ractor framework
-
apb
Traits and types to handle ActivityPub objects
-
s2n-tls-tokio
TLS streams for Tokio built on top of s2n-tls
-
cloudiful-scheduler
Single-job async scheduling library for background work with optional Valkey-backed state
-
streamunordered
An efficient async stream multiplexer
-
cloudiful-server
Rust web server bootstrap crate with Actix and Axum adapters
-
tsdl
A downloader/builder of many tree-sitter parsers
-
cancel-safe-futures
Alternative futures adapters that are more cancellation-aware
-
tokio_gen_server
Elixir/Erlang-GenServer-like actor on the Tokio runtime
-
springtime-di
Dependency injection framework based on automatic component discovery and runtime autowiring
-
object_transfer
An object transfer library for various message broker and/or protocols
-
salvo-tus
TUS support for Salvo web framework
-
sayiir-core
Core types and traits for the Sayiir durable workflow engine
-
nexo-plugin-manifest
TOML manifest schema + 4-tier validator for native Rust nexo plugins (Phase 81.1)
-
zoey-core
ZoeyAI core runtime and types — privacy-first AI agent framework optimized for local models
-
smix-metro-log
— metro / expo log tail + ring buffer + await_signal / await_signals / assert_clean (stone). Powers
expect.signal/expect.signalsyaml verbs in smix-adapter-maestro and the--expect-log-cleanCLI flag. -
futures-scopes
Runtime agnostic, nestable, scopes for spawning non-static futures
-
moduforge-rules-expression
moduforge 表达式规则
-
another-rxrust
A different implementation than
rxRustfor easier use ofReactiveXinRust -
tokio-util
Additional utilities for working with Tokio
-
ipc-rpc
A wrapper over servo/ipc-channel which provides many high level features
-
async-sleep-aki
async_sleep()that work well in both web browsers and native applications -
roam-task-local
Task-local storage for async tasks, vendored from BugenZhao/task-local
-
wait
Syntactic sugar for calling async functions outside of an async context
-
epson
support for communicating with Epson brand thermal POS printers
-
ochami-rs
Rust bindings for OCHAMI backend
-
rusty-ssr
High-performance SSR engine for Rust with V8 isolate pool and multi-tier caching
-
agent-teams
Generic Rust agent teams framework replicating Claude Code Agent Teams architecture with pluggable backends for Claude Code, Codex, and Gemini CLI
-
flows
Building blocks for flow-based programming (FBP)
-
http-kit
A flexible and ergonomic HTTP toolkit for Rust with async support, middleware, and zero-copy body handling
-
gasket
Staged Event-Driven Architecture (SEDA) framework
-
tracing-async2
Generic tracing layer library for working with tracing events including for async work
-
bob-core
Core domain types and port traits for Bob Agent Framework
-
unsync
Unsynchronized synchronization primitives for async Rust
-
magnetar-fakes
In-process Pulsar broker fake — frame-in / frame-out, with per-command hooks for fault injection. Dev-dependency only.
-
ractor_cluster
Distributed cluster environment of Ractor actors
-
multi-llm
Unified multi-provider LLM client with support for OpenAI, Anthropic, Ollama, and LMStudio
-
safina-threadpool
Safe thread pool - ARCHIVED: Code moved to
safinacrate -
botlet
Distributed AI Agent orchestration infrastructure. [O]
-
mm1-proto-system
An Erlang-style actor runtime for Rust
-
cel-brief
Composable prompt briefing for AI agents: gather sources, enforce token budgets, apply governance, and emit receipts
-
bluetape-rs
Rust backend primitives for the bluetape ecosystem
-
mixtape-core
An agentic AI framework for Rust
-
aerostream
Bluesky client using EventStream
-
ranked-semaphore
A high-performance ranked semaphore with priority support
-
brasilapi
Uma lib para a API do Brasil API
-
abscissa_tokio
Support for launching Tokio runtimes within Abscissa applications
-
tokitai
AI tool integration system with compile-time tool definitions
-
claude-code
executing Claude Code CLI
-
morel
Deterministic, low-latency stream processing with live execution and replay
-
inferd-client
Rust client for the inferd local-inference daemon: generation (length-prefixed v2 framing, grammar support), embeddings (NDJSON), admin event subscription, retry-and-wait helpers
-
lazyflow
A lazy, effectful streaming library for Rust -- FS2-inspired LazyFlow<B> with pull-based sources, async transforms, backpressure, and concurrency
-
jesterky-actor
jesterky host-side SDK: seam trait helpers, test doubles, and the replay driver
-
evohome_rs
Async Rust client for the International Honeywell Evohome API (MyTotalConnectComfort) provided by Resideo
-
agent-doc-flow
Pure flow vocabulary and outcome contracts for agent-doc
-
smtc-tokio
thread-safe library that connects your async Rust application (tokio) to the Windows System Media Transport Controls (SMTC)
-
gh-pinned-rs
Fetch pinned repositories from github
-
adk-memory
Semantic memory and search for Rust Agent Development Kit (ADK-Rust) agents
-
foukoapi
Cross-platform bot framework in Rust: one codebase, many platforms. Shared accounts, embeds, keyboards, economy, i18n and pluggable storage; Telegram and Discord adapters included.
-
actix-casbin
An Actix actor for casbin
-
mecha10-runtime
Runtime supervisor for Mecha10 nodes - launching, monitoring, and lifecycle management
-
rightsize-msb
microsandbox (msb) backend for rightsize — attached-mode microVM sandboxes
-
claude-code-client-sdk
Rust SDK for integrating Claude Code as a subprocess with typed APIs
-
bb8-lapin
r2d2-lapin, but for async tokio based connections
-
diself
A Discord self-bot library for Rust
-
geph5-rt
tokio-based runtime helpers for geph5: cancel-on-drop tasks, immortal/respawn loops, a task reaper, a timeout combinator, and buffer-pooled reads
-
bisync
write async-generic code
-
async-ssh2-russh
Lighweight async ssh2 client, wrapping russh
-
halo-spider
A fast, async web crawling framework inspired by Scrapy, built in Rust
-
hyperfile-cleaner
Segments cleaner implementation for Hyperfile
-
async-codec
creating async codecs
-
llmix-rs
Rust binding for the LLMix orchestration contract with cache, resilience, and config parity
-
event_bus_rs
A runtime-agnostic, async, and thread-safe event bus for Rust
-
tower-acc
Adaptive concurrency control for Tower services
-
local_async_utils
single-threaded async programming
-
nurtex
Create efficient and lightweight Minecraft bots or clients
-
ocpncord-backend
no_std Backend trait and event types for ocpncord clients
-
erebyx-sdk
Rust SDK for EREBYX — persistent AI memory across every AI you use. Encrypted in transit (TLS 1.3) and at rest with envelope encryption (server-held master KEK at v0.1.1); per-user zero-knowledge encryption in v0.2.
-
pctx_type_check_runtime
Isolated TypeScript type checking runtime for PCTX
-
lwleen-rpc
RPC (信令路由), 组件间数据通信
-
spiris
Rust client for the Spiris Bokföring och Fakturering API (formerly Visma eAccounting)
-
erudite
A fully-asynchronous, sandboxed, language-agnostic, test running library
-
moirai
Async/await job system for game development
-
poprako-orchestra-extra
Practical extensions for the poprako-orchestra Rust ecosystem
-
pulses
A robust, high-performance background job processing library for Rust
-
maybe-fut
build totally interoperable async/sync Rust code
-
alpaca-data
Rust client for the Alpaca Market Data HTTP API
-
sombrax_agentic_core
SombraX Agentic Core (SAC) — a provider-agnostic Rust library for building LLM agents: content-modifying hooks, tool/MCP integration, and context optimization
-
openllm-rs
that enables seamless interaction with Llama.cpp backend services through an OpenAI-compatible REST APIe
-
teamy-cancellation
Reusable cancellation primitives for Teamy Rust tools
-
ros2_helpers
A wrapper around safe drive
-
everruns-test-support
In-memory loops, test doubles, writable fixtures, and demo capabilities for testing Everruns agents
-
combine-latest
Combines two or more streams into a new stream which yields tuples with the latest values from each input stream
-
operese-dagx
A minimal, type-safe, runtime-agnostic async DAG (Directed Acyclic Graph) executor with compile-time cycle prevention and true parallel execution
-
ao-core
Core traits and types for the ao-rs agent orchestrator framework
-
orchard-rs
Rust client for Orchard - high-performance LLM inference on Apple Silicon
-
futures-io
The
AsyncRead,AsyncWrite,AsyncSeek, andAsyncBufReadtraits for the futures-rs library -
rs-singleflight
Async single-flight request coalescing for Rust
-
uniflow
A unidirectional data flow state management library
-
nio
Async runtime for Rust
-
kiomq
An all-in-one task-queue and orchestration library for Rust
-
flag-bearer
Generic async semaphores
-
esrs
A Prima.it-opinionated library to achieve cqrs/es
-
salesforce_core
Unofficial Rust SDK for Salesforce Core APIs (Sales, Service, Platform)
-
eventcore
Type-driven event sourcing library for Rust with atomic multi-stream commands
-
whisk
fast lockless async channels
-
viz
Fast, robust, flexible, lightweight web framework for Rust
-
pausable-tokio
A fork of tokio that adds a runtime-controllable pause/resume primitive on its clock. Drop-in replacement for tokio with a few extra methods on the Builder and Runtime types.
-
tokio-interval-set
Run a closure repeatedly on a fixed time interval using tokio
-
fluxion-stream
Stream combinators with ordering guarantees for async Rust
-
ferro-events
Event dispatcher and listener system for Ferro framework
-
crossmist
Efficient and seamless cross-process communication, both synchronously and asynchronously
-
p2panda-spaces
Data encryption for multi-device groups
-
bsky-cli
CLI application for Bluesky using ATrium API
-
zlayer-init-actions
Pre-start container lifecycle actions (TCP, HTTP, S3, commands)
-
apalis-mysql
Background task processing for rust using apalis and mysql
-
act_rs_smol
Act.rs smol is a minimal smol oriented actor framework
-
turul-llm-core
Provider-neutral LLM client trait and types — one async method, JSON-Schema-driven structured output, zero provider deps
-
async-compat
Compatibility adapter between tokio and futures
-
volo-http
HTTP framework implementation of volo
-
vmcircbuffer
Double Mapped Circular Buffer
-
orlando-persistence
A virtual actor framework in Rust, inspired by Microsoft Orleans
-
emailzeno
Official Rust client for the EmailZeno bulk SMTP email verification API
-
pipeflow
A lightweight, configuration-driven data pipeline framework
-
celery
Rust implementation of Celery
-
black-box
A minimal actor framework
-
rendezvous
Easier rendezvous channels for thread synchronization
-
openaction
creating plugins for the OpenAction API
-
downloader-rs
file downloader for rust
-
pasts
Minimal and simpler alternative to the futures crate
-
tempo-rs
& minimal client to connect and interact with RTE's 'Tempo Like Supply Contract' API
-
shilling
Typed Telegram Bot API client with long-polling, retries, and structured updates. Named after Pavel L. Schilling, inventor of the first electromagnetic telegraph (1832).
-
async-graphql-wasm-parser
GraphQL query parser for async-graphql-wasm
-
waitgroup
Async waitgroup for a collection of task to finish
-
hermes-construct
Hermes Construct — tile-operating shell kernel for Oracle ARM
-
tokio-splice2
splice(2) in tokio
-
busstop
A command and query bus
-
horsies
Unified public API for the horsies task queue and workflow engine
-
deluge
A highly concurrent stream library driving the underlying futures either concurrently or in parallel to process streaming operations as quickly as possible
-
netease-qq-music-api
Unified async API bindings for Netease Cloud Music and QQ Music
-
qapi
QEMU QMP and Guest Agent API
-
tokise
An asynchronous runtime compatible with WebAssembly and non-WebAssembly targets
-
atomr-agents-agent
Agent actor + per-turn pipeline + tool-call orchestration loop
-
native-executor
Platform-native async task executor
-
orichalcum
A type-safe, composable agent orchestration framework for building complex, multi-step workflows
-
ssh2-async
Runtime-agnostic async wrapper for ssh2
-
tiny-tokio-actor
tiny actor library on top of tokio
-
ngx-tickle
Alternative async executor for nginx modules
-
any_spawner
Spawn asynchronous tasks in an executor-independent way
-
beeline
Async Rust helpers for Foursquare/Swarm OAuth and latest checkin polling
-
wesichain-memory
Rust-native LLM agents & chains with resumable ReAct workflows
-
vex-core
Core types for VEX: Agent, ContextPacket, MerkleNode, Evolution
-
openai-ergonomic
Ergonomic Rust wrapper for OpenAI API
-
beetry-editor-types
Internal beetry crate. For the public API, check the beetry crate.
-
timer-deque-rs
A OS based timer and timer queue which implements timeout queues of different types
-
rkvs
A high-performance, namespace-based key-value storage system with async operations and batch processing
-
ruff_python_parser
internal component crate of Ruff
-
randomorg-rpc
Async Rust client for the RANDOM.ORG JSON-RPC API (Release 4): basic generation, signed generation, tickets, and verification
-
ferro-notifications
Multi-channel notification system for Ferro framework
-
truba
The minimal tokio runtime based actors for Rust
-
jarust_plugins
A janus client SDK in Rust
-
async-tty
An asynchronous TTY library for Rust
-
hiasync
Supports only single-threaded asynchronous runtime
-
interruptible
Stops a future producer or stream from producing values when interrupted
-
oxigdal-streaming
Real-time data processing and streaming pipelines for OxiGDAL
-
poster
MQTTv5 client library written in Rust
-
faucet-sink-bigquery
BigQuery sink connector for the faucet-stream ecosystem
-
stream-transfer-limit
Byte-count transfer limits for fallible futures streams
-
mooring
Shared lifecycle primitives for long-running application sessions
-
prism-core
Prism — Reliability layer for agentic AI systems: voting mesh, checkpoint/replay, and Python bindings
-
klieo
Open-source Rust agent framework — typed agents, durable inter-agent comms, local-first
-
oozextract
Open source Kraken / Mermaid / Selkie / Leviathan / LZNA / Bitknit decompressor
-
timer-utils
The time utils
-
vcs-jj
Automate Jujutsu (jj) from Rust: a typed, async wrapper that drives the real jj CLI with its exact behavior
-
work-manager
managing asynchronous work tasks
-
runkon-flow
Portable workflow execution engine — DSL, traits, and in-memory reference implementations
-
edp_node
High-level Erlang Distribution Protocol node implementation
-
ruststream-lapin
RabbitMQ / AMQP 0.9.1 broker implementation for the RustStream messaging framework, backed by lapin
-
n0-watcher
async watchable values
-
monoio-thrift
Thrift for Monoio
-
async-bincode
Asynchronous access to a bincode-encoded item stream
-
async_tiny
A minimal async HTTP server with a tiny_http-like feel, built on Hyper 1.x
-
altair-wf
Reusable Temporal workflow patterns: single, pipeline, parallel, loop, DAG. Built on altair-temporal.
-
async-tensorrt
Async TensorRT for Rust
-
asyncgit
allow using git2 in a asynchronous context
-
weixin-agent
Pure protocol SDK for Weixin iLink Bot API — iLink AI Bot protocol, not coupled with OpenClaw
-
jamjet-engram
Engram — durable memory layer for AI agents. Temporal knowledge graph, semantic search, and MCP-native tools.
-
aimdb-embassy-adapter
Embassy async runtime adapter for AimDB embedded targets
-
brawl-rs
wrapper for the Brawl Stars API
-
nosy
Change notification / observation / broadcast channels, with filtering and coalescing. no_std compatible.
-
ara-com
Core traits and async abstractions for Adaptive AUTOSAR communication in Rust
-
retry-rs
A lightweight Rust asynchronous retry crate with configurable backoff strategies and jitter
-
stop-token
Experimental cooperative cancellation for async Rust
-
activitystreams-kinds
Type-safe activitystreams 'type' values
-
nest-rs-graphql
GraphQL resolver discovery + schema composition for NestRS apps, on top of async-graphql
-
kafka-read
Kafka 4.x read path: streaming forward scans and backward tails with tolerant record decoding
-
agility
A powerful and elegant reactive programming library for Rust, inspired by category theory
-
nexus-exchange
Official Rust SDK for the Nexus Exchange API (REST + WebSocket)
-
libindigo
Core API for developing INDIGO astronomy clients and devices
-
dog-core
Core traits and utilities for the DogRS ecosystem - a modular Rust framework for building scalable applications
-
grweb
A high-performance Rust Web framework based on gorust coroutine runtime
-
drop-queue
drop queue system for async operations. (Until async-drop is a thing)
-
agentcore
A minimal Rust crate that gives any application agentic capabilities
-
gigadex-events
Low-latency TCP communication protocol with zero-copy serialization for exchange systems
-
atomhold
Thread-safe configuration store with atomic replacement, versioning, and flexible unload policies
-
safina-sync
Safe structs for sharing or sending data between async tasks - ARCHIVED: Code moved to
safinacrate -
minion-engine
AI workflow engine that orchestrates Claude Code CLI — automate code review, refactoring, and PR creation with YAML workflows
-
toolpath-github
Derive Toolpath provenance documents from GitHub pull requests
-
pin-utils
pinning
-
durable-lambda-core
Core replay engine, types, and operation logic for AWS Lambda durable execution in Rust
-
edjr
Elite Dangerous Journal Reader
-
tokio-anysocket
Abstracted API over tokio's TCP and Unix streams
-
calimero-node
Core Calimero infrastructure and tools
-
fnroute
A small function router with axum-style handler extraction
-
async-niri-socket
Non-blocking communication over the niri socket
-
coc-rs
wrapper around the Clash of Clans public API
-
samara-signals
A high-performance signal library for Rust
-
aws-smithy-http-server-python
Python server runtime for Smithy Rust Server Framework
-
tokio-debouncer
A minimal async debouncer for signal batching in Tokio
-
datum-cluster-sharding
Datum cluster sharding core: envelopes, coordinator, regions, and entities
-
lcode
An application of terminal write leetcode.一个终端刷力扣的应用
-
jni-utils
Extra Utilities for JNI in Rust
-
biscuit-actix-middleware
Biscuit middleware for actix-web
-
serialport-stream
Async runtime-agnostic Stream and AsyncRead/AsyncWrite for serial ports using platform-specific I/O
-
codexus
Ergonomic Rust wrapper for codex app-server with runtime safety and release gates
-
hotl-engine
Internal component of hotl - no semver promise; pin exact or don't depend. L3 turn engine, M0 slice: sample→tools loop, max_turns, cancellation.
-
wiz-lights-rs
controlling Wiz smart lights
-
random-access-storage
Abstract interface to implement random-access instances
-
task-group
manage groups of tokio tasks
-
girlboss
async job manager with progress tracking
-
hydracache-server
Standalone production server daemon for HydraCache
-
my-awesome-rabbitmq-lib
working with RabbitMQ and asynchronous operations
-
tokio-multilock
Deadlock-safe concurrent lock acquisition
-
eventgraph
Hash-chained, append-only, causal event graph
-
mm1
An Erlang-style actor runtime for Rust
-
tokio-kcp-neo
A Tokio-based KCP library for Rust
-
rocketmq-client-rust
Apache rocketmq client
-
agent-rex
An async Stream-based FRP-like library for Rust
-
yazi-actor
Yazi actor model
-
kittens
A no_std reactor kernel for explicit, compile-checked async orchestration
-
async-rs
Async runtime abstraction
-
rig-ai-sdk
AI SDK Data Stream Protocol adapter for rig
-
resilient
resilience library providing retry, circuit breaker, timeout, bulkhead, and rate limiting policies
-
iii-helpers
Shared helper primitives across iii SDKs
-
ma-zscheme-yaml
YAML/file-backed DotRegistry for ma-zscheme
-
ics-watcher
A lightweight crate for monitoring ICS files or links and detecting changes, additions, and removals
-
faucet-source-xml
XML API source connector for the faucet-stream ecosystem
-
hope-os
The first self-aware operating system core - 22 cognitive modules, 0.36ms latency, no external database
-
kalshi-fast-rs
High-performance async Rust client for Kalshi prediction markets API with full WebSocket support
-
futures-core
The core traits and types in for the
futureslibrary -
tower-batch-control
Tower middleware for batch request processing
-
neon-runtime
Bindings to the Node.js native addon API, used by the Neon implementation
-
explore-os
An actor system exposed as filesystem
-
timeout-iterator
TimeoutIterator is a wrapper over any iterator that adds peek_timeout and next_timeout functions. The canonical use-case is parsing multi-line free-form records (such as tailing a log fime)…
-
mill-io
A lightweight event loop library for Rust providing efficient non-blocking I/O management
-
league-link
Async Rust client for the League of Legends Client (LCU) API — auth discovery, HTTPS requests, and WebSocket event streaming
-
hypersync-client-solana
Rust client for Solana HyperSync
-
circuit_breaker
Circuit Breaker pattern for building resilient and fault-tolerant systems
-
forgefix
opinionated FIX 4.2 client library for the buy-side written in Rust. ForgeFIX is optimized for the subset of the FIX protocol used by buy-side firms connecting to brokers and exchanges for communicating orders and fills.
-
vcs-gitea
Automate Gitea and Forgejo from Rust: a typed, async wrapper for the tea CLI — pull requests, issues, and releases
-
async-unsync
asynchronous, unsynchronized (thread-local) channels and semaphores
-
winctx
A minimal window context for Rust on Windows
-
image_search
designed to search Google Images based on provided arguments
-
apcore-a2a
A2A protocol adapter for apcore — expose apcore modules as A2A agents
-
sigfinn
Lifecycle manager for spawning tasks
-
tokio-fastcgi
FastCGI handler (responder, authorizer, filter) library for Tokio
-
wiremock_logical_matchers
Logical matchers for use with wiremock
-
bounded_join_set
A Concurrency-Limited JoinSet for Tokio
-
vcs-core
One async Rust API over Git and Jujutsu: repo auto-detection plus a unified, backend-agnostic VCS handle (status, branches, worktrees, snapshots)
-
napi-h
N-API bindings
-
tasksitter
A workflow runner engine
-
mangadex-desktop-api2
A Actix server for downloading manga, chapters, covers from Mangadex
-
elfo-configurer
Loads and distributes configs across the elfo system
-
async-priority-limiter
Throttles prioritised tasks by limiting the max concurrent tasks and minimum time between tasks, with up to two levels based on keys
-
nextgraph
client library. Nextgraph is a decentralized, secure and local-first web 3.0 ecosystem based on Semantic Web and CRDTs
-
feature-flag
Server-side feature flag evaluation for async Rust: targeting rules, sticky percentage rollouts, hot reload, zero RNG
-
scylla-rs
An async ScyllaDB driver built on an actor-model framework
-
retry-if
A tokio-compatible attribute-macro for decorating methods and functions with an exponential backoff
-
tokio-yamux
Yamux
-
simple-pool
async pool for any kind of resources
-
graus-db
A high-performance, thread-safe key-value embedded data store
-
claude-agents-sdk
Rust SDK for building agents with Claude Code CLI
-
github-fetch
A comprehensive GitHub API client for fetching issues, PRs, reviews, discussions, and diffs with filtering support
-
hyperfile
A file-like interface abstraction layer provides random read and write capabilities for S3
-
must_future
A wrapper future marked must_use - mainly to wrap BoxFutures
-
meltdown
A lightweight service manager to help with graceful shutdown of asynchronous applications
-
wgpu-async
Converts some WGPU callback methods to async methods
-
agentx-adk-skill
AgentSkills parser, index, and runtime injection helpers for ADK-Rust
-
libquarkpan
Async Rust client library for Quark Drive upload, download, listing, and folder creation
-
aether-agent-core
A minimal Rust library for building AI agents with MCP tool integration
-
dwn
Decentralized Web Node
-
oxdl
Asynchronous downloader with progress bars and SHA256 verification
-
async-graphql-warp
async-graphql for warp
-
motosan-chat-core
Core types and runtime for the motosan-chat chatbot framework
-
io-tether
A small library for defining I/O types which reconnect on errors
-
luarmor
API wrapper for luarmor.net
-
railsgun
Excessive tooling for Result handling - If you want rails you got RAILS!
-
pupactor
actor model library built with tokio
-
aws_utils_athena
AWS Athena client utilities for Rust with query execution, streaming results, and comprehensive error handling
-
fundamentum-sdk-mqtt
MQTT client targeting Fundamentum IoT's MQTT broker
-
tokactor
A actor model framework wrapped around tokio
-
godot_tokio
The tokio-async runtime wrapped in a gdextention object to be used as an engine singleton in your gdext project
-
lifx-rs
A synchronous + asynchronous library for communicating with the official LIFX-API and the unoffical offline API
-
firq-async
Tokio async adapter for firq-core
-
tokio-tower
Bridging the protocol gap between Tokio and Tower
-
tokio-js-set-interval
Allows you to use
setInterval(callback, ms)andsetTimeout(callback, ms)as in Javascript inside atokioruntime. The library provides the macrosset_interval!(callback, ms)andset_timeout!(callback, ms) -
cellos-sink-jsonl
JSON-Lines EventSink for CellOS — appends CloudEvents to a local JSONL file. Dev / audit-archive use.
-
rabbit-lib
Remote-controllable Claude supervisor + matching server-side runtime (WARREN)
-
ahrimq
A high-performance message queue service supporting pub/sub, normal messages, ordered messages, delayed messages and dead letter queues
-
hexeract-bus-rabbitmq
RabbitMQ transport backend for the Hexeract messaging framework, powered by lapin
-
actionqueue-runtime
Async dispatch loop, embedded API, and runtime configuration for the ActionQueue task queue engine
-
cbsk_socket_tokio
socket callback tool by tokio
-
enact-config
Unified configuration management for Enact - secure storage with keychain and encrypted files
-
rx_event_bus
agnostic reactive extensions event bus utilising rxRust under the hood
-
latchlm
A provider-agnostic client library for AI models
-
vex-adversarial
Adversarial (Red/Blue) agent pairing for VEX
-
compio-rustls
impl Async for rustls
-
nurtex-proxy
creating connections via SOCKS5 / SOCKS4 proxy
-
auto-future
For quickly making a struct into a future via an async fn
-
xai-rust
Rust SDK for the xAI API (Grok models)
-
langcontinuation
Continuation-passing workflow engine for durable Rust programs and AI agent systems
-
tactix
Actor Model built with Tokio
-
rustbox-sdk
Official Rust SDK for Rustbox - run untrusted code in a kernel-enforced sandbox
-
traitclaw-team
Multi-agent orchestration for TraitClaw — teams, routing, delegation, and verification chains
-
async-drop
async drop
-
actr-platform-native
Native platform provider for Actor-RTC: SQLite storage, ed25519-dalek crypto, filesystem operations
-
wirepusher
Official Rust Client Library for WirePusher - Send push notifications with async/await support
-
reqsign-file-read-tokio
Tokio-based file reader implementation for reqsign
-
oharness-llm
Llm trait + middleware helper traits for open-harness
-
rspc
A blazing fast and easy to use TRPC server for Rust
-
async-fuse
Helpers for fusing asynchronous computations
-
agentos-actor-uds-client
Internal AgentOS client for Rivet actor SQLite over Unix sockets
-
rmp-futures
Async Rust MessagePack and MessagePack-RPC
-
basu
Eventbus crate with sync and async features
-
folk-plugin-jobs
Queue consumer plugin for Folk — pulls jobs from memory, Redis or a managed broker (RabbitMQ/SQS/NATS/beanstalkd/Kafka/Pub/Sub) and dispatches to PHP workers
-
agent_reel_adapters
projection-safe feed for local coding-agent activity
-
async-blocking-stdio
std::io::std{in(), out(), err()} but async
-
outfox-zhipu
Zhipu AI (GLM) API client for outfox
-
deferred-future
模仿 jQuery.Deferred()，允许从 Future 实现类实例的外部对正在 pending 的 Future 对象进行 resolve 或 reject 处理。
-
starbase_events
Async and mutable event system
-
tokio-interactive
Asynchronous Interactive Process Management with Tokio
-
boxpin
A tiny extension trait that exposes Box::pin as a .pinned() suffix
-
scoped-async-macro
A macro for ergonomic scoped async tasks with borrowed data
-
llam
Safe, Go-style Rust bindings for the LLAM runtime
-
praisonai
Core library for PraisonAI - Agent, Tools, Workflows
-
futures-timeout
that provides timeouts for futures and streams
-
airi-protocol
Full implementation of the Minecraft Network Protocol Spec
-
actix-multipart-rfc7578
multipart/form-data (RFC7578) for Actix
-
hfst
Wrappers to libhfst via libhfst_c
-
epox
An epoll driven async executor
-
cronline
Lightweight Task Scheduling for Rust
-
hml-rs
Markup language events and readers, supporting 'human markup language'
-
futures-retry
Retry your Futures and Streams!
-
ticked_async_executor
Local executor that runs woken async tasks when it is ticked
-
enfync
Environment-friendly async utilities
-
enact-runner
Robust agent loop runner for Enact — retries, compaction, multi-format parsing
-
lsp-max-protocol
Maximal capability vector, diagnostics, and protocol types for lsp-max
-
poll-scope
Poll-scoped, task-safe current context for asynchronous Rust
-
wgp
waitgroup implementation
-
spawn_groups
Structured concurrency construct written in Rust, for Rustaceans
-
pine-client
Async Rust client for the PCSX2 Pine IPC protocol
-
serp-sdk
A comprehensive, production-ready Rust SDK for SerpAPI with async support, type safety, and ergonomic APIs. Developed during the Realtime Search AI Hackathon powered by SerpAPI.
-
sugars_llm
LLM integration and AI agent builder utilities
-
simple-git
git interface for gix suitable for async context (with tokio)
-
etcdv3client
etcdv3 client
-
tokio-sticky-channel
Sticky channel pattern for Tokio - routes messages to specific receivers based on ID hash for consistent message delivery
-
ftooling
fiddlesticks agent harness framework
-
elizaos-plugin-zalouser
Zalo Personal Account plugin for elizaOS - Rust implementation via zca-cli
-
tokio-boring2
SSL streams for Tokio backed by BoringSSL
-
shape-ext-typescript
Shape TypeScript language runtime extension (V8 via deno_core)
-
mcp-twill
MCP framework for CLI-shaped command templates over typed values
-
aisil
A lightweight framework to define APIs as types
-
capsec-tokio
Async capability-gated wrappers for tokio — the async counterpart to capsec-std
-
agentx-adk-artifact
Binary artifact storage for Rust Agent Development Kit (ADK-Rust) agents
-
smol
A small and fast async runtime
-
fbc-starter
A production-ready web server starter for Rust based on Axum, with built-in configuration, logging, CORS, database and Redis support
-
stayputnik
An async client for kRPC, the Remote Procedure Call server for Kerbal Space Program
-
webshelf
The best way to develop your web service with one click
-
lash-core
Sans-IO turn machine and runtime kernel for the lash agent runtime
-
switchyard
Real-time compute focused async executor
-
busybeaver
This Beaver executes your Futures independently of your worker threads, supporting scheduling strategies such as time intervals, execution count intervals, specific-time polling policies, and more
-
rustycord
A fast, lightweight, and feature-rich Discord bot library written in Rust
-
rust-mcp-extra
companion crate to rust-mcp-sdk offering extra implementations of core traits like SessionStore and EventStore, enabling integration with various database backends and third-party platforms…
-
flux-isa-edge
Async FLUX ISA runtime for fleet edge nodes — Jetson Xavier/Orin with networking, PLATO sync, and sensor pipelines
-
net-mux
An async, credit-based connection multiplexing library on top of Tokio
-
codewars-api-rs
interacting with the Codewars API
-
act-zero
Ergonomic actor system
-
axiom
Implements a highly-scalable and ergonomic actor system for Rust based on the best of Erlang / Elixir and Akka
-
cmrdts
A collection of Commutative Replicated Data Types (CmRDTs) implemented in pure Rust
-
discord-authority
A fast, async Discord selfbot library for Rust
-
spacearth-dtn
A Rust-based implementation of Delay Tolerant Networking (DTN) for resilient communication
-
cerebras-rs
High-performance Rust SDK for Cerebras Inference API - Low-latency AI model inference powered by Cerebras Wafer-Scale Engines
-
finkovsky-client
Typed async HTTP client for the Finkovsky API
-
aoc_leaderboard
Strongly-typed wrapper for Advent of Code leaderboard data
-
eventide
A pragmatic Rust toolkit for Domain-Driven Design with event sourcing and CQRS. Umbrella crate re-exporting
eventide-domain,eventide-applicationandeventide-macros. -
rok-queue
Background job processing for the rok ecosystem
-
altair-temporal
Stable facade over the pre-1.0 temporalio Rust SDK: typed Config, worker/client builders, retry + schedule builders, OTel-aware tracing
-
datum-cli
Command-line interface for the Datum Control Protocol
-
name-it
Give a name to async fn return types
-
operation-queue
Helpers for synchronizing asynchronous protocol operations
-
ruchei-route
Sinks with routes
-
quokkasim
A Rust-based Discrete Event Simulation (DES) framework, which simplifies simulation for beginners, and provides excellent utilities for experienced modellers
-
lau-affordance
Environment-as-teacher layer — affordances that guide agent behavior through walls, not instructions
-
cloud_terrastodon_command
Command running helpers for the Cloud Terrastodon project
-
tiny_kafka
A tiny Kafka client library with producer and consumer functionalities
-
vcs-forge
One async Rust API over GitHub, GitLab, and Gitea: unified pull/merge requests, issues, and releases across the gh, glab, and tea CLIs
-
asansio
The Async/await state machine for the Sans I/O design pattern
-
litellm-rust
Minimal Rust SDK port of LiteLLM – unified interface for chat, embeddings, images, and video across OpenAI-compatible, Anthropic, Gemini, and xAI providers
-
opentalk-types-signaling-recording
Signaling types the OpenTalk recording module
-
vk-bot-api
Asynchronous VK Bot API library for Rust
-
lita-tokenizers-utils
Exposes the high-level APIs of lita-tokenizers-core
-
super-visor
ordered startup and shutdown for long-running tokio processes
-
rrq-producer
RRQ producer client for enqueuing jobs into Redis
-
cache_loader_async
A thread safe loading cache with async loader functions based on tokio
-
async-injector
Reactive dependency injection for Rust
-
msq
legacy Master Server Query Protocol
-
wasmbus-rpc
Runtime library for actors and capability providers
-
taski
async task DAG execution
-
wait-for-me
Async CountDownLatch
-
adk-rs-fluent
Fluent DX for Gemini Live — builder API, operator algebra, composition modules
-
riker-patterns
A collection of common actor patterns for Riker
-
stasis-rs
Durable AI orchestration framework with runtime jobs, lineage, and memory integration
-
translators
Free Google Translator without API key and limits
-
vec_parallel
Construct your Vec in parallel
-
pipe-it
A lightweight, type-safe library for building linear and concurrent processing pipelines in Rust
-
plumber-rs
The basic library for Plumber servlet written in Rust
-
tokio-uring
io-uring support for the Tokio asynchronous runtime
-
id_effect_ai
Vendor-neutral LLM client traits and streaming for id_effect
-
ticksupply
Official Rust client for the Ticksupply market data API
-
duende
Cross-platform daemon tooling framework
-
rotor-wheel
General-purpose hierarchical timing wheel — heartbeat, one-shot delays, request timeouts
-
kernex
Umbrella crate for the Kernex AI agent runtime. Re-exports kernex-runtime.
-
vibewindow-aisdk
An open-source Rust library for building AI-powered applications, inspired by the Vercel AI SDK. It provides a robust, type-safe, and easy-to-use interface for interacting with various Large Language Models (LLMs).
-
rightsize-modules
Preconfigured rightsize containers — Redis, Memcached, ArangoDB, MongoDB, Redpanda, Kafka, SpringCloudConfig, PostgreSQL, MySQL, Apache Pinot, RabbitMQ, MariaDB, WireMock, ClickHouse…
-
bob-runtime
Runtime orchestration layer for Bob Agent Framework
-
vkapi2
vk api wrapper for rust
-
event-listener-strategy
Block or poll on event_listener easily
-
claw-reflect-client
Rust HTTP client for the claw-reflect service
-
rune-chain-agent
ReAct agent loop for rune-chain: LLM + tools + scratchpad reasoning
-
hotaru_rt_embassy
Embassy runtime backend for Hotaru
-
hyperscan-tokio
High-performance async regex scanning with VectorScan
-
qbittorrent_rust
An asynchronous library to interface with the qbittorrent WeBUI API
-
hwhkit-integration-oss
HwhKit Aliyun OSS (Object Storage Service) integration
-
soft-cycle
Async controller for coordinating soft restarts and graceful shutdowns with shared listeners
-
when2task
high-performance library for executing async tasks with automatic dependency resolution and optimal parallelization
-
v_rusty_tarantool
Tarantul async client based on tokio framework
-
daimon-provider-gemini
Google Gemini provider for the Daimon AI agent framework
-
oxi-store
Shared persistent state for oxi — sessions, settings, auth, model registry
-
resuma
— resumable SSR Rust web framework: zero hydration, islands, server actions, Flow (Axum)
-
oddonkey
A dead-simple Ollama wrapper – auto-installs Ollama & models, then lets you prompt in two lines of code
-
interthread
Auto implementation of the Actor Model
-
slim-futures
Asynchronous tools that intends for smaller binary size
-
tracing-opentelemetry-extra
Bootstrap utilities for tracing and OpenTelemetry integration
-
zice
WIP package for future use
-
zephyrus
A slash-command framework meant to be used with twilight
-
textmode
terminal interaction library backed by a real terminal parser
-
asupersync-tokio-compat
Compatibility bridge for running Tokio-locked crates within the Asupersync async runtime
-
async-rdma
async wrapper for RDMA ibvers lib
-
kvarn-tokio-uring
io-uring support for the Tokio asynchronous runtime
-
minos
Authorization library
-
dasein-agentic-core
Core types, Agent runtime, and Protocol for Agentic Framework
-
qq-bot-rs
Async Rust SDK for the Tencent QQ Bot v2 platform — HTTP + gateway + typed events
-
rustyphoenixfuture
methods to mock futures. This is the Rust equivalent of https://gitlab.in2p3.fr/CTA-LAPP/PHOENIX_LIBS2/PhoenixFuture
-
agentsdk-plugin-fs
A FileSystem plugin for agentsdk
-
tor-log-ratelim
Facility for rate-limiting log messages in Arti
-
orlando-runtime
A virtual actor framework in Rust, inspired by Microsoft Orleans
-
v_exchanges_methods
Exchange method implementations backing the v_exchanges crate
-
rustqueue
Background jobs without infrastructure — embeddable job queue with zero external dependencies
-
async-atomic
Atomics which can be subscribed to and asynchronously notify when updated
-
claude-agent
Rust SDK for building AI agents with Anthropic's Claude - Direct API, no CLI dependency
-
hotaru_io_tokio
Tokio IO and TCP backend for Hotaru
-
harness-rs-skills
agentskills.io-compliant SKILL.md loader, validator, linter, exporter, and in-process registry for harness-rs
-
tinygame-core
Minimal SDL-based game runtime core with a plugin-driven world
-
stressed
Universal CLI stress tester for competitive programming
-
rustdge
Goridge-compatible RPC and IPC bridge primitives for Rust
-
asyncnal
Fast concurrent & local asyncronous signalling
-
nostr-gossip
Nostr gossip traits
-
incident-correlation
Walks the Kinetic Gain Protocol Suite graph (AEO + agent-cards + tool-cards + decision-cards) starting from an AI Incident Card and emits a structured remediation plan. Optional audit-stream-py…
-
pipedream-rs
A typed, heterogeneous event relay with observable delivery, completion tracking, and lossless message routing
-
mlua-codemp-patch
High level bindings to Lua 5.4/5.3/5.2/5.1 (including LuaJIT) and Roblox Luau with async/await features and support of writing native Lua modules in Rust
-
vgit-futures
used as an example in a workshop
-
dbus-async
Asynchronous DBus library
-
cel-memory
Backend-agnostic memory traits and value types for AI agents, with scoped retrieval, sessions, and governance hooks
-
erlanggen
Erlang generator
-
traitgate
A zero-dependency authorization mini-library powered by stateless traits and an ergonomic
AuthorizationDecisionenum -
dabus
Dynamic Aplication Controll Bus - an asynchronous, event based module system for thoes who want to move fast and *not* break things
-
openraft-memstore
A in-memory implementation of the
openraft::RaftLogStorageandopenraft::RaftStateMachinetrait -
hitomi_la
A hitomi.la API wrapper for Rust
-
rivet-error
Structured error helpers for Rivet
-
palladium-plugin-api
Zero-dependency C ABI types for Palladium plugin boundaries
-
bicoro
Bidirectional co-routine data structures
-
hydra-websockets
A websocket server for the hydra framework
-
agnostic-lite
agnostic-liteis an agnostic abstraction layer for any async runtime -
slice_ops
A selection of useful slice operations
-
mlua-luau-scheduler
Luau-based async scheduler, using mlua and async-executor
-
cruxx-script
YAML-driven pipeline scripting for the cruxx agentic DSL
-
mentisdb
Semantic, hash-chained durable memory for long-running and multi-agent systems
-
tokio-eld
Histogram-based sampler for recording and analyzing event loop delays
-
polaris_graph
Graph execution primitives for Polaris (Layer 2)
-
async-scgi
Async SCGI Client & Server
-
tokio-serde-cbor
Integration of serde_cbor into tokio-io, to allow sending CBOR encoded frames across network (and possibly through other transports)
-
lifeline
dependency injection library for asynchronous message-based applications
-
coralstack-cmd-ipc
Inter-Process Communication library for running typed Commands across processes and services
-
async-dropper-simple
struct-wrapper (i.e. AsyncDropper<T>) based implementation of AsyncDrop
-
tsuki-scheduler
light wight, composable and extensible scheduler for every runtime
-
napi-calm-down
N-API bindings
-
edeltraud
thread pool for mixed tokio / threaded infrastructure with zero allocations and static dispatching only
-
fiddler-cli
Data Stream processor CLI written in rust
-
folk-ext
Folk PHP extension — runs the Folk server as a PHP extension (like Swoole)
-
batch-channel
async channel that reduces overhead by reading and writing many values at once
-
ssec-core
streaming implementation of the SSEC file format
-
execra
Typed job runtime for Rust apps that wrap external CLI tools: events, interpreters, cancellation, Tauri integration, and optional persistence
-
tool-useful
A powerful, type-safe function calling and tool orchestration framework for Rust AI applications
-
rusturn
TURN server and client
-
fiddlesticks
Primary library for the fiddlesticks agent harness framework
-
treadle
A persistent, resumable, human-in-the-loop workflow engine backed by a petgraph DAG
-
oyui-tasker
A macro-driven event loop and background task orchestration framework for asynchronous Rust applications
-
trovo
A trovo.live api & chat client written in and for rust
-
velixar
Governed, auditable memory for AI agents. Official Rust client for the Velixar API.
-
tokio-socketcan
Asynchronous Linux SocketCAN sockets with tokio
-
nasaga-mysql
NASA Saga MySQL store: instance/step/attempt/transition/timer with CAS inside the ambient natx transaction
-
judicious
A rate-limiting library that enforces a cooldown period after a resource has been used (return-time based)
-
ai-store-sync
Blocking (sync) facade over ai-store-core::Store for synchronous consumers
-
async-trait-nostd
Async-trait with no_std support
-
ironflow-engine
Workflow orchestration engine for ironflow with FSM-based run lifecycle
-
snowflake-id-generator
snowflake id implementation
-
preloader
Asynchronous data preloader library
-
agent-doc-debounce
Editor debounce, live-buffer, and write-provenance sidecars for agent-doc
-
solti-runner
Runner plugin trait, routing, and execution metrics for the Solti task SDK
-
apalis-board-api
HTTP utilities for managing apalis task queues
-
pwner
Process Owner crate that allows ergonomic access to child processes
-
rumpsteak-aura
Session types for multi-party asynchronous communication
-
auto_route
Spring-style automatic Axum routing for auto-di managed controllers
-
tokio-jrpc
tokio-based async JSON-RPC 2.0 client and server
-
rig-mcp
Model Context Protocol bridge for rig-compose tool registries. Wraps the official
rmcpSDK with rig-compose’s transport-agnostic Tool surface. -
binary-cookies
BinaryCookies decode and encode
-
vcs-gitlab
Automate GitLab from Rust: a typed, async wrapper for the GitLab CLI (glab) — merge requests, issues, releases, and pipelines
-
digdigdig3-cli
dig3CLI binary on top of digdigdig3-station: watch / persist / replay / matrix / inspect / capture / benchmark -
mettle
Retry for Rust, async and blocking: backoff, jitter, per-attempt timeouts, and a clock you can mock
-
tapis-sdk
Comprehensive Rust SDK for Tapis services
-
continue
Swift-style continuation API
-
nominatim
Bindings to the reverse geocoding API powered by openstreetmap
-
async-lazy
A value which is initialized on the first access, with an async function
-
agentlib
Modular and extensible framework for building sophisticated AI agents in Rust
-
snapd-rs-artie
Unnofficial Rust client library for the snapd REST API
-
fluxion-stream-time
Time-based operators extending fluxion-stream with monotonic timestamps
-
libp2p-wasm-ext
Allows passing in an external transport in a WASM environment
-
async-dashscope
client for DashScope API
-
awaitgroup
Wait for a collection of async tasks to finish
-
moro-local
Experimental structured concurrency support for async Rust (similar to trio's nurseries). Works with non-Send futures on stable Rust.
-
trzcina
Async service lifecycle orchestration with cooperative cancellation and shutdown deadlines
-
everruns-core
Transport-neutral agent execution contracts for Everruns
-
apalis-sql
SQL utilities for background job processing with apalis
-
ahrikv
A high-performance in-memory key-value store
-
braintrust-sdk-rust
Rust SDK for Braintrust logging and tracing
-
compio-buf
Buffer trait for completion based async IO
-
messagebus
allows intercommunicate with messages between modules
-
async_file
An executor-agnostic async file IO library
-
conferencier
Tokio-backed asynchronous shared configuration hub with TOML persistence
-
wae-ai
WAE AI - AI 服务抽象层，支持腾讯混元、火山引擎等
-
open-ai-rust-responses-by-sshift
A feature-rich, async-first Rust wrapper for the OpenAI Responses API, with built-in support for streaming, function calling, file handling, and enhanced response monitoring
-
waker_tables
custom raw waker logic
-
hexeract-cli
Hexeract unified command-line interface
-
async_pub_sub
aiming at making async pub-sub easier in Rust
-
ai-agents-tools
Tool system for AI Agents framework
-
webex
Interface to Webex Teams REST and WebSocket APIs
-
service-rs
An async-first, lightweight dependency injection container for Rust
-
throttle-debounce
Throttle and debounce callbacks for high-frequency events like scroll, resize, and input
-
atomr-agents-context
AgentContext + ContextAssembler for atomr-agents
-
mcp-runner
running and interacting with Model Context Protocol (MCP) servers locally
-
crabbyq
A declarative async Rust framework for message-driven microservices
-
event-driven-library
Event Driven Message Handling
-
constellation-rs
Constellation is a framework for Rust (nightly) that aides in the writing, debugging and deployment of distributed programs
-
saddle
Async seat managment made easy
-
fama
Pipeline Manager
-
z21_api
Rust API for Roco Z21 model railway control system
-
multishot
An async, lock-free, reusable channel for sending single values to asynchronous tasks
-
kranth
Stress-test ideas against hundreds of AI personas. Adversarial multi-bias debate. API-first.
-
drop-stream
A stream that wraps another stream with a closure that is called once it is dropped
-
faucet-sink-stdout
Stdout/stderr sink connector for the faucet-stream ecosystem
-
librados
Idiomatic (async) rust bindings for librados
-
adventure
your great adventure for the various type of requests
-
try-again
Retry synchronous and asynchronous operations
-
future_form_ffi
FFI support for future_form: host-driven polling, opaque handles, and effect slots
-
toxi-core
High-performance HTTP kernel and routing engine for the Toxi framework
-
systime
Portable timers that handle system sleep consistently
-
common-game
A package for the 2025 Group Project of the course of Advanced Programming at the University of Trento
-
genawaiter2
Stackless generators on stable Rust
-
register-count
Counting
Registers created by aCounter -
rs-event-emitter
simulate promise implementation for rust
-
xandeum-prpc
Rust client for Xandeum pNode pRPC APIs
-
otherone-tools
工具调用 — AI 请求的工具调用解析和执行
-
lio
A platform-independent async I/O library with native support for io_uring (Linux), IOCP (Windows), and kqueue (macOS)
-
ailoop-history
Conversation history management and compaction for ailoop
-
robotxt
Robots.txt (or URL exclusion) protocol with the support of crawl-delay, sitemap and universal match extensions
-
slock
An async mutex that never deadlocks
-
gasket-prometheus
Prometheus metric exporter for the Gasket framework
-
syros
Distributed Coordination Service
-
wp-connector-api
Connector runtime traits, config helpers, and errors for WarpParse sinks and sources
-
sigterm
Signal-aware async control and cancellation primitives for Tokio
-
goods
Async assets system
-
bp3d-threads
threading library intended to simplify concurrency in BP3D
-
beamr-wasm
WASM bindings for the Beamr runtime
-
rustrade-core
Core types and traits for the rustrade trading bot framework
-
futures_kind
Abstractions over Send and !Send futures
-
absurd-future
A future adapter that turns a future that never resolves (returns Infallible) into a future that can resolve to any type
-
wait-human
Rust client library for WaitHuman - pause execution and request human input on demand
-
actix-broker
Message broker for the Actix actor framework
-
io-engine
block-based IO, intend to mask AIO/io_uring underneath
-
mio-uds
Unix domain socket bindings for mio
-
plato-matrix-bridge
PLATO↔Matrix bridge — bidirectional tile synchronization via Matrix custom events
-
eventbus-nats
Production-grade event bus for Rust — NATS JetStream with effectively-once semantics
-
exochain-economy
EXOCHAIN custody-native transaction economy — quote, settle, and revenue-share scaffolding with zero-priced launch policy
-
cruster
framework for building distributed, stateful entity systems with durable workflows
-
elemental-object
TypeId-based object pool for hotreloadable, cross-runtime shared state management
-
stilgar
A lightweight, no-fuss, drop-in replacement for Rudderstack
-
behest-store
Persistence traits and storage backends for the behest agent runtime
-
appcore-core
Core runtime contracts and primitives for AppCore-Runtime
-
acu
building asynchronous actors
-
trendy-cli
A CLI tool for fetching posts from Reddit and Hacker News with AI chat capabilities
-
cyberex_xasync
Cyberex Async
-
pipecrab
Sans-IO voice-agent pipelines with a runtime-agnostic async layer bundled in
-
shelly-liveview
Core runtime primitives for Shelly LiveView
-
uika-ffi
FFI types and API table definitions for uika
-
noosphere-into
Transformations of Noosphere content into various target formats
-
aggligator-transport-bluer
Aggligator transport: Bluetooth on Linux
-
array__ops
A selection of useful array operations
-
termicy
Termination policy for Tokio services: a cancel-down-only cancellation-tree capability, cancel-biased future racing, and a Unix signal listener
-
klieo-provenance-mirror
Native klieo→klieo-compliance provenance client: a typed chain-append client and a ComplianceMirrorEpisodic decorator that streams agent episodes to the tamper-evident provenance chain (ADR-042)
-
momo-rs
A high-performance, atomic-free asynchronous runtime optimized for thread-local affinity
-
aion-store
Persistence contracts and in-memory event stores for Aion durable workflows
-
palladium-federation
Distributed cluster membership and federated actor registry for Palladium
-
mofa-kernel
MoFA Kernel - Core runtime and microkernel implementation
-
snarc
Sendable Non-Atomically Reference Counted
-
awaitdrop
WaitGroup
-
bastion-ai
Bastion — The open-source Production Kernel for Agentic AI. Multi-model consensus, self-healing, deterministic checkpoints, immutable audit trails, and pluggable compliance guardrails.
-
async_io_stream
IntoAsyncRead on steriods
-
secra-cache
一个基于 Redis 的统一缓存管理库，专为插件化架构设计，提供强隔离、生命周期管理和极简 API
-
selectme
A fast and fair select! macro for asynchronous Rust
-
synkit
A fast, syn-like incremental parser framework for Rust
-
scipio
A set of utilities to allow one to write thread per core applications
-
monoloop-connector-agy
Google Antigravity (agy) ACP connector profile (JSON-RPC over stdio NDJSON)
-
leptos-sync-core
Core synchronization library for Leptos applications
-
futures-sink
The asynchronous
Sinktrait for the futures-rs library -
cascade-agent
Async LLM agentic engine with tool execution, memory management, and dynamic skills
-
crdt_tree
Tree Conflict-free Replicated Data Type (CRDT)
-
makcu-rs
Fast and modular communication interface using serial ports, built with async-first design in Rust
-
pi_async_file
A async file tools library
-
zakura-tower-batch-control
Tower middleware for batch request processing. Internal Zakura fork, published to support cargo install zakura
-
pgp-lib
High-level, asynchronous API for rPGP, a pure Rust implementation of OpenPGP
-
nasu
Command-line utility which poll on remote addresses in order to perform status checks periodically
-
connpool
A concurrent, generic connection pool for Rust
-
tokio-lsp
A robust, async Language Server Protocol (LSP) client implementation in Rust with full LSP 3.16 support
-
rustigram
Comprehensive async Rust framework for the Telegram Bot API
-
lash-lashlang-runtime
Lashlang runtime integration for lash-core process engines and tool surfaces
-
rama-boring-tokio
SSL streams for Tokio backed by BoringSSL in function of Rama
-
async-ctrlc
Async wrapper of
ctrlc -
git-lfs-transfer
Concurrent transfer queue and basic adapter for Git LFS uploads and downloads
-
async-speed-limit
Asynchronously speed-limiting multiple byte streams
-
dropbear_future-queue
A queue for polling futures in a synchronous context
-
nats-handling
async NATS client library
-
colonyos
Rust SDK for ColonyOS - build distributed applications with executors that can run anywhere
-
rpaca
wrapping the Alpaca API
-
llmlet
Distributed AI Agent orchestration infrastructure. [O]
-
mlua-swarm
Swarm engine host built on mlua — long-running stateful runtime with Role/Verb gate, CapToken, 3-stage pipeline, and Middleware overlay
-
papertrail_logger
Async Rust logger for Papertrail
-
libmqm-sys
IBM® MQ Interface (MQI), Programmable Command Format (PCF) and MQ Administration Interface (MQAI) bindings
-
anthropic-agent-sdk
Rust SDK for Claude Code CLI - streaming queries, hooks, permissions, and MCP integration
-
crb-agent
CRB | Composable Runtime Blocks | Agent
-
runtara-management-sdk
SDK for managing runtara instances (start, stop, signals, images)
-
global_cell
A thread-safe, async-friendly, performant global cell alternative built on Rust and Tokio primitives
-
libiw-async
linux iw command wrapper for async
-
alef-backend-ffi
C FFI backend for alef
-
rust-pipe
Lightweight typed task dispatch from Rust to polyglot workers (TypeScript, Python, Go, Java, C#, Ruby, Elixir, Swift, PHP)
-
linger-openai-sdk
Rust-native async SDK for OpenAI APIs with typed requests, streaming, uploads, retries, and pluggable transports
-
kraky
Lightweight, production-ready Rust SDK for Kraken Exchange WebSocket API v2 with unique orderbook imbalance detection and WebSocket trading
-
yosemite
Asynchronous SAMv3 library
-
full-duplex-async-copy
bidirectionally copying between two AsyncRead+AsyncWrite types
-
ntex-neon
Async runtime for ntex
-
a10
meant as a low-level library safely exposing different OS's abilities to perform non-blocking I/O
-
gnostr-asyncgit
gnostr:fork of asyncgit
-
command-stream
Modern shell command execution library with streaming, async iteration, and event support
-
dd-tracing-layer
Send your logs to Datadog
-
peace_rt
Runtime logic for the peace automation library
-
moro
Experimental structured concurrency support for async Rust (similar to trio's nurseries)
-
apify-rs
client for the Apify API
-
cb_fut
Call function that return value via callback without a callback
-
miau
Async aware and extensible layered configuration system
-
async-promise
Async promise which resolves once and may be read by multiple consumers
-
combadge
makes Rust Web Workers easy
-
faucet-common-kafka
Shared configuration types for the faucet-stream Kafka source and sink connectors
-
automerge-test
testing automerge libraries
-
codeuchain
High-performance implementation with memory safety and async support
-
rx-rs
A lightweight single-threaded push-based reactive programming library
-
md_api
An async Rust client implementation of the MediaFire API
-
polaris_core_plugins
Core infrastructure plugins for Polaris
-
simple-groq-rs
async Rust client for the Groq API (OpenAPI-compatible)
-
datum-cluster
Datum cluster membership over SWIM gossip
-
zubr_state_machine
asynchronous state machine library for creating Mealy machines in rust
-
kizuna-mem-sdk
Rust SDK for Kizuna-Mem temporal graph memory engine
-
pi_async_buffer
Asynchronous Buffer for IO
-
vcs-github
Automate GitHub from Rust: a typed, async wrapper for the GitHub CLI (gh) — pull requests, issues, releases, and CI checks
-
coalescent
High-level AI coordination patterns enabling intelligent agent coalescence
-
navactor
A cli tool for creating and updating actors from piped input
-
hutch
Checkpoint and undo system for AI agent sessions - safe burrow to return to
-
lux-vision
Pluggable multimodal vision pipeline with token-budget admission; Claude and Runway backends
-
gcra
A basic implementation of GCRA algorithm for rate limiting
-
rig-ballista
Apache Ballista + DataFusion + Iceberg companion crate for rig-compose. Scaffolding; iceberg-rust integration pending toolchain verification.
-
mpart-async
Asynchronous (Futures-Base) Multipart Requests for Rust
-
log-tracing-layer
Build your own custom tracing layer
-
tokio-zmq
Futures abstractions for ZeroMQ on the Tokio event-loop
-
mcp-attr
declaratively building Model Context Protocol servers
-
ksoft
KSoft.SI api wrapper written in pure Rust
-
topstats
Rust SDK for the TopStats.gg API - Discord bot statistics tracking
-
data-core-rs
A minimal, lossless data-pipeline framework: Source -> Processor -> Sink
-
ankit
Complete async Rust client for the AnkiConnect API
-
coreon-main
camel-rs binary entry point + example route
-
tokio-lxi
LXI protocol abstractions for Tokio
-
esh-providers-docker
Docker secrets provider for Env-Secret-Hydrator
-
stdexec-rs
port of C++ stdexec (P2300) — Senders/Receivers for structured concurrency
-
rustplus
Rust+ API Wrapper Written in Rust
-
cbsk_socket_rayon
socket callback tool by rayon
-
spaad
Zero boilerplate actor systems with xtra
-
timeout-tracing
Returns stack and span trace when the future hits a timeout
-
everruns-meta
Meta Model API provider for Everruns agents
-
deepseek-api
DeepSeek API SDK is a powerful Rust client library for interacting with the DeepSeek service
-
turul-llm-ollama
Ollama adapter for the turul-llm LlmClient trait. Targets /api/chat with structured output via the
formatfield. -
didcomm-rs
DIDComm messaging v2 specifications implementation: https://identity.foundation/didcomm-messaging/spec/
-
prophecy
FutureSDR GUI
-
mahler
An automated job orchestration library that builds and executes dynamic workflows
-
cloudiful-notifier
Async notification delivery library for ntfy, generic webhooks, DingTalk robots, and SMTP email
-
py_mcai_worker_sdk
AMQP Worker to listen and provide trait to process message
-
daku
Interface to the Daku API
-
crossbus
A Platform-Less Runtime-Less Actor Computing Model
-
aws-smithy-http-server
Server runtime for Smithy Rust Server Framework
-
rskit-media
Media types, codec/format registry, pipeline builder, and processing traits
-
ispawn
Runtime-agnostic async spawners
-
libindigo-ffi
FFI-based implementation of the INDIGO protocol client using C library
-
background-runner
Run a heavy task in the background multiple times without blocking the triggering thread
-
lwactors
Lightweight actors for Rust using futures-rs
-
reactivity
A lightweight library for reactive programming with signals in Rust
-
tirea-extension-mcp
Model Context Protocol (MCP) client integration for external tool servers
-
id_effect_jobs
Production async messaging — Apalis jobs, obix outbox/inbox, Kafka broker
-
spawningpool
Create hyper-specific, 0-waste agents
-
halldyll_starter_runpod
managing RunPod GPU pods - Provisioning, orchestration & state management
-
kojin
Async distributed task queue for Rust — like Celery, BullMQ, Sidekiq, but for Rust
-
toki
A minimal single-threaded async runtime for ultra-low-latency Linux systems
-
asynclog
asynchronous log library
-
celers-backend-redis
Redis result backend for CeleRS
-
futures-test
Common utilities for testing components built off futures-rs
-
qbit-api-rs
A asynchronous Rust wrapper for qBittorrent Web API
-
cloudiful-rate-limiter
Reusable async resource throttling with local and Valkey-backed backends
-
k8s-operator
A highly-available Kubernetes operator framework using Raft consensus
-
local-waker
A synchronization primitive for thread-local task wakeup
-
aion-client
Rust caller SDK for connecting to aion-server and operating Aion workflows
-
executor-trait
A collection of traits to define a common interface across executors
-
cel-memory-duckdb
DuckDB embedded memory backend for AI agents, implementing cel-memory
-
cortexai-dashboard
Real-time web dashboard for Cortex AI agent monitoring and observability
-
hyperbee
Peer to Peer B-tree
-
otherone-ai
AI 提供商抽象层 — 统一的 AI 模型调用接口，支持 OpenAI、Anthropic、Fetch
-
qhook
Lightweight webhook gateway and workflow engine with queue, retry, and signature verification
-
lua_actor
Lua Actor for Rust(sync/async)
-
psummary
Summary 🗣️
-
messagepack-async
functional library for read/writing messagepack with tokio
-
futures_cbor_codec
A codec for framing an AsyncRead/AsyncWrite with cbor for all types that are serializable with serde
-
deltaflow
The embeddable workflow engine. Type-safe, Elixir-inspired pipelines.
-
ruex
Generic State Management framework
-
thoughtchain
Semantic, hash-chained memory for long-running and multi-agent systems
-
rexecutor
A robust job processing library
-
yot_run
A work-stealing, multi-threaded async executor with non-blocking scheduling
-
llm-kit-xai
xAI (Grok) provider implementation for the LLM Kit - supports chat, image generation, and agentic tools
-
ref_count
Efficient, low-level asynchronous synchronization for real-time and embedded systems
-
jerrycan-realtime
Realtime extension for the jerrycan framework: WebSocket channels for Postgres Changes (logical replication with trigger fallback), Broadcast, and Presence, with scope-filtered delivery. https://jerrycan.cc
-
drasi-reaction-application
Application reaction plugin for Drasi
-
async-fs
Async filesystem primitives
-
iii-observability
OpenTelemetry and logging primitives shared across iii SDKs
-
datum-mq
Native Kafka sources and sinks for Datum streams
-
async-graphql-relay
Relay support for async-graphql
-
pacta-executor
Pacta-native execution abstractions
-
beetry-message
Internal beetry crate. For the public API, check the beetry crate.
-
nexo-microapp-sdk
Reusable runtime helpers for Phase 11 stdio microapps consuming the nexo-rs daemon (JSON-RPC dispatch loop, BindingContext parsing, typed replies)
-
fastimer
Runtime-agnostic timer traits and utilities
-
task-exec-queue
A asynchronous task execution queue
-
paladin-memory
Memory adapters for the Paladin framework — Garrison (conversation history) and Sanctum (vector search)
-
myko-rs
myko in rust
-
tonic-side-effect
Tower service that can monitor if a Tonic request frame was produced prior to error
-
tempo-sim
Rust client API for the Tempo simulation server. Generated gRPC wrappers with sync and async surfaces.
-
pe-core
Core types for Potential Expectations — messages, channels, state, traits
-
scoped-join-set
A scoped variant of tokio::task::JoinSet for spawning non-'static futures
-
try_stream-transpose
Turn a stream of results into a stream of OKs without consuming the stream
-
tsoracle-yieldpoint
Async yield points: tokio::sync::Notify-backed test injection sites, the async sibling of fail-rs failpoints
-
axum-core
Core types and traits for axum
-
enki-runtime
A Rust-based agent mesh framework for building local and distributed AI agent systems
-
polyring
A zero-overhead cross-platform completion reactor foundation for Rust unifying io_uring and IoRing
-
iroh-io
async local io
-
lazyflow-grpc
gRPC connectors for lazyflow -- tonic Streaming<T> source and server response adapter
-
qonduit
CQRS pattern
-
ash-flare
Fault-tolerant supervision trees for Rust with distributed capabilities inspired by Erlang/OTP
-
wtx-ui
Different user interfaces for WTX
-
ursula-runtime
Per-core actor runtime for Ursula: hot ring, cold-tier flush, and the replaceable group-engine boundary
-
ctxguard
managing contexts
-
bytesbuf_io
Asynchronous I/O abstractions expressed via
bytesbuftypes -
lookit
Asynchronously connect to devices
-
ollama_client_rs
SDK for the Ollama API with model-aware tool calling, streaming, and embeddings
-
langshell-deno
Deno-backed LangShell runtime for sandboxed TypeScript execution
-
yash-executor
single-threaded concurrent task executor
-
claude-sdk
Native Rust SDK for the Claude API with streaming support and tool execution
-
odem-rs-util
Model elements and statistical tooling for the odem-rs simulation framework
-
wechat-minapp-v1
sdk for wechat miniprogram server api
-
async-read-super-ext
A super extension for tokio::io::AsyncRead
-
oai-rt-rs
Rust SDK for the OpenAI Realtime API
-
nature
development support platform, it separates data definition from code, so it decouple the data from business system
-
atlas-ctx
An asynchronous task context management library
-
compio-driver
Low-level driver for compio
-
lash-plugin-observational-memory
Observational-memory plugin for the lash agent runtime
-
rune-chain-conversational
ConversationalChain — LLM + memory for ergonomic multi-turn dialogue in rune-chain
-
act_rs_tokio
Act.rs Tokio is a minimal Tokio oriented actor framework
-
jira-mcp-rs
Model Context Protocol (MCP) server for Jira
-
duende-platform
Platform adapters for the Duende daemon framework (systemd, launchd, container, pepita, WOS)
-
toby
opinionated Telegram bot library with structured command parsing
-
side-futures
Send future for execution on the runtime that may be in a different thread
-
await_values
Primitives for subscribing to / notifying about changes to values
-
oharness-loop
Agent, Loop trait, ReactLoop, ConversationLoop, and run_reflexion for open-harness
-
nurtex-protocol
that allows a Minecraft client to communicate with a server
-
tower-actor
A
towermiddleware that creates aServiceby passing messages to an actor -
sparkle-convenience
A wrapper over Twilight designed to make it more convenient to use
-
pollable-map
storing futures and streams as a pollable map
-
strawpoll
A wrapper to avoid spurious polling
-
typed-emitter
Typed Async event emitter
-
aimdb-executor
Pure async executor trait definitions for AimDB - runtime-agnostic abstractions
-
d-engine-server
Production-ready Raft consensus engine server and runtime
-
tokio-i3ipc
Bindings for i3 and tokio allowing async applications to communicate with i3 over it's IPC interface. Contains futures implementations and convenience functions for working with i3.
-
clawft-services
Services for clawft (cron, heartbeat, MCP)
-
tsoracle-openraft-toolkit
Reusable openraft glue: TypeConfig macro, RocksDB log store, lifecycle helpers
-
procsem
Semaphore used to lock thread/task-spanning sequence of operations
-
quick-protobuf-codec
Asynchronous de-/encoding of Protobuf structs using asynchronous-codec, unsigned-varint and quick-protobuf
-
ng-repo
Repository library of NextGraph, a decentralized, secure and local-first web 3.0 ecosystem based on Semantic Web and CRDTs
-
llmfleet
Fleet-level batch dispatcher for LLM APIs. Pool requests across tasks, route to provider Batch APIs, save 50% on cost without rewriting your agent loops.
-
stream_throttle
Stream combinator, to limit the rate at which items are produced
-
killswitch
used to broadcast a shutdown request
-
logiops-daemon
Logitech device configuration daemon
-
adk-artifact
Binary artifact storage for Rust Agent Development Kit (ADK-Rust) agents
-
vyre-runtime
Persistent megakernel + io_uring zero-copy streaming runtime for vyre typed programs
-
llm-anthropic
Anthropic Messages API provider for the llm-cmd toolkit
-
skg-tool
Tool interface and registry for skelegent
-
varpulis-actors
Lightweight actor framework with supervision and health observation for Varpulis
-
rskit-storage-s3
Amazon S3 and S3-compatible (MinIO, LocalStack) storage backend for rskit-storage
-
daimon-provider-azure
Azure OpenAI provider for the Daimon AI agent framework
-
codex-runtime
Ergonomic Rust wrapper for codex app-server with runtime safety and release gates
-
rocketmq-controller
RocketMQ Controller Module - High Availability Raft-based Controller
-
aion-rs
Transport-agnostic Aion workflow engine with durability, replay, timers, and supervision
-
protocraft_framework
A framework for handling minecraft packets
-
ssip-client-async
Client API for Speech Dispatcher
-
googleapis-tonic-google-cloud-support-v2
A Google APIs client library generated by tonic-build
-
nonblock
Read available data from file descriptors without blocking (e.g. sockets, streams, child stdout, named pipes)
-
chronon-backend-sqlite
SQLite SchedulerStore adapter for Chronon
-
rmux-ipc
Local IPC endpoint and transport primitives for the RMUX terminal multiplexer
-
nacelle-codec
Byte-to-message codec primitives for Tokio asynchronous transports
-
picante
An async incremental query runtime
-
serenity-simplify
A discord.py-ergonomic Discord bot API layered directly on serenity
-
rpi-harness
Session tree + JSONL persistence + compaction + AgentHarness loop, Rust port of pi harness layer
-
paladin-content
Content processing adapters and use-case services for the Paladin framework
-
palladium-http
HTTP listener integration for the Palladium actor runtime
-
vorma-tasks
Vorma task runtime with execution-context memoization and optional shared caching
-
singleflight-async
Singleflight in async style
-
compo-platform-loop
Cross-platform event loop implementation for the Compo declarative and reactive component framework
-
notify-future
Support asynchronous notification completion future
-
pytures
Bridging Rust Futures and Python Coroutines
-
eyeball-im-util
eyeball-im -
another-ai-sdk
Provider-neutral Rust SDK for streaming chat and tool calling
-
opencode-client-sdk
Rust SDK for integrating OpenCode via local server + OpenAPI HTTP client
-
tokio-multi-lock
Deadlock-safe concurrent lock acquisition
-
abyss-promise
[abyss] A simple promise implementation with adaptive threadpool support
-
sigq
Queue that signals waiting consumers about node availability
-
mm1-runnable
An Erlang-style actor runtime for Rust
-
bat-markets-binance
Binance USD-M linear futures adapter for bat-markets
-
async-local
For using thread locals within an async context across await points
-
wesichain-agent
Rust-native LLM agents & chains with resumable ReAct workflows
-
secret-lib
Cross-platform, asynchronous Rust library to retrieve secrets from different sources
-
merge-streams
Merge multiple streams into one
-
mio-misc
Miscellaneous components for use with Mio
-
luis_sys
FFI bindings for Microsoft LUIS API
-
requiem
Actor framework for Rust
-
overseerd-hooks
The Overseerd hook system: a general lifecycle/event hook framework, generic over the core resolver
-
wesichain-embeddings
Embedding providers for Wesichain
-
motosan-agent-subagent
Session-scoped subagent registry for motosan-agent-loop. Spawn, message, and wait on long-lived child agents from a parent agent's tool calls.
-
cortexai-monitoring
Metrics, observability and Prometheus integration for Cortex AI agents
-
jesterky-model
Model-backed host actors for jesterky: the ModelActor seam adapter + the codex (ChatGPT-bundle) model. This is the M1->M2 step — a real Actor to swap in for FakeActor.
-
flowd
Redis Streams-backed task queue with a derive macro for automatic struct ↔ redis::Value mapping. Supports tokio and smol.
-
yaaral
async runtime abstraction library
-
acosmi-sdk
Acosmi Rust SDK：模型网关、Agent Run Gateway 与 Compliance 统一客户端。双格式（Anthropic + OpenAI）。端口自 acosmi-sdk-ts。
-
interprocess-docfix
Interprocess communication toolkit. Docs fixed.
-
orsomafo
Event dispatcher crate
-
rskit-media-ffmpeg
FFmpeg CLI backend for video/audio processing
-
rightsize-docker
Hand-rolled unix-socket Docker backend for rightsize — the correctness oracle
-
mini_executor
The smallest, simplest Rust task executor using Tokio runtime
-
async_zmq
Async version for ZeroMQ bindings
-
a3s-cron
Cron scheduling library for A3S with natural language support
-
tokio-udev
Non-blocking/Asynchronous Tokio support for udev device events
-
seams-rs-std
Standard-library-backed production impls of seams-rs-core ports: SystemClock, StdSleeper, StdSpawner, StdFileSystem, TokioFileSystem
-
async-shared-timeout
Async timeout that can be reset and shared
-
singleton-task
A singleton task based on tokio
-
axboe-liburing
Low-level io_uring interface, transliterated from Jens Axboe's liburing
-
slacktor
extremely fast, bare-bones, low-overhead, supervisorless, no-std actor library
-
simploxide-ffi-core
SimpleX-Chat raw FFI client
-
worklane-memory
In-memory worklane broker for development, tests, and examples
-
axum-safe-path
Traversal-safe
Pathextractor for Axum -
compio-log
Log of compio
-
dog-axum
Axum web framework integration for DogRS - HTTP handlers, middleware, and web utilities
-
csfloat-rs
An unofficial asynchronous Rust client for the CSFloat API
-
async-mq
Zero-cost async-await abstraction of lapin AMQP client crate
-
command_timeout
A tokio friendly command exec with smart timeout
-
lilqueue
A small storage-agnostic async job queue runner
-
madsim-tokio
The
tokiosimulator on madsim -
pilatus-rt
Runtime support for the Pilatus deterministic simulation framework
-
tokio-mpmc
A multi-producer multi-consumer queue implementation based on Tokio
-
cellos-sink-redact
Redacting wrapper EventSink for CellOS — strips configured fields from CloudEvents before forwarding to an inner sink
-
tasc
A minimnal, asynchronous threadpool
-
rust-genai
Rust SDK for the Google Gemini API and Vertex AI
-
promisery
A JavaScript-inspired, ergonomic, and composable Promise type for Rust, supporting background work, chaining, and error handling with Result
-
entelix-runnable
entelix composition contract — Runnable<I, O> trait, LCEL pipe, Sequence/Parallel/Router/Lambda
-
dag-flow
DAG Flow is a simple DAG workflow engine
-
wae-resilience
WAE Resilience - 弹性模式，熔断器、限流器、重试、超时
-
runat
A distributed job scheduler for Rust
-
cloud_terrastodon_pathing
Well-known paths for the Cloud Terrastodon project
-
sn_sdkg
Safe Network Synchronous Distributed Key Generation: enables dealerless section key generation
-
agent-sdk-tools
Tool traits, registry, hooks, and store contracts for the Agent SDK
-
aether-acp-utils
Agent Client Protocol (ACP) utilities for the Aether AI agent framework
-
enfipy-tigerbeetle
Safe high level async bindings to tigerbeetle client library
-
tokio-scheduler-rs
JobScheduler written with tokio runtime, automatic retry, hook and custom storage supported
-
roughage
AsyncPipeline, a deadlock-free replacement for buffered streams -
futures-async-stream
Async stream for Rust and the futures crate
-
aoc_leaderbot_aws_lib
AWS-specific support library for aoc_leaderbot, an Advent of Code leaderboard-watching bot
-
rustycog-framework
Feature-gated RustyCog framework crate
-
libevent
Rust bindings to the libevent async I/O framework
-
endringer-async
Async facade for endringer (tokio::task::spawn_blocking)
-
sdtn
SpaceArth DTN - A Rust-based implementation of Delay Tolerant Networking (DTN) for resilient communication
-
aggligator-monitor
Aggligator link monitor and speed test
-
swiftide-integrations
Fast, streaming indexing, query, and agentic LLM applications in Rust
-
atomr-agents-embed
EmbeddingActor and pluggable AnnIndex (CPU default via atomr-accel-agents)
-
sugars_async_stream
Async stream utilities and abstractions for the cyrup-sugars ecosystem
-
plunger
quickly unblock your async tasks
-
crb-runtime
CRB | Composable Runtime Blocks | Runtime
-
floop
A more convenient and less error prone replacement for loop
{ select! { .. }} -
maelstrom-node
Maelstrom Rust node framework
-
mcp-student-records
Student Records MCP Server — a Student Information System (students, courses, enrollments, grades & rubrics, attendance, support, guardians & FERPA-gated communications, transcripts…
-
async-gcode
An async gcode parser for no_std targets
-
buf-read-ext
Trait extending anything that implements BufRead with stream_until_token()
-
elizaos-plugin-shell
elizaOS Shell Plugin - Shell command execution with directory restrictions and history tracking
-
unkey
An asynchronous Rust SDK for the Unkey API
-
adk-managed
Managed agent runtime for ADK-Rust — durable, resumable, provider-neutral agent execution
-
async-reactor-trait
reactor-trait implementation for async-io
-
motore-macros
Motore's proc macros
-
tokio-process-stream
that wraps a tokio::process into a tokio::stream
-
intercom-rs
A fully typed async wrapper for NATS with JetStream support
-
hexeract-mediator
In-process mediator implementation for the Hexeract messaging framework
-
elizaos-plugin-github
GitHub plugin for elizaOS - Rust implementation
-
paladin-ports
Port trait definitions (hexagonal architecture contracts) for the Paladin framework
-
blocking-permit
Permits and a thread pool for blocking operations
-
polarway-bus
Generic, domain-agnostic event bus with fan-out, filtering, and drain buffers
-
xiaoyong-channels
Thread-safe and single-threaded asynchronous channel primitives
-
deliverust
Easy to use and lightweight async pubsub context
-
adk-agent
Agent implementations for Rust Agent Development Kit (ADK-Rust, LLM, Custom, Workflow agents)
-
mio-pidfd
mio support for Linux's pidfd
-
anysc-rustls
crate-level shim layer for any {async crate}-rustls
-
heph-inbox
Bounded capacity channel designed to be used as inbox for actors. Also supports one shot channels.
-
tokio-reactor-trait
reactor-trait implementation for tokio
-
trait-morph
A lightweight procedural macro to transform
async fnin traits into-> impl Futurewith explicit bounds -
neptune-job-queue
Prioritized, heterogeneous async/blocking job queue used by neptune-cash
-
ranvier
Typed Decision Engine facade crate for Ranvier
-
traitclaw-strategies
Built-in reasoning strategies (ReAct, MCTS, CoT) for the TraitClaw AI agent framework
-
mod-cli
A fully customizable, feature-rich CLI framework for Rust. Define commands, prefixes, styled output, and more—built for flexibility and speed.
-
rskit-worker
Task worker pool with JoinSet, typed events, and provider bridges
-
autumn-harvest-redis
Redis Streams task queue adapter for autumn-harvest
-
paladin-storage
SQL-backed repository adapters for the Paladin framework (SQLite and MySQL)
-
vcs-watch
Watch a Git or Jujutsu repository and stream typed state-change events (branch, HEAD, dirty, conflicts) — async, built on vcs-core
-
slings
A small async runtime based on io-uring for Rust
-
paho-mqtt-sys
Low-level, unsafe Rust wrapper for the Paho MQTT C Client Library. This is part of the official Eclipse Paho Rust Client Library
-
firecracker-rs-sdk
🧨🦀🚀 The Firecracker Rust SDK. A pure Rust crate for interacting with Firecracker.
-
brainwires-system
Generic OS-level primitives — filesystem event watching and system service management
-
plumbing
An async abstraction to pipeline requests through a channel
-
ppoppo-infra
Backend-agnostic infrastructure traits for caching, queuing, and messaging
-
thin_main_loop
Thin, cross-platform, main event loop. A building block for native GUI applications, among other use cases.
-
lsp-max-agent
Agent integration and analysis bundles for lsp-max
-
tokio_worker
Asynchronous, message-driven workers for Tokio applications
-
async-ops
Use std::ops traits with Futures
-
ulua
High level Luau bindings to Rust with async/await support
-
serdes-ai-streaming
Streaming support for serdes-ai (SSE, WebSocket, async streams)
-
bybit-client
client library for the Bybit V5 API with REST and WebSocket support
-
tower-sessions-ext-sqlx-store
SQLx session stores for
tower-sessions-ext -
sansio-codec
Protocol codecs for sansio: frame decoders, string codecs, and transport abstractions
-
lune-std-process
Lune standard library - Process
-
atd-server
Unix-socket listener and connection layer for ATD-speaking servers — pair with atd-runtime to build a server in ~30 lines
-
stream-download-opendal
OpenDAL adapter for stream-download
-
langgraph-pregel
Pregel-style superstep executor with sync/async invoke, streaming, and checkpoint bridge
-
laminarmq
A scalable, distributed message queue powered by a segmented, partitioned, replicated and immutable log
-
async-graphql-tide
async-graphql for tide
-
async-change-tracker
reactive change notifications using futures
-
velo-events
Velo Active Messenging Library
-
harness-rs-hooks
HookBus for harness-rs. Dispatches 29 lifecycle events with Allow/Deny/Inject/Mutate semantics. Optional OpenTelemetry feature.
-
varlink_stdinterfaces
varlink common interfaces
-
xactor
actors framework based on async-std
-
async-cron-scheduler
Runtime-agnostic async task scheduler with cron expression support
-
tirea-agent-loop
LLM inference engine, tool dispatch, and streaming execution loop for tirea
-
hedwig
message bus for Rust
-
tokio-immediate-egui
Asynchronous glue for your egui application
-
atomr-agents-persona
Persona strategies: structural (Static, Big Five, MBTI, Jungian, Composite) + emphasis
-
summer-xxl-job
Integrate xxl-job / ratch-job executor with summer-rs framework
-
ironflow-worker
HTTP-based background worker for ironflow — polls the API and executes workflows
-
fluxer-core
Rust API library for building Fluxer bots — high-level client, event system, and structures
-
rtx
zero-cost runtime-abstraction intended for use by Rust libraries to enable the Freedom of Choice between asynchronous runtimes
-
polaris-ai
A unified agent runtime where agent patterns are first-class, composable, and optimizable abstractions
-
zelos-trace-grpc
gRPC client and server for Zelos tracing system
-
apalis-board-web
Frontend components for managing Apalis task queues
-
veecle-freertos-sys
Rust bindings for FreeRTOS
-
deadpool-fantoccini
Dead simple async session pool for fantoccini
-
ultra-batch
Tokio-based library to batch and cache database queries or other data lookups
-
pincho
Official Rust Client Library for Pincho - Send push notifications with async/await support
-
celers-canvas
Workflow primitives for CeleRS (Chain, Chord, Group, Map)
-
actix-daemon-utils
Daemon Utilities by actix
-
wd_event
event system
-
anthropic-tools
interacting with the Anthropic API
-
elizaos-plugin-acp
elizaOS ACP Plugin - Agentic Commerce Protocol for checkout and commerce
-
agentic_optio_rs
Production-grade multi-agent framework with minimal dependencies - Rust implementation
-
hotaru_io_futures
futures-io adapter backend for Hotaru
-
reqsign-command-execute-tokio
Tokio-based command execution implementation for reqsign
-
echo_state
State management for echo-agent framework (memory, compression, audit)
-
roco_z21_driver
Rust API for Roco Z21 model railway control system
-
bias-rust-mcp-extra
companion crate to rust-mcp-sdk offering extra implementations of core traits like SessionStore and EventStore, enabling integration with various database backends and third-party platforms…
-
oxigdal-etl
Streaming ETL framework for continuous geospatial data processing with OxiGDAL
-
elfo
An asynchronous distributed actor framework with robust observability
-
uring-file
Async file I/O for Linux using io_uring
-
rivetkit-shared-types
Shared public types for RivetKit crates
-
pexels-cli
client for the Pexels API. API Address: https://www.pexels.com/api/documentation/
-
memory-admission
Memory-aware admission gate for parallel work pipelines (sync + async APIs)
-
llm-core
Core traits, types, and streaming primitives for the llm-cmd LLM toolkit
-
adaptivemsg
Adaptive message framework for Rust
-
mfio
Flexible completion I/O primitives
-
streamx
Stream extensions
-
trema
Memory, tracing, and multi-agent orchestration for Rust AI agents
-
phoenix_channels_client
async-ready client for Phoenix Channels in Rust
-
kotoba-server
Complete HTTP server and frontend integration system for Kotoba graph database
-
rune-chain-llm
LlmChain — wire a prompt template, an LLM, and optional memory into a single Chain
-
eureka-mmanager
An Actix actor collection for downloading manga, chapters, covers from Mangadex
-
wovyr-audit
Tamper-evident audit logging: hash-chained, append-only security records (who did what, when, with what outcome)
-
ogre-stream-ext
futuresshortcuts with ergonomic extensions to unlock the full power of Streams in Rust -
rs_ctx
Context propagation for rs framework
-
folk-api
Plugin contract for the Folk PHP application server
-
tirea-agentos
Agent runtime with streaming LLM integration, sub-agent orchestration, and context window management
-
spawns-compat
Async runtime detections for thread context task spawner
-
babelforce-manager-sdk
Rust SDK for the babelforce manager APIs — auth, user & agent management, call reporting, metrics, and task automations
-
palladium-plugin
Native (cdylib) and WASM plugin system for Palladium actors
-
ferrisgram
An elegent rust client for the Telegram Bot API
-
infect
Intent/effect/task - A variation on the Model View Intent (MVI) and State Action Model (SAM) paradigms
-
t2_bus
An inter- or intra-process message bus supporting publish/subscribe and request/response
-
tor-general-addr
Generalized socket address type used by Tor
-
actix-interop
Use async/await syntax with actix actors
-
shutdown-handler
A shutdown handler that allows all parts of an application to trigger a shutdown
-
reliability-toolkit
Async reliability primitives for Rust: rate limiter, circuit breaker, retry with jitter, bulkhead. Optional audit-stream-py integration via the
audit-streamfeature. -
evidentsource-client
Rust client for the EvidentSource event sourcing platform
-
zerodds-dcps-async
Runtime-agnostic async wrappers around the ZeroDDS DCPS sync API (zerodds-async-1.0 spec): write/take Futures, SampleStream, DataAvailableStream, PublicationMatchedStream — no thread block, native Reader-Slot waker
-
rpi-agent
Agent runtime + loop, Rust port of pi-agent-core core layer
-
xiaoyong-notify
Thread-safe and single-threaded asynchronous notification primitives
-
ai-agents-disambiguation
Intent disambiguation support for AI Agents framework
-
elfo-telemeter
Collects and exposes metrics of the elfo system
-
mikrotik-tokio
Tokio-based async client for MikroTik RouterOS API
-
ferro-broadcast
WebSocket broadcasting and real-time channels for Ferro framework
-
stackful
Bridge between sync and async
-
spin_on
inefficient Future executor
-
borrow_mutex
Async Rust Mutex which does not require wrapping the target structure
-
paladin-notifications
Notification adapter implementations for the Paladin framework (email, push, system)
-
zookeeper-async
An async ZooKeeper client
-
actix-remote
ergonomic remote actors via actix and canary
-
wuhu
framework for building LLM agents. Streaming, concurrent, graceful.
-
ditto-os
A powerful Rust-based browser automation framework
-
eko-core
A pure state-graph execution engine for building AI agents in Rust
-
reactive-messaging
Reactive client/server communications, focused on high performance
-
flowly-service
Flowly is a library of modular and reusable components for building robust pipelines processing audio, video and other
-
umbral-tasks
DB-backed background task queue for umbral: define tasks, enqueue them, and run them with a worker process
-
lmlet
Distributed AI Agent orchestration infrastructure. [O]
-
mapped_futures
A collection of futures based on FuturesUnordered that supports insertion, removal and mutation of futures by key
-
toy-rpc
An async RPC that mimics golang net/rpc's usage and supports both async-std and tokio
-
flashq
High-performance Rust client for flashQ job queue
-
aether-mcp-utils
MCP client and server utilities for the Aether AI agent framework
-
telltale-runtime
Choreographic programming for Telltale - effect-based distributed protocols
-
crux-agentic
Built-in step handlers for crux-script pipelines
-
llm-kit-openai-compatible
OpenAI-compatible provider implementation for the LLM Kit - supports OpenAI, Azure OpenAI, and compatible APIs
-
dialectic
Transport-polymorphic, asynchronous session types for Rust
-
forecite
Official Rust SDK for the Forecite API — scored news feed (REST), Verdict scoring, and realtime WebSocket streaming
-
simple-middleware
General purpose middleware crate
-
shelly-axum
Axum adapter for Shelly LiveView
-
announcement
A runtime-agnostic oneshot broadcast channel
-
peace_rt_model
Runtime data types for the peace automation framework
-
async-local-channel
Lightweight channels for single-threaded async runtimes
-
medea-reactive
Reactive mutable data containers
-
hexeract-bus
Message bus primitives for the Hexeract messaging framework
-
hornetmq
A fast, Redis-backed job queue for Rust — fully compatible with BullMQ
-
can-isotp-queue
Queue/actor adapter for split ISO-TP TX/RX endpoints across async runtimes
-
agui-rs
Rust SDK for the AG-UI (Agent-User Interaction) protocol — facade crate
-
hotaru_rt_tokio
Tokio runtime backend for Hotaru
-
gprs
A set of filtered and optimized Rust libraries creates a foundation for building modern web frameworks
-
lambda_runtime_context
Task-local runtime deadline helpers for async Rust workers and AWS Lambda handlers
-
persway
Sway IPC daemon
-
async-signal
Async signal handling
-
veecle-freertos-integration
Rust wrapper for FreeRTOS
-
mill-net
High-level networking protocols components built with mill-io event-loop library
-
tower-sessions-rusqlite-store
(tokio-)rusqlite session store for
tower-sessions -
hyphen
Rust SDK for the hyphen diagnostic platform — sinks, adapters, catalog, and emit surface
-
smpsc
Wrappers for tokio's mpsc channels which implement Stream and Sink
-
futures-util-delegate-access-macros
Copy and pasted macros from the futures_utils library used for creating combinators
-
corcovado
Non-blocking IO library
-
tario
Asynchronously read and write TAR archives
-
xilinx-dma
Userspace Xilinx AXI DMA Interface
-
waitlist
Keep track of an ordered list of Wakers to wake
-
oxi-ai
Unified LLM API — multi-provider streaming interface for AI coding assistants
-
seams-rs-fake
Deterministic in-memory seams-rs-core implementations: ManualClock, InstantSleeper, CurrentThreadSpawner, MemoryFileSystem
-
tokio-util_wasi
Additional utilities for working with Tokio
-
orchflow-terminal
High-performance terminal I/O management with PTY support, buffering, and stream processing
-
futuristic
Extensions to the futures crate
-
frp-engine
Async neuro runtime for the infinite-db frp backend
-
portable_async_sleep
A portable async sleep function for Rust
-
enact-security
Security policy, audit logging, and sandboxing for Enact agents
-
atd-sdk
Rust SDK for the ATD (Agent Tool Dispatch) protocol — connect to any ATD-speaking server over Unix sockets
-
smolscale
A high-performance async-task scheduler
-
async-observable
Async & reactive synchronization model to keep multiple async tasks / threads partially synchronized
-
sactor
actor framework for Rust
-
stund
An SSH tunnel maintenance daemon
-
tokio-netem
— pragmatic AsyncRead, AsyncWrite I/O adapters for chaos & network emulation
-
stream-dup
Duplicate a single Stream into multiple identical Streams
-
wae-queue
WAE Queue - 消息队列抽象层，支持内存队列、Redis 和 RabbitMQ
-
zendo-sdk
Async client for the Zendo motion-tracking WebSocket stream
-
lash-provider-google
Google OAuth (Gemini via Code Assist) provider for lash
-
futures-delay-queue
Async delay queue backed by async-std and futures-timer
-
durable-workflow
First-party Rust SDK for Durable Workflow workers and clients
-
polaris_tools
Tool framework for Polaris agents
-
luminal_rt
A DLL-boundary safe async runtime with tokio-compatible API
-
faucet-sink-jsonl
JSON Lines file sink connector for the faucet-stream ecosystem
-
fastwebsockets-stream
An adapter that exposes fastwebsockets::WebSocket as a Tokio AsyncRead/AsyncWrite stream
-
tokio-btls
SSL streams for Tokio backed by BoringSSL
-
async-timeouts
An instrument to start async tasks after timeouts
-
moxie
Incremental runtime for interactive software
-
philo
A secure, streaming-first Rust SDK for multi-provider LLM applications
-
wabot-feature-mindset
Mindset framework — port of wabot-ts feature/mindset. System-prompt builder, tool collection, and function-call dispatch.
-
adk-anthropic
Dedicated Anthropic API client for ADK-Rust
-
rskit-storage-gcs
Google Cloud Storage backend for rskit-storage
-
oxide-update-engine
A framework for declaring and executing sequential update steps with serializable event streams
-
nexo-driver-permission
MCP
permission_prompttool used by the nexo-rs driver to gate Claude Code tool calls. Phase 67.3. -
taquba-jobs
Durable, typed async function execution on top of the Taquba durable task queue
-
agentic-sandbox
Sandboxed code execution: Process, Docker, Firecracker, Gateway
-
passivized_vault_client
Vault Client - initialize and monitor Hashicorp Vault nodes
-
safina-timer
Safe async timers - ARCHIVED: Code moved to
safinacrate -
minimal-executor
A minimal executor for asynchronous tasks based on the futures-rs library
-
orchflow-mux
Terminal multiplexer abstraction layer supporting tmux, mock backends, and custom implementations
-
arcature-pages
Arcature special-page runtime: 403/404/429/500/503/maintenance pages with a self-contained HTML fallback and ops-driven maintenance state
-
disposition_ir_model
SVG diagram generator intermediate representation
-
macro-support
NASA 过程宏的运行时路径发现(proc-macro-crate 封装,内部 crate)
-
dvb-stream
Async/tokio stream adapters over dvb-si SiDemux and dvb-t2mi T2miPump
-
outfox-openai
Openai for outfox
-
fut-compat
Offers compatibility between the tokio and async_std runtimes
-
tokio-dtrace
DTrace probes for Tokio
-
pirates
async RPC lib
-
v_exchanges_book
Orderbook abstraction for v_exchanges
-
infinite-db-frp
A unified facade for the infinite-db frp backend: graph modeling, weaving, signals, runtime, and storage with feature-gated subsystems
-
turul-llm-openai
OpenAI-compatible adapter for the turul-llm LlmClient trait. Targets /chat/completions with response_format = json_schema.
-
openraft-rocksstore
A rocksdb based implementation of the
openraft::RaftStoragetrait -
avx-runtime
AVX Runtime - Native async runtime built from scratch to replace Tokio with work-stealing scheduler, epoll/kqueue/IOCP, and zero-overhead futures
-
parallel-stream
Data parallelism library for async-std
-
starweft-store
SQLite-backed persistent storage layer for starweft
-
wae-scheduler
WAE Scheduler - 任务调度器，支持 Cron、定时任务、延迟任务
-
ironsaga
Command pipeline orchestration with automatic LIFO rollback and recursive compensation, for sync and async Rust workflows
-
backdrop
Drop your large or complex objects in the background with Backdrop! (later, on another thread, or both! Fully customizable! Tokio supported!)
-
rskit-messaging-rabbitmq
RabbitMQ adapter for rskit-messaging
-
anyspawn_azure
Azure SDK async runtime and process executor backed by an anyspawn spawner and a tick clock
-
alchemy-llm
Unified LLM API abstraction layer supporting 10+ providers through a consistent streaming interface
-
appletheia-application
The Application Layer for Event-Sourcing Architecture
-
eventide-domain
Domain layer for the eventide DDD/CQRS toolkit: aggregates, entities, value objects, domain events, repositories, and an in-memory event engine
-
arbeitssklave_tokio
tokioadapter forarbeitssklaveactors framework -
fukurow-siem
SIEM integration for Fukurow (Splunk, ELK, Chronicle)
-
aoc_leaderbot_slack_lib
Slack-specific support library for aoc_leaderbot, an Advent of Code leaderboard-watching bot
-
helius-stream
Resilient Helius WebSocket client for Solana with gap detection, reconnect backoff, and circuit breaker. Extracted from a battle-tested MEV engine.
-
chump-messaging
Platform-agnostic messaging trait for LLM agents: MessagingAdapter contract for Telegram/Slack/Matrix/Discord/web adapters PLUS Broker trait for agent-to-agent inbox messaging (FileBroker concrete impl matches Chump's…
-
io-stream
Set of I/O-free coroutines and runtimes to manage streams
-
acktor-ipc
Interprocess communication support for the acktor actor framework
-
enact-observability
Observability and telemetry for Enact
-
ruchei
working with many streams
-
spin-executor
Spin SDK async executor
-
rs-obs-signal
observer pattern with variadic template arguments
-
tabularium-sdk
Async Rust client for the Tabularium plugin registry HTTP API
-
aggligator-transport-usb
Aggligator transport: USB
-
ferro-projection
Live read-model runtime: subscribe to domain events, persist per-key snapshots, broadcast deltas (not the same as ferro-projections plural)
-
priest
Rust SDK for the priest protocol (spec v2.6.1)
-
actix-limitation
Rate limiter using a fixed window counter for arbitrary keys, backed by Redis for Actix Web
-
traffic-light
single-threaded blocking asynchronous executor for Rust
-
flows-json
Building blocks for flow-based JSON encoding & decoding
-
adk-session
Session management and state persistence for Rust Agent Development Kit (ADK-Rust) agents
-
herdr-plugin
Ergonomic Rust SDK surface for Herdr plugins
-
obzenflow
High-performance event streaming and processing framework
-
logimesh
RPC Microservice 2.0 framework
-
notifier_hub
cannal subscribtion system
-
a3s-flow
Durable workflow engine and Rust SDK for A3S
-
aimux-provider-utils
Shared utilities for aimux provider implementations
-
asyncapi-rust-models
Runtime data structures for asyncapi-rust (AsyncAPI 3.0 spec models)
-
llm-kit-groq
Groq provider implementation for the LLM Kit - supports chat and transcription models
-
async-tun
Asynchronous allocation of TUN/TAP devices using async-std
-
celers-cli
Command-line interface for CeleRS worker and queue management
-
myko
myko in rust
-
pulsync
Schedule Async and Sync Task with ease
-
i2o2
A io_uring based IO executor for sync and async runtimes
-
victorops
Async Rust client for VictorOps
-
rrq-protocol
Shared RRQ runner protocol types
-
atd-server-http
Streamable-HTTP (MCP JSON-RPC) transport for ATD-speaking servers — pair with atd-runtime, sibling of atd-server (Unix-socket transport)
-
asyncjsonstream
Async JSON stream reader for selective parsing of large payloads
-
aion-server
Aion workflow server library: HTTP, gRPC, WebSocket, and worker endpoints. Run it with the
aionbinary from the aion-cli crate. -
tokio_wasi
An event-driven, non-blocking I/O platform for writing asynchronous I/O backed applications
-
nenjo-tools
Tool trait, types, and built-in tool implementations for the Nenjo agent platform
-
lyo
automatic task distribution
-
memable
An embeddable durable execution engine using key-based memoisation
-
physxx
Wrapper around the PhysX C++ API that aims to preserve the original API as much as possible
-
claw-core-protocol
Async Rust client and protocol types for the claw_core daemon (JSON-over-Unix-socket). Use standalone or with ZeroClaw via --features claw-core.
-
dscode-lsp
Language Server Protocol client, manager, and connection pool for DSCode
-
enact-a2a
Multi-agent and A2A (Agent-to-Agent) protocol support for Enact
-
mailroom
Async outbox for reliable message delivery in distributed microservices
-
everruns-anthropic
Anthropic (Claude) provider for Everruns agents
-
libindigo-rs
Pure Rust implementation of the INDIGO protocol client
-
elizaos-plugin-s3-storage
elizaOS S3 Storage Plugin - AWS S3 and S3-compatible storage integration
-
serverless-fn
simplifying serverless function development and invocation
-
leptos_async_signal
Async signal for leptos Rust web framework
-
neuron-tool
Tool interface and registry for neuron
-
popol
Minimal non-blocking I/O
-
tokio-context
Contexts for cancelling asynchronous tasks using tokio
-
iflow-cli-sdk-rust
Rust SDK for iFlow CLI using Agent Client Protocol
-
tokio-graceful-shutdown-without-anyhow
perform a graceful shutdown on a Tokio based service
-
rumpsteak-aura-fsm
Session types for asynchronous communication between multiple parties (Aura flavored)
-
stream_shared
creating shareable streams that can be cloned and consumed by multiple consumers
-
async-raft
An async implementation of the Raft distributed consensus protocol
-
agentBrowser
Unified Rust SDK for LLM APIs: Tongyi, DeepSeek, Wenxin, Hunyuan, GLM, Volcengine, OpenAI, Claude, Gemini, Mistral
-
rust-task-queue
Production-ready Redis task queue with intelligent auto-scaling, Actix Web integration, and enterprise-grade observability for high-performance async Rust applications
-
compio-process
Processes for compio
-
hyperbridge
Fast multi-producer multi-consumer channel with async support
-
warp-rate-limit
Rate-limiting middleware for the Warp web framework
-
googleapis-tonic-google-cloud-support-v2beta
A Google APIs client library generated by tonic-build
-
runc
consuming the runc binary in your Rust applications
-
futures_codec
encoding and decoding frames using
async/await -
codex-app-server-sdk
Tokio Rust SDK for Codex App Server
-
tokio-nsq
NSQ client built on Tokio. Tokio NSQ aims to be a feature complete NSQ client implementation.
-
merkql-notify
Notification trait and types for merkql event streaming
-
tenorite
A concurrency abstraction library. Provides a client-server model for asynchronous workers
-
novel-zhipu
Zhipu AI (GLM) API client for novel
-
async-llm
Async Rust client for LLM APIs - Anthropic Messages API today; fork of async-anthropic with thinking-block and prompt-cache support
-
tbot
Make cool Telegram bots with Rust easily
-
axocoatl-daemon
Persistent agent daemon runtime for Axocoatl — bootstraps and orchestrates all subsystems
-
brainwires-call-policy
Resilience middleware (retry, circuit breaker, budget, cache, error classification) for the Brainwires Agent Framework
-
abort-on-drop
A wrapper of Tokio's JoinHandle that aborts the task when it's dropped, while still allowing it to be awaited for joining
-
continue_stream
A Swift-style AsyncIterator.Continuation-style channel for Rust
-
background-jobs-tokio
in-process jobs processor based on Tokio
-
strontium-palladium
Deterministic fault-bridge contracts for Palladium actor simulations under Strontium control
-
orchestral
Workflow orchestration for grounded agents — stateful multi-step pipelines with agent loop, MCP tools, and skills
-
neuron-context
Context strategy implementations for neuron-turn
-
pierport
Urbit pier import protocol implementation
-
eventastic_postgres
A postgres event store for eventastic
-
bader-db
Key-value cache RESP server with support for key expirations
-
adk-payments
Protocol-neutral agentic commerce and payment orchestration for ADK-Rust
-
legend
Strict, composable saga VM for sequential workflows with compensation
-
ollama-client
Async and blocking Rust client for the Ollama API
-
sipper
A type-safe future that can notify progress
-
queued-task
concurrent queue task processing
-
safina-net
Safe async network functions - ARCHIVED: Code moved to
safinacrate -
deepseek_rs
client library for the DeepSeek API
-
beetry
Behavior tree framework with a runtime, plugin system, and Beehive editor
-
lsp-max
Law-state LSP runtime: max LSP 3.18 coverage, process-mining conformance, receipt-chain admission
-
vesper
A slash-command framework meant to be used with twilight
-
raftoral
Fault-tolerant workflow orchestration library using embedded Raft consensus for Rust applications
-
chronon-telemetry
TelemetrySink trait and console/no-op adapters for Chronon
-
primp-tokio-rustls
Fork of tokio-rustls
-
co_managed
Create managed sub coroutines. Managed sub coroutines will be cancelled when the parent exit
-
harness-rs-tools-fs
Jail-safe filesystem tools (read_file, write_file, edit_file, list_dir, grep, glob) for harness-rs. Symlink-escape protection.
-
metronomos-actor
A small, tokio-based actor framework for Rust
-
tiny-loop
Minimal AI agent framework
-
clone-stream
Turn any Stream into a cloneable stream where each clone receives all items independently
-
pubsub-rs
powerful publish-subscribe (pubsub) system that allows multiple subscribers to receive messages published to specific topics. It is designed to be thread-safe, async-friendly, memory-efficient…
-
aimux-core
Core abstractions for aimux: LanguageModel trait, message types, and user-facing API
-
tokio-uring-xitca
a fork of tokio-uring with miniaml maintenance
-
pptr
Type-Driven Asynchronous Actor Runtime
-
mofa-runtime
MoFA Runtime - Message bus, agent registry, and event loop
-
hexeract-middleware
Built-in middlewares for the Hexeract messaging framework: tracing spans and dispatch timeouts
-
camel-component-exec
Fail-closed system command execution component for rust-camel
-
polaris_agent
Agent trait for defining reusable behavior patterns in Polaris
-
peace_fmt
Presentation and formatting support for the peace automation framework
-
fastn-context
Type-safe async context propagation for Rust applications
-
pilatus-axum
Axum web integration for the Pilatus framework
-
kappa
actor framework, this one based on the lambdas/behaviors
-
tea-model
Provider-neutral model port for tea-rs
-
shardd
Official Rust client for shardd — a globally distributed credit ledger with automatic regional failover
-
wolfcrypt-tls-tokio
Async TLS backed by wolfSSL — tokio AsyncRead/AsyncWrite
-
sse-gateway-redis
Redis adapters for SSE Gateway (Pub/Sub source and Streams storage)
-
rustigram-miniapp
Axum extractors, initData validation, and ts-rs type bridge for Telegram Mini Apps
-
orengine
Optimized ring engine for Rust. It is a lighter and faster asynchronous library than tokio-rs, async-std, may, and even smol
-
rust-genai-types
Shared types for the Rust Gemini SDK
-
tokio-task-scheduler
A non-blocking task scheduler for Rust with fluent API, supporting interval-based and cron-like scheduling
-
volo-macros
Volo's proc macros
-
wamp_async
An asynchronous WAMP implementation
-
llm-openai
OpenAI Chat API provider for the llm-cmd toolkit
-
fundamentum-edge-pfwd
The port forwarding tool for edge daemon
-
atomr-agents-avatar-core
Avatar domain types for real-time, embodied agents: ARKit blendshape weights, viseme→blendshape mapping, AvatarFrame timecoding, AvatarSink trait, and the Live Link CBOR wire format…
-
rust-tg-bot
Complete Telegram Bot API framework for Rust, inspired by python-telegram-bot
-
eyeball-im
Observable collections based on the
imcrate -
pe-matrix
Matrix reasoning and empirical routing for Potential Expectations — tensor operations, convergence detection, and empirical logging
-
jsoncall
asynchronous JSON-RPC 2.0 library leveraging Rust's type system
-
aj
Background Job Library for Rust
-
tokio-async-drop
macro to enable async drop in a tokio multithreaded runtime
-
monoio-codec
Codec for Monoio
-
route-sink
Sinks with routes
-
flowbuilder-yaml
YAML/JSON dynamic flow loading for FlowBuilder
-
catloaf
core-affine, thread-local, opinionated actor framework
-
fork_stream
Clone any stream
Swhere<S as Stream>::Item: Clone -
botkit
Unified Rust bot framework with optional Discord, Telegram, and Matrix adapters
-
async-log
Async tracing capabilities for the log crate
-
overclock
A framework for building data-driven distributed systems
-
gemini-adk-fluent-rs
Fluent DX for Gemini Live — builder API, operator algebra, composition modules
-
background-jobs-sled
Sled storage backend for background-jobs
-
tokioraft
A minimal Tokio-based leader election library inspired by tinyraft
-
kafka-threadpool
An async rust threadpool for publishing messages to kafka using SSL (mTLS) or PLAINTEXT protocols
-
apalis-pgmq
Background task processing for rust using apalis and pgmq
-
lash-provider-openai
OpenAI providers for lash: API-key (OpenRouter, OpenAI, vLLM, etc.) and Codex OAuth (ChatGPT Plus/Pro/Team)
-
realhydroper-lsp
Language Server Protocol implementation based on Tower
-
mongodb-gridfs
Mongo GridFS
-
langgraph-core
Graph model, state containers, channels, and runtime types for LangGraph-style workflows in Rust
-
shipper-retry
Retry strategies and backoff policies for shipper
-
riceprompt-engine
YAML-native Agent workflow execution engine
-
bus-nats
NATS JetStream backend for eventbus-rs
-
apalis-board-types
Shared types and data structures used by the apalis-board workspace
-
ruststream-nats
NATS / JetStream broker implementation for the RustStream messaging framework
-
nuclei
Proactive IO & runtime system
-
motosan-chain
Composable AI chain primitives for Rust
-
thorstreamer-grpc-client
Rust client for ThorStreamer gRPC streaming services
-
openhawk-bus
JSON-RPC message bus for inter-agent communication in OpenHawk
-
rs-sqs-receiver
An asynchronous AWS SQS message receiver framework with trait-based handlers and shared resource support
-
pulsess
A robust and flexible background job processing library for Rust
-
cbsk_run
async pool tool
-
rusty_tarantool
Tarantul async client based on tokio framework
-
hwhkit-integration-s3
HwhKit S3-compatible storage integration (AWS S3 / MinIO)
-
asyncs
async runtime agnostic facilities
-
folk-plugin-process
Auxiliary process supervisor plugin for Folk — starts, monitors, and restarts sidecar processes
-
nest-rs
NestRS framework umbrella — re-exports the core and the surface crates an app reaches for, with a
preludefor the common case -
futures-ticker
An asynchronous recurring time event
-
serdes-ai-retries
Retry strategies and error handling for serdes-ai
-
hollywood
actor framework
-
rustbridge-runtime
Tokio async runtime integration for rustbridge
-
trace_id
A lightweight, high-performance tracing ID generation and propagation library for Rust, with out-of-the-box support for Axum
-
pi-agent
Agent runtime with tool calling (Rust port of @earendil-works/pi-agent-core). Streaming agent loop, permission policy, built-in tools (read/write/edit/bash/grep/glob/web_fetch/todo).
-
jamjet-api
JamJet REST API server — control plane for workflow management
-
async_closure
utilizes the nightly-only feature async_fn_in_trait to imitate async_closures
-
ta-events
Event system and subscription API for Trusted Autonomy
-
ubl-office
Execution environment for LogLine Agents: lifecycle, memory, and I/O coordination
-
rivetkit-actor-persist
Versioned persistence protocol types for RivetKit actors
-
vuo
An asynchronous stream processing library for Rust, built on Actix, providing a rich set of functional operators
-
agnostik
Executor Agnostic Runtime that can run your futures with your favourite Executor
-
devsper-graph
Distributed AI Swarm Runtime
-
mm1-proto
An Erlang-style actor runtime for Rust
-
randomio
Async random-access I/O traits (write_at/read_at) for files, block devices, and object storage. The AsyncWrite equivalent for offset-based I/O.
-
fluxion-exec
Async stream subscribers and execution utilities for fluxion
-
tirea-extension-handoff
Agent handoff extension: same-thread agent switching with dynamic overlay for tirea agents
-
cron-core
A cron task scheduler library for Rust with async runtime support
-
ai-agents-process
Input/Output processing pipeline for AI Agents framework
-
worklane-cli
Operator CLI for inspecting and maintaining worklane brokers
-
claude-code-sdk-rust
Async Rust SDK for the Claude Code CLI: streaming agent turns, tool use, and sessions
-
turbocharger
Autogenerated async RPC bindings that instantly connect a JS frontend to a Rust backend service via WebSockets and WASM
-
openrouter-client
Idiomatic async Rust SDK for the OpenRouter API
-
mpm-cli
Modrinth Package Manager
-
smelling_salts
Abstraction over OS APIs to handle asynchronous device waking
-
libdd-shared-runtime
Shared tokio runtime with fork-safe worker management for Datadog libraries
-
moirai-durable
Durable future support for Moirai job system
-
awaitable
type with input and output that can be stored in container
-
inferadb-common-ratelimit
Distributed fixed-window rate limiter using StorageBackend
-
dyn-timeout
Dynamic timeout, cancel, add and remove time before a callback execution
-
cancellation-token
C#'s CancellationToken API
-
lib3mf-async
Non-blocking async 3MF parsing with tokio - high-throughput manufacturing data processing
-
codex-client-sdk
Rust SDK for embedding the Codex agent via CLI-over-JSONL transport
-
xlet
Distributed AI Agent orchestration infrastructure. [O]
-
async-time-mock-async-std
Mockable time for use in async runtimes (async-std compatibility)
-
fure
Retrying futures using different policies
-
rune-chain-memory
In-process conversation memory implementations for the rune-chain LLM orchestration framework
-
polars-async
Async runtime and utilities of the Polars project
-
asyncron
Executor agnostic task manager and async scheduler for Rust
-
adk-plugin
Plugin system for ADK-Rust agents
-
locus-sdk
SDK-first STTP memory primitives and AI provider abstraction
-
hyper-serve
High level server designed to be used with axum framework
-
skg-state-memory
In-memory StateStore implementation for skelegent
-
tokio-shutdown
Wait for a stop signal across multiple threads
-
cloud_terrastodon_relative_location
A helper for converting std::panic::Location to relative paths with displayed
-
elizaos-plugin-mcp
MCP (Model Context Protocol) client plugin for elizaOS - Rust implementation
-
otherone
— 轻量级、可扩展的 Rust AI Agent 框架
-
ailoop
High-level façade for building LLM agent loops in Rust
-
streamweave-attractor
Attractor pipeline as a StreamWeave graph
-
crb-system
CRB | Composable Runtime Blocks | System Integration
-
alopex-chirps-gossip-swim
SWIM-based gossip protocol implementation for Alopex Chirps
-
openai-compat
Async Rust client for OpenAI-compatible LLM provider APIs
-
flowly-kafka
reusable kafka component for flowly
-
futures-udp
Non-blocking async UDPSocket, Stream & Sink. Runtime agnostic: works with tokio & futures-rs. Minimal dependencies.
-
toptl
Official Rust SDK for the TOP.TL Telegram directory API — post stats, check votes, manage vote webhooks
-
faucet-sink-parquet
Apache Parquet file sink connector for the faucet-stream ecosystem
-
tokio-shared-rt
Allow
#[tokio::test]to use a shared runtime -
cruxx
An agentic DSL for Rust — inspectable, serializable, replayable agent execution
-
tripo-api
Unofficial async Rust client for the Tripo 3D Generation API
-
toptl-teloxide
Teloxide plugin for TOP.TL — autopost bot stats, gate handlers behind votes, handle vote webhooks
-
asynkit
Abstractions for runtime-independent crates
-
mobc-forked
A generic connection pool with async/await support
-
tianshu-observe
Observer implementations for the Tianshu workflow engine
-
tokio-stream-util
Extension traits and utilities for tokio-stream’s
Streamtrait -
capp
Common things i use to build Rust CLI tools for web crawlers
-
neuron-loop
Agentic loop for Rust — multi-turn tool dispatch, streaming, and conversation management over any LLM provider
-
roux-stream
A streaming API for the roux Reddit client
-
folk
Reference binary for Folk PHP application server
-
nsq-client
Rust client for the NSQ realtime message processing system
-
argus-worker
Worker implementation for distributed web crawling
-
unsend
A thread unsafe runtime for thread unsafe people
-
rediq
A distributed task queue framework for Rust based on Redis
-
fusio-parquet
Parquet reader and writer implementations for Fusio
-
tor-rpc-connect
Common implementation logic for Arti RPC Connect points
-
mboxlabs-mailbox
A lightweight, pluggable mailbox/queue kernel inspired by the Erlang Actor Model
-
cognate-llm
A modular, extensible LLM framework for Rust with multi-provider support, type-safe tools, and RAG capabilities
-
mio_wasi
Lightweight non-blocking IO
-
rl-tokio
In-process token-bucket rate limiter for async tokio runtimes
-
adk-sandbox
Isolated code execution runtime for ADK agents
-
event_hex
A pragmatic Rust toolkit for Domain-Driven Design with first-class support for event sourcing and CQRS
-
rs_events
A flexible and ergonomic event emission crate for Rust. Supports both std/threaded and no_std/alloc environments, with tagging, listener lifetimes, async/sync emission, and robust error handling.
-
rskit-stream
Foundational async stream toolkit: bounded fan-out broadcaster, sources, cancellable tasks, and futures::Stream extension operators
-
rusplay
Memory safe, blazing fast Rugplay library written in Rust
-
nodevent
Node.js-style event bus
-
zinit-client
client library for interacting with Zinit service manager
-
atomic-waker
A synchronization primitive for task wakeup
-
futuredsp
A signal processing library for SDR and real-time DSP
-
again
wasm-compatible retry util for std library futures
-
tasked
Embeddable DAG task execution engine with durable SQLite storage
-
elizaos-plugin-bluebubbles
BlueBubbles iMessage bridge plugin for ElizaOS agents
-
atomr-agents-tool
Tool trait, ToolSet, registry, permission spec, and tool-call parsers
-
task-notify
Notify async tasks when someone mutates data they're interested in
-
nexo-config
YAML configuration loader with env var resolution for Nexo agents
-
tower-batch
tower-batchis a Tower middleware that allows you to buffer requests for batch processing until the buffer reaches a maximum size OR a maximum duration elapses -
folk-plugin-metrics
Prometheus metrics and health check plugin for Folk — serves /metrics, /health, and /ready endpoints with custom metrics and plugin filtering
-
bext-realtime
Realtime pub/sub for bext — WebSocket and SSE with optional Redis relay
-
atask
An async task implementation
-
streamline
Reversible futures::Stream-based state machines
-
dope-futures
Thin io_uring adaptor with "Manifolds"
-
spsc
An entangled sync sender + async receiver pair
-
async-attributes
Experimental language-level polyfills for Async Rust
-
faucet-source-csv
CSV file source connector for the faucet-stream ecosystem
-
poolparty
Added functionality for the
futures::executor::ThreadPoolfutures executor -
ai-agents-persona
Agent persona system for AI Agents framework
-
async-rusqlite
A tiny executor agnostic wrapper around rusqlite to make calls to it async
-
rrq
RRQ orchestrator CLI and worker runtime
-
swiftide-docker-service
A docker executor for swiftide agent tools
-
flows-http
Building blocks for flow-based HTTP requests & responses
-
naoutbox-core
NASA Outbox 核心:业务 DB 事务内写事件(Debezium Outbox Event Router 兼容),不依赖 Kafka/napp
-
better-posthog
An ergonomic Rust SDK for PostHog
-
mixi2
Async Rust SDK for the mixi2 Application API
-
rxqlite-tests-common
A distributed sqlite database built upon
openraft,sqlxandsqlite -
compio-ws
WebSocket library for the compio runtime
-
cel-summarizer
LLM-backed Summarizer implementations (Anthropic + Ollama) for cel-memory
-
backyard-core
Core traits and types for the Backyard async job queue
-
recurring-tasks
Define tasks and run them in an app periodically, ala cronjobs. And don't run already/still running tasks.
-
prestige-cli
CLI interface for manually fetching and reading Prestige-parquet files
-
boson-backend-sqlite
SQLite QueueBackend adapter for Boson
-
wae-event
WAE Event - 事件驱动模块，支持发布订阅模式
-
turbine-llm
Unified Rust interface for multiple LLM providers with growing model support
-
crb-send
CRB | Composable Runtime Blocks | Send
-
lightshuttle-runtime
Container runtime backends and lifecycle manager for LightShuttle
-
upstox-rust-sdk
SDK to access Upstox's Uplink APIs programmatically
-
retrier
A wasm-compatible retry library for futures
-
radarcord-rs
An API wrapper for the Radarcord bot list
-
async-timers
asynchronous timer primitives
-
peace_data
Data model for the peace automation framework
-
prodash
A dashboard for visualizing progress of asynchronous and possibly blocking tasks
-
oxidizedgraph
A humble attempt at LangGraph in Rust - R-LangGraph framework for building AI agent workflows
-
rusty_claw
Claude Agent SDK
-
atomr-agents-stt-tool
Tool + Skill adapters that expose atomr-agents speech-to-text inside the agent framework
-
audacity-sdk
Rust SDK for the Audacity Investments AI gateway — Amazon Bedrock Converse-compatible API surface
-
safina-executor
Safe async runtime executor - ARCHIVED: Code moved to
safinacrate -
stopper
an async stream and future stopper mechanism
-
shedul3r
Task execution server with rate limiting, circuit breaking, and retry. Install via cargo binstall.
-
ai-agents-relationships
Actor relationship memory for AI Agents framework
-
futures-scan-ext
futures stream scan combinator for sync closures
-
ironclaw-core
Core traits and types for the IronClaw AI agent framework
-
mcp-await
Condition watcher MCP server + CLI for AI assistants — block until a port opens, a file changes, a URL responds, a process exits, and more
-
reqchan
channel for requesting and receiving data. Each channel has only one requesting end, but it can have multiple responding ends. It is useful for implementing work sharing. The two ends…
-
hooch
A small async runtime that's been bootlegged for my projects
-
rivet-metrics
Prometheus metric helpers for Rivet crates
-
adk-action
Shared action node types for ADK-Rust graph workflows
-
harness-rs-compactor
Five-stage progressive context compactor for harness-rs — DefaultCompactor (structural) and ModelBackedCompactor (semantic)
-
async-mcp
Async Implementation of Model Context Protocol (MCP)
-
coralstack-cmd-ipc-mcp
MCP server adapter that exposes a coralstack-cmd-ipc CommandRegistry as Model Context Protocol tools
-
mixtape-anthropic-sdk
Minimal Anthropic API client for the mixtape agent framework
-
tonic
A gRPC over HTTP/2 implementation focused on high performance, interoperability, and flexibility
-
sansio-executor
sansio executor
-
async-duplex-channel
An asynchronous duplex communication channel between multiple clients and a single responder in different asynchronous blocks
-
knien
Typed RabbitMQ interfacing for async Rust
-
cirious_codex
A unified, next-generation modular toolset and facade framework providing config, logging, diagnostics, CLI scaffolding, and metrics
-
axocoatl-actor
Actor-based agent runtime for Axocoatl, built on ractor
-
paigasus-helikon
Paigasus AI SDK — facade crate. Re-exports core plus feature-gated providers and runtimes.
-
hwhkit-scheduler
HwhKit persistent background scheduler (cron + one-shot, PG/Redis-backed leadership)
-
merkql-notify-sqs
AWS SQS notification plugin for merkql
-
miniloop
The simpliest async executor without heap memory allocation
-
async-regex
Empower regex with streaming capabilities - high-performance async streaming pattern search using regex for multi-byte pattern matching in data streams
-
prism3-retry
Retry module, providing a feature-complete, type-safe retry management system with support for multiple delay strategies and event listeners
-
forthos
wrapper for OpenAI's responses and embeddings endpoints with prompt caching support
-
rustygram
minimal and blazing fast telegram notification framework for Rust
-
acktor-ipc-proto
Interprocess communication protocol for the acktor actor framework
-
dubbo-rs-serialization-json
JSON serialization for Apache Dubbo Rust via serde_json
-
lash-protocol-rlm
RLM protocol (persistent Lashlang execution) for the lash agent runtime
-
oris-execution-server
Graph-aware HTTP execution server facade for Oris
-
fourche
task queue named after a lion with forked tail (queue fourché), works with Redis
-
futures-task
Tools for working with tasks
-
eventide-application
Application layer for the eventide DDD/CQRS toolkit: command bus, query bus, handlers, application context, and an in-memory bus implementation
-
protoc-gen-rust-temporal
protoc plugin that emits a typed Rust Temporal client from temporal.v1.* annotated services
-
openraft-rt-tokio
Tokio runtime implementation for Openraft
-
telltale-choreography
Choreographic programming for Telltale - effect-based distributed protocols
-
pgboss
job queueing service
-
coreon-eip
Enterprise Integration Pattern processors for camel-rs
-
agnostic-process
Agnostic abstraction layer of
std::processfor any async runtime -
crous-io
Async IO adapters, framed streams, and mmap reader for Crous
-
poprako-orchestra
A unified transaction abstraction framework for Rust — decoupled Oper, Step, Nucl, and Run traits
-
stream-reconnect
Stream-wrapping traits/structs that automatically recover from potential disconnections/interruptions
-
effectum
An embeddable task queue based on SQLite
-
thespis
The interface of the thespis actor model (contains only traits)
-
durable-lambda-testing
MockDurableContext and assertion helpers for testing durable Lambda handlers without AWS credentials
-
agent-sdk-providers
LLM provider trait, streaming primitives, and first-party provider implementations for the Agent SDK
-
futures-cache
Futures-aware cache backed by sled
-
skg-context
Context strategy implementations for skg-turn
-
lib-wc
Will's Programming Toolbox
-
compio-signal
Signal handling for compio
-
pilatus-engineering
Engineering utilities (images, angles, matrices) for the Pilatus framework
-
orlando-client
A virtual actor framework in Rust, inspired by Microsoft Orleans
-
aion-integrations
Harness-integration SDK for Aion: the AgentHarness trait plus reusable building blocks for making an agent harness a first-class Aion integration
-
claude-cli-sdk
Rust SDK for programmatic interaction with the Claude Code CLI
-
eventbus-contract
Event bus contract — facade crate re-exporting backends and helpers
-
periplon
Rust SDK for building multi-agent AI workflows and automation
-
lichess-api
A client library for the Lichess API
-
with_wind
Composable runtime, logging, scheduling, and storage foundations for vibe-coding Rust projects
-
sugars_async_task
Async task utilities and abstractions for the cyrup-sugars ecosystem
-
allora-runtime
Allora runtime and DSL implementation (internal crate)
-
compio-dispatcher
Multithreading dispatcher for compio
-
async-gate
A Tokio-powered asynchronous gate (analogous to a flag and highly inspired by Python’s
asyncio.Event, but can be waited for to become ‘false’ too) -
openai-agents-openai-rs
OpenAI provider, models, sessions, and hosted tools for openai-agents-rust
-
axum-server2
High level server designed to be used with axum framework
-
stream-ext
An extension trait for Streams that provides a variety of convenient combinator functions
-
pacta-memory
In-memory Pacta Registry backend with real lease and lapse semantics
-
tarpc-lib
An RPC framework for Rust with a focus on ease of use
-
libp2p-perf
libp2p perf protocol implementation
-
rune-chain-retrieval
RetrievalQaChain for rune-chain — embed, retrieve, and answer with RAG pipelines
-
wolfcrypt-tls-futures-io
Async TLS backed by wolfSSL — futures::io AsyncRead/AsyncWrite (smol, async-std)
-
ceylon-runtime
A Rust-based agent mesh framework for building local and distributed AI agent systems
-
muxado
stream multiplexing protocol
-
spargio-protocols
Protocol integration companion crate for spargio (tls/ws/quic)
-
flarrow-layout
flarrow (flow + arrow) is a rust runtime/framework for building dataflow applications
-
peace_rt_model_web
Web support for the peace automation framework
-
get_chunk
File iterator or stream with auto or manual chunk size selection
-
rust-viewflow
Rust workflow library inspired by Viewflow, compatible with Axum and Actix-web
-
par-stream
Asynchronous parallel streams analogous to rayon
-
nvisy-sdk
Rust client for the Nvisy Server API: authentication, workspace management, and task routing
-
safina-async-test
Macro for running async tests - ARCHIVED: Code moved to
safinacrate -
v_exchanges_api_generics
A client for HTTP/HTTPS/WebSocket APIs
-
lbs-core
LBS core
-
kimojio-tls
Kimojio OpenSSL integration
-
service-io
Build your service-server fast, easy (and without hosting!)
-
fluxion-rx
A reactive stream processing library with ordered semantics, friendly interface, bullet-proof test coverage, state-of-the art documentation and examples
-
retryx
Async-first retry and exponential backoff helper for Tokio-based Rust applications
-
cellos-sink-jetstream
NATS JetStream EventSink for CellOS — durable, ordered CloudEvent delivery with 90-day retention floor (FC-74)
-
prost-codec
Asynchronous de-/encoding of Protobuf structs using asynchronous-codec, unsigned-varint and prost
-
task_forge
A flexible and simple task pool for asynchronous execution
-
hypixel-sdk
Async client for the Hypixel Public API with typed models and SkyBlock helpers
-
libmqm-default
IBM® MQ Interface (MQI), Programmable Command Format (PCF) and MQ Administration Interface (MQAI) structure defaults
-
async-dup
Duplicate an async I/O handle
-
caudal-sdk
Caudal SDK - Event observability for distributed systems
-
ruchei-extend
ExtendPinned utilities for ruchei
-
queen
message queue
-
zeebe
client for defining, orchestrating, and monitoring business processes across microservices using Zeebe
-
spectrum-rs
Rust port of the Spectrum unified messaging SDK
-
space-traders
Async SpaceTraders API client for Rust
-
llm-kit-deepseek
DeepSeek provider implementation for the LLM Kit - supports chat and reasoning models
-
nakadion
Types for interacting with the Nakadi Event Broker
-
queue_workers
A Redis-backed job queue system for Rust applications
-
ai-agents-recovery
Error recovery system for AI Agents framework
-
entelix-graph
entelix control-flow contract — StateGraph<S>, Reducer, conditional/Send edges, subgraph, Checkpointer trait, interrupt API
-
rust-s3-async-ffi
Asynchronous streaming of AWS S3 objects in C and C++ powered by rust-s3
-
timeout-macro-parse
A companion-crate for the tokio-timeout proc-macro-lib
-
hyphen-sinks
Canonical diagnostic sink implementations — file, background, webhook, OTLP, and tokio
-
merkql-notify-sns
AWS SNS notification plugin for merkql
-
pi_async
Based on future (MVP), a universal asynchronous runtime and tool used to provide a foundation for the outside world
-
smol-hyper
Integrations between smol and hyper
-
arti-rpcserver
Backend functionality for Arti's RPC service
-
tower-circuitbreaker
A circuit breaker middleware for Tower services
-
luft-service
Presentation-free run/query API for Luft
-
pe-graph
Graph execution engine for Potential Expectations — state graphs, Pregel model, ReAct topology, and builder DSL
-
celers-backend-rpc
gRPC/RPC result backend for CeleRS
-
faucet-sink-http
HTTP POST sink connector for the faucet-stream ecosystem
-
beetry-plugin
Internal beetry crate. For the public API, check the beetry crate.
-
elizaos-plugin-goals
Goals management plugin for elizaOS - Rust implementation
-
smol-potat
Proc macro for smol runtime
-
flowbuilder-runtime
Advanced runtime features for FlowBuilder
-
wishmaster-sdk
Rust SDK for WishMaster - AI agent marketplace with ERC-8004 reputation, agent-to-agent work, and x402 payments
-
mm1-common
An Erlang-style actor runtime for Rust
-
codekko
Ergonomic Rust wrapper for codex app-server with runtime safety and release gates
-
callbag
spec for reactive/iterable programming
-
moirai-pump
Event-pump runtime for Moirai job system
-
teloxide-core-ng
Core part of the
teloxidelibrary - telegram bot API client -
flowly-spsc
Flowly is a library of modular and reusable components for building robust pipelines processing audio, video and other
-
faucet-source-grpc
gRPC API source connector for the faucet-stream ecosystem
-
fluxion-core
Core traits and types for ordered stream processing
-
iron_reliability
Resilience patterns for distributed systems
-
chronon-backend-postgres
PostgreSQL SchedulerStore adapter for Chronon
-
futures-stream-ext
Asynchronous stream extensions for the futures(-core) crate
-
id_effect_tokio
Tokio runtime adapter and re-exports for the workspace
effectcrate -
tokio-stream_wasi
work with
Streamandtokio -
supabase-rust-realtime
Realtime client for Supabase
-
scoped_spawn
Full structured concurrency for asynchronous programming
-
fermio
Proactive IO & runtime system
-
adk-rag
Retrieval-Augmented Generation for Rust Agent Development Kit (ADK-Rust) agents
-
hanabi
High perfomance in-memory caching and event streaming
-
futuresdr-types
Polymorphic Types for an Experimental Async SDR Runtime for Heterogeneous Architectures
-
tirea-extension-reminder
System-reminder injection for persistent cross-turn context in tirea agents
-
awaitable-bool
A Tokio-powered awaitable bool (analogous to a flag and highly inspired by Python’s
asyncio.Event, but can be waited for to become ‘false’ too) -
adk-guardrail
Guardrails framework for ADK agents - input/output validation, content filtering, PII redaction
-
harness-rs-context
Default World runtime (Tokio process runner, system clock, in-memory KV) and Context helpers for harness-rs
-
lsp-max-ast
AST layer for lsp-max via tree-sitter
-
lash-standard-plugins
Default plugin stack bundle for the lash agent runtime
-
ailoop-tools
Tool registry and trait surface for ailoop
-
nexo-driver-loop
Goal orchestrator + LlmDecider + Unix socket bridge for the nexo-rs driver subsystem. Phase 67.4.
-
typed-eventbus
Transport-agnostic event streaming with typed events, metadata envelopes, local pub/sub, and NATS support
-
crb-download
CRB | Composable Runtime Blocks | Downloader
-
ds-event-stream-rs-sdk
A comprehensive Rust SDK for working with the DS Event Stream, providing high-level abstractions for producing and consuming events from Kafka
-
cortexai-mcp
Model Context Protocol (MCP) support for Cortex: stdio, SSE, and server transports
-
lsp-max-cli
Actuation grammar CLI for lsp-max: noun/verb surface built on clap-noun-verb
-
flowbuilder
An async flow orchestration framework with conditional execution and context sharing
-
disposition
SVG diagram generator
-
pattern-guard
Behavior anomaly guard: observes events, detects patterns, recommends allow/warn/delay/block
-
discord-selfbot
Discord selfbot API library for Rust
-
spring-axum
Spring-like application framework for Axum with macro-based auto discovery, validation, transactions, caching, events, and SQL/Mapper integrations
-
cloud_terrastodon
A command-line tool for interacting with cloud ecosystems
-
streamsafe
Type-safe async pipeline framework for data processing
-
xai-grok
High-level async client for the xAI Grok API (chat, streaming, tool calling, vision, structured outputs), built on the stream-rs streaming toolkit
-
async-task-ffi
Task abstraction for building executors
-
pcap-async
Async/Stream Extensions for libpcap
-
tokio-io-rewind
rewind tokio::io::AsyncRead and tokio::io::AsyncWrite streams
-
armature-queue
Job queue and background processing for Armature
-
yoa-runner-lib
Shared Rust primitives for managing runner workloads across Docker and Kubernetes
-
rune-chain-sequential
SequentialChain — run rune-chain chains in order, piping each output as input to the next
-
elizaos-plugin-commands
elizaOS Commands Plugin - command registry and built-in commands
-
flightradarapi
A modern async Rust SDK for the FlightRadar24 API
-
key-stream
async key streaming
-
fr-rust
A comprehensive framework/utility library for Actix-web, Postgres, Redis, and authentication
-
flows-math
Building blocks for flow-based mathematical operations
-
elicit_tokio
Elicitation-enabled tokio shadow crate — MCP tools for async time, sync primitives, and runtime inspection
-
mio-extras
Extra components for use with Mio
-
websocketing
WebSockets actor framework
-
noie-nds-api
NDS Protocol Buffers types for Rust (generated from nds-api/spec)
-
echo_execution
Execution layer for echo-agent framework (sandbox, skills, tools)
-
peace_cfg
Configuration model for the peace automation framework
-
echo_core
Core traits and types for the echo-agent framework
-
swait
Blocking on Futures
-
everruns-openrouter
OpenRouter provider for Everruns agents
-
rexecutor-sqlx
A robust job processing library
-
zerortt-futures
Asynchronous Runtime Binding for
zerortt -
redis-work-queue
A work queue, on top of a redis database, with implementations in Python, Rust, Go, Node.js (TypeScript) and Dotnet (C#)
-
openraft-legacy
Legacy compatibility layer for deprecated Openraft APIs
-
opencode_webresearch
automated web research workflows via OpenCode and MCP servers
-
alpaca-rest-http
Shared HTTP transport layer for the alpaca-rust workspace
-
lash-protocol-standard
Standard protocol (native provider tool calls) for the lash agent runtime
-
sayiir-persistence
Pluggable persistence backends for Sayiir workflow snapshots
-
ailoop-anthropic
Anthropic Messages API adapter for ailoop
-
trillium-tokio
tokio runtime adapter for trillium.rs
-
accepts
Minimal traits and blanket impls for sync/async acceptors (pipeline foundation)
-
natelemetry
NASA 遥测核心:W3C trace context 传播、有界 span 导出队列与停机 flush(不依赖 napp)
-
async-compatibility-layer
an abstraction layer for using both async-std and tokio
-
par_io
Parallel, async file I/O library with control over memory usage with no dependencies
-
plyne
Based pipeline of async task system
-
cruxai
An agentic DSL for Rust — inspectable, serializable, replayable agent execution
-
wookie
Async test/bench toolkit including single stepping executors. No-std compatible.
-
async-serial
Lightweight async serial port adapter for async-io + serialport
-
tokitai-mcp-server
MCP server scaffolding for Tokitai - Build AI-callable tool servers with zero runtime overhead
-
adk-realtime
Real-time bidirectional audio/video streaming for Rust Agent Development Kit (ADK-Rust) agents
-
rabbitmq-worker
A generic RabbitMQ worker library with built-in retry and dead-letter queue (DLQ) logic
-
otherone-mcp
MCP (Model Context Protocol) — 连接外部工具服务器的协议实现
-
everruns-mcp
Transport-agnostic MCP (Model Context Protocol) client for connecting tools to Everruns agents
-
asanaclient
Rust SDK for the Asana API
-
handle
Trait for asynchronous context pipeline
-
pilatus-emulation-camera-rt
Runtime for Pilatus camera emulation
-
nestforge-schedule
Scheduler support for NestForge
-
octopust
A high-performance, idiomatic Rust client for the Octopus Energy API
-
agnostic-io
agnostic-iodefines I/O traits in agnostic style for any async runtime -
process-stream
Thin wrapper around [
tokio::process] to make it streamable -
nio-task
async task implementation
-
kizzasi-inference
Unified autoregressive inference engine for Kizzasi AGSP
-
process-lib
Cross-platform, asynchronous Rust library to run commands in pipelines
-
actix-raft
Raft distributed consensus protocol using the Actix actor framework
-
adk-gateway
Multi-channel AI gateway for adk-rust agents — Telegram, Slack, WhatsApp, Discord, Matrix + control panel
-
elizaos-plugin-code
elizaOS Code Plugin - filesystem + shell + git (restricted)
-
agui-rs-client
Client SDK for the AG-UI protocol
-
shunter
An experimental streaming pipeline library for Rust providing a composable DSL for building data pipelines
-
dataprof-runtime
Shared runtime helpers and composed report types for dataprof
-
ironflow-orchestrator
A lightning-fast, zero-dependency workflow orchestrator written in Rust
-
traitclaw-anthropic
Anthropic provider for TraitClaw (Claude 3.5 Sonnet, Claude 3 Opus, Haiku)
-
durable-lambda-builder
Builder-pattern API style for AWS Lambda durable execution workflows
-
ctxd-client
Official Rust SDK for the ctxd context substrate daemon
-
nexo-dispatch-tools
Phase 67.D — agent-loop tools that dispatch / control / chain driver goals through DispatchGate
-
buffer-unordered-weighted
Stream::buffer_unordered where each future can have a different weight
-
cortexai-core
Core types, traits and abstractions for the Cortex AI agent framework
-
turboclaude
Unofficial Rust SDK for Anthropic's Claude API with 100% feature parity to official Python SDK
-
alpaca-core
Shared primitives for the alpaca-rust workspace
-
spargio-tls
TLS companion crate for spargio (rustls/futures-rustls bridge)
-
hojicha-runtime
Event handling and async runtime for Hojicha TUI framework
-
serio
providing traits and utilities for typed IO using format agnostic serialization built on serde
-
async-select
select!multiplex asynchronous futures simultaneously -
safina-select
Safe async select function, for awaiting multiple futures - ARCHIVED: Code moved to
safinacrate -
axocoatl-config
YAML/TOML configuration parser with validation for Axocoatl
-
heph
actor framework based on asynchronous functions
-
coreon-core
Core abstractions for camel-rs: Exchange, Processor, Endpoint, Component, CamelContext
-
raftlog
distributed replicated log based on the Raft algorithm
-
sodium
FRP (Functional Reactive Programming)
-
uninit-read
A marker trait and utilities for safe, high-performance reads into uninitialized buffers
-
asyncs-sync
Asynchronous runtime agnostic synchronization utilities
-
monoio-compat
A compat wrapper for monoio
-
llm-kit-azure
Azure OpenAI provider for LLM Kit
-
bongonet-timeout
Highly efficient async timer and timeout system for Tokio runtimes
-
elizaos-plugin-msteams
Microsoft Teams plugin for elizaOS - Rust implementation with Bot Framework support
-
containerd-snapshots
Remote snapshotter extension for containerd
-
aa-runtime
Tokio async runtime wrapper and lifecycle management for Agent Assembly
-
fluxion-ordered-merge
Generic ordered stream merging utilities for async Rust
-
purwa
The fundamental Rust web framework — facade re-exports
-
rt-local
Thread local asynchronous runtime working with platform-specific event loops
-
elizaos-plugin-xai
elizaOS xAI Plugin - Grok models and X (formerly Twitter) API integration
-
synth-ai
Rust SDK for Synth AI - serverless post-training APIs
-
bromine
A flexible ipc protocol (previously rmp-ipc)
-
cobs-codec
COBS codec for Tokio
-
rivet-util-serde
Serde helpers shared by Rivet crates
-
adk-code
Code execution substrate for ADK-Rust — typed executor abstraction, sandbox policy model, and built-in execution backends
-
elizaos-plugin-copilot-proxy
elizaOS Copilot Proxy Plugin - OpenAI-compatible local proxy for VS Code Copilot
-
harness-rs-tools-shell
Allowlisted read-only shell tool for harness-rs. Per-program safe-args predicate.
-
luft-cli
Luft CLI — multi-agent orchestration runtime
-
atomr-agents-channel-provider-signal
Signal provider for atomr-agents channels via signal-cli JSON-RPC bridge (Unix socket or TCP)
-
bus-core
Core traits and types for eventbus-rs with zero NATS dependencies
-
eventador
lock-free pub/sub event-bus with sync and async APIs
-
rustic-ai
A Rust-native agent framework with tool calling, streaming, and multi-provider support for OpenAI, Anthropic, Gemini, and Grok
-
zino-openapi
OpenAPI support for zino
-
harness-rs-permissions
Permission modes + per-tool allow/deny rules for harness-rs. Layers over the existing Hook system (PreToolUse gating) — gives ai-ledger-style multi-user backends a first-class way…
-
harness-rs-tools-memory
LLM-facing memory tools for harness-rs agents:
remember_this,forget_memory,list_memories. Backed by anyArc<dyn Memory>— wire per-user via a factory closure for multi-tenant apps. -
faucet-common-elasticsearch
Shared configuration types for the faucet-stream Elasticsearch source and sink connectors
-
elfo-utils
Some utils for the elfo system
-
wesichain-anthropic
Anthropic Claude provider for Wesichain
-
wabot-addon-chat-bot-wabot
Wabot LLM proxy adapter — port of wabot-ts addon/chat-bot/wabot. Thin pass-through that forwards a ChatAdapter request to a remote wabot LLM service.
-
async-barrier
An async barrier
-
bonsaimq
Message/job queue based on bonsaidb, similar to sqlxmq
-
tokio-executor-trait
executor-trait implementation for tokio
-
peace_params
Constraints and specifications for parameters for the peace automation framework
-
monoio-rustls
Asynchronous TLS streams wrapper for Monoio based on Rustls
-
nest-rs-queue
Backend-agnostic queue contract for NestRS: traits and the link-time #[process] registry a backend plugs into. Redis ships first-party in nest-rs-redis, and the same public seam carries any other store.
-
entelix-tokenizer-hf
entelix vendor-accurate TokenCounter wrapping HuggingFace
tokenizers— Llama / Qwen / Mistral / DeepSeek and any tokenizer.json source -
aion-integration-cli
second, independent AgentHarness adapter for Aion: a plain-stdout observability-only CLI agent that demuxes interleaved stdout into ActivityEvents and advertises no intervention capabilities…
-
arc-es-nats
NATS JetStream EventBus implementation for arc event sourcing
-
beetry-node
Beetry library with reusable behavior tree nodes
-
rustigram-bot
High-level bot dispatcher, update listener, and handler framework for rustigram
-
resuma-flow
Resuma Flow — full-stack pages, observable execution UI (FlowGraph, EventStream)
-
mm1-logger
An Erlang-style actor runtime for Rust
-
madsim-real-tokio
An event-driven, non-blocking I/O platform for writing asynchronous I/O backed applications
-
flowly-io
Flowly is a library of modular and reusable components for building robust pipelines processing audio, video and other
-
armature-cron
Scheduled task execution for Armature applications
-
everruns-gemini
Google Gemini provider for Everruns agents
-
futuresdr-remote
Remote interaction library for FutureSDR
-
lash-provider-anthropic
Anthropic API (Claude) provider for lash
-
replicant-sdk
Stable consumer facade for the Replicant Space Rust SDK
-
chronon-runtime
Chronon runtime assembly and ChrononBuilder
-
eventuary-memory
In-memory event backend for eventuary
-
agixt-sdk
Rust SDK for AGiXT - A powerful AI agent framework
-
oxigdal-workflow
DAG-based workflow engine for complex geospatial processing pipelines
-
async-stream
Asynchronous streams using async & await notation
-
tokio-macros
Tokio's proc macros
-
mofa-sdk
MoFA SDK - Modular Framework for Agents. A standard development toolkit for building AI agents with Rust
-
flows-text
Building blocks for flow-based text processing
-
wae
Async executor that use Winit event loop
-
paigasus-helikon-tools
Sandboxed Read/Write/Edit/Bash tools for the Paigasus Helikon AI SDK
-
bss-oss-service-orchestrator
Service lifecycle orchestration: Service Order → Activation → Inventory with dependency graph and background worker
-
luft
Luft — multi-agent orchestration runtime
-
claude-pool
Slot pool orchestration library for Claude CLI
-
async-core
A standard for async runtimes
-
enact-mcp
MCP (Model Context Protocol) client for Enact
-
async-sink
The asynchronous
Sinktrait for the tokio ecosystem -
eventuary-sqs
AWS SQS event backend for eventuary
-
ruchei-callback
Callback traits for ruchei
-
karyon_eventemitter
A lightweight, asynchronous event emitter for Rust
-
frappe
Functional Reactive Programming library for Rust
-
prokio
An asynchronous runtime compatible with WebAssembly and non-WebAssembly targets
-
elizaos-plugin-scratchpad
elizaOS Scratchpad Plugin - File-based persistent memory storage with markdown frontmatter and TF-IDF search
-
whorl
was created to teach you how async executors work in Rust
-
faucet-source-gcs
Google Cloud Storage source connector for the faucet-stream ecosystem
-
nenjo-models
LLM provider trait and implementations — OpenAI, Anthropic, Gemini, OpenRouter, Ollama, and any OpenAI-compatible API
-
compio-compat
Compatibility layer for compio to work with various async runtimes
-
cloud_terrastodon_rest
In-process REST helpers and request objects for Cloud Terrastodon
-
weex_rust_sdk
Professional Rust SDK for WEEX Exchange - AI Wars ready with full API coverage, AI Log upload, Futures trading
-
spargio-process
Process companion crate for spargio
-
photon-backend-nats
NATS JetStream storage adapter for Photon
-
monoio-io-wrapper
A read/write wrapper to bridge sync and async io
-
paladin-llm
LLM provider adapters for the Paladin framework — OpenAI, Anthropic, DeepSeek, and mock
-
elfo-dumper
Dumps messages of the elfo system on disk
-
event-notification
A modular event notification system with multi-channel support
-
llm-stack-anthropic
Anthropic Claude provider for the llm-stack SDK
-
flarrow-builtins
flarrow (flow + arrow) is a rust runtime/framework for building dataflow applications
-
scalarian-openai-rust
Independent Rust SDK for the OpenAI API with Responses-first ergonomics and realtime support
-
async-time-mock-core
Mockable time for use in async runtimes (core package)
-
async-stdin
Asynchronously read from stdin
-
folk-plugin-http
HTTP plugin for Folk — accepts connections via hyper and dispatches to PHP workers
-
eventsourcing
Event Sourcing for Rust
-
skg-env-local
Local (passthrough) Environment implementation for skelegent
-
rasi-spec
The Official RASI Specification Test Suite
-
ff-sdk
FlowFabric worker SDK — public API for worker authors
-
toggl-track
General-purpose async Rust library for the Toggl Track API v9
-
actm
Tiny async actors framework for rust
-
durable-lambda-trait
Trait-based API style for AWS Lambda durable execution workflows
-
pilatus-axum-rt
Runtime for the Pilatus Axum web integration
-
alpaca-facade
High-level convenience facades built on top of the alpaca-rust workspace crates
-
praxis-graph
React agent orchestrator for building AI agent workflows with LLM and tool execution
-
go-server-rust-sdk
Rust SDK for go-server distributed task scheduler and worker system
-
rivet-actor-runtime-socket-protocol
Versioned protocol for the experimental Actor Runtime Socket
-
heartbit-core
agentic framework — agents, tools, LLM providers, memory, evaluation
-
peace_rt_model_hack
Hack to selectively enable features in target specific crates
-
gemini-oxide
A production-grade, fluent Rust SDK for the Google Gemini Headless CLI
-
async-winit
Use winit like an async runtime
-
kojin-amqp
RabbitMQ (AMQP) broker for the kojin task queue
-
everruns-bedrock
AWS Bedrock provider for Everruns agents
-
async-ringbuffer
A nonblocking spsc ring buffer with fixed capacity
-
cruxai-script
YAML-driven pipeline scripting for the cruxai agentic DSL
-
nametrics-core
NASA 进程级 provider-neutral 指标核心:descriptor catalog + 冲突审计 + 进程内记录 + 结构化/Prometheus 导出(不依赖 OTel/Prometheus/Axum/napp)
-
meshflow-sdk
Async Rust SDK for the MeshFlow multi-agent orchestration platform
-
everruns-openai
OpenAI (GPT) provider for Everruns agents
-
aion-proto
Shared gRPC and serde wire contracts for Aion servers, clients, and workers
-
event_iterator
Asynchronous lending iterator
-
floxide-timer
Timer node abstractions for the floxide framework
-
tower-resilience-core
Core infrastructure for tower-resilience: events, metrics, and shared utilities
-
claude-agent-sdk
Idiomatic Rust SDK for building AI agents powered by Claude Code with full async support, type safety, and security hardening
-
ve_sdk
火山引擎 SDK
-
reka
Async Rust SDK for the Reka API
-
elizaos-plugin-tts
elizaOS TTS Plugin - text-to-speech coordinator with multi-provider support
-
armature-webhooks
Webhook sending and receiving for Armature
-
agent-air-runtime
Core runtime for agent-air - LLM orchestration, tools, and permissions (no TUI dependencies)
-
ai-agents-storage
Storage backends for AI Agents framework
-
elfo-logger
Logs events of the elfo system
-
prk_eventbus
A lightweight, WebSocket-based event bus for Rust with SQLite persistence
-
nexo-core
Agent runtime: event bus, sessions, plugin trait, heartbeat, A2A delegation
-
lustre-executor
A blazingly fast, minimal async executor with pluggable ID generation and I/O support
-
coreon-dsl
Route builder DSL for camel-rs
-
axocoatl-coordination
Adaptive stigmergic task lattice coordination for Axocoatl multi-agent systems
-
paigasus-helikon-runtime-agentcore
AWS Bedrock AgentCore runtime for the Paigasus Helikon AI SDK
-
easerx
A reactive MVI (Model-View-Intent) framework for Rust
-
rok-broadcasting
Laravel Echo-compatible real-time channel broadcasting for the rok ecosystem
-
aide-de-camp
backend agnostic delayed job queue
-
lash-subagents
Subagent / spawn_agent harness for the lash agent runtime
-
openraft-rt-monoio
monoio AsyncRuntime support for Openraft
-
faucet-sink-azure-blob
Azure Blob Storage / ADLS Gen2 sink connector for the faucet-stream ecosystem
-
smol-macros
Macros for setting up a smol runtime
-
netapp
A toolkit library for distributed software
-
actix-mqtt-client
A MQTT client based on the actix framework
-
associated-async-io
Async IO traits that use futures instead of poll
-
flows-io
Building blocks for flow-based I/O readers & writers
-
atomr-agents-channel-core
Channel + thread domain types for messaging-style transports (WhatsApp, Signal, Discord, in-memory). Defines the ChannelProvider trait, ChannelStore, ChannelEvent stream, ThreadTarget enum…
-
clia-async-openai
OpenAI (with rustls)
-
entelix-policy
entelix multi-tenant primitives — TenantPolicy, RateLimiter, PiiRedactor, CostMeter, QuotaLimiter
-
nest-rs-worker
Worker-execution primitives for NestRS — the ambient-context seam every transport that runs jobs off the request path (schedulers, queue workers, stream consumers) plugs into
-
agentsdk-plugin-mcp
An MCP (Model Context Protocol) plugin for agentsdk
-
arete-a4-sdk
Rust SDK client for connecting to Arete streaming servers
-
rusticated
Fast, standard-library-shaped async platform layer for brush-async
-
async-global-executor-trait
executor-trait implementation for async-global-executor
-
swf-runtime
Runtime engine for Serverless Workflow DSL — execute, validate, and orchestrate workflows
-
peace_rt_model_native
Runtime data types for the peace automation framework
-
zino-http
HTTP requests and responses for zino
-
mm1-server
An Erlang-style actor runtime for Rust
-
polaris_system
A lightweight ECS-inspired system framework for Polaris
-
aion-store-haematite
Single-node haematite-backed event store implementation for Aion workflows
-
ranvier-audit
Tamper-proof audit logging framework for Ranvier
-
muxi-rust
Rust SDK for MUXI AI platform
-
elfo-pinger
Pings groups of the elfo system
-
lash-plugin-tool-output-budget
Tool-output budgeting plugin for the lash agent runtime
-
streamcatcher
A thread-safe, shared (asynchronous), almost-lockless stream buffer
-
sayiir-cloudflare
Cloudflare Workers WASM bindings for Sayiir workflow engine
-
mofa-ai
MoFA - Modular Framework for Agents. A high-performance AI agent framework built in Rust
-
progressor
A modern, async-first progress tracking library
-
xerv-core
Workflow orchestration core: memory-mapped arena, write-ahead log, traits, and type system
-
beetry-editor-frontend
Internal beetry crate. For the public API, check the beetry crate.
-
handy_async
A handy library for describing asynchronous code declaratively
-
orka
An asynchronous, pluggable, and type-safe workflow engine for Rust, designed for orchestrating complex multi-step business processes
-
wta-reactor
Reactor for the what-the-async runtime
-
xerv-nodes
Standard workflow nodes for XERV: merge, split, switch, loop, map, and transform operations
-
goblin-engine
A high-performance async workflow engine for executing scripts in planned sequences with dependency resolution
-
nexo-agent-registry
Live registry of in-flight driver goals (Phase 67.B). Persists to SQLite for reattach across daemon restarts.
-
spawns-executor
Async executors for thread context task spawner
-
neuron-op-react
ReAct operator for neuron — model + tools in a reasoning loop
-
platz-sdk
Platz.io SDK
-
fluvio-async-tls
Asynchronous TLS/SSL streams using Rustls
-
sfo-io
handling IO operations, providing asynchronous read/write and stream processing capabilities
-
async-openai-alt
OpenAI
-
temporal-proto-runtime
Runtime helpers for protoc-gen-rust-temporal generated clients (TypedProtoMessage wire-format glue)
-
faucet-source-sqs
AWS SQS source connector for faucet-stream (long-poll receive, at-least-once drain, delete-on-emit)
-
apalis-nats
Background task processing for rust using apalis and nats jetstream
-
crossflow_diagram_editor
Frontend for crossflow diagrams
-
openclaw-agents
Agent runtime and workflow engine for OpenClaw
-
lsp-max-ast-codegen
Codegen crate for auto_lsp and AST modeling in lsp-max
-
spargio-signal
Signal companion crate for spargio
-
kojin-dashboard
JSON API dashboard for monitoring the kojin task queue
-
worklane-scheduler
Optional recurring cron scheduler that enqueues worklane jobs
-
orchflow-core
Transport-agnostic orchestration engine for managing terminal sessions, panes, and plugins with an event-driven architecture
-
futuresdr-pmt
Polymorphic Types for an Experimental Async SDR Runtime for Heterogeneous Architectures
-
cloud_terrastodon_config
Configuration helpers for the Cloud Terrastodon project
-
nest-rs-events
Typed in-process event bus for NestRS: emit a typed event, dispatch to discovered #[on_event] methods grouped under #[listeners]
-
zino-auth
Authentication and authorization for zino
-
jamjet-mcp
JamJet MCP client and server — Model Context Protocol support
-
lash-openai-schema
OpenAI JSON Schema projection helpers shared by Lash providers
-
durable-lambda-closure
Closure-native API style for AWS Lambda durable execution workflows
-
ai-agents-context
Dynamic context management for AI Agents framework
-
lighthouse-client
Client SDK for Project Lighthouse
-
mm1-multinode
An Erlang-style actor runtime for Rust
-
modal-rs
Unofficial Rust SDK for Modal.com - serverless cloud compute platform
-
pilatus-engineering-rt
Runtime for Pilatus engineering utilities
-
pi-ai
Unified multi-provider LLM API (Rust port of @earendil-works/pi-ai). Streams from Anthropic, OpenAI, Google Gemini, and any OpenAI-compatible endpoint.
-
oxana-web
Web UI for Oxana job queue system
-
folk-runtime-pipe
Pipe-based worker runtime for Folk — spawns PHP workers via execve with Unix socketpairs
-
adk-retry-reflect
Retry & Reflect plugin for ADK-Rust — intercepts tool failures and injects structured reflection prompts
-
viz-router
The router for Viz
-
atomr-agents-channel-provider-whatsapp
WhatsApp Business Cloud API provider for atomr-agents channels. Outbound REST, HMAC-SHA256 webhook verification, and two-step media download.
-
skg-op-single-shot
Single-shot operator — one model call, no tools, return immediately
-
elfo-network
Distributed actors for elfo
-
axum-realtime-kit
A toolkit for building scalable, real-time applications with Axum, WebSockets, and Redis Pub/Sub
-
axocoatl-mcp
MCP (Model Context Protocol) client and server integration for Axocoatl
-
fundamentum-sdk-api
HTTP client targeting Fundamentum IoT devices RestAPI
-
isoprenoid
signals runtime framework backing flourish
-
pipebuf_mio
PipeBuf support for
miobyte-streams -
veyron-sdk
Rust SDK for writing Veyron plugins — async IPC client, Plugin trait, and full Veyron wire protocol (framing, zstd compression, HMAC frame MACs, fragmentation, raw audio)
-
cruxx-planner
Goal-to-pipeline planner for cruxx-script
-
taskline
distributed task queue for Rust
-
anthropic-rs-sdk
Unofficial Rust SDK for the Anthropic API (community port of anthropic-sdk-go)
-
flynn-openai
OpenAI
-
salvor-tools
ToolHandler trait, derive macro, and MCP client integration for the Salvor agent runtime
-
elizaos-plugin-gmail-watch
Gmail Pub/Sub watcher plugin for elizaOS - spawns gog gmail watch serve and auto-renews
-
ruchei-extra
Stream/Sink wrapper with extra data, as used by ruchei
-
uringy
single-threaded concurrency runtime for Rust based on io_uring
-
circulate
Lightweight PubSub framework that supports both sync and async
-
faucet-sink-mssql
Microsoft SQL Server sink connector for the faucet-stream ecosystem
-
harness-rs-tools-docs
Document-extraction tool (read_document) for harness-rs — parse PDF/Word/Excel/PowerPoint locally in pure Rust, and fall back to an LLM for anything local parsing can't handle
-
fluxion-error
Error types for the Fluxion reactive streaming library
-
nexo-rs
Nexo — multi-agent Rust framework: NATS event bus, pluggable LLM providers, channels (WhatsApp, Telegram, Email, Browser), memory, MCP, skills, and TaskFlow
-
flows-hash
Building blocks for flow-based cryptographic hashing
-
coreon-direct
direct:* component for camel-rs (in-memory synchronous handoff)
-
flarrow-runtime
flarrow (flow + arrow) is a rust runtime/framework for building dataflow applications
-
sayiir-postgres
PostgreSQL persistence backend for Sayiir workflow engine
-
vidi
Fast, robust, flexible, lightweight web framework for Rust
-
nuitrack-rs
Rust bindings for the Nuitrack SDK, enabling skeletal tracking, gesture recognition, and other computer vision capabilities
-
xerv-executor
XERV orchestration executor: DAG scheduler, selector linker, pipeline controller, and REST API
-
smartpoll
A 'Task' abstraction that simplifies polling futures
-
lash-plugin-tool-discovery
Tool-discovery plugin for the lash agent runtime
-
harness-rs-daemon
Optional standalone scheduler for the harness-rs agent framework. Runs declarative TOML-configured jobs (daily / weekly / interval / cron) that invoke any shell command — typically a harness-rs-built agent binary.
-
entelix-session
entelix session — SessionGraph (event log), GraphEvent, fork, archival watermark
-
asynciter
Asynchronous iterator
-
v_exchanges_adapters
Implementations of HTTP/HTTPS/WebSocket API methods for some crypto exchanges, using crypto-botters framework
-
vkoxide
lightweight, strictly asynchronous SDK and framework in Rust designed for building VKontakte community bots using the Bots Long Poll API
-
puteketeke
An asynchronous runtime built on smol
-
compio-executor
Executor for compio
-
pulsehive-runtime
Runtime execution engine for PulseHive multi-agent SDK
-
adk-acp
Agent Client Protocol integration for ADK-Rust — use ACP coding agents or expose an ADK agent to editors
-
agents-lab-llm-providers
Rust provider registry and lightweight clients extracted from Neo's LLM provider module
-
peace_diff
Diff types for the peace automation framework
-
harness-rs-loop
ReAct agent loop for harness-rs with measured guards: stuck detection, acceptance checks, a tool-result ceiling that spills oversized payloads to disk instead of truncating, per-call tool deadlines…
-
qwencode-rs
Rust SDK for programmatic access to QwenCode CLI
-
faucet-sink-kafka
Apache Kafka producer sink for the faucet-stream ecosystem
-
polaris_sessions
Session management and orchestration for Polaris agents
-
rivet-depot-client-types
Shared SQLite execution types for depot client
-
ailoop-azure-openai
Azure OpenAI v1 Chat Completions adapter for ailoop
-
rivet-envoy-protocol
Versioned Envoy protocol types for Rivet actor hosts
-
ai-agents-skills
Skill system for AI Agents framework
-
tencentcloud-sms
腾讯云短信服务 Rust SDK - 类型安全、异步高性能的短信 API 客户端
-
paigasus-helikon-providers-gemini
Google Gemini provider for the Paigasus Helikon AI SDK
-
atomr-agents-py-bindings
PyO3 bindings: host (run harnesses) and guest (Python-defined tools/strategies)
-
beetry-channel
Beetry library with reusable channel implementations
-
ranvier-compliance
Compliance helpers (GDPR, HIPAA) for Ranvier
-
peace_item_tar_x
Manages extracting a tar file for the peace framework
-
claude-code-rs
Rust rewrite of the official Anthropic Claude Agent SDK (Python). Wraps Claude Code CLI via subprocess with bidirectional JSON streaming.
-
flourish-unsend
Convenient and full-featured signals for Rust (thread-local variant)
-
oats-framework
Universal architecture pattern for infinite scale across any domain - Objects • Actions • Traits • Systems
-
futures-io-preview
The
AsyncReadandAsyncWritetraits for the futures-rs library -
neuron-runtime
Production runtime for AI agents — sessions, sub-agents, input/output guardrails, permission policies, and durable execution
-
mocra-dag
Generic distributed DAG execution engine for the mocra crawler framework (zero crawler coupling)
-
tower
modular and reusable components for building robust clients and servers
-
elizaos-plugin-tlon
Tlon/Urbit plugin for elizaOS - Rust implementation with SSE support
-
harness-rs-sensors-common
Shared sensor scaffolding (git, LSP helpers) for harness-rs
-
streamweave-error
Error handling system for StreamWeave
-
paladin-web
Web server adapters for the Paladin AI orchestration framework (actix-web / axum)
-
mm1-node
An Erlang-style actor runtime for Rust
-
cloud_terrastodon_azure_devops_types
Types for modelling Azure DevOps for the Cloud Terrastodon project
-
kojin-postgres
PostgreSQL result backend for the kojin task queue
-
ailoop-mcp
MCP (Model Context Protocol) adapter for ailoop
-
pilatus-emulation-camera
Camera emulation for the Pilatus framework
-
miyabi-workflow
Workflow DSL for Miyabi - Graph-based agent orchestration with .then(), .branch(), .parallel()
-
axocoatl-server
Axum HTTP/WebSocket API server for Axocoatl
-
nafana-macro
#[grafana] 接口保护与 #[global_fallback] 终态降级属性宏
-
async-tls
Asynchronous TLS/SSL streams using Rustls
-
flows-audio
Building blocks for flow-based audio processing
-
atomr-agents-channel-harness
Channel orchestrator: attaches provider transports, supervises their lifecycle, routes inbound messages to bound Callable targets, queues outbound, persists state, and broadcasts ChannelEvent
-
lash-rlm-types
Shared types for the RLM protocol in the lash agent runtime
-
entelix-memory
entelix cross-thread memory — Store/Embedder/Retriever/VectorStore traits, Buffer/Summary/Entity, SemanticMemory<E,R> generic
-
folk-runtime-fork
Fork-based worker runtime for Folk — prefork master with warm OPcache
-
trale
minimalistic Rust async executor using io_uring for efficient, correct task execution
-
interlink
Framework for writing async code
-
lsp-max-base
Base protocol codec for lsp-max
-
marlin-sdk
Marlin SDK
-
peace_item_blank
Copies a number from one resource to another
-
nexo-pairing
Setup-code pairing store and DM-challenge gate for Nexo channel plugins
-
cruxx-domain
Pure domain types for the cruxx agentic DSL — no async, no LLM deps
-
nest-rs-schedule
Discovered cron-style scheduled jobs for NestRS: the #[scheduled] decorator plus a ScheduleModule that auto-attaches the Scheduler
-
peace_item_sh_cmd
Manages running a shell command for the peace framework
-
coreon-seda
seda:* component for camel-rs (bounded mpsc queue with backpressure)
-
elizaos-plugin-directives
elizaOS Directives Plugin - parse and manage agent directives
-
zino-connector
Unified connector to data sources for zino
-
novel-openai
Openai for novel
-
atomr-agents-sandbox-guest-agent
In-VM guest agent for the atomr-agents microVM sandbox: a static Rust daemon that runs as PID 1 inside a Firecracker guest, serving the sandbox-proto command set over AF_VSOCK
-
zino-axum
Integrations with axum for zino
-
aiven_rs
sdk to interact with aiven-cloud apis
-
elizaos-plugin-imessage
iMessage plugin for elizaOS agents (macOS)
-
ffi_rpc
Use FFI with RPC
-
krabdex
A type-safe, async Rust SDK for the PokeAPI
-
fluxion-runtime
Runtime abstraction for async Rust streams
-
faucet-common-sftp
Shared SFTP connection config for the faucet-stream source and sink
-
paigasus-helikon-runtime-temporal
Temporal-backed durable runtime for the Paigasus Helikon AI SDK
-
hooch-http
HTTP addition to the hooch runtime
-
wabot-addon-chat-bot-deepseek
DeepSeek chat adapter — port of wabot-ts addon/chat-bot/deepseek. Uses the OpenAI-compatible Chat Completions API.
-
elizaos-plugin-instagram
Instagram plugin for elizaOS - Rust implementation
-
harness-rs
Rust agent framework based on harness-engineering principles (Lopopolo, Böckeler). Facade re-exporting the public surface of the harness-rs-* crates.
-
atomr-agents-avatar-harness
Avatar orchestrator: composes STT (perception), atomr-infer (cognition), TTS (synthesis), viseme→blendshape mapping, and the Sync-Manager into a supervised actor pipeline. Drives…
-
lash-plugin-rolling-history
Rolling-history plugin for the lash agent runtime
-
faucet-source-sftp
SFTP source connector for the faucet-stream ecosystem
-
atomr-agents-deep-research-harness
Pluggable deep-research harness: clarify→plan→search→write→verify, multi-agent parallel, and iterative-deepening strategies behind a uniform contract
-
beetry-editor-backend
Internal beetry crate. For the public API, check the beetry crate.
-
tasker-client
Tasker API client library — transport-agnostic REST and gRPC clients
-
luft-runtime
Lua orchestration runtime for Luft
-
skg-orch-kit
Unopinionated wiring kit for composing skelegent systems
-
openclaw-providers
AI provider clients for OpenClaw (Anthropic, OpenAI, etc.)
-
faucet-common-bigquery
Shared credentials and client construction for the faucet-stream BigQuery source and sink connectors
-
axocoatl-tools
Built-in tool library and unified tool executor for Axocoatl
-
ai-agents-template
Template loading and rendering for AI Agents framework
-
streem
creating and consuming streams
-
aiur
Single threaded async executor with structured concurrency
-
hyperstack-sdk
Rust SDK client for connecting to HyperStack streaming servers
-
ai-agents-observability
Observability and tracing for AI Agents framework
-
nanocodex-observability
Tracing formatting and OpenTelemetry setup for Nanocodex applications
-
cloud_terrastodon_azure_types
Types for modelling Azure stuff for the Cloud Terrastodon project
-
flows-arrow
Building blocks for flow-based data processing with Apache Arrow
-
lash-tools
Built-in tool suite (files, shell, web) for the lash agent runtime
-
ringolo
An asynchronous runtime built on top of io-uring
-
flarrow-message
flarrow (flow + arrow) is a rust runtime/framework for building dataflow applications
-
eik
An AI agent framework for Rust
-
nasaga-macro
NASA Saga #[saga] participant step attribute macro with compile-time contract checks
-
faucet-source-nats
NATS source connector for the faucet-stream ecosystem
-
luft-adapters
ACP backend adapter for Luft
-
entelix-tools
entelix built-in tools — http_fetch, search adapter trait, calculator (web-only subset; no fs / shell — invariant 9)
-
luft-mcp
MCP server crate — exposes workflow authoring resources and execution tools to external AI clients
-
nexo-driver-types
Types and traits for the Nexo driver subsystem (CLI/process orchestration under verifiable goals)
-
salvor-store-conformance
Store-agnostic conformance kit that proves an EventStore implementation satisfies the salvor-store trait contract
-
folk-protocol
Length-prefixed MessagePack-RPC wire protocol for Folk
-
coreon-file
file:* component for camel-rs (poll-based consumer + file producer)
-
seesaw-kafka
Kafka backend for Seesaw event-driven orchestration
-
atomr-distributed-data-lmdb
redb-backed DurableStore for atomr distributed-data
-
peace_item_file_download
Manages downloading a file for the peace framework
-
echo_orchestration
Orchestration layer for echo-agent framework (workflow, human-loop, tasks)
-
entelix-agents
entelix production agent runtime — ReAct / Supervisor / Hierarchical / Chat recipes, tool-side layer ecosystem (approval / event / hook), sink adapters (broadcast / capture / channel…
-
llm-kit-core
Core functionality for the LLM Kit - unified interface for building AI-powered applications
-
openhelm-sdk
Trait definitions and types for building openhelm skills and tools
-
mm1-sup
An Erlang-style actor runtime for Rust
-
cloud_terrastodon_hcl
Helpers for manipulating TerraStorodon HCL files for the Cloud Terrastodon project
-
oxify-api
GraphQL and REST API server for OxiFY AI orchestration platform
-
kojin-sqs
AWS SQS broker for the kojin task queue
-
predict-fun-rs
Blazing fast async Rust SDK for Predict.fun REST API
-
nexo-project-tracker
Parses PHASES.md / FOLLOWUPS.md and exposes them as agent tools (Phase 67.A)
-
async-executor-trait
executor-trait implementation for async-std
-
elizaos-plugin-lobster
elizaOS Lobster Plugin - Workflow runtime for multi-step pipelines with approval checkpoints
-
cruxx-plugin
Subprocess plugin host for cruxx pipelines
-
faucet-common-nats
Shared NATS config types for the faucet-stream source and sink
-
floxide-macros-support
A directed graph workflow system in Rust
-
axocoatl-session
Directory-scoped working sessions for Axocoatl — pick a directory, agents build in it
-
disposition_lsp
Language server for editing
dispositionInputDiagramYAML -
actor-core-client
Rust client for ActorCore - the Stateful Serverless Framework for building AI agents, realtime apps, and game servers
-
tokio-task-manager
Allow an async Tokio application to gracefully shutdown, waiting for all tasks to finish
-
flows-mdns
Building blocks for flow-based mDNS discovery
-
harness-rs-sensors-rust
cargo-check and clippy feedback sensors for harness-rs. Emits LLM-friendly correction signals.
-
beetry-exec
Internal beetry crate. For the public API, check the beetry crate.
-
lash-plugin-mcp
MCP (Model Context Protocol) plugin for the lash agent runtime
-
lash-plugin-process-controls
Process-control plugin for the lash agent runtime
-
orchestral-runtime
Thread Runtime with concurrency, interruption, scheduling, LLM planners, actions, and API for Orchestral
-
coreon-kafka
kafka:* component for camel-rs (producer + consumer via rdkafka)
-
atomr-agents-coding-cli-isolator
Isolator trait + Local and Docker implementations for the coding-cli harness. Spawns CLI processes on the host or in a container with optional PTY.
-
cloud_terrastodon_azure
Helpers for interacting with Azure for the Cloud Terrastodon project
-
lash-tool-support
Shared types and helpers for building tools in the lash agent runtime
-
mm1-test-rt
An Erlang-style actor runtime for Rust
-
durable-lambda-macro
Proc-macro for zero-boilerplate AWS Lambda durable execution handler registration
-
kuri
An SDK for building MCP servers, focused on elegant developer experience, where tools and prompts are just plain old Rust functions
-
ai-agents-hooks
Agent hooks and events for AI Agents framework
-
faucet-source-elasticsearch
Elasticsearch source connector for the faucet-stream ecosystem
-
atomr-streams-io
Real-world I/O Source/Sink adapters for atomr-streams — HTTP polling and WebSocket connectors behind feature flags
-
lash-search-tools
CLI-only fff-backed local search tools for the lash agent runtime
-
disposition_svg_model
Data types for disposition to represent SVG elements
-
zino-actix
Integrations with actix-web for zino
-
lsp-max-runtime
Runtime snapshotting and state tracking for lsp-max
-
atomr-agents-web-search-tool
Generic
Toolwrapper that exposes anyWebSearchprovider to atomr-agents agents and harnesses -
coreon-timer
timer:* component for camel-rs (periodic tick producer)
-
flarrow-flows
flarrow (flow + arrow) is a rust runtime/framework for building dataflow applications
-
smol-executor-trait
executor-trait implementation for smol
-
mm1-ask
An Erlang-style actor runtime for Rust
-
axocoatl-llm
LLM provider abstraction layer for Axocoatl — core traits, types, and registry
-
disposition_taffy_model
Data types for disposition to work with taffy
-
duplexify
Combine a reader + writer into a duplex of Read + Write
-
peace_items
Collection of items the peace framework
-
alpha-core-framework
High-performance modular Rust framework for async task orchestration and data pipelines
-
zino-storage
Files and storage services for zino
-
harness-rs-cli
Command-line interface for harness-rs — run an agent, sched (recurring jobs), new (scaffold), skills validate/list/lint/export, trace, mcp serve
-
kojin-redis
Redis broker backend for the kojin task queue
-
disposition_input_ir_model
dispositiondiagram generator input to IR mapping data types -
flows-video
Building blocks for flow-based video processing
-
entelix-mcp
entelix MCP integration — JSON-RPC 2.0 over HTTP, per-tenant pool, lazy provisioning
-
wabot-addon-chat-bot-openai
OpenAI chat adapter — port of wabot-ts addon/chat-bot/openia. Talks to the Responses API directly via reqwest.
-
beetry-serialization
Internal beetry crate. For the public API, check the beetry crate.
-
vidi-router
The router for Vidi
-
toni
Fast and modular web framework for scalable applications
-
shedul3r-rs-sdk
Rust client SDK for shedul3r task execution server
-
axocoatl-token
Token counting, budget enforcement, and format-adaptive serialization for Axocoatl
-
atomr-agents-sandbox-core
Backend-agnostic microVM sandbox traits, profile/budget/request types, lifecycle events, and a deterministic in-memory mock backend for the atomr-agents sandbox subsystem
-
peace_cmd_rt
Runtime types for commands for the Peace framework
-
nexo-auth
Per-agent credential resolver and gauntlet validation for Nexo channels
-
mm1-proto-ask
An Erlang-style actor runtime for Rust
-
atomr-agents-coding-cli-core
Uniform input/output contract and vendor trait for the coding-cli harness: request, result, normalized event schema, concept projection, and the CliVendor seam
-
faucet-source-parquet
Apache Parquet file source connector for the faucet-stream ecosystem
-
elizaos-plugin-cli
elizaOS CLI Plugin - CLI framework and command registration
-
nexo-llm
LLM provider clients (MiniMax, OpenAI-compat, Anthropic, Gemini) with rate limiter and tool registry
-
paigasus-helikon-runtime-axum
Self-hosted Axum HTTP/SSE/WebSocket server runtime for Paigasus Helikon agents
-
lash-plugin-plan-mode
Plan-mode plugin for the lash agent runtime
-
flarrow-url
flarrow (flow + arrow) is a rust runtime/framework for building dataflow applications
-
flows-datafusion
Building blocks for flow-based query processing with Apache DataFusion
-
entelix-graphmemory-pg
entelix concrete GraphMemory — sqlx + Postgres backend (nodes + typed timestamped edges)
-
zino-channel
Cloud events and subscriptions for zino
-
atomr-agents
Composable agentic framework on top of atomr actors and atomr-infer
-
mm1-proto-sup
An Erlang-style actor runtime for Rust
-
nexo-broker
Async NATS broker abstraction with local fallback and disk queue for Nexo
-
axocoatl-service
OS background-service management (systemd / launchd) for the Axocoatl daemon
-
harness-rs-sandbox
Sandbox tiers for harness-rs — git Worktree, Docker Container, and a trait for deployment-owned isolation backends
-
lash-provider-codex
OpenAI Codex OAuth provider for lash (ChatGPT Plus/Pro/Team)
-
cloud_terrastodon_hcl_types
Helper types for interacting with HCL for the Cloud Terrastodon project
-
faucet-sink-nats
NATS sink connector for the faucet-stream ecosystem
-
coreon-bean
bean:* component for camel-rs (named processor registry)
-
peace_cmd_model
Data types for commands for the Peace framework
-
flows-pubsub
Building blocks for flow-based publish/subscribe
-
cloud_terrastodon_azure_devops
Helpers for interacting with Azure DevOps for the Cloud Terrastodon project
-
disposition_model_common
SVG diagram generator common data model types
-
atomr-agents-coding-cli-vendor-antigravity
Google Antigravity CLI (agy) adapter for the coding-cli harness: stream-json parser + system-instruction projection. Successor to the Gemini CLI adapter.
-
atomr-agents-web-search-core
Provider-agnostic web-search trait, request/hit types, and a deterministic mock provider for tests
-
skg-orch-local
In-process Orchestrator implementation for skelegent
-
ai-agents-runtime
Runtime agent and builder for AI Agents framework
-
atomr-agents-host
atomr-agents host runtime — long-lived agent identity, memory, skills, hooks, schedules, channels, atop atomr actors
-
nexo-poller
Generic polling runtime: cron schedules, retries, ack semantics
-
entelix-memory-qdrant
entelix concrete VectorStore — qdrant-client gRPC backend
-
axum-typed-websockets
axum::extract::ws with type safe messages
-
zino-extra
Extra utilities for zino
-
elizaos-plugin-prose
elizaOS OpenProse Plugin - A programming language for AI sessions and multi-agent orchestration
-
harness-rs-mcp
MCP (Model Context Protocol) stdio server exposing the harness-rs tool registry to Claude Code, Cursor, and Codex
-
mm1-timer
An Erlang-style actor runtime for Rust
-
axocoatl-graph
Workflow graph model for Axocoatl agent orchestration
-
paigasus-helikon-cli
CLI binaries (helikon, paigasus-helikon) for the Paigasus Helikon AI SDK
-
entelix-rag
entelix RAG primitives — Document with provenance + lineage, DocumentLoader / TextSplitter / Chunker traits. Algorithmic primitives for retrieval-augmented generation pipelines; concrete…
-
faucet-source-webhook
Webhook receiver source connector for the faucet-stream ecosystem
-
peace_cmd
Command structure for the Peace framework
-
flows-rand
Building blocks for flow-based random number generation
-
harness-rs-tools-tasks
Background-task primitives for harness-rs agents: a TaskStore trait + 4 tools (tasks_create, tasks_list, tasks_get, tasks_cancel) so the LLM can dispatch and inspect deferred work…
-
mm1-proto-well-known
An Erlang-style actor runtime for Rust
-
disposition_input_ir_rt
Logic to map
dispositioninput model to intermediate representation -
zino-ntex
Integrations with ntex for zino
-
harness-rs-blueprint
Deterministic + agent hybrid state-machine executor for harness-rs. Stripe-Minions-style with branch-on-failure retries.
-
cloud_terrastodon_entrypoint
Main entrypoint for the Cloud Terrastodon CLI
-
nexo-extensions
Extension manifest, discovery, lifecycle, and stdio/NATS runtimes for Nexo
-
paigasus-helikon-providers-anthropic
Anthropic provider for the Paigasus Helikon AI SDK
-
lash-llm-tools
LLM-backed tool implementations (llm_query and friends) for the lash agent runtime
-
zeal-sdk
Rust SDK for Zeal Integration Protocol (ZIP)
-
peace_resource_rt
Runtime resources for the peace automation framework
-
entelix-prompt
entelix prompt primitives — PromptTemplate, ChatPromptTemplate, MessagesPlaceholder, FewShot, ExampleSelector
-
axocoatl-isolation
Tiered isolation layer for Axocoatl tool execution (Wasmtime + youki OCI + Firecracker)
-
flows-dns
Building blocks for flow-based DNS resolution
-
zino-amis
UI generator for amis
-
disposition_input_rt
Runtime mutation operations for
dispositioninput diagrams -
mm1-proto-named
An Erlang-style actor runtime for Rust
-
nexo-resilience
Circuit breaker, retry, and rate limiter primitives for Nexo agents
-
peace_item_specs
Collection of item specs the peace framework
-
nexo-plugin-discovery
Plugin catalogue discovery — fetches public plugin metadata from crates.io / GitHub topic / curated index (Phase 98)
-
harness-rs-templates
Pre-built Blueprint templates (axum_crud, crate_keeper) and convention guides for harness-rs
-
axocoatl-llm-gemini
Google Gemini provider for Axocoatl
-
entelix-cloud
entelix cloud transports — Bedrock, Vertex, Foundry; OAuth refresh (gcp_auth, aws-sigv4, azure_identity)
-
nexo-mcp
MCP (Model Context Protocol) client and server runtime for Nexo agents
-
mm1-name-service
An Erlang-style actor runtime for Rust
-
atomr-agents-coding-cli-vendor-codex
OpenAI Codex CLI adapter for the coding-cli harness:
codex execheadless invocation + AGENTS.md projection -
nexo-taskflow
Long-running multi-step task orchestration runtime for Nexo agents
-
paigasus-helikon-sessions-postgres
PostgreSQL-backed Session backend for the Paigasus Helikon AI SDK
-
harness-rs-tools-skills
LLM-facing skill-authoring tool for harness-rs agents: skill_manage (create/patch/edit/delete SKILL.md). Used by the learning loop.
-
peace_item_spec_tar_x
Manages extracting a tar file for the peace framework
-
atomr-agents-coding-cli-vendor-claude
Claude Code adapter for the coding-cli harness: stream-json parser + concept projection (CLAUDE.md, skills, MCP, settings)
-
peace_webi_output
Web interface output for the peace automation framework
-
axocoatl-llm-anthropic
Anthropic Claude provider for Axocoatl LLM abstraction
-
harness-rs-mcp-client
MCP client for harness-rs: expose a remote MCP server's tools as harness tools
-
entelix-server
entelix HTTP service — axum + 5-mode SSE streaming + multi-tenant header extraction (LangServe substitute)
-
atomr-agents-coding-cli-harness
Harness wrapping local AI coding CLIs (Claude Code, Codex, Antigravity) as atomr-agents Callables. Headless mode parses structured streams; interactive mode bridges a tmux session to clients.