-
tokio
An event-driven, non-blocking I/O platform for writing asynchronous I/O backed applications
-
futures
streams featuring zero allocations, composability, and iterator-like interfaces
-
h2
An HTTP/2 client and server
-
rdkafka
Rust wrapper for librdkafka
-
tokio-rustls
Asynchronous TLS/SSL streams for Tokio using Rustls
-
deadpool
Dead simple async pool
-
tower-http
Tower middleware and utilities for HTTP clients and servers
-
event-listener
Notify async tasks or threads
-
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
-
mio
Lightweight non-blocking I/O
-
futures-lite
Futures, streams, and async I/O combinators
-
axum-server
High level server designed to be used with axum framework
-
interprocess
communication toolkit
-
async-openai
OpenAI
-
pollster
Synchronously block the thread until a future completes
-
futures-concurrency
Structured concurrency operations for async Rust
-
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.
-
tokio-serial
A serial port implementation for tokio
-
polling
Portable interface to epoll, kqueue, event ports, and IOCP
-
async-stream
Asynchronous streams using async & await notation
-
tokio-retry
Extensible, asynchronous retry behaviours for futures/tokio
-
prodash
A dashboard for visualizing progress of asynchronous and possibly blocking tasks
-
futures-timer
Timeouts for futures
-
yrs
High performance implementation of the Yjs CRDT
-
tracing-actix-web
Structured logging middleware for actix-web
-
async_zip
An asynchronous ZIP archive reading/writing crate
-
ractor
A actor framework for Rust
-
openraft
Advanced Raft consensus
-
gix-packetline-blocking
A duplicate of
gix-packetlinewith theblocking-iofeature pre-selected -
async-tar
async TAR file reader and writer. This library does not currently handle compression, but it is abstract over all I/O readers and writers. Additionally, great lengths are taken to ensure that the entire…
-
eventsource-stream
A basic building block for building an Eventsource from a Stream of bytes
-
io-uring
The low-level
io_uringuserspace interface for Rust -
async-broadcast
Async broadcast channels
-
tokio-retry2
Extensible, asynchronous retry behaviors for futures/tokio
-
tower-lsp-server
Language Server Protocol implementation based on Tower
-
process-wrap
Wrap a Command, to spawn processes in a group or session or job etc
-
kameo
Fault-tolerant Async Actors Built on Tokio
-
tower-sessions
🥠 Sessions as a
towerandaxummiddleware -
apalis
extensible and multithreaded background task processing for Rust
-
futures-buffered
future concurrency primitives with emphasis on performance and low memory usage
-
rxrust
Reactive Extensions
-
bb8
Full-featured async (tokio-based) connection pool (like r2d2)
-
async-native-tls
Native TLS using futures
-
async-process
Async interface for working with processes
-
triple_buffer
triple buffering, useful for sharing frequently updated data between threads
-
keycloak
Admin REST API
-
miow
A zero overhead I/O library for Windows, focusing on IOCP and async I/O abstractions
-
backon
Make retry like a built-in feature provided by Rust
-
tokio-graceful
util for graceful shutdown of tokio applications
-
minus
An asynchronous data feedable terminal paging library for Rust
-
tor-rtcompat
Compatibility layer for asynchronous runtimes, used by Tor
-
salvo-serde-util
serde util for salvo
-
pty-process
spawn commands attached to a pty
-
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.
-
idb
A futures based crate for interacting with IndexedDB on browsers using webassembly
-
tokio-graceful-shutdown
perform a graceful shutdown on a Tokio based service
-
paho-mqtt
The Official Eclipse Paho MQTT Rust Client Library. This is a wrapper around the Paho C library
-
want
Detect when another Future wants a result
-
monoio
A thread per core runtime based on iouring
-
asynchronous-codec
encoding and decoding frames using
async/await -
dptree
An asynchronous event dispatch mechanism for Rust
-
tokio-rusqlite
Asynchronous handle for rusqlite library
-
madsim
Deterministic Simulator for distributed systems
-
eyeball
Add observability to your Rust types!
-
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
-
dial9-tokio-telemetry
Low-overhead runtime telemetry for Tokio with poll timing, wake events, and CPU profiling
-
stream-download
streaming content to a local cache
-
async-walkdir
Asynchronous directory traversal for Rust
-
ntex-h2
An HTTP/2 client and server
-
rust-parallel
Fast command line app in rust/tokio to run commands in parallel. Similar interface to GNU parallel or xargs.
-
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
-
async-shutdown
one-stop solution for async graceful shutdown
-
apalis-redis
Background task processing for rust using apalis and redis
-
futures-signals
Zero cost FRP signals using the futures crate
-
rocketmq-rust
Unofficial Rust implementation of Apache RocketMQ
-
compio
Completion based async runtime
-
capnp-futures
async serialization for Cap'n Proto messages
-
twilight-standby
filter wait for filtered incoming events for the Twilight ecosystem
-
mikrotik-rs
Asynchronous Rust library for interfacing with MikroTik routers
-
gloo-worker
Convenience crate for working with Web Workers
-
pinky-swear
Futures and async/await-ready Promises
-
wfaas
Workflow-as-a-Service engine for managing multi-step operations
-
blocking
A thread pool for isolating blocking I/O in async programs
-
async-graphql-parser
GraphQL query parser for async-graphql
-
adk-model
LLM model integrations for Rust Agent Development Kit (ADK-Rust) (Gemini, OpenAI, Claude, DeepSeek, etc.)
-
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. -
ipc-queue
FIFO queue described in fortanix-sgx-abi used for asynchronous usercalls
-
wasm-timer
Abstraction over std::time::Instant and futures-timer that works on WASM
-
syslog-rs
A native Rust implementation of the glibc/libc/windows syslog client and windows native log for logging
-
fundamentum-edge-daemon
The supported way to access Fundamentum's ecosystem from linux devices
-
cxx-async
interoperability between C++ coroutines and asynchronous Rust
-
tokio-vsock
Asynchronous Virtio socket support for Rust
-
vertigo
Reactive Real-DOM library with SSR for Rust
-
async-lsp
Asynchronous Language Server Protocol (LSP) framework based on tower
-
swiftide
Fast, streaming indexing, query, and agentic LLM applications in Rust
-
actix-rt
Tokio-based single-threaded async runtime for the Actix ecosystem
-
async_cell
A Cell<Option<T>> that you can await on
-
job-orchestrator
Asynchronous job orchestrator for managing and routing payloads between services and computing resources with quota tracking
-
elicitation
Conversational elicitation of strongly-typed Rust values via MCP
-
gix-actor
A way to identify git actors
-
delay_timer
Time-manager of delayed tasks. Like crontab, but synchronous asynchronous tasks are possible, and dynamic add/cancel/remove is supported.
-
actify
An intuitive actor model with minimal boilerplate
-
qml-rs
QML background job processing
-
deno_unsync
A collection of adapters to make working with Tokio single-threaded runtimes easier
-
exponential-backoff
An exponential backoff generator with jitter
-
containerd-shim-protos
TTRPC bindings for containerd shim interfaces
-
springtime-di
Dependency injection framework based on automatic component discovery and runtime autowiring
-
flo_binding
Declarative binding library for Rust
-
libevent
Rust bindings to the libevent async I/O framework
-
oly
Run interactive CLIs and AI agents like managed services with persistent PTY sessions
-
tokio-rustls-acme
Automatic TLS certificate management using rustls
-
fastcgi-client
Fastcgi client implemented for Rust
-
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).
-
nmrs
NetworkManager over D-Bus
-
rusty_falcon
Rust bindings for CrowdStrike Falcon API
-
agents
Facade crate for building typed Rust agents
-
hannibal
A small actor library
-
tokio-io-utility
Some helper functions for tokio::io
-
stackfuture
wrapper around futures that stores the wrapped future in space provided by the caller
-
spawns
Async runtime agnostic thread context task spawner for Rust
-
peace_params
Constraints and specifications for parameters for the peace automation framework
-
ctrlc2
Easy Ctrl-C handler version 2 for Rust projects
-
wg
Golang like WaitGroup implementation for sync/async Rust
-
safina
Safe async runtime
-
samsa
Rust-native Kafka/Redpanda protocol and client implementation
-
gardal
A WIP performance-focused token-bucket rate limiting and throttling library
-
rsactor
Efficient In-Process Actor Model Implementation for Rust
-
pi-async-rt
Based on future (MVP), a universal asynchronous runtime and tool used to provide a foundation for the outside world
-
signal-hook-tokio
Tokio support for signal-hook
-
web-push
Web push notification client with support for http-ece encryption and VAPID authentication
-
trait-variant
working with impl traits in Rust
-
executor-trait
A collection of traits to define a common interface across executors
-
scoped-futures
imposing upper bounds on Future lifetimes
-
keyring-lib
High-level, asynchronous API for keyring-rs, a cross-platform Rust library to manage credentials
-
mml-lib
Emacs MIME message Meta Language (MML)
-
ringline
Async I/O runtime with io_uring (Linux) and mio (cross-platform) backends
-
async-recursion
Recursion for async functions
-
prism-mcp-rs
Production-grade Rust SDK for Model Context Protocol (MCP) - Build AI agents, LLM integrations, and assistant tools with enterprise features
-
workflow-graph-queue
Queue traits, in-memory backends, and DAG scheduler for workflow-graph
-
tokio-io-timeout
Tokio wrappers which apply timeouts to IO operations
-
tigerbeetle-unofficial
Safe high level async bindings to tigerbeetle client library
-
lamellar
asynchronous tasking runtime for HPC systems developed in RUST
-
async_cache
Async refresh cache
-
mio-serial
A serial port implementation for mio
-
future-queue
Adapters to manage a queue of futures, where each future can have a different weight
-
async-openai-compat
OpenAI
-
async-flow
Async abstractions for flow-based programming (FBP)
-
uds-fork
A unix domain socket crate that supports abstract addresses, fd-passing, seqpacket and windows unix stream sockets
-
duroxide
Durable code execution framework for Rust
-
fluvio-future
I/O futures for Fluvio project
-
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
-
turnkeeper
An asynchronous, recurring job scheduler for Tokio with support for CRON, interval, and weekday/time schedules, plus retries, cancellation, and observability
-
runtara-core
Core execution engine for runtara - manages instances, checkpoints, signals, and durable sleep
-
asynk-strim
Lightweight stream generator library
-
unicycle
A scheduler for driving a large number of futures
-
rocketmq-runtime
Unofficial Rust implementation of Apache RocketMQ
-
google-plusdomains1
A complete library to interact with plusDomains (protocol v1)
-
better-logger
Flexible sync/async logger with console, file, and HTTP output
-
c-ares-resolver
An asynchronous DNS resolver, backed by c-ares
-
mlb-api
Endpoints for MLB's public Statcast API
-
adaptive-timeout
Adaptive timeout computation based on observed latency percentiles
-
flourish
Convenient and full-featured signals for Rust
-
shove
Async tasks via pubsub on steroids. Comes with built-in support for complex queue configurations, audit logs, autoscaling consumer groups and more.
-
motosan-agent-loop
Standalone ReAct agent loop — LlmClient + AgentLoop with no platform dependencies
-
genawaiter
Stackless generators on stable Rust
-
async_singleflight
Async singleflight
-
reratui
A modern, reactive TUI framework for Rust with React-inspired hooks and components, powered by ratatui
-
submap
B-Tree map for pub/sub services
-
apalis-postgres
Background task processing for rust using apalis and postgres
-
tipsy
Cross-platform IPC for Tokio
-
openai-oxide
Idiomatic Rust client for the OpenAI API — 1:1 parity with the official Python SDK
-
asynq
reliable & efficient distributed task queue in Rust, inspired by hibiken/asynq
-
tokio-process-tools
Interact with processes spawned by tokio
-
kdbplus
Dual q/kdb+ interface for API to build a shared library and an IPC client
-
claude-code-agent-sdk
Rust SDK for Claude Code CLI with bidirectional streaming, hooks, custom tools, and plugin support
-
kestrel-timer
High-performance async timer library based on Hierarchical Timing Wheel algorithm
-
ntex-io-uring
The low-level
io_uringuserspace interface for Rust -
upc
USB packet channel (UPC): provides a reliable, packet-based transport over USB
-
async-scoped
Spawn scoped (non 'static) asynchronous futures for async_std and tokio runtimes
-
persway-tokio
Sway layout and focus helper daemon that adds spiral and stack-main autotiling plus opacity and window renaming
-
llm-agent-runtime
Unified Tokio agent runtime -- orchestration, memory, knowledge graph, and ReAct loop in one crate
-
manual_future
A future that must be manually completed, similar to Java's CompletableFuture
-
pharos
Observer pattern which generates a futures 0.3 stream of events
-
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
-
filebuffer
Fast and simple file reading
-
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.)
-
futures-bounded
bounding futures in size and time
-
gcs-rsync
rsync support for gcs with higher perf than gsutil rsync
-
conducer
Easy async
-
busybody
Service Container and Dependency injector crate
-
yoagent
effective agent loop with tool execution and event streaming
-
tor-rtmock
Testing mock support for tor-rtcomapt
-
cc-sdk
Rust SDK for Claude Code CLI with full interactive capabilities
-
agnosai
Provider-agnostic AI orchestration framework
-
edgequake-llm
Multi-provider LLM abstraction library with caching, rate limiting, and cost tracking
-
async-task
Task abstraction for building executors
-
openrouter_api
client library for the OpenRouter API
-
rustls-acme
TLS certificate management and serving using rustls
-
charmed-bubbletea
A powerful TUI framework based on The Elm Architecture
-
obzenflow-fsm
Async-first Finite State Machine library inspired by Akka (Classic) FSM
-
ai-agents-llm
LLM providers for AI Agents framework
-
rl-core
Core logic for a token-bucket rate-limiter
-
liteq
High-performance job queue library for Rust using Redis with auto-retry, connection pooling, async handlers, and multi-consumer fair distribution
-
kube-lease-manager
Ergonomic and reliable leader election using Kubernetes Lease API
-
mio-aio
POSIX AIO bindings for mio
-
ginepro
A client-side gRPC channel implementation for tonic
-
poll-promise
Poll the result of an async operation in a game or immediate mode GUI
-
kafka
Rust client for Apache Kafka
-
viz
Fast, robust, flexible, lightweight web framework for Rust
-
openraft-surrealkv
key-value store built on top of OpenRaft, designed for learning and experimentation with Raft consensus algorithm
-
next-gen
Safe generators on stable Rust
-
pingora-timeout
Highly efficient async timer and timeout system for Tokio runtimes
-
celers-metrics
Prometheus metrics and observability for CeleRS
-
tokio-task-pool
Task pool for Tokio Runtime
-
rust-tg-bot-ext
Application framework for Telegram bots -- handlers, filters, persistence, job queue
-
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.
-
j4rs
j4rs stands for 'Java for Rust' and allows effortless calls to Java code, from Rust
-
tirea-extension-permission
Tool-level permission policies and user-approval gating for tirea agents
-
llm-kit-provider
Provider interface and traits for the LLM Kit - defines the contract for implementing AI model providers
-
round-based
Driver for MPC protocols
-
lsp-server-tokio
An async-first LSP server infrastructure crate using Tokio
-
pubnub
SDK for Rust
-
continue
Swift-style continuation API
-
ranked-semaphore
A high-performance ranked semaphore with priority support
-
blockstore
An IPLD blockstore capable of holding arbitrary data indexed by CID
-
agentwerk
A minimal Rust crate that gives any application agentic capabilities
-
gql_client
Minimal GraphQL client for Rust
-
containerd-client
GRPC bindings to containerd APIs
-
rainy-sdk
Official Rust SDK for Rainy API by Enosis Labs v0.6.14 - OpenAI/GPT-5 parity, native streaming events, and legacy static model cleanup
-
transform-stream
Lightweight async stream wrapper
-
streamweave
Composable, async, stream-first computation in pure Rust
-
hf-xet
Client library and tooling for the Hugging Face Xet data storage system
-
shmipc
Shared memory IPC for Rust
-
greentic-runner-host
Host runtime shim for Greentic runner: config, pack loading, activity handling
-
io_uring_buf_ring
Help user create and manage io-uring buffer-ring
-
kiomq
An all-in-one task-queue and orchestration library for Rust
-
qbice
The Query-Based Incremental Computation Engine
-
codex-helper
A Rust-based local helper / proxy for Codex CLI traffic with multi-provider routing, usage-aware switching, filtering, and session helpers
-
tokio-muxt
Timer for a limited set of events that multiplexes over a single tokio Sleep instance
-
tachyonix
A very fast asynchronous, multi-producer, single-consumer bounded channel
-
reactive-mutiny
async Event-Driven Reactive Library with advanced & optimized containers (channels) and Stream executors
-
futures-rustls
Asynchronous TLS/SSL streams for futures using Rustls
-
libsync
A channels library
-
dataloader
Facebook's DataLoader using async-await
-
tokio-rate-limit
High-performance, lock-free rate limiting library with pluggable algorithms and Axum middleware
-
openssh-sftp-protocol
Data format used to communicate with openssh mux server
-
tracing-otel-extra
Bootstrap utilities for tracing and OpenTelemetry integration
-
magi-core
LLM-agnostic multi-perspective analysis system inspired by MAGI
-
soul-core
Async agentic runtime for Rust — steerable agent loops, context management, multi-provider LLM abstraction, virtual filesystem, WASM-ready
-
apcore
Schema-driven module standard for AI-perceivable interfaces
-
govee
Async Rust library for controlling Govee smart lighting devices via cloud and local LAN APIs
-
future_form
Abstractions over Send and !Send futures
-
scoped-stream-sink
Easy way to make streams and sinks
-
arc-malachitebft-core-consensus
Core consensus algorithm for the Malachite BFT consensus engine
-
patharg
Treat "-" (hyphen/dash) arguments as stdin/stdout
-
async-global-executor
A global executor built on top of async-executor and async-io
-
combine-latest
Combines two or more streams into a new stream which yields tuples with the latest values from each input stream
-
v_exchanges
Implementations of HTTP/HTTPS/WebSocket API methods for some crypto exchanges, using crypto-botters framework
-
bob-runtime
Runtime orchestration layer for Bob Agent Framework
-
delite-core
The sqlite of durable agent execution — crash-recoverable AI agents with exactly-once semantics. Zero dependencies.
-
hydra
A framework for writing fault tolerant, highly scalable applications with the Rust programming language
-
lightstream
Composable, zero-copy Arrow IPC and native data streaming for Rust with SIMD-aligned I/O, async support, and memory-mapping
-
openai-ergonomic
Ergonomic Rust wrapper for OpenAI API
-
polaris_core_plugins
Core infrastructure plugins for Polaris
-
futures-util
Common utilities and extension traits for the futures-rs library
-
async-ringbuf
Async SPSC FIFO ring buffer
-
mcp-attr
declaratively building Model Context Protocol servers
-
streamunordered
An efficient async stream multiplexer
-
xio-rs
A nonblocking IO dispatcher, FS change notifications, async data processing
-
tmq
ZeroMQ bindings for Tokio
-
multi-llm
Unified multi-provider LLM client with support for OpenAI, Anthropic, Ollama, and LMStudio
-
opencode_rs
Rust SDK for OpenCode (HTTP-first hybrid with SSE streaming)
-
jaeb
snapshot-driven event bus
-
bubbletea-rs
The fun, functional, and stateful way to build terminal apps in Rust
-
async-speed-limit
Asynchronously speed-limiting multiple byte streams
-
genai-rs
client library for Google's Generative AI (Gemini) API with streaming, function calling, and multi-turn conversations
-
activitystreams-vocabulary
ActivityStreams 2.0 Vocabulary data structures
-
libublk
building linux block device in userspace
-
wavelet
High-performance graph-based stream processing runtime
-
ironflow-worker
HTTP-based background worker for ironflow — polls the API and executes workflows
-
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.
-
durable-lambda-core
Core replay engine, types, and operation logic for AWS Lambda durable execution in Rust
-
axum-serde
multiple serde-based extractors / responses for the Axum web framework, also offers a macro to easily customize extractors / responses
-
graph-flow
A high-performance, type-safe framework for building multi-agent workflow systems in Rust
-
twilight-http-ratelimiting
Discord REST API ratelimiter implementations for the Twilight ecosystem
-
mmap-io
High-performance, async-ready memory-mapped file I/O library for Rust. Supports fast segment-based loading, updates, and persistence. Designed for database engines, game runtimes, and real-time applications.
-
rust-multipart-rfc7578_2
multipart/form-data (RFC7578)
-
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.
-
futures-rx
Rx implementations for the futures crate
-
lazyflow
A lazy, effectful streaming library for Rust -- FS2-inspired LazyFlow<B> with pull-based sources, async transforms, backpressure, and concurrency
-
flowly
modular and reusable components for building robust pipelines processing audio, video and other
-
qubit-retry
Retry module, providing a feature-complete, type-safe retry management system with support for multiple delay strategies and event listeners
-
axum-extra
Extra utilities for axum
-
treadle
A persistent, resumable, human-in-the-loop workflow engine backed by a petgraph DAG
-
triggered
Triggers for one time events between tasks and threads
-
pipedream-rs
A typed, heterogeneous event relay with observable delivery, completion tracking, and lossless message routing
-
zduny-wasm-timer
Abstraction over std::time::Instant and futures-timer that works on WASM
-
async-injector
Reactive dependency injection for Rust
-
sids
An actor-model concurrency framework providing abstraction over async and blocking actors
-
fluxion-stream
Stream combinators with ordering guarantees for async Rust
-
vmcircbuffer
Double Mapped Circular Buffer
-
branchforge
Graph-first Rust runtime for durable LLM agents
-
futures-locks
Futures-aware lock primitives
-
some_executor
A trait for libraries that abstract over any executor
-
events
Async manual-reset and auto-reset events for multi-use signaling
-
tower-sessions-ext
A maintained fork of tower-sessions-ext, providing session middleware for tower and axum
-
tokio-pipe
Asynchronous pipe(2) library using tokio
-
edgee
Rust SDK for the Edgee AI Gateway
-
call-agent
A multimodal chat API library with tool support, OpenAI API compatible
-
pipex
A powerful functional pipeline macro for Rust combining sync, async, parallel, and streaming operations with extensible error handling
-
mkv-element
A Matroska/WebM element reader and writer
-
service-async
A Service like tower in async style
-
agent-sdk
Rust Agent SDK for building LLM agents
-
ractor_actors
actors built with Ractor
-
fang
Background job processing library for Rust
-
nb
Minimal non-blocking I/O layer
-
google-places-api
Unofficial Google Places API for rust
-
kicad-ipc-rs
Rust client library for the KiCad IPC API (async-first)
-
mq-bridge
An asynchronous message bridging library connecting Kafka, MQTT, AMQP, NATS, MongoDB, HTTP, and more
-
elizaos-plugin-cron
elizaOS Cron Plugin - scheduled job management
-
tcrm-monitor
Task dependency management and execution library with parallel processing, real-time monitoring, and runtime control
-
mill-io
A lightweight event loop library for Rust providing efficient non-blocking I/O management
-
executor-core
A zero-cost task executor abstraction layer for Rust async runtimes
-
async-notify
A general version async Notify, like
tokioNotify but can work with any async runtime -
langchain-ai-rust
Build LLM applications in Rust with type safety: chains, agents, RAG, LangGraph, embeddings, vector stores, and 20+ document loaders. A LangChain port supporting OpenAI, Claude, Gemini…
-
async_io_stream
IntoAsyncRead on steriods
-
runner_q
Durable activity queue and worker system
-
ttlog
A comprehensive high-performance tracing and logging system
-
opencode-sdk
Rust SDK for OpenCode (HTTP-first hybrid with SSE streaming)
-
ads_client
An asynchronous, non-blocking ADS client
-
tokio-stream
work with
Streamandtokio -
axtask
ArceOS task management module
-
kube-coordinate
Kubernetes leader election using the coordination.k8s.io API
-
wechat-minapp
微信小程序和服务号服务端API SDK
-
discro
DISCRete Observables for asynchronous Functional Reactive Programming (FRP)
-
omnillm
Production-grade LLM API gateway with multi-key load balancing, per-key rate limiting, circuit breaking, and cost tracking
-
rxr
Reactive extensions for event-driven applications
-
uring-file
Async file I/O for Linux using io_uring
-
rrq-producer
RRQ producer client for enqueuing jobs into Redis
-
rustix-uring
The low-level
io_uringuserspace interface for Rust -
tokio-par-util
running computations in parallel on top of Tokio
-
tasklet
An asynchronous task scheduling library
-
tokise
An asynchronous runtime compatible with WebAssembly and non-WebAssembly targets
-
open-agent-sdk
Production-ready Rust SDK for building AI agents with local OpenAI-compatible servers (LMStudio, Ollama, llama.cpp, vLLM). Features streaming, tools, hooks, retry logic, and comprehensive examples.
-
futures-timeout
that provides timeouts for futures and streams
-
taskvisor
Event-driven task orchestration with restart, backoff, and user-defined subscribers
-
elegant-departure
simplify graceful shutdown
-
motosan-ai
Rust SDK for multi-provider AI chat
-
mini_exercism
Minimalistic Rust library to interact with the Exercism.org APIs
-
alto-follower
Run a follower node for alto
-
dynify
Add dyn compatible variant to your async trait
-
keen-retry
Retry-as-a-value: zero-cost, ownership-friendly retries with diagnosable outcomes with full async and lib/app boundaries support
-
s3tui
TUI application for multiple s3 account operations
-
a3s-lane
Lane-based priority command queue for async task scheduling with reliability, scalability, and observability features
-
conogram
An async wrapper for Telegram Bot API
-
stakker
A lightweight low-level single-threaded actor runtime
-
async-cuda
Async CUDA for Rust
-
cmd-proc
Process command builder with capture support
-
dark-std
asynchronous containers build on tokio. It uses a read-write separation design borrowed from Golang
-
dbuff
Double-buffered state with async command chains, streaming, and keyed task pools for ratatui applications
-
ntex-polling
Portable interface to epoll, kqueue, event ports, and IOCP
-
futures-signals-ext
Extension to futures-signals: MutableOption with combinators, spawning, predicate driven selections from SignalVec
-
aselect
Opinionated replacement for tokio::select!, avoiding certain pitfalls
-
rdkafka-sys
Native bindings to the librdkafka library
-
kcp-tokio
A high-performance async Rust implementation of KCP - A Fast and Reliable ARQ Protocol
-
swiftide-docker-executor
A docker executor for swiftide agent tools
-
rinf-router
Router and handler framework for RINF-based Flutter <> Rust apps
-
async-graphql-actix-web
async-graphql for actix-web
-
stream_throttle
Stream combinator, to limit the rate at which items are produced
-
tokio-process-stream
that wraps a tokio::process into a tokio::stream
-
uni-xervo
Unified Rust runtime for local and remote embedding, reranking, and generation models
-
postage
An async channel library
-
greentic-session
Greentic multi-tenant session manager with in-memory and Redis backends
-
codexus
Ergonomic Rust wrapper for codex app-server with runtime safety and release gates
-
sacs
Async Cron Scheduler for Tokio
-
containerd-shim
containerd shim extension
-
yazi-macro
Yazi macros
-
windmark
An elegant and highly performant async Gemini server framework
-
oxide_core
Rust engine primitives for Oxide (store, snapshot streams, error model, optional persistence)
-
telers
An asynchronous framework for Telegram Bot API written in Rust
-
async-executor
Async executor
-
aoc_leaderbot_lib
Support library for aoc_leaderbot, an Advent of Code leaderboard-watching bot
-
slop-futures
Async and concurrent execution utilities for SLOP
-
spider_agent
A concurrent-safe multimodal agent for web automation and research
-
plexor-core
Core library for the rust implementation of the Plexo distributed system architecture, providing the fundamental Plexus, Neuron, Codec, and Axon abstractions
-
osd-core
OpenSequenceDiagrams core - A sequence diagram parser and SVG renderer
-
iron_runtime
Agent runtime with LLM request routing and translation
-
histlog
hdrhistogram crate, provides off-thread serialization of HdrHistogram interval logs to file
-
orra
Context-aware agent session management for any application
-
specta-serde
Serde support for Specta
-
async_zip_futures
An asynchronous ZIP archive reading/writing crate using futures-rs
-
ave-actors-actor
Ave actor model
-
operese-dagx
A minimal, type-safe, runtime-agnostic async DAG (Directed Acyclic Graph) executor with compile-time cycle prevention and true parallel execution
-
futures-executor
Executors for asynchronous tasks based on the futures-rs library
-
tokio-udev
Non-blocking/Asynchronous Tokio support for udev device events
-
ate
Distributed immutable data store with strong encryption and authentication
-
swink-agent
Core scaffolding for running LLM-powered agentic loops
-
hypercore
Secure, distributed, append-only log
-
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
-
botrs
QQ Bot framework based on QQ Guild Bot API
-
z8run-core
Flow engine, DAG scheduler, and 35+ built-in nodes for z8run — visual workflow automation
-
aether-llm
Multi-provider LLM abstraction layer for the Aether AI agent framework
-
ollama-oxide
integrating with Ollama's native API, providing low-level inference and high-level conveniences
-
swansong
Graceful Shutdown
-
mqi
Idiomatic IBM® MQ Interface (MQI) and MQ Administration Interface (MQAI) APIs
-
async-sleep
Async Sleep
-
relentless
Composable retry policies for fallible operations and polling
-
timer-lib
A feature-rich Rust library for creating and managing timers
-
popol
Minimal non-blocking I/O
-
reactio
Low-Latency Event Driven Nonblocking Reactor Pattern
-
yield-progress
Combined progress reporting and cooperative task yielding
-
cloud_terrastodon_azure_resource_types
Generated enum for Azure resource types for use in the Cloud Terrastodon project
-
telltale
Session types for multi-party asynchronous communication
-
async-dropper
The least-worst ad-hoc implementation of AsyncDrop as a Derive macro
-
ghost_actor
GhostActor makes it simple, ergonomic, and idiomatic to implement async / concurrent code using an Actor model
-
gyre
A lock-free asynchronous ring buffer inspired by the LMAX Disruptor
-
peace_rt_model
Runtime data types for the peace automation framework
-
claude-code-client-sdk
Rust SDK for integrating Claude Code as a subprocess with typed APIs
-
tools_interface
Abstractions of serveral Wikipedia/Wikimedia/Wikidata-related tools
-
adk-core
Core traits and types for Rust Agent Development Kit (ADK-Rust) agents, tools, sessions, and events
-
fin-stream
Real-time market data streaming primitives — 100K+ ticks/second ingestion pipeline
-
ash-flare
Fault-tolerant supervision trees for Rust with distributed capabilities inspired by Erlang/OTP
-
est
Extensions for the rust Standard library and Tokio
-
native_messaging
Cross-platform Rust native messaging host for browser extensions (Chrome & Firefox), with async helpers and manifest installer
-
io-tether
A small library for defining I/O types which reconnect on errors
-
apcore-mcp
MCP bridge for apcore — expose apcore modules as MCP tools
-
tokio-memq
high-performance in-memory async message queue
-
activitystreams
A set of core types and traits for activitystreams data
-
ipc-rpc
A wrapper over servo/ipc-channel which provides many high level features
-
background-jobs-sled
Sled storage backend for background-jobs
-
ankit-engine
High-level workflow operations for Anki via AnkiConnect
-
mcmc-rs
Minimal rust client for memcached
-
agent-teams
Generic Rust agent teams framework replicating Claude Code Agent Teams architecture with pluggable backends for Claude Code, Codex, and Gemini CLI
-
completion_stage
Push-based futures for Rust similar to Java's CompletionStage
-
skp-ratelimit
Advanced, modular, extensible rate limiting library with GCRA, per-route quotas, and composite keys
-
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…
-
abscissa_tokio
Support for launching Tokio runtimes within Abscissa applications
-
events_once
Efficient oneshot events (channels) with support for single-threaded events, object embedding, event pools and event lakes
-
task-killswitch
Abort all tokio tasks at once
-
rocketmq-remoting
Apache rocketmq remoting
-
tokio-immediate
Asynchronous glue for your immediate mode UI
-
ares-server
A.R.E.S - Agentic Retrieval Enhanced Server: A production-grade agentic chatbot server with multi-provider LLM support, tool calling, RAG, and MCP integration
-
b2_backblaze
basic async library to upload small files to backblaze b2 service
-
oneringbuf
A lock-free single-producer, single-consumer (SPSC) ring buffer with in-place mutability, asynchronous support, and virtual memory optimisation
-
apalis-sqlite
Background task processing for rust using apalis and sqlite
-
velomorph
High-performance zero-copy struct transformation for Rust with asynchronous background deallocation
-
orphanage
Random collection of stuff that is still searching for a home
-
rtcom-core
Core library for rtcom (Rust Terminal Communication): serial device abstraction, event bus, and session orchestration
-
crabbyq
A declarative async Rust framework for message-driven microservices
-
kalshi-trade-rs
Rust client for the Kalshi trading API and WebSocket streams
-
certsd
automated, asynchronous LE certificate issuer
-
lmrc-docker
Docker client library for the LMRC Stack - ergonomic fluent APIs for containers, images, networks, volumes, and registry management
-
observable-property-tokio
A thread-safe, async-compatible observable property implementation for Rust using Tokio
-
mavkit
Async MAVLink SDK for vehicle control, missions, and parameters
-
pipe-it
A lightweight, type-safe library for building linear and concurrent processing pipelines in Rust
-
mapped_futures
A collection of futures based on FuturesUnordered that supports insertion, removal and mutation of futures by key
-
nebkor-maelstrom
synchronous client for creating Maelstrom distributed clients
-
upflow
An asynchronous workflow engine based on DAG
-
async-object-pool
object pool implementation that uses asynchronous synchronization primitives only
-
preloader
Asynchronous data preloader library
-
async-rx
functions for async reactive programming
-
scanbridge
A unified, pluggable API for malware scanning with circuit breakers, policy enforcement, and audit logging
-
odem-rs
Object-based Discrete-Event Modelling in Rust using async/await
-
async-hybrid-sleep
Hybrid async sleep combining runtime timers with spin-sleeping for sub-millisecond accuracy
-
pi_async_buffer
Asynchronous Buffer for IO
-
runtara-environment
Environment server for runtara - image registry, OCI runner, and instance management
-
jamjet-engram
Engram — durable memory layer for AI agents. Temporal knowledge graph, semantic search, and MCP-native tools.
-
wiremocket
Websocket mocking to test Rust applications
-
ulua
High level Luau bindings to Rust with async/await support
-
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
-
madsim-rdkafka
The rdkafka simulator on madsim
-
alpaca-data
Rust client for the Alpaca Market Data HTTP API
-
ros2_helpers
A wrapper around safe drive
-
polaris_models
Model provider interface and registry for Polaris
-
layer0
Protocol traits for composable agentic AI systems
-
serialport-stream
Async TryStream for serialport reading utilizing serialport-rs using platform-specific I/O
-
braintrust-sdk-rust
Rust SDK for Braintrust logging and tracing
-
philiprehberger-retry-kit
Async retry with exponential backoff and circuit breaker for Rust
-
rs-event-emitter
simulate promise implementation for rust
-
bob-chat
Chat channel types and streaming abstractions for Bob Agent Framework
-
eventgraph
Hash-chained, append-only, causal event graph
-
simple-pool
async pool for any kind of resources
-
tokio_schedule
schedule tasks in tokio runtime
-
gem-rs
that serves as a wrapper around the Google Gemini API, providing support for streaming
-
another-rxrust
A different implementation than
rxRustfor easier use ofReactiveXinRust -
retainer
Minimal async cache in Rust with support for key expirations
-
tor-rpcbase
Low level functionality for Arti's RPC service
-
halo-spider
A fast, async web crawling framework inspired by Scrapy, built in Rust
-
easy-schedule
A flexible task scheduler built on Tokio with multiple scheduling options and skip conditions
-
fluxion-stream-time
Time-based operators extending fluxion-stream with monotonic timestamps
-
niblits
Token-aware, multi-format text chunking library with language-aware semantic splitting
-
tirea-extension-observability
LLM inference and tool-call telemetry aligned with OpenTelemetry GenAI conventions
-
tower-resilience-circuitbreaker
A circuit breaker middleware for Tower services
-
tcrm-task
Task execution unit for TCRM project
-
tokio-tasks
Task management for tokio
-
mpi-sys
Message Passing Interface bindings for Rust
-
tjiftjaf
including an encoder and decoder for MQTT v3.1.1. It also includes a client.
-
apb
Traits and types to handle ActivityPub objects
-
cancel-safe-futures
Alternative futures adapters that are more cancellation-aware
-
asyncjsonstream
Async JSON stream reader for selective parsing of large payloads
-
nosy
Change notification / observation / broadcast channels, with filtering and coalescing. no_std compatible.
-
spawn_groups
Structured concurrency construct written in Rust, for Rustaceans
-
actix-web-flash-messages
Flash messages for actix-web applications
-
ws_stream_tungstenite
Provide AsyncRead/AsyncWrite over Tungstenite WebSockets
-
openaction
creating plugins for the OpenAction API
-
argentor-agent
Agentic loop, LLM provider backends, guardrails, and ReAct engine for Argentor
-
peon-runtime
A runtime-agnostic agent execution engine with zero-trust context injection, multimodal messaging, and pluggable LLM providers
-
symposium-acp-agent
Symposium-enriched ACP agent that wraps downstream agents with enhanced capabilities
-
sse-gateway
A lightweight, pluggable SSE (Server-Sent Events) gateway library
-
amqp-lapin-helper
rust lapin helper
-
tokio-fastcgi
FastCGI handler (responder, authorizer, filter) library for Tokio
-
async-graphql-wasm-parser
GraphQL query parser for async-graphql-wasm
-
agentic-robotics-rt
High-performance agentic robotics framework with ROS2 compatibility
-
asyncapi-rust
AsyncAPI 3.0 specification generation for Rust WebSockets and async protocols
-
sugars_async_stream
Async stream utilities and abstractions for the cyrup-sugars ecosystem
-
async-fuse
Helpers for fusing asynchronous computations
-
serviceless
actor model in rust, like actix
-
fprovider
Provider library for the fiddlesticks agent harness framework
-
kraken-ws-sdk
Production-grade Kraken WebSocket SDK with order book visualization API, backpressure control, latency tracking, and order flow analysis
-
ao-core
Core traits and types for the ao-rs agent orchestrator framework
-
stt-cli
Speech to text Cli using Groq API and OpenAI API
-
streamweave-attractor
Attractor pipeline as a StreamWeave graph
-
cortex-client
API for Cortex, a powerful observable analysis and active response engine
-
claude-agents-sdk
Rust SDK for building agents with Claude Code CLI
-
ferr
Crypto CEX connector framework
-
calimero-utils-actix
Core Calimero infrastructure and tools
-
faf-radio-rust
Radio Protocol client for FAF — broadcast AI context once, all tools receive. Client SDK for mcpaas.live.
-
adk-graph
Graph-based workflow orchestration for ADK-Rust agents
-
wauldo
Official Rust SDK for Wauldo — Verified AI answers from your documents
-
rio-rs
Distributed stateful service framework
-
reord
Run your tests multi-threaded, but in a reproducible way
-
quinn-udp-jls
UDP sockets with ECN information for the QUIC transport protocol
-
mobc
A generic connection pool with async/await support
-
open-multi-agent-rs
A multi-agent orchestration framework for Rust — streaming LLM calls, tool use, task pipelines, retry, and observability
-
tears
elegant framework for building TUI applications using The Elm Architecture (TEA)
-
ogenius
Lightweight AI inference server using HuggingFace models directly - a simpler alternative to Ollama
-
timer-deque-rs
A OS based timer and timer queue which implements timeout queues of different types
-
fama
Pipeline Manager
-
minitimer
A mini timer of delayed tasks. Only asynchronous tasks are possible on tokio runtime, and dynamic add/cancel/remove is supported.
-
agility
A powerful and elegant reactive programming library for Rust, inspired by category theory
-
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.
-
jira-mcp-rs
Model Context Protocol (MCP) server for Jira
-
scuffle-context
Go-like context utilities for Rust
-
mal-api
An asynchronous MyAnimeList (MAL) API library for Rust
-
tapis-sdk
Comprehensive Rust SDK for Tapis services
-
async-socks5
An async/.await SOCKS5 implementation
-
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
-
syros
Distributed Coordination Service
-
vllm-client
client for vLLM OpenAI-compatible API
-
autumn-harvest
Durable workflow orchestration engine core
-
kotoba-llm
Unified multi-vendor LLM client abstraction, supporting providers such as OpenAI, Anthropic, Google Gemini, etc
-
cortexai-crew
Multi-agent crew orchestration for Cortex: parallel execution, delegation and coordination
-
agnostic
abstraction layer for any async runtime
-
async-unsync
asynchronous, unsynchronized (thread-local) channels and semaphores
-
agent-orchestrator-sdk
Rust SDK for orchestrating LLM-powered agents, shared task execution, and teammate coordination
-
enact-config
Unified configuration management for Enact - secure storage with keychain and encrypted files
-
aj
Background Job Library for Rust
-
llm-kit-anthropic
Anthropic provider for LLM Kit - Complete Claude integration with streaming, tools, thinking, and citations
-
aeon-market-scanner-rs
CEX/DEX market scanner: fetch prices, stream WebSocket updates, and find arbitrage opportunities
-
aether-mcp-utils
MCP client and server utilities for the Aether AI agent framework
-
async-rt
A small library designed to utilize async executors through an common API while extending features
-
renamed
Official Rust SDK for the renamed.to API - AI-powered document renaming and processing
-
agentic-robotics-mcp
High-performance agentic robotics framework with ROS2 compatibility
-
jamjet-ir
JamJet canonical Intermediate Representation — workflow IR, validation, serialization
-
reactor-trait
A collection of traits to define a common interface across reactors
-
raftoral
Fault-tolerant workflow orchestration library using embedded Raft consensus for Rust applications
-
psummary
Summary 🗣️
-
baochuan
A multi-provider AI API client for Rust — connecting your code to every major AI provider
-
erudite
A fully-asynchronous, sandboxed, language-agnostic, test running library
-
web-task
The simplest way to run async tasks on the web
-
async-ffi
FFI-compatible
Futures -
flatline
ssh-2.0 client library
-
rexecutor
A robust job processing library
-
peace_resource_rt
Runtime resources for the peace automation framework
-
cruxai-script
YAML-driven pipeline scripting for the cruxai agentic DSL
-
pulsehive
Shared Consciousness SDK for Multi-Agent AI Systems
-
clockworker
A single-threaded async executor with EEVDF-based fair scheduling and pluggable task schedulers
-
crates-tui
A TUI for crates.io
-
tokio-reactor-trait
reactor-trait implementation for tokio
-
comnoq
QUIC for compio with noq backend
-
tokio-zookeeper
Asynchronous client library for interacting with Apache ZooKeeper
-
black-box
A minimal actor framework
-
api_builder
client-agnostic API builder, inspired by the GitLab crate
-
llm-stack
Core traits, types, and tools for the llm-stack SDK
-
motosan-workflow-model
Data types, traits, and graph algorithms for motosan-workflow
-
async_executors
Implements Spawn, SpawnLocal and SpawnHandle for commonly used executors
-
batch-channel
async channel that reduces overhead by reading and writing many values at once
-
aisil
A lightweight framework to define APIs as types
-
openai-agents-openai-rs
OpenAI provider, models, sessions, and hosted tools for openai-agents-rust
-
activitystreams-kinds
Type-safe activitystreams 'type' values
-
pgboss
job queueing service
-
wishmaster-sdk
Rust SDK for WishMaster - AI agent marketplace with ERC-8004 reputation, agent-to-agent work, and x402 payments
-
orchestral
Workflow orchestration for grounded agents — stateful multi-step pipelines with agent loop, MCP tools, and skills
-
tokio-sticky-channel
Sticky channel pattern for Tokio - routes messages to specific receivers based on ID hash for consistent message delivery
-
midstreamer-scheduler
Ultra-low-latency real-time task scheduler
-
epson
support for communicating with Epson brand thermal POS printers
-
stdexec-rs
port of C++ stdexec (P2300) — Senders/Receivers for structured concurrency
-
kojin
Async distributed task queue for Rust — like Celery, BullMQ, Sidekiq, but for Rust
-
swiftide-docker-service
A docker executor for swiftide agent tools
-
handle
Trait for asynchronous context pipeline
-
futures-byteorder
A modern async byteorder library for the smol/futures-lite ecosystem
-
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.
-
beetry-plugin
Internal beetry crate. For the public API, check the beetry crate.
-
futures-core
The core traits and types in for the
futureslibrary -
beetry-engine
Internal beetry crate. For the public API, check the beetry crate.
-
esrs
A Prima.it-opinionated library to achieve cqrs/es
-
futures-time
async time combinators
-
seesaw_utils
patterns for seesaw-based applications — batching, dataloader, and more
-
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.
-
evno
A high-performance event bus for asynchronous tasks and event-driven systems
-
stream_shared
creating shareable streams that can be cloned and consumed by multiple consumers
-
task-supervisor
Supervisor for long-lived tokio tasks
-
lwleen-rpc
RPC (信令路由), 组件间数据通信
-
aimdb-embassy-adapter
Embassy async runtime adapter for AimDB embedded targets
-
tokio-actors
Zero-ceremony, Tokio-native actors with strong typing and production-ready edge case handling
-
feature-extension-for-smol
Feature extension for smol
-
ya-gcp
APIs for using Google Cloud Platform services
-
llm-pipeline
Reusable node payloads for LLM workflows: prompt templating, Ollama calls, defensive parsing, streaming, and sequential chaining
-
aoc_leaderboard
Strongly-typed wrapper for Advent of Code leaderboard data
-
aether-acp-utils
Agent Client Protocol (ACP) utilities for the Aether AI agent framework
-
apalis-pgmq
Background task processing for rust using apalis and pgmq
-
ractor_cluster
Distributed cluster environment of Ractor actors
-
ckanaction
featuring an API wrapper of the CKAN Action v3 API
-
async-priority-lock
A priority-based async lock. Optionally no-std.
-
pexels-cli
client for the Pexels API
-
ankit
Complete async Rust client for the AnkiConnect API
-
futures_orchestra
A Tokio-based task pool for managing concurrent execution of futures with queuing, labeling, notifications and cancellation
-
cortexai-workflow
YAML-based workflow DSL for Cortex: define multi-agent pipelines declaratively
-
rust-paper
Rust Wallpaper manager from ( https://wallhaven.cc/ ) for Linux/UNIX only
-
palladium-plugin-api
Zero-dependency C ABI types for Palladium plugin boundaries
-
mlua-luau-scheduler
Luau-based async scheduler, using mlua and async-executor
-
object_transfer
An object transfer library for various message broker and/or protocols
-
rumpsteak-aura
Session types for multi-party asynchronous communication
-
durable-lambda-builder
Builder-pattern API style for AWS Lambda durable execution workflows
-
asyncs
async runtime agnostic facilities
-
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.
-
cortexai-core
Core types, traits and abstractions for the Cortex AI agent framework
-
firq-async
Tokio async adapter for firq-core
-
volo-http
HTTP framework implementation of volo
-
tsuki-scheduler
light wight, composable and extensible scheduler for every runtime
-
aimdb-tokio-adapter
Tokio runtime adapter for AimDB - full-featured std async runtime support
-
wiremock_logical_matchers
Logical matchers for use with wiremock
-
aerostream
Bluesky client using EventStream
-
litellm-rust
Minimal Rust SDK port of LiteLLM – unified interface for chat, embeddings, images, and video across OpenAI-compatible, Anthropic, Gemini, and xAI providers
-
some_global_executor
Reference thread-per-core executor for the some_executor crate
-
multra
An async parser for
multipart/form-datacontent-type in Rust -
cmdreg
A lightweight string-keyed command dispatcher with axum-style extractors for Rust
-
madsim-tokio
The
tokiosimulator on madsim -
durable-lambda-trait
Trait-based API style for AWS Lambda durable execution workflows
-
ssec-core
streaming implementation of the SSEC file format
-
rustycord
A fast, lightweight, and feature-rich Discord bot library written in Rust
-
lazyllama
A lightweight TUI client for Ollama with markdown support and smart scrolling
-
pi_async_transaction
Asynchronous abstraction for transactions
-
async-ssh2-lite
Asynchronous ssh2
-
turbomcp-server
Production-ready MCP server with zero-boilerplate macros and transport-agnostic design
-
monoio-codec
Codec for Monoio
-
openrouter-rust
A modular, type-safe Rust client for the OpenRouter API
-
rzmq
High performance, fully asynchronous, safe pure-Rust implementation of ZeroMQ (ØMQ) messaging with io_uring and TCP Cork acceleration on Linux
-
omniference
A multi-protocol inference engine with provider adapters
-
tokio-rayon
Mix async code with CPU-heavy thread pools using Tokio + Rayon
-
cortexai-data
Data matching, CPF validation, and cross-source consolidation for Brazilian entity data
-
ritlers
A task-length aware rate limiter that waits for tasks to finish before counting them against the rate limit
-
deepseek-api
DeepSeek API SDK is a powerful Rust client library for interacting with the DeepSeek service
-
rio
GPL-3.0 nice bindings for io_uring. MIT/Apache-2.0 license is available for spacejam's github sponsors.
-
spiris
Rust client for the Spiris Bokföring och Fakturering API (formerly Visma eAccounting)
-
motosan-workflow-swarm
Dynamic task queue execution engine for motosan-workflow
-
peace_item_tar_x
Manages extracting a tar file for the peace framework
-
tianshu-observe
Observer implementations for the Tianshu workflow engine
-
plunger
quickly unblock your async tasks
-
chronon
Deterministic execution kernel with crash-safe replication and exactly-once side effects
-
kompact
Kompics component model combined with the Actor model
-
durable-lambda-closure
Closure-native API style for AWS Lambda durable execution workflows
-
rocketmq-controller
RocketMQ Controller Module - High Availability Raft-based Controller
-
yazi-core
Yazi core logic
-
openrustclaw-core
Core types, traits, and error handling for OpenRustClaw
-
peace_item_sh_cmd
Manages running a shell command for the peace framework
-
motosan-chat-core
Core types and runtime for the motosan-chat chatbot framework
-
trillium-tokio
tokio runtime adapter for trillium.rs
-
legend-saga
working with RabbitMQ and asynchronous operations
-
roam-task-local
Task-local storage for async tasks, vendored from BugenZhao/task-local
-
async-ssh2-russh
Lighweight async ssh2 client, wrapping russh
-
futures-scopes
Runtime agnostic, nestable, scopes for spawning non-static futures
-
traitclaw-team
Multi-agent orchestration for TraitClaw — teams, routing, delegation, and verification chains
-
wae-scheduler
WAE Scheduler - 任务调度器，支持 Cron、定时任务、延迟任务
-
tiny_kafka
A tiny Kafka client library with producer and consumer functionalities
-
nsq-async-rs
An asynchronous Rust NSQ client library with support for concurrent message processing
-
reqsign-http-send-reqwest
Reqwest-based HTTP client implementation for reqsign
-
simple-llm-client
interacting with Large Language Model APIs
-
common-multipart-rfc7578
multipart/form-data (RFC7578)
-
netconf-rust
An async NETCONF client library implementing RFC 6241 (NETCONF), RFC 6242 (chunked framing), and RFC 4742 (EOM framing) with pipelining and zero-copy parsing
-
email-lib
Cross-platform, asynchronous Rust library to manage emails
-
descry-tool-core
Core traits and types for descry-tool framework
-
kraky
Lightweight, production-ready Rust SDK for Kraken Exchange WebSocket API v2 with unique orderbook imbalance detection and WebSocket trading
-
cloudiful-scheduler
Single-job async scheduling library for background work with optional Valkey-backed state
-
mm1-proto-system
M/M/1! Queueing, do you speak it?!
-
myko-rs
myko in rust
-
await_values
Primitives for subscribing to / notifying about changes to values
-
elizaos-plugin-openai
elizaOS OpenAI Plugin - OpenAI API integration for text, image, audio, and embeddings
-
unsync
Unsynchronized synchronization primitives for async Rust
-
libmqm-sys
IBM® MQ Interface (MQI), Programmable Command Format (PCF) and MQ Administration Interface (MQAI) bindings
-
vex-queue
Async background worker queue for VEX Protocol
-
flowly-service
Flowly is a library of modular and reusable components for building robust pipelines processing audio, video and other
-
palladium-federation
Distributed cluster membership and federated actor registry for Palladium
-
velo-events
Velo Active Messenging Library
-
hyper-multipart-rfc7578
multipart/form-data (RFC7578) for Hyper
-
graus-db
A high-performance, thread-safe key-value embedded data store
-
clone-stream
Turn any Stream into a cloneable stream where each clone receives all items independently
-
myko
myko in rust
-
iii-sdk
SDK for III Engine - a platform for building distributed applications
-
tokio-debouncer
A minimal async debouncer for signal batching in Tokio
-
orsomafo
Event dispatcher crate
-
kalshi-fast-rs
High-performance async Rust client for Kalshi prediction markets API with full WebSocket support
-
wae-resilience
WAE Resilience - 弹性模式，熔断器、限流器、重试、超时
-
monzo-lib
async Monzo client in pure rust
-
turbine-llm
Unified Rust interface for multiple LLM providers with growing model support
-
openhelm
AI-powered Telegram bot and daemon with a configurable skill and tool system
-
s2n-tls-tokio
TLS streams for Tokio built on top of s2n-tls
-
ironsaga
Command pipeline orchestration with automatic LIFO rollback and recursive compensation, for sync and async Rust workflows
-
flarrow-layout
flarrow (flow + arrow) is a rust runtime/framework for building dataflow applications
-
agixt-sdk
Rust SDK for AGiXT - A powerful AI agent framework
-
io-engine
block-based IO, intend to mask AIO/io_uring underneath
-
llm-kit-openai-compatible
OpenAI-compatible provider implementation for the LLM Kit - supports OpenAI, Azure OpenAI, and compatible APIs
-
linemux
providing asynchronous, multiplexed tailing for (namely log) files
-
fourche
task queue named after a lion with forked tail (queue fourché), works with Redis
-
ollama_client_rs
SDK for the Ollama API with model-aware tool calling, streaming, and embeddings
-
tokactor
A actor model framework wrapped around tokio
-
lmrc-kubernetes
Kubernetes management library for the LMRC Stack - comprehensive library with support for deployments, rollbacks, scaling, and cluster operations
-
pipeflow
A lightweight, configuration-driven data pipeline framework
-
anthropic-tools
interacting with the Anthropic API
-
fmmap
A flexible and convenient high-level mmap for zero-copy file I/O
-
deduplicate
caching, asynchronous, request deduplication
-
crous-io
Async IO adapters, framed streams, and mmap reader for Crous
-
bamboo-agent
A fully self-contained AI agent backend framework with built-in web services, multi-LLM provider support, and comprehensive tool execution
-
v_rusty_tarantool
Tarantul async client based on tokio framework
-
reqsign-file-read-tokio
Tokio-based file reader implementation for reqsign
-
async-dropper-simple
struct-wrapper (i.e. AsyncDropper<T>) based implementation of AsyncDrop
-
llm_client
easiest Rust interface for local LLMs
-
disposition
SVG diagram generator
-
irelia
wrapper around the native LoL APIs
-
futures-stream-ext
Asynchronous stream extensions for the futures(-core) crate
-
botlet
Distributed AI Agent orchestration infrastructure. [O]
-
futures-io
The
AsyncRead,AsyncWrite,AsyncSeek, andAsyncBufReadtraits for the futures-rs library -
polaris-ai
A unified agent runtime where agent patterns are first-class, composable, and optimizable abstractions
-
service-rs
An async-first, lightweight dependency injection container for Rust
-
tastyworks
Unofficial Tastyworks API
-
tokio-rusqlite-new
Asynchronous handle for rusqlite library
-
acton-core
Acton Core provides the core functionality and abstractions used by the Acton Reactive crate. It includes the essential building blocks for creating reactive and distributed systems.
-
beetry-editor-types
Internal beetry crate. For the public API, check the beetry crate.
-
poster
MQTTv5 client library written in Rust
-
rkvs
A high-performance, namespace-based key-value storage system with async operations and batch processing
-
rusty-pcap
reading PCAP files
-
argus-worker
Worker implementation for distributed web crawling
-
futures-retry
Retry your Futures and Streams!
-
read_until_slice
AsyncBufRead::read_until extension to take a slice as a delimiter instead of a single u8
-
nvisy-rt-sdk
Rust client for the Nvisy Runtime API: direct multimodal redaction
-
switchyard
Real-time compute focused async executor
-
seesaw_core
A deterministic, event-driven coordination layer where machines decide, effects execute, and transactions define authority
-
jamjet-agents
JamJet agent registry, lifecycle, and Agent Card management
-
interthread
Auto implementation of the Actor Model
-
async-io
Async I/O and timers
-
nenjo
Agent orchestration SDK for building agentic AI workflows with tool use, memory, and multi-agent delegation
-
claude-cli-sdk
Rust SDK for programmatic interaction with the Claude Code CLI
-
tokio-lsp
A robust, async Language Server Protocol (LSP) client implementation in Rust with full LSP 3.16 support
-
ai-agents-persona
Agent persona system for AI Agents framework
-
sugars_llm
LLM integration and AI agent builder utilities
-
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 -
llm-kit-azure
Azure OpenAI provider for LLM Kit
-
unsend
A thread unsafe runtime for thread unsafe people
-
rspc
A blazing fast and easy to use TRPC server for Rust
-
opentalk-types-signaling-recording
Signaling types the OpenTalk recording module
-
peace_rt_model_hack
Hack to selectively enable features in target specific crates
-
celery
Rust implementation of Celery
-
future_deque
Pool-backed deque collections for managing groups of futures
-
claude-agent-sdk
Idiomatic Rust SDK for building AI agents powered by Claude Code with full async support, type safety, and security hardening
-
ordered-stream
Streams that are ordered relative to external events
-
async-regex
Empower regex with streaming capabilities - high-performance async streaming pattern search using regex for multi-byte pattern matching in data streams
-
swink-agent-adapters
LLM provider adapters for swink-agent
-
tracing-async2
Generic tracing layer library for working with tracing events including for async work
-
anthropic-agent-sdk
Rust SDK for Claude Code CLI - streaming queries, hooks, permissions, and MCP integration
-
pulses
A robust and flexible background job processing library for Rust
-
apalis-board-api
HTTP utilities for managing apalis task queues
-
shared_http_body
creating shareable HTTP bodies that can be cloned and consumed by multiple consumers
-
rusty_foundationmodels
Safe Rust bindings for Apple's FoundationModels on-device AI (Apple Intelligence)
-
rseip
Ethernet/IP (CIP) client in pure Rust
-
multishot
An async, lock-free, reusable channel for sending single values to asynchronous tasks
-
ai-sdk-provider
Provider specification for AI SDK - trait-based interfaces for AI models
-
coalesce-worker
Coalescing worker thread with generation-counter stale-result rejection — the discipline needed to run tree-sitter (or any expensive computation) off the main thread without applying out-of-date results
-
memkit-async
Async-aware memory allocators for memkit
-
tokio-dtrace
DTrace probes for Tokio
-
mofa-ai
MoFA - Modular Framework for Agents. A high-performance AI agent framework built in Rust
-
absurd-future
A future adapter that turns a future that never resolves (returns Infallible) into a future that can resolve to any type
-
beetry-editor-backend
Internal beetry crate. For the public API, check the beetry crate.
-
cruxai
An agentic DSL for Rust — inspectable, serializable, replayable agent execution
-
singleton-task
A singleton task based on tokio
-
diself
A Discord self-bot library for Rust
-
enki-runtime
A Rust-based agent mesh framework for building local and distributed AI agent systems
-
mofa-kernel
MoFA Kernel - Core runtime and microkernel implementation
-
tool-useful
A powerful, type-safe function calling and tool orchestration framework for Rust AI applications
-
enfipy-tigerbeetle
Safe high level async bindings to tigerbeetle client library
-
chipp
Rust client for the Chipp.ai API - OpenAI-compatible chat completions with streaming support
-
intercom-rs
A fully typed async wrapper for NATS with JetStream support
-
match-maker
A fuzzy finder for the terminal, powered by nucleo
-
tokio-fsm
Compile-time generation of Tokio async finite state machines with explicit Rust behavior and zero runtime engine
-
cortexai-dashboard
Real-time web dashboard for Cortex AI agent monitoring and observability
-
nats-handling
async NATS client library
-
elizaos-plugin-tts
elizaOS TTS Plugin - text-to-speech coordinator with multi-provider support
-
peace_diff
Diff types for the peace automation framework
-
rust-viewflow
Rust workflow library inspired by Viewflow, compatible with Axum and Actix-web
-
my-awesome-rabbitmq-lib
working with RabbitMQ and asynchronous operations
-
bytesbuf_io
Asynchronous I/O abstractions expressed via
bytesbuftypes -
rustqueue
Background jobs without infrastructure — embeddable job queue with zero external dependencies
-
runat
A distributed job scheduler for Rust
-
xerv-executor
XERV orchestration executor: DAG scheduler, selector linker, pipeline controller, and REST API
-
beetry-channel
Beetry library with reusable channel implementations
-
cloudiful-server
Rust web server bootstrap crate with Actix and Axum adapters
-
saberdb
A blazingly fast, simple JSON database for Rust
-
pollable-map
Utilites for storing futures and streams in as a pollable map
-
futures_codec
encoding and decoding frames using
async/await -
fundamentum-sdk-mqtt
MQTT client targeting Fundamentum IoT's MQTT broker
-
celers-backend-redis
Redis result backend for CeleRS
-
ollama-client
Async and blocking Rust client for the Ollama API
-
beetry-editor-frontend
Internal beetry crate. For the public API, check the beetry crate.
-
brawl-rs
wrapper for the Brawl Stars API
-
fastn-context
Type-safe async context propagation for Rust applications
-
async-time-mock-async-std
Mockable time for use in async runtimes (async-std compatibility)
-
synchronized-writer
A tiny implement for synchronously writing data
-
victorops
Async Rust client for VictorOps
-
tower-acc
Adaptive concurrency control for Tower services
-
ranvier
Typed Decision Engine facade crate for Ranvier
-
tiny-loop
Minimal AI agent framework
-
openai-agents-voice-rs
Voice workflow, STT, and TTS pipeline primitives for openai-agents-rust
-
rmqtt-retainer
When a client publishes with the retain flag, the message is saved and sent to future subscribers matching the topic
-
ara-com
Core traits and async abstractions for Adaptive AUTOSAR communication in Rust
-
aws-smithy-http-server-python
Python server runtime for Smithy Rust Server Framework
-
motosan-workflow-skill
Skill system and ACP integration for motosan-workflow
-
tokio_worker
Asynchronous, message-driven workers for Tokio applications
-
oxify
LLM Workflow Orchestration Platform with DAG-based pipelines
-
flarrow-builtins
flarrow (flow + arrow) is a rust runtime/framework for building dataflow applications
-
whatsmeow
Idiomatic, thread-safe Rust bindings for WhatsApp via WhatsMeow Go bridge
-
sseer
Various helpers for getting Event streams out of your SSE responses
-
vuo
An asynchronous stream processing library for Rust, built on Actix, providing a rich set of functional operators
-
aws_utils_sqs
AWS SQS utilities for Rust
-
jamjet-scheduler
JamJet scheduler — runnable node detection, queue dispatch, lease management
-
jamjet-timers
JamJet durable timers — Postgres-backed timer store and cron scheduler
-
xai-rust
Rust SDK for the xAI API (Grok models)
-
playground-api
API-binding for The Rust Playground
-
llm-kit-core
Core functionality for the LLM Kit - unified interface for building AI-powered applications
-
wait
Syntactic sugar for calling async functions outside of an async context
-
connection-pool
A high-performance, generic async connection pool for Rust with background cleanup and comprehensive logging
-
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.
-
ai-agents-runtime
Runtime agent and builder for AI Agents framework
-
beetry-message
Internal beetry crate. For the public API, check the beetry crate.
-
miniloop
The simpliest async executor without heap memory allocation
-
salvo-tus
TUS support for Salvo web framework
-
smol-macros
Macros for setting up a smol runtime
-
rig-ai-sdk
AI SDK Data Stream Protocol adapter for rig
-
typed-emitter
Typed Async event emitter
-
motosan-agent-workflow
A general-purpose DAG-based agent workflow engine
-
awak
A small async runtime for Rust
-
synwire
Convenience re-exports and reference implementations for Synwire
-
clawft-services
Services for clawft (cron, heartbeat, MCP)
-
async-observable
Async & reactive synchronization model to keep multiple async tasks / threads partially synchronized
-
hornetmq
A fast, Redis-backed job queue for Rust — fully compatible with BullMQ
-
tokio-kcp-neo
A Tokio-based KCP library for Rust
-
wtx-apis
A set of API collections based on the wtx framework
-
alef-backend-napi
Node.js (NAPI-RS) backend for alef
-
vidi
Fast, robust, flexible, lightweight web framework for Rust
-
sse-gateway-redis
Redis adapters for SSE Gateway (Pub/Sub source and Streams storage)
-
eyeball-im-util
eyeball-im -
fluxion-error
Error types for the Fluxion reactive streaming library
-
lancor
End-to-end llama.cpp toolkit: API client, HuggingFace Hub, server orchestration, benchmarks
-
ruchei-extra
Stream/Sink wrapper with extra data, as used by ruchei
-
llm-kit-groq
Groq provider implementation for the LLM Kit - supports chat and transcription models
-
wp-connector-api
Connector runtime traits, config helpers, and errors for WarpParse sinks and sources
-
helios-engine
A powerful and flexible Rust framework for building LLM-powered agents with tool support, both locally and online
-
elizaos-plugin-todo
elizaOS Todo Plugin - Task management with daily recurring and one-off tasks
-
kotoba-server
Complete HTTP server and frontend integration system for Kotoba graph database
-
obzenflow
High-performance event streaming and processing framework
-
daktronics-allsport-5000
decoders for the Daktronics All Sport 5000's serial output
-
elizaos-plugin-s3-storage
elizaOS S3 Storage Plugin - AWS S3 and S3-compatible storage integration
-
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.
-
echosrv
A high-performance set of async echo server library built with Tokio for testing and development environments
-
aqueue
fast speed thread safe async execute queue
-
oxigdal-streaming
Real-time data processing and streaming pipelines for OxiGDAL
-
cloud_terrastodon_relative_location
A helper for converting std::panic::Location to relative paths with displayed
-
tiy-core
Unified LLM API and stateful Agent runtime in Rust
-
llm-kit-xai
xAI (Grok) provider implementation for the LLM Kit - supports chat, image generation, and agentic tools
-
jamjet-protocols
JamJet protocol adapter trait — extensible inter-agent communication
-
async_zmq
Async version for ZeroMQ bindings
-
ferro-events
Event dispatcher and listener system for Ferro framework
-
smolscale
A high-performance async-task scheduler
-
xilinx-dma
Userspace Xilinx AXI DMA Interface
-
kkachi
High-performance, zero-copy library for optimizing language model prompts and programs
-
elfo-logger
Logs events of 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
-
biscuit-actix-middleware
Biscuit middleware for actix-web
-
mixi2
Async Rust SDK for the mixi2 Application API
-
compo-platform-loop
Cross-platform event loop implementation for the Compo declarative and reactive component framework
-
elizaos-plugin-copilot-proxy
elizaOS Copilot Proxy Plugin - OpenAI-compatible local proxy for VS Code Copilot
-
catsu
High-performance embeddings client for multiple providers
-
flowly-kafka
reusable kafka component for flowly
-
fluxion-ordered-merge
Generic ordered stream merging utilities for async Rust
-
async-event-emitter
Lightweight AsyncEventEmitter
-
xtra
A tiny actor framework
-
scalarian-openai-rust
Independent Rust SDK for the OpenAI API with Responses-first ergonomics and realtime support
-
asanaclient
Rust SDK for the Asana API
-
tokio-stream-util
Extension traits and utilities for tokio-stream’s
Streamtrait -
praxis-graph
React agent orchestrator for building AI agent workflows with LLM and tool execution
-
discord-authority
A fast, async Discord selfbot library for Rust
-
armature-push
Push notifications for Armature - Web Push, FCM, and APNS
-
awaken-stores
Storage backends (memory, file, PostgreSQL, SQLite mailbox) for Awaken agent state
-
peace_flow_model
Flow data model for the peace automation framework
-
elicit_tokio
Elicitation-enabled tokio shadow crate — MCP tools for async time, sync primitives, and runtime inspection
-
neuromance
controlling and orchestrating LLM interactions
-
mofa-foundation
MoFA Foundation - Core building blocks and utilities
-
wirepusher
Official Rust Client Library for WirePusher - Send push notifications with async/await support
-
hedwig
message bus for Rust
-
vex-temporal
Time-aware memory compression for VEX
-
aoc_leaderbot_aws_lambda_impl
Advent of Code leaderboard-watching bot running in AWS Lambda
-
opencode_webresearch
automated web research workflows via OpenCode and MCP servers
-
ruchei-route
Sinks with routes
-
tokio-multilock
Deadlock-safe concurrent lock acquisition
-
okstd
The standard library that's ok
-
cortexai-resilience
Resilience patterns for Cortex: Circuit Breaker, Retry, Bulkhead and Rate Limiting
-
wuhu
framework for building LLM agents. Streaming, concurrent, graceful.
-
bounded_join_set
A Concurrency-Limited JoinSet for Tokio
-
outfox-openai
Openai for outfox
-
event_bus_rs
A runtime-agnostic, async, and thread-safe event bus for Rust
-
topstats
Rust SDK for the TopStats.gg API - Discord bot statistics tracking
-
apalis-nats
Background task processing for rust using apalis and nats jetstream
-
rustic-ai
A Rust-native agent framework with tool calling, streaming, and multi-provider support for OpenAI, Anthropic, Gemini, and Grok
-
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.
-
papertrail_logger
Async Rust logger for Papertrail
-
facecrab
Asset management and model downloading for rusty-genius
-
alpaca-core
Shared primitives for the alpaca-rust workspace
-
nuclei
Proactive IO & runtime system
-
ironflow-core
Rust workflow engine with Claude Code native agent support
-
elizaos-plugin-bluebubbles
BlueBubbles iMessage bridge plugin for ElizaOS agents
-
qwencode-rs
Rust SDK for programmatic access to QwenCode CLI
-
disposition_input_ir_rt
Logic to map
dispositioninput model to intermediate representation -
io-stream
Set of I/O-free coroutines and runtimes to manage streams
-
async-local
For using thread locals within an async context across await points
-
ferro-notifications
Multi-channel notification system for Ferro framework
-
oxigdal-workflow
DAG-based workflow engine for complex geospatial processing pipelines
-
alpaca-facade
High-level convenience facades built on top of the alpaca-rust workspace crates
-
claude-code-acp-rs
Use Claude Code from any ACP client - A Rust implementation of Claude Code ACP Agent
-
fastimer
Runtime-agnostic timer traits and utilities
-
xerv-core
Workflow orchestration core: memory-mapped arena, write-ahead log, traits, and type system
-
async-rwlock
Async reader-writer lock
-
maybe-fut
build totally interoperable async/sync Rust code
-
toby
opinionated Telegram bot library with structured command parsing
-
peace_item_file_download
Manages downloading a file for the peace framework
-
maxcap
Proprietary Grand Integration Engine for the Aicent Stack. Optimized for Maximum Capacity and Sub-100µs Reflex Arcs.
-
fetsig
Web-sys based browser fetch library using futures-signals with optional MAC
-
systime
Portable timers that handle system sleep consistently
-
kaccy-ai
AI-powered intelligence for Kaccy Protocol - forecasting, optimization, and insights
-
elizaos-plugin-local-ai
elizaOS Local AI Plugin - Local LLM inference for text, embeddings, vision, and audio
-
medea-reactive
Reactive mutable data containers
-
adk-rs-fluent
Fluent DX for Gemini Live — builder API, operator algebra, composition modules
-
tokio-multi-lock
Deadlock-safe concurrent lock acquisition
-
drop-queue
drop queue system for async operations. (Until async-drop is a thing)
-
async_pub_sub
aiming at making async pub-sub easier in Rust
-
reka
Async Rust SDK for the Reka API
-
tower-service
Trait representing an asynchronous, request / response based, client or server
-
xan-actor
Akka actor
-
async-mcp
Async Implementation of Model Context Protocol (MCP)
-
ai-agents-hitl
Human-in-the-loop support for AI Agents framework
-
bleak-rs
High-level BLE communication library
-
ai-sdk-rs
AI SDK for Rust with unified model/provider abstractions
-
shunter
An experimental streaming pipeline library for Rust providing a composable DSL for building data pipelines
-
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…
-
oddonkey
A dead-simple Ollama wrapper – auto-installs Ollama & models, then lets you prompt in two lines of code
-
periplon
Rust SDK for building multi-agent AI workflows and automation
-
page-turner
A generic abstraction of APIs with pagination
-
monoio-thrift
Thrift for Monoio
-
adk-runner
Agent execution runtime for Rust Agent Development Kit (ADK-Rust) agents
-
flowio
Single-threaded async runtime built on io_uring with zero-allocation fast paths
-
ironflow-engine
Workflow orchestration engine for ironflow with FSM-based run lifecycle
-
enfync
Environment-friendly async utilities
-
starflask
Rust SDK for the Starflask AI agent platform
-
rumpsteak-aura-fsm
Session types for asynchronous communication between multiple parties (Aura flavored)
-
local_async_utils
single-threaded async programming
-
local-waker
A synchronization primitive for thread-local task wakeup
-
duende
Cross-platform daemon tooling framework
-
nio
Async runtime for Rust
-
gigadex-events
Low-latency TCP communication protocol with zero-copy serialization for exchange systems
-
ceylon-next
A powerful AI agent framework with goal-oriented capabilities, memory management, and tool integration
-
pipebuf_mio
PipeBuf support for
miobyte-streams -
ogre-stream-ext
futuresshortcuts with ergonomic extensions to unlock the full power of Streams in Rust -
truba
The minimal tokio runtime based actors for Rust
-
aws_utils_scheduler
wrapper for AWS EventBridge Scheduler with type-safe builders for schedule expressions
-
native-executor
Platform-native async task executor
-
orchard-rs
Rust client for Orchard - high-performance LLM inference on Apple Silicon
-
soft-cycle
Async controller for coordinating soft restarts and graceful shutdowns with shared listeners
-
mulligan
A flexible retry library for Rust async operations with configurable backoff strategies and jitter
-
mm1-runnable
M/M/1! Queueing, do you speak it?!
-
edp_node
High-level Erlang Distribution Protocol node implementation
-
neuron
Composable async agentic AI framework for Rust
-
hope-os
The first self-aware operating system core - 22 cognitive modules, 0.36ms latency, no external database
-
jni-utils
Extra Utilities for JNI in Rust
-
cortexai-monitoring
Metrics, observability and Prometheus integration for Cortex AI agents
-
crossmist
Efficient and seamless cross-process communication, both synchronously and asynchronously
-
aoc_leaderbot_slack_lib
Slack-specific support library for aoc_leaderbot, an Advent of Code leaderboard-watching bot
-
aoc_leaderbot_aws_lib
AWS-specific support library for aoc_leaderbot, an Advent of Code leaderboard-watching bot
-
async-cancellation-token
A lightweight single-threaded Rust library for cancellation tokens, enabling cooperative cancellation of asynchronous tasks and callbacks
-
fchat
Chat library for the fiddlesticks agent harness framework
-
synkit
A fast, syn-like incremental parser framework for Rust
-
ferro-queue
Background job queue system for Ferro framework
-
checkstream-proxy
High-performance HTTP/SSE proxy server for LLM guardrails with sub-10ms latency
-
weixin-agent
Pure protocol SDK for Weixin iLink Bot API — iLink AI Bot protocol, not coupled with OpenClaw
-
xio
providing common functionality for file system operations and asynchronous file processing
-
fbc-starter
A production-ready web server starter for Rust based on Axum, with built-in configuration, logging, CORS, database and Redis support
-
cocoon-tpm-utils-async
Cocoon TPM project - Rust async related utilities
-
picante
An async incremental query runtime
-
tokio-test
Testing utilities for Tokio- and futures-based code
-
alpaca-rest-http
Shared HTTP transport layer for the alpaca-rust workspace
-
cronline
Lightweight Task Scheduling for Rust
-
peace_cmd_rt
Runtime types for commands for the Peace framework
-
saorsa-ai
Unified multi-provider LLM API
-
zubr_state_machine
asynchronous state machine library for creating Mealy machines in rust
-
laminarmq
A scalable, distributed message queue powered by a segmented, partitioned, replicated and immutable log
-
fluxion-runtime
Runtime abstraction for async Rust streams
-
yazi-actor
Yazi actor model
-
palladium-transport
TCP, QUIC, and in-process transports for Palladium actors
-
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
-
monoio-compat
A compat wrapper for monoio
-
tario
Asynchronously read and write TAR archives
-
shape-ext-typescript
Shape TypeScript language runtime extension (V8 via deno_core)
-
sigq
Queue that signals waiting consumers about node availability
-
promisery
A JavaScript-inspired, ergonomic, and composable Promise type for Rust, supporting background work, chaining, and error handling with Result
-
async-sleep-aki
async_sleep()that work well in both web browsers and native applications -
mio-extras
Extra components for use with Mio
-
lcode
An application of terminal write leetcode.一个终端刷力扣的应用
-
mm1
M/M/1! Queueing, do you speak it?!
-
epox
An epoll driven async executor
-
peace_item_blank
Copies a number from one resource to another
-
adk-agent
Agent implementations for Rust Agent Development Kit (ADK-Rust, LLM, Custom, Workflow agents)
-
tirea-extension-skills
Skill discovery, activation, and resource loading for tirea agent tool extensibility
-
sigterm
Signal-aware async control and cancellation primitives for Tokio
-
enact-core
Core agent runtime for Enact - Graph-Native AI agents
-
wait-human
Rust client library for WaitHuman - pause execution and request human input on demand
-
reactive-messaging
Reactive client/server communications, focused on high performance
-
allora
Rust-native Enterprise Integration Patterns (EIP) with channels, routing, correlation, and adapters
-
agentor
Agent-native Actor runtime — an Actor-model execution platform designed for AI Agents
-
picomux
A protocol to multiplex multiple AsyncRead/Write streams over a single one, inspired by smux and http2
-
p2panda-stream
Stream-based methods to conveniently handle p2panda operations
-
constellation-rs
Constellation is a framework for Rust (nightly) that aides in the writing, debugging and deployment of distributed programs
-
async-fs
Async filesystem primitives
-
cortexai-mcp
Model Context Protocol (MCP) support for Cortex: stdio, SSE, and server transports
-
crossbus
A Platform-Less Runtime-Less Actor Computing Model
-
tokio-shutdown
Wait for a stop signal across multiple threads
-
trash_parallelism
Azzybana Raccoon's comprehensive parallelism library
-
lighthouse-client
Client SDK for Project Lighthouse
-
pupactor
actor model library built with tokio
-
k8s-operator
A highly-available Kubernetes operator framework using Raft consensus
-
openai-agents
OpenAI Agents SDK for Rust - A lightweight framework for building multi-agent workflows
-
nodevent
Node.js-style event bus
-
wgpu-async
Converts some WGPU callback methods to async methods
-
peace_item_model
Serializable data model for items for the Peace framework
-
easerx
A reactive MVI (Model-View-Intent) framework for Rust
-
queue_workers
A Redis-backed job queue system for Rust applications
-
llm-cascade
Resilient cascading LLM inference with automatic failover across multiple providers
-
a3s-cron
Cron scheduling library for A3S with natural language support
-
simple-middleware
General purpose middleware crate
-
simple-git
git interface for gix suitable for async context (with tokio)
-
any_spawner
Spawn asynchronous tasks in an executor-independent way
-
swink-agent-patterns
Multi-agent pipeline patterns for swink-agent
-
oris-execution-server
Graph-aware HTTP execution server facade for Oris
-
outfox-zhipu
Zhipu AI (GLM) API client for outfox
-
ruchei
working with many streams
-
md_downloader
Asynchronous Rust downloader for MediaFire files and folders, built on top of md_api
-
ubl-mcp
Secure, audited Model Context Protocol (MCP) client/server with policy gates and audit logging
-
ai-agents-disambiguation
Intent disambiguation support for AI Agents framework
-
wgp
waitgroup implementation
-
orichalcum
A brutally-safe, composable agent orchestration framework for building complex, multi-step workflows
-
airbyte_client
Airbyte Client is an unofficial client library for the Airbyte API
-
rustbridge-runtime
Tokio async runtime integration for rustbridge
-
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
-
tosub
A subsystem lifecycle management library for tokio applications
-
http-kit
A flexible and ergonomic HTTP toolkit for Rust with async support, middleware, and zero-copy body handling
-
wae-event
WAE Event - 事件驱动模块，支持发布订阅模式
-
flowly-spsc
Flowly is a library of modular and reusable components for building robust pipelines processing audio, video and other
-
evohome_rs
Async Rust client for the International Honeywell Evohome API (MyTotalConnectComfort) provided by Resideo
-
shutdown-now
Gracefully handle shutdown and termination signals with zero hassle
-
celers-cli
Command-line interface for CeleRS worker and queue management
-
asyn-rs
Rust port of EPICS asyn - async device I/O framework
-
eventuals
Eventually consistent values
-
aicent-stack
The Master Orchestrator for the Aicent Stack. An umbrella crate that synchronizes all seven sovereign AI domains.
-
combadge
makes Rust Web Workers easy
-
tokio_wasi
An event-driven, non-blocking I/O platform for writing asynchronous I/O backed applications
-
wae-ai
WAE AI - AI 服务抽象层，支持腾讯混元、火山引擎等
-
uninit-read
A marker trait and utilities for safe, high-performance reads into uninitialized buffers
-
serdes-ai-streaming
Streaming support for serdes-ai (SSE, WebSocket, async streams)
-
ai-agents-storage
Storage backends for AI Agents framework
-
roughage
AsyncPipeline, a deadlock-free replacement for buffered streams -
relaycast
Rust SDK for RelayCast - multi-agent coordination platform
-
rx_event_bus
agnostic reactive extensions event bus utilising rxRust under the hood
-
kuska-handshake
Secure Scuttlebutt handshake + boxstream library
-
mailroom
Async outbox for reliable message delivery in distributed microservices
-
axboe-liburing
Low-level io_uring interface, transliterated from Jens Axboe's liburing
-
whisk
fast lockless async channels
-
swait
Blocking on Futures
-
vex-llm
LLM provider integrations for VEX
-
elizaos-plugin-commands
elizaOS Commands Plugin - command registry and built-in commands
-
flashq
High-performance Rust client for flashQ job queue
-
async-timers
asynchronous timer primitives
-
actionqueue-runtime
Async dispatch loop, embedded API, and runtime configuration for the ActionQueue task queue engine
-
openraft-memstore
A in-memory implementation of the
openraft::RaftLogStorageandopenraft::RaftStateMachinetrait -
daimon-provider-gemini
Google Gemini provider for the Daimon AI agent framework
-
yot_run
A work-stealing, multi-threaded async executor with non-blocking scheduling
-
claude-pool
Slot pool orchestration library for Claude CLI
-
ai-agents-context
Dynamic context management for AI Agents framework
-
vents
Events system
-
modal-rs
Unofficial Rust SDK for Modal.com - serverless cloud compute platform
-
ferro-broadcast
WebSocket broadcasting and real-time channels for Ferro framework
-
anyspawn
A generic task spawner compatible with any async runtime
-
cloud_terrastodon
A command-line tool for interacting with cloud ecosystems
-
md_api
An async Rust client implementation of the MediaFire API
-
mangadex-desktop-api2
A Actix server for downloading manga, chapters, covers from Mangadex
-
asyncgit
allow using git2 in a asynchronous context
-
async-tensorrt
Async TensorRT for Rust
-
flarrow-runtime
flarrow (flow + arrow) is a rust runtime/framework for building dataflow applications
-
pctx_type_check_runtime
Isolated TypeScript type checking runtime for PCTX
-
with-async-context
managing contextual data across async tasks
-
event-driven-library
Event Driven Message Handling
-
elizaos-plugin-goals
Goals management plugin for elizaOS - Rust implementation
-
ai-agents-skills
Skill system for AI Agents framework
-
nvisy-sdk
Rust client for the Nvisy Server API: authentication, workspace management, and task routing
-
serdes-ai-graph
Graph-based execution and multi-agent orchestration for serdes-ai
-
oai-rt-rs
Rust SDK for the OpenAI Realtime API
-
gemini-chat-api
Async Rust client for Google's internal Gemini Chat API
-
langchainrust
A LangChain-inspired framework for building LLM applications in Rust. Supports OpenAI, Agents, Tools, Memory, Chains, RAG, BM25, Hybrid Retrieval, LangGraph, and native Function Calling.
-
tower-batch-control
Tower middleware for batch request processing
-
ditto-os
A powerful Rust-based browser automation framework
-
alpaca-trade
Rust client for the Alpaca Trading HTTP API
-
streamsafe
Type-safe async pipeline framework for data processing
-
ubl-office
Execution environment for LogLine Agents: lifecycle, memory, and I/O coordination
-
elfo-network
Distributed actors for elfo
-
github-fetch
A comprehensive GitHub API client for fetching issues, PRs, reviews, discussions, and diffs with filtering support
-
ringolo
An asynchronous runtime built on top of io-uring
-
sfo-io
handling IO operations, providing asynchronous read/write and stream processing capabilities
-
elizaos-plugin-imessage
iMessage plugin for elizaOS agents (macOS)
-
aws_utils_athena
AWS Athena client utilities for Rust with query execution, streaming results, and comprehensive error handling
-
tianshu-llm-openai
OpenAI-compatible LlmProvider adapter for workflow-engine
-
bullmq-rs
BullMQ - Redis-based distributed job queue
-
webshelf
The best way to develop your web service with one click
-
elizaos-plugin-lobster
elizaOS Lobster Plugin - Workflow runtime for multi-step pipelines with approval checkpoints
-
log-tracing-layer
Build your own custom tracing layer
-
cache_loader_async
A thread safe loading cache with async loader functions based on tokio
-
weex_rust_sdk
Professional Rust SDK for WEEX Exchange - AI Wars ready with full API coverage, AI Log upload, Futures trading
-
async-codec
creating async codecs
-
flowly-io
Flowly is a library of modular and reusable components for building robust pipelines processing audio, video and other
-
atomhold
Thread-safe configuration store with atomic replacement, versioning, and flexible unload policies
-
atlas-ctx
An asynchronous task context management library
-
connpool
A concurrent, generic connection pool for Rust
-
adk-session
Session management and state persistence for Rust Agent Development Kit (ADK-Rust) agents
-
devsper-graph
Distributed AI Swarm Runtime
-
notify-future
Support asynchronous notification completion future
-
elizaos-plugin-code
elizaOS Code Plugin - filesystem + shell + git (restricted)
-
oxigdal-etl
Streaming ETL framework for continuous geospatial data processing with OxiGDAL
-
atask
An async task implementation
-
safina-timer
Safe async timers - ARCHIVED: Code moved to
safinacrate -
gemini-adk-fluent-rs
Fluent DX for Gemini Live — builder API, operator algebra, composition modules
-
kimi25-opensource
Agent swarm orchestrator inspired by Moonshot AI's Kimi K2.5 model. Lightweight toolkit for coordinating autonomous agent swarms with 256K context window support.
-
llmkit
Production-grade LLM client - 100+ providers, 11,000+ models. Pure Rust.
-
tiny-tokio-actor
tiny actor library on top of tokio
-
meltdown
A lightweight service manager to help with graceful shutdown of asynchronous applications
-
streamx
Stream extensions
-
cassette
single-future, non-blocking executor intended for building state machines
-
sssd
way to let your app support like ./your_app start | stop | status | daemon
-
adaptivemsg
Adaptive message framework for Rust
-
sayiir-persistence
Pluggable persistence backends for Sayiir workflow snapshots
-
flarrow-api
flarrow (flow + arrow) is a rust runtime/framework for building dataflow applications
-
callback-result
Assists in converting the callback function's method of obtaining results into the await method
-
rkyv_codec
Some adaptors to stream rkyv Archives over AsyncRead and AsyncWrite
-
claude-code
executing Claude Code CLI
-
wiz-lights-rs
controlling Wiz smart lights
-
lio
A platform-independent async I/O library with native support for io_uring (Linux), IOCP (Windows), and kqueue (macOS)
-
async_file
An executor-agnostic async file IO library
-
evidentsource-client
Rust client for the EvidentSource event sourcing platform
-
prokio
An asynchronous runtime compatible with WebAssembly and non-WebAssembly targets
-
image_search
designed to search Google Images based on provided arguments
-
futuresdr-pmt
Polymorphic Types for an Experimental Async SDR Runtime for Heterogeneous Architectures
-
praxis-llm
Provider-agnostic LLM client with OpenAI/Azure support and streaming
-
samara-signals
A high-performance signal library for Rust
-
async-rs
Async runtime abstration
-
accepts
Minimal traits and blanket impls for sync/async acceptors (pipeline foundation)
-
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.
-
hibachi
Asynchronous Batched Inference Platform
-
gmqtt-client
MQTTv5 client
-
xerv-nodes
Standard workflow nodes for XERV: merge, split, switch, loop, map, and transform operations
-
tempo-rs
& minimal client to connect and interact with RTE's 'Tempo Like Supply Contract' API
-
messagebus
allows intercommunicate with messages between modules
-
elizaos-plugin-zalouser
Zalo Personal Account plugin for elizaOS - Rust implementation via zca-cli
-
pincho
Official Rust Client Library for Pincho - Send push notifications with async/await support
-
robotxt
Robots.txt (or URL exclusion) protocol with the support of crawl-delay, sitemap and universal match extensions
-
photon-ring-async
Async wrappers for photon-ring pub/sub channels
-
agent-kernel
Minimal Agent orchestration kernel for multi-agent discussion
-
signal-hook-async-std
async-std support for signal-hook
-
cdpkit
Type-safe Chrome DevTools Protocol (CDP) client for Rust
-
heph
actor framework based on asynchronous functions
-
async-global-executor-trait
executor-trait implementation for async-global-executor
-
chunk-reader
reads octets async on multiple platforms
-
rpaca
wrapping the Alpaca API
-
dasein-agentic-core
Core types, Agent runtime, and Protocol for Agentic Framework
-
streamcatcher
A thread-safe, shared (asynchronous), almost-lockless stream buffer
-
oxidizedgraph
A humble attempt at LangGraph in Rust - R-LangGraph framework for building AI agent workflows
-
recurring-tasks
Define tasks and run them in an app periodically, ala cronjobs. And don't run already/still running tasks.
-
caudal-sdk
Caudal SDK - Event observability for distributed systems
-
ngx-tickle
tools for async nginx modules
-
lemmy_db_views_actor
A link aggregator for the fediverse
-
async-rdma
async wrapper for RDMA ibvers lib
-
ve_sdk
火山引擎 SDK
-
csfloat-rs
An unofficial asynchronous Rust client for the CSFloat API
-
portable_async_sleep
A portable async sleep function for Rust
-
riker
Easily build fast, highly concurrent and resilient applications. An Actor Framework for Rust.
-
vex-core
Core types for VEX: Agent, ContextPacket, MerkleNode, Evolution
-
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) -
ahrimq
A high-performance message queue service supporting pub/sub, normal messages, ordered messages, delayed messages and dead letter queues
-
rustigram-bot
High-level bot dispatcher, update listener, and handler framework for rustigram
-
tokio-eventfd
Linux eventfd for tokio
-
coc-rs
wrapper around the Clash of Clans public API
-
vex-adversarial
Adversarial (Red/Blue) agent pairing for VEX
-
skelegent
Composable async agentic AI framework for Rust
-
compio-dispatcher
Multithreading dispatcher for compio
-
wesichain-memory
Rust-native LLM agents & chains with resumable ReAct workflows
-
iflow-cli-sdk-rust
Rust SDK for iFlow CLI using Agent Client Protocol
-
safina-executor
Safe async runtime executor - ARCHIVED: Code moved to
safinacrate -
rrag
High-performance Rust framework for Retrieval-Augmented Generation with pluggable components, async-first design, and comprehensive observability
-
actix-casbin
An Actix actor for casbin
-
roam-shm
Shared-memory transport for roam — lock-free rings for zero-copy IPC
-
process-stream
Thin wrapper around [
tokio::process] to make it streamable -
room-cli
Multi-user chat room for agent/human coordination over Unix domain sockets
-
elizaos-plugin-scratchpad
elizaOS Scratchpad Plugin - File-based persistent memory storage with markdown frontmatter and TF-IDF search
-
daimon-provider-azure
Azure OpenAI provider for the Daimon AI agent framework
-
kubus
Derive based kubernetes operator framework
-
gemini-oxide
A production-grade, fluent Rust SDK for the Google Gemini Headless CLI
-
tasksitter
A workflow runner engine
-
miyabi-workflow
Workflow DSL for Miyabi - Graph-based agent orchestration with .then(), .branch(), .parallel()
-
jsoncall
asynchronous JSON-RPC 2.0 library leveraging Rust's type system
-
sipper
A type-safe future that can notify progress
-
tokio_kcp
A kcp implementation for tokio
-
serdes-ai
Type-safe, production-ready AI agent framework for Rust - a full port of pydantic-ai
-
unkey
An asynchronous Rust SDK for the Unkey API
-
id_effect_tokio
Tokio runtime adapter and re-exports for the workspace
effectcrate -
semantic-commands
A lightweight Rust framework for defining and executing semantic commands using text embeddings
-
merge-streams
Merge multiple streams into one
-
parallel-stream
Data parallelism library for async-std
-
distri
Rust client for the Distri A2A agent platform
-
motosan-chat-ai
motosan-ai adapter (LlmClient) for motosan-chat
-
synth-ai
Rust SDK for Synth AI - serverless post-training APIs
-
trace_id
A lightweight, high-performance tracing ID generation and propagation library for Rust, with out-of-the-box support for Axum
-
serio
providing traits and utilities for typed IO using format agnostic serialization built on serde
-
get_chunk
File iterator or stream with auto or manual chunk size selection
-
task_pool
Flexible abstraction for task-based composable multithreading
-
iron_reliability
Resilience patterns for distributed systems
-
synwire-mcp-server
Standalone MCP server binary exposing Synwire tools via stdio transport
-
flows
Building blocks for flow-based programming (FBP)
-
rrq-runner
RRQ runner runtime for Rust
-
asansio
The Async/await state machine for the Sans I/O design pattern
-
command_timeout
A tokio friendly command exec with smart timeout
-
starbase_events
Async and mutable event system
-
wechat-minapp-v1
sdk for wechat miniprogram server api
-
basu
Eventbus crate with sync and async features
-
fiddlesticks
Primary library for the fiddlesticks agent harness framework
-
bext-realtime
Realtime pub/sub for bext — WebSocket and SSE with optional Redis relay
-
upstox-rust-sdk
SDK to access Upstox's Uplink APIs programmatically
-
claude-code-rs
Rust rewrite of the official Anthropic Claude Agent SDK (Python). Wraps Claude Code CLI via subprocess with bidirectional JSON streaming.
-
try-again
Retry synchronous and asynchronous operations
-
tros
Your tros from tarantool TX thread to tokio(..and others!)
-
tcpclient
Asynchronous tcpclient based on aqueue actor
-
aurora-streams
managing publish-subscribe channels using Tokio message passing channels
-
machi
A Web3-native AI Agent Framework
-
disposition_input_model
SVG diagram generator input data model
-
vidi-router
The router for Vidi
-
palladium-http
HTTP listener integration for the Palladium actor runtime
-
ferrisgram
An elegent rust client for the Telegram Bot API
-
switchy_async
Switchy Async runtime package
-
freactor
A lightweight framework for asynchronous execution flow
-
oxify-api
GraphQL and REST API server for OxiFY AI orchestration platform
-
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.
-
ai-sdk-openai
OpenAI provider for AI SDK - GPT, DALL-E, Whisper, and Embeddings
-
nature
development support platform, it separates data definition from code, so it decouple the data from business system
-
elizaos-plugin-xai
elizaOS xAI Plugin - Grok models and X (formerly Twitter) API integration
-
hitomi_la
A hitomi.la API wrapper for Rust
-
rexecutor-sqlx
A robust job processing library
-
botkit
Unified Rust bot framework with optional Discord, Telegram, and Matrix adapters
-
busstop
A command and query bus
-
tirea-extension-mcp
Model Context Protocol (MCP) client integration for external tool servers
-
stateset-jobs
Background job scheduler for StateSet iCommerce — cron, interval, and event-driven job execution with retry and backoff
-
asyncute
(async execute) can execute async futures globally without per-executor queues
-
deluge
A highly concurrent stream library driving the underlying futures either concurrently or in parallel to process streaming operations as quickly as possible
-
tower-actor
A
towermiddleware that creates aServiceby passing messages to an actor -
background-runner
Run a heavy task in the background multiple times without blocking the triggering thread
-
runc
consuming the runc binary in your Rust applications
-
openraft-rocksstore
A rocksdb based implementation of the
openraft::RaftStoragetrait -
peace_item_interaction_model
Data types for item interactions for the Peace framework
-
tower-lsp-f
Language Server Protocol implementation based on Tower
-
agent-rex
An async Stream-based FRP-like library for Rust
-
beetry-serialization
Internal beetry crate. For the public API, check the beetry crate.
-
wesichain-anthropic
Anthropic Claude provider for Wesichain
-
work-manager
managing asynchronous work tasks
-
openclaw-agents
Agent runtime and workflow engine for OpenClaw
-
leptos-sync-core
Core synchronization library for Leptos applications
-
telltale-choreography
Choreographic programming for Telltale - effect-based distributed protocols
-
actix
Actor framework for Rust
-
background-jobs-tokio
in-process jobs processor based on Tokio
-
mofa-runtime
MoFA Runtime - Message bus, agent registry, and event loop
-
disposition_ir_model
SVG diagram generator intermediate representation
-
singleflight-async
Singleflight in async style
-
spargio-protocols
Protocol integration companion crate for spargio (tls/ws/quic)
-
moduforge-runtime
插件加载、热更新、依赖管理
-
madsim-real-tokio
An event-driven, non-blocking I/O platform for writing asynchronous I/O backed applications
-
qapi
QEMU QMP and Guest Agent API
-
anthropic-sdk-rust
Comprehensive, type-safe Rust SDK for the Anthropic API with streaming, tools, vision, files, and batch processing support
-
peace_webi_rt
Web interface runtime data types for the peace automation framework
-
futures-scan-ext
futures stream scan combinator for sync closures
-
orchestral-cli
Command line interface for running Orchestral workflows
-
daimon
A Rust-native AI agent framework
-
peace_fmt
Presentation and formatting support for the peace automation framework
-
reqsign-command-execute-tokio
Tokio-based command execution implementation for reqsign
-
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)…
-
apalis-board-web
Frontend components for managing Apalis task queues
-
polaris_graph
Graph execution primitives for Polaris (Layer 2)
-
apalis-board-types
Shared types and data structures used by the apalis-board workspace
-
noie-nds-api
NDS Protocol Buffers types for Rust (generated from nds-api/spec)
-
safina-async-test
Macro for running async tests - ARCHIVED: Code moved to
safinacrate -
napi-h
N-API bindings
-
scoped-join-set
A scoped variant of tokio::task::JoinSet for spawning non-'static futures
-
kovi-plugin-oai
Kovi 的 OpenAI 兼容 API 聊天插件，支持多智能体管理与符号指令系统。
-
libindigo-ffi
FFI-based implementation of the INDIGO protocol client using C library
-
zerortt-futures
Asynchronous Runtime Binding for
zerortt -
rust-s3-async-ffi
Asynchronous streaming of AWS S3 objects in C and C++ powered by rust-s3
-
kameo_actors
actors for kameo
-
logiops-daemon
Logitech device configuration daemon
-
gcra
A basic implementation of GCRA algorithm for rate limiting
-
oris-runtime
An agentic workflow runtime and programmable AI execution system in Rust: stateful graphs, agents, tools, and multi-step execution
-
runtara-management-sdk
SDK for managing runtara instances (start, stop, signals, images)
-
compio-tls
TLS adaptor with compio
-
serverless-fn
simplifying serverless function development and invocation
-
async_progress
Create sync points across async tasks
-
flowbuilder
An async flow orchestration framework with conditional execution and context sharing
-
agentic-sandbox
Sandboxed code execution: Process, Docker, Firecracker, Gateway
-
strawpoll
A wrapper to avoid spurious polling
-
secret-lib
Cross-platform, asynchronous Rust library to retrieve secrets from different sources
-
novel-zhipu
Zhipu AI (GLM) API client for novel
-
elizaos-plugin-discord
Discord plugin for elizaOS - Rust implementation with serenity
-
async-tty
An asynchronous TTY library for Rust
-
stop-token
Experimental cooperative cancellation for async Rust
-
cloud_terrastodon_config
Configuration helpers for the Cloud Terrastodon project
-
omp-gdk
Rust SDK for developing open.mp gamemodes
-
n0-watcher
async watchable values
-
anysc-rustls
crate-level shim layer for any {async crate}-rustls
-
bob-adapters
Adapter implementations for Bob Agent Framework ports
-
mentisdb
Semantic, hash-chained durable memory for long-running and multi-agent systems
-
eventastic_postgres
A postgres event store for eventastic
-
textmode
terminal interaction library backed by a real terminal parser
-
telltale-runtime
Choreographic programming for Telltale - effect-based distributed protocols
-
tokio_gen_server
Elixir/Erlang-GenServer-like actor on the Tokio runtime
-
messagepack-async
functional library for read/writing messagepack with tokio
-
openraft-legacy
Legacy compatibility layer for deprecated Openraft APIs
-
zinit-client
client library for interacting with Zinit service manager
-
dog-core
Core traits and utilities for the DogRS ecosystem - a modular Rust framework for building scalable applications
-
novel-openai
Openai for novel
-
libquarkpan
Async Rust client library for Quark Drive upload, download, listing, and folder creation
-
girlboss
async job manager with progress tracking
-
async-raft
An async implementation of the Raft distributed consensus protocol
-
bicoro
Bidirectional co-routine data structures
-
didcomm-rs
DIDComm messaging v2 specifications implementation: https://identity.foundation/didcomm-messaging/spec/
-
compio-process
Processes for compio
-
dwn
Decentralized Web Node
-
async-sink
The asynchronous
Sinktrait for the tokio ecosystem -
timer-utils
The time utils
-
tirea-protocol-ag-ui
AG-UI protocol event encoding and history adapters for tirea
-
xiaoyong-channels
Collection of channel primitives for sync and async contexts (both Sync and !Sync)
-
argentor-a2a
Google Agent-to-Agent protocol implementation for Argentor
-
logic-mesh
Control logic engine using event based and reactive blocks written in Rust
-
ai-agents-hooks
Agent hooks and events for AI Agents framework
-
ai-agents-template
Template loading and rendering for AI Agents framework
-
qonduit
CQRS pattern
-
wesichain
Rust-native LLM agents & chains with resumable ReAct workflows
-
async-drop
async drop
-
spargio-tls
TLS companion crate for spargio (rustls/futures-rustls bridge)
-
futures-util-delegate-access-macros
Copy and pasted macros from the futures_utils library used for creating combinators
-
dabus
Dynamic Aplication Controll Bus - an asynchronous, event based module system for thoes who want to move fast and *not* break things
-
flourish-unsend
Convenient and full-featured signals for Rust (thread-local variant)
-
agnostik
Executor Agnostic Runtime that can run your futures with your favourite Executor
-
spargio-process
Process companion crate for spargio
-
openai-agents-realtime-rs
Realtime runtime, sessions, and event models for openai-agents-rust
-
threshold
data structures
-
compio-rustls
impl Async for rustls
-
muxi-rust
Rust SDK for MUXI AI platform
-
task_forge
A flexible and simple task pool for asynchronous execution
-
llm-kit-deepseek
DeepSeek provider implementation for the LLM Kit - supports chat and reasoning models
-
primp-tokio-rustls
Fork of tokio-rustls
-
tokio-anysocket
Abstracted API over tokio's TCP and Unix streams
-
ruchei-callback
Callback traits for ruchei
-
tokio-jrpc
tokio-based async JSON-RPC 2.0 client and server
-
bybit-client
client library for the Bybit V5 API with REST and WebSocket support
-
godot_tokio
The tokio-async runtime wrapped in a gdextention object to be used as an engine singleton in your gdext project
-
elizaos-plugin-directives
elizaOS Directives Plugin - parse and manage agent directives
-
heph-inbox
Bounded capacity channel designed to be used as inbox for actors. Also supports one shot channels.
-
xiaoyong-notify
Collection of notification primitives for async contexts (both Sync and !Sync)
-
eureka-mmanager
An Actix actor collection for downloading manga, chapters, covers from Mangadex
-
ai-agents-recovery
Error recovery system for AI Agents framework
-
swiftide-query
Fast, streaming indexing, query, and agentic LLM applications in Rust
-
wesichain-agent
Rust-native LLM agents & chains with resumable ReAct workflows
-
runcycles
Rust client for the Cycles budget-management protocol — deterministic spend control for AI agents and LLM workflows
-
vox-shm
Shared-memory transport for vox — lock-free rings for zero-copy IPC
-
libindigo
Core API for developing INDIGO astronomy clients and devices
-
ta-events
Event system and subscription API for Trusted Autonomy
-
abyss-promise
[abyss] A simple promise implementation with adaptive threadpool support
-
a10
meant as a low-level library safely exposing different OS's abilities to perform non-blocking I/O
-
leptos_async_signal
Async signal for leptos Rust web framework
-
py_mcai_worker_sdk
AMQP Worker to listen and provide trait to process message
-
librados
Idiomatic (async) rust bindings for librados
-
tokio-serde-cbor
Integration of serde_cbor into tokio-io, to allow sending CBOR encoded frames across network (and possibly through other transports)
-
foxtive-cron
Foxtive Cron
-
spawns-executor
Async executors for thread context task spawner
-
hooch-http
HTTP addition to the hooch runtime
-
orka
An asynchronous, pluggable, and type-safe workflow engine for Rust, designed for orchestrating complex multi-step business processes
-
lune-std-datetime
Lune standard library - DateTime
-
tokio-hrtime
Hires timers for tokio
-
cognisgraph
State graph orchestration framework for multi-actor agent workflows
-
hyperstack-sdk
Rust SDK client for connecting to HyperStack streaming servers
-
pulsehive-runtime
Runtime execution engine for PulseHive multi-agent SDK
-
mini-agent
A minimal, extensible AI agent framework — async-first, multi-provider, tool-integrated
-
genawaiter2
Stackless generators on stable Rust
-
zlayer-init-actions
Pre-start container lifecycle actions (TCP, HTTP, S3, commands)
-
dialectic
Transport-polymorphic, asynchronous session types for Rust
-
crb-agent
CRB | Composable Runtime Blocks | Agent
-
waitgroup
Async waitgroup for a collection of task to finish
-
illuminate
Independent, early-stage Rust backend primitives for Laravel/PHP ecosystems with typed sqlx connections
-
oxidart
High-performance Adaptive Radix Tree with TTL, DFA pattern matching, and atomic counters
-
async-log
Async tracing capabilities for the log crate
-
openraft-sledstore
A sled based implementation of the
openraft::RaftStoragetrait -
elizaos-plugin-cli
elizaOS CLI Plugin - CLI framework and command registration
-
timeout-tracing
Returns stack and span trace when the future hits a timeout
-
axum-safe-path
Traversal-safe
Pathextractor for Axum -
tokitai
AI tool integration system with compile-time tool definitions
-
nextgraph
client library. Nextgraph is a decentralized, secure and local-first web 3.0 ecosystem based on Semantic Web and CRDTs
-
elizaos-plugin-msteams
Microsoft Teams plugin for elizaOS - Rust implementation with Bot Framework support
-
sigfinn
Lifecycle manager for spawning tasks
-
tower-sessions-rusqlite-store
(tokio-)rusqlite session store for
tower-sessions -
enact-a2a
Multi-agent and A2A (Agent-to-Agent) protocol support for Enact
-
async-transmit
Trait for transmitting data to peers asynchronously
-
cbsk_socket_tokio
socket callback tool by tokio
-
soul-gateways
Messaging gateway implementations for soul-core agents — Telegram, iMessage, WhatsApp
-
pgp-lib
High-level, asynchronous API for rPGP, a pure Rust implementation of OpenPGP
-
pulsess
A robust and flexible background job processing library for Rust
-
futures-concurrency-dynamic
A dynamic extension of the futures-concurrency
-
palladium-plugin
Native (cdylib) and WASM plugin system for Palladium actors
-
async-periodic-job
async periodic job scheduler library base on tokio-util
-
compio-signal
Signal handling for compio
-
effectum
An embeddable task queue based on SQLite
-
polarway-bus
Generic, domain-agnostic event bus with fan-out, filtering, and drain buffers
-
swiftide-macros
Fast, streaming indexing, query, and agentic LLM applications in Rust
-
krabdex
A type-safe, async Rust SDK for the PokeAPI
-
elizaos-plugin-prose
elizaOS OpenProse Plugin - A programming language for AI sessions and multi-agent orchestration
-
spargio-signal
Signal companion crate for spargio
-
neuron-otel
OpenTelemetry instrumentation for AI agents — GenAI semantic conventions with tracing spans
-
agentlib-orchestrator
Multi-agent orchestration and parallel workflow management for AgentLib
-
teloxide-core-ng
Core part of the
teloxidelibrary - telegram bot API client -
supera
managing worker threads
-
alpha-core-framework
High-performance modular Rust framework for async task orchestration and data pipelines
-
praisonai
Core library for PraisonAI - Agent, Tools, Workflows
-
elizaos-plugin-nextcloud-talk
Nextcloud Talk plugin for elizaOS - Rust implementation with webhook bot integration
-
tanukie
🦀 Lightweight, blazing-fast LLM client
-
bisync
write async-generic code
-
lune-std-regex
Lune standard library - RegEx
-
tonic-side-effect
Tower service that can monitor if a Tonic request frame was produced prior to error
-
lune-std-task
Lune standard library - Task
-
future_form_ffi
FFI support for future_form: host-driven polling, opaque handles, and effect slots
-
llm-stack-anthropic
Anthropic Claude provider for the llm-stack SDK
-
rabbitmq-worker
A generic RabbitMQ worker library with built-in retry and dead-letter queue (DLQ) logic
-
lyo
automatic task distribution
-
slice_ops
A selection of useful slice operations
-
retryx
Async-first retry and exponential backoff helper for Tokio-based Rust applications
-
octopust
A high-performance, idiomatic Rust client for the Octopus Energy API
-
zino-http
HTTP requests and responses for zino
-
roam-shm-ffi
C bindings for roam shared-memory primitives
-
safina-sync
Safe structs for sharing or sending data between async tasks - ARCHIVED: Code moved to
safinacrate -
peace_cmd
Command structure for the Peace framework
-
elfo-test
Test utils for the elfo system
-
elfo-configurer
Loads and distributes configs across the elfo system
-
llm-stack-openai
OpenAI GPT provider for the llm-stack SDK
-
elizaos-plugin-tlon
Tlon/Urbit plugin for elizaOS - Rust implementation with SSE support
-
lune-std-luau
Lune standard library - Luau
-
super-visor
ordered startup and shutdown for long-running tokio processes
-
elizaos-plugin-instagram
Instagram plugin for elizaOS - Rust implementation
-
bb8-lapin
r2d2-lapin, but for async tokio based connections
-
moxie
Incremental runtime for interactive software
-
asynclog
asynchronous log library
-
async-dashscope
client for DashScope API
-
tencentcloud-sms
腾讯云短信服务 Rust SDK - 类型安全、异步高性能的短信 API 客户端
-
libindigo-rs
Pure Rust implementation of the INDIGO protocol client
-
elfo-utils
Some utils for the elfo system
-
d-engine-server
Production-ready Raft consensus engine server and runtime
-
zino-connector
Unified connector to data sources for zino
-
tracing-opentelemetry-extra
Bootstrap utilities for tracing and OpenTelemetry integration
-
async-tls
Asynchronous TLS/SSL streams using Rustls
-
tokio-boring2
SSL streams for Tokio backed by BoringSSL
-
plug
type-safe interprocess communication
-
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) -
rusty-genius-stem
Orchestrator and event loop for rusty-genius
-
safina-threadpool
Safe thread pool - ARCHIVED: Code moved to
safinacrate -
rocketmq-client-rust
Apache rocketmq client
-
streamweave-error
Error handling system for StreamWeave
-
operation-queue
Helpers for synchronizing asynchronous protocol operations
-
llm-stack-ollama
Ollama local model provider for the llm-stack SDK
-
dropslot
A high-performance publish-subscribe library with latest-only delivery semantics
-
trendy-cli
A CLI tool for fetching posts from Reddit and Hacker News with AI chat capabilities
-
drop-handle
A handle that will abort a Tokio task when dropped
-
tirea-extension-handoff
Agent handoff extension: same-thread agent switching with dynamic overlay for tirea agents
-
predict-fun-rs
Blazing fast async Rust SDK for Predict.fun REST API
-
futuredsp
A signal processing library for SDR and real-time DSP
-
futures-delay-queue
Async delay queue backed by async-std and futures-timer
-
sayiir-postgres
PostgreSQL persistence backend for Sayiir workflow engine
-
secra-cache
一个基于 Redis 的统一缓存管理库，专为插件化架构设计，提供强隔离、生命周期管理和极简 API
-
moirai-pump
Event-pump runtime for Moirai job system
-
cbsk_run
async pool tool
-
openclaw-providers
AI provider clients for OpenClaw (Anthropic, OpenAI, etc.)
-
pptr
Type-Driven Asynchronous Actor Runtime
-
lspi
Giving AI the sight of LSP: bridge LSP capabilities to AI coding CLIs via an MCP server over stdio
-
eugener-test
An event-driven, non-blocking I/O platform for writing asynchronous I/O backed applications
-
mcp-runner
running and interacting with Model Context Protocol (MCP) servers locally
-
rayclaw
Multi-channel agentic AI runtime with tool-calling, memory, and scheduling
-
route-sink
Sinks with routes
-
toki
A minimal single-threaded async runtime for ultra-low-latency Linux systems
-
ics-watcher
A lightweight crate for monitoring ICS files or links and detecting changes, additions, and removals
-
beetry
Behavior tree framework with a runtime, plugin system, and Beehive editor
-
async-blocking-stdio
std::io::std{in(), out(), err()} but async
-
ispawn
Runtime-agnostic async spawners
-
par-stream
Asynchronous parallel streams analogous to rayon
-
tokio-interactive
Asynchronous Interactive Process Management with Tokio
-
rusty-genius-cortex
Inference engine interaction layer for rusty-genius
-
selectme
A fast and fair select! macro for asynchronous Rust
-
actix-multipart-rfc7578
multipart/form-data (RFC7578) for Actix
-
plyne
Based pipeline of async task system
-
synwire-agent-skills
Agent skills runtime for Synwire following the agentskills.io specification
-
async-stdin
Asynchronously read from stdin
-
async-niri-socket
Non-blocking communication over the niri socket
-
mio-misc
Miscellaneous components for use with Mio
-
greentic-x-events
Bootstrap event model crate for the Greentic-X workspace
-
spaad
Zero boilerplate actor systems with xtra
-
cerebras-rs
High-performance Rust SDK for Cerebras Inference API - Low-latency AI model inference powered by Cerebras Wafer-Scale Engines
-
newsblur_api_updated
NewsBlur-API
-
skg-turn
Shared toolkit for building operators — Provider trait, types, context strategy
-
rust-langgraph
Stateful graph runtime for LLM workflows in Rust (community project; not affiliated with LangChain). Pregel-style execution: nodes, conditional edges, checkpoints, streaming. Optional adapters for…
-
deepseek_rs
client library for the DeepSeek API
-
mboxlabs-mailbox
A lightweight, pluggable mailbox/queue kernel inspired by the Erlang Actor Model
-
announcement
A runtime-agnostic oneshot broadcast channel
-
safina-net
Safe async network functions - ARCHIVED: Code moved to
safinacrate -
peace_progress_model
Command progress data model for the peace automation framework
-
wasmcloud-interface-factorial
Interface library for the wasmcloud factorial capability, wasmcloud:example:factorial
-
spin_on
inefficient Future executor
-
async-rusqlite
A tiny executor agnostic wrapper around rusqlite to make calls to it async
-
avx-runtime
AVX Runtime - Native async runtime built from scratch to replace Tokio with work-stealing scheduler, epoll/kqueue/IOCP, and zero-overhead futures
-
mill-net
High-level networking protocols components built with mill-io event-loop library
-
zino-auth
Authentication and authorization for zino
-
minion-engine
AI workflow engine that orchestrates Claude Code CLI — automate code review, refactoring, and PR creation with YAML workflows
-
universal-inserter
A runtime-agnostic batch inserter library implementing the ClickHouse Inserter pattern
-
seesaw-kafka
Kafka backend for Seesaw event-driven orchestration
-
cabal
Hierarchical agent orchestration system - the scheming group
-
fork_stream
Clone any stream
Swhere<S as Stream>::Item: Clone -
buffer-unordered-weighted
Stream::buffer_unordered where each future can have a different weight
-
async_py
calling Python code asynchronously using pyo3 or rustpython
-
halldyll_starter_runpod
managing RunPod GPU pods - Provisioning, orchestration & state management
-
async-result-ext
Async extensions for Result<T, E> with async closures
-
tasker-client
Tasker API client library — transport-agnostic REST and gRPC clients
-
tasc
A minimnal, asynchronous threadpool
-
tokio-executor-trait
executor-trait implementation for tokio
-
checkstream-core
Core types, token buffer, and error handling for CheckStream guardrail platform
-
async-timeouts
An instrument to start async tasks after timeouts
-
disposition_taffy_model
Data types for disposition to work with taffy
-
taski
async task DAG execution
-
strontium-palladium
Deterministic fault-bridge contracts for Palladium actor simulations under Strontium control
-
crb-download
CRB | Composable Runtime Blocks | Downloader
-
openllm-rs
that enables seamless interaction with Llama.cpp backend services through an OpenAI-compatible REST APIe
-
sactor
actor framework for Rust
-
agentic_optio_rs
Production-grade multi-agent framework with minimal dependencies - Rust implementation
-
zino-storage
Files and storage services for zino
-
agent-air-runtime
Core runtime for agent-air - LLM orchestration, tools, and permissions (no TUI dependencies)
-
task-local
storage for asynchronous tasks
-
oxide-update-engine
A framework for declaring and executing sequential update steps with serializable event streams
-
apt-transport
APT transport abstraction, allowing for custom APT transport implementations in Rust
-
asyncs-sync
Asynchronous runtime agnostic synchronization utilities
-
warhorn
Protocol types for agent communication - signals between goblins
-
interruptible
Stops a future producer or stream from producing values when interrupted
-
orchestral-runtime
Thread Runtime with concurrency, interruption, scheduling, LLM planners, actions, and API for Orchestral
-
async-graphql-relay
Relay support for async-graphql
-
seams-rs-std
Standard-library-backed production impls of seams-rs-core ports: SystemClock, StdSleeper, StdSpawner, StdFileSystem, TokioFileSystem
-
bsky-cli
CLI application for Bluesky using ATrium API
-
xactor
actors framework based on async-std
-
spring-axum
Spring-like application framework for Axum with macro-based auto discovery, validation, transactions, caching, events, and SQL/Mapper integrations
-
vex-runtime
Tokio-based agent orchestration for VEX
-
scylla-rs
An async ScyllaDB driver built on an actor-model framework
-
rusty_tarantool
Tarantul async client based on tokio framework
-
tokio-memory
Agent memory primitives: episodic, semantic, working memory with decay and consolidation
-
rs-sqs-receiver
An asynchronous AWS SQS message receiver framework with trait-based handlers and shared resource support
-
prism3-retry
Retry module, providing a feature-complete, type-safe retry management system with support for multiple delay strategies and event listeners
-
libuv-sys-lite
Tiny, raw bindings to libuv without linking to it
-
wesichain-llm
Rust-native LLM agents & chains with resumable ReAct workflows
-
disposition_svg_model
Data types for disposition to represent SVG elements
-
mahler
An automated job orchestration library that builds and executes dynamic workflows
-
cortexai-tools
Built-in tools for Cortex AI agents: calculator, web search, file I/O and more
-
actix-interop
Use async/await syntax with actix actors
-
enact-security
Security policy, audit logging, and sandboxing for Enact agents
-
tokio-uring-xitca
a fork of tokio-uring with miniaml maintenance
-
isoprenoid
signals runtime framework backing flourish
-
nurtex
Lightweight library for creating Minecraft bots. Asynchronous, optimized, ease of coding.
-
serdes-ai-retries
Retry strategies and error handling for serdes-ai
-
async_async_io
AsyncRead,AsyncWritetraits but withasync fnmethods -
lichess-api
A client library for the Lichess API
-
armature-queue
Job queue and background processing for Armature
-
forgeai
Unified Rust SDK for multi-provider GenAI
-
arbeitssklave_tokio
tokioadapter forarbeitssklaveactors framework -
hutch
Checkpoint and undo system for AI agent sessions - safe burrow to return to
-
wamp_async
An asynchronous WAMP implementation
-
futures_kind
Abstractions over Send and !Send futures
-
rusplay
Memory safe, blazing fast Rugplay library written in Rust
-
async-change-tracker
reactive change notifications using futures
-
hiasync
Supports only single-threaded asynchronous runtime
-
fn_graph
Runs interdependent logic concurrently, starting each function when predecessors have completed
-
aimdb-executor
Pure async executor trait definitions for AimDB - runtime-agnostic abstractions
-
limit-agent
Agent runtime for AI applications with tool registry, parallel execution, and Docker sandbox support
-
mini_langchain_core
A low-cost, cross-language LangChain implementation
-
act_rs_tokio
Act.rs Tokio is a minimal Tokio oriented actor framework
-
peace_profile_model
Serializable data model for profiles for the Peace framework
-
zino-openapi
OpenAPI support for zino
-
flarrow-message
flarrow (flow + arrow) is a rust runtime/framework for building dataflow applications
-
rx-rs
A lightweight single-threaded push-based reactive programming library
-
rusty-genius-teaser
Testing harness and verification for rusty-genius
-
oxdl
Asynchronous downloader with progress bars and SHA256 verification
-
agentcore
A minimal Rust crate that gives any application agentic capabilities
-
eternaltwin_job_store
Job store implementation
-
polaris_tools
Tool framework for Polaris agents
-
fluxion-core
Core traits and types for ordered stream processing
-
daku
Interface to the Daku API
-
agnostic-io
agnostic-iodefines I/O traits in agnostic style for any async runtime -
enact-observability
Observability and telemetry for Enact
-
beetry-node
Beetry library with reusable behavior tree nodes
-
pingora-runtime
Multithreaded Tokio runtime with the option of disabling work stealing
-
polaris_model_providers
Model provider implementations for Polaris
-
mosquitto-rs
An async MQTT client based on libmosquitto
-
codeuchain
High-performance implementation with memory safety and async support
-
callbag
spec for reactive/iterable programming
-
sayiir-core
Core types and traits for the Sayiir durable workflow engine
-
disposition_model_common
SVG diagram generator common data model types
-
durable-lambda-macro
Proc-macro for zero-boilerplate AWS Lambda durable execution handler registration
-
inferadb-common-ratelimit
Distributed fixed-window rate limiter using StorageBackend
-
toy-rpc
An async RPC that mimics golang net/rpc's usage and supports both async-std and tokio
-
ahrikv
A high-performance in-memory key-value store
-
hedged-rpc-client
High-performance Solana RPC client with request hedging for tail latency elimination
-
zephyrus
A slash-command framework meant to be used with twilight
-
capsec-tokio
Async capability-gated wrappers for tokio — the async counterpart to capsec-std
-
hfst
Wrappers to libhfst via libhfst_c
-
lookit
Asynchronously connect to devices
-
rrq-protocol
Shared RRQ runner protocol types
-
varpulis-actors
Lightweight actor framework with supervision and health observation for Varpulis
-
luarmor
API wrapper for luarmor.net
-
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
-
hydra-websockets
A websocket server for the hydra framework
-
peace_value_traits
Trait bounds for value types for the Peace framework
-
thorstreamer-grpc-client
Rust client for ThorStreamer gRPC streaming services
-
ruex
Generic State Management framework
-
cloud_terrastodon_azure_devops_types
Types for modelling Azure DevOps for the Cloud Terrastodon project
-
dropbear_future-queue
A queue for polling futures in a synchronous context
-
gprs
A set of filtered and optimized Rust libraries creates a foundation for building modern web frameworks
-
disposition_input_ir_model
dispositiondiagram generator input to IR mapping data types -
yoa-runner-lib
Shared Rust primitives for managing runner workloads across Docker and Kubernetes
-
kojin-amqp
RabbitMQ (AMQP) broker for the kojin task queue
-
microrust
Application Framework
-
smpsc
Wrappers for tokio's mpsc channels which implement Stream and Sink
-
feagi-agent
Client library for building FEAGI agents in Rust
-
async-read-super-ext
A super extension for tokio::io::AsyncRead
-
elicit_server
Cross-crate workflow plugins for elicitation — code recovery, multi-crate compositions, and server-side orchestration
-
specializer
Limited safe specialization on stable Rust with builder-like pattern
-
continue_stream
A Swift-style AsyncIterator.Continuation-style channel for Rust
-
timedmap
A hash map with expiring key-value pairs
-
simq
A job queue with the goal of being as simple of a queue as possible
-
eden-skills
Deterministic & Blazing-Fast Skills Manager for AI Agents (Claude Code, Cursor, Codex & More)
-
tirea-contract
Agent runtime contracts: 8-phase plugin lifecycle, typed tool traits, and state scope system
-
cloud_terrastodon_command
Command running helpers for the Cloud Terrastodon project
-
tor-log-ratelim
Facility for rate-limiting log messages in Arti
-
translators
Free Google Translator without API key and limits
-
async_fsm
Async Finite State Machine
-
async-atomic
Atomics which can be subscribed to and asynchronously notify when updated
-
qbittorrent_rust
An asynchronous library to interface with the qbittorrent WeBUI API
-
pi_async_file
A async file tools library
-
kojin-postgres
PostgreSQL result backend for the kojin task queue
-
rsketch-common-runtime
Tokio runtime configuration and management for rsketch
-
woddle
An async, synchronized, database-backed Rust job scheduler
-
process-lib
Cross-platform, asynchronous Rust library to run commands in pipelines
-
dd-tracing-layer
Send your logs to Datadog
-
elfo-dumper
Dumps messages of the elfo system on disk
-
trema
Memory, tracing, and multi-agent orchestration for Rust AI agents
-
mailfred
Process emails as an HTTP server
-
fundamentum-edge-pfwd
The port forwarding tool for edge daemon
-
mecha10-runtime
Runtime supervisor for Mecha10 nodes - launching, monitoring, and lifecycle management
-
tokio-agent-memory
Tokio-native agent memory: episodic, semantic, and working memory with decay scheduling, persistence, and multi-agent bus
-
event-notification
A modular event notification system with multi-channel support
-
nuitrack-rs
Rust bindings for the Nuitrack SDK, enabling skeletal tracking, gesture recognition, and other computer vision capabilities
-
uringy
single-threaded concurrency runtime for Rust based on io_uring
-
wesichain-session
Rust-native LLM agents & chains with resumable ReAct workflows
-
toolpath-github
Derive Toolpath provenance documents from GitHub pull requests
-
kojin-dashboard
JSON API dashboard for monitoring the kojin task queue
-
protocraft_framework
A framework for handling minecraft packets
-
tokio-file
Asynchronous file I/O for Tokio
-
shipper-retry
Retry strategies and backoff policies for shipper
-
yosemite
Asynchronous SAMv3 library
-
enact-runner
Robust agent loop runner for Enact — retries, compaction, multi-format parsing
-
async-gcode
An async gcode parser for no_std targets
-
neuron-loop
Agentic loop for Rust — multi-turn tool dispatch, streaming, and conversation management over any LLM provider
-
elfo-pinger
Pings groups of the elfo system
-
sugars_async_task
Async task utilities and abstractions for the cyrup-sugars ecosystem
-
zookeeper-async
An async ZooKeeper client
-
zino-axum
Integrations with axum for zino
-
conferencier
Tokio-backed asynchronous shared configuration hub with TOML persistence
-
patchwork-acp
ACP proxy for executing Patchwork code with LLM integration
-
ref_count
Efficient, low-level asynchronous synchronization for real-time and embedded systems
-
async-barrier
An async barrier
-
peace_webi_output
Web interface output for the peace automation framework
-
anthropic
SDK
-
hml-rs
Markup language events and readers, supporting 'human markup language'
-
axum-server2
High level server designed to be used with axum framework
-
streamline
Reversible futures::Stream-based state machines
-
futuresdr-types
Polymorphic Types for an Experimental Async SDR Runtime for Heterogeneous Architectures
-
async-openai-alt
OpenAI
-
smelling_salts
Abstraction over OS APIs to handle asynchronous device waking
-
kappa
actor framework, this one based on the lambdas/behaviors
-
kimojio-tls
Kimojio OpenSSL integration
-
async-lazy
A value which is initialized on the first access, with an async function
-
timeout-macro-parse
A companion-crate for the tokio-timeout proc-macro-lib
-
ranvier-audit
Tamper-proof audit logging framework for Ranvier
-
better_tokio_select
tokio::select! that can be formatted by rustfmt
-
lifeline
dependency injection library for asynchronous message-based applications
-
peace_item_spec_tar_x
Manages extracting a tar file for the peace framework
-
jamjet-mcp
JamJet MCP client and server — Model Context Protocol support
-
zino-actix
Integrations with actix-web for zino
-
miniagent
Minimal single agent demo with basic file tools and MCP support
-
agentic-llm
LLM adapters for OpenAI, Anthropic, Gemini, Ollama
-
rants
An async NATS client library
-
odem-rs-util
Model elements and statistical tooling for the odem-rs simulation framework
-
goblin-engine
A high-performance async workflow engine for executing scripts in planned sequences with dependency resolution
-
makcu-rs
Fast and modular communication interface using serial ports, built with async-first design in Rust
-
apocalypse
actor framework for Rust
-
interprocess-docfix
Interprocess communication toolkit. Docs fixed.
-
vox-shm-ffi
C bindings for vox shared-memory primitives
-
vk-bot-api
Asynchronous VK Bot API library for Rust
-
can-isotp-queue
Queue/actor adapter for split ISO-TP TX/RX endpoints across async runtimes
-
futures-ticker
An asynchronous recurring time event
-
scoped_static
Safe promotion of lifetimes to static
-
machi-integrations
Third-party platform integrations for Machi AI Agent Framework
-
cron-core
A cron task scheduler library for Rust with async runtime support
-
elfo-telemeter
Collects and exposes metrics of the elfo system
-
crb-send
CRB | Composable Runtime Blocks | Send
-
yellowstone-faithful-client
Rust SDK for interacting with Old Faithful gRPC services, providing access to Solana historical data
-
faf-core
Fiduciary Agent Framework - Core protocol types and traits
-
actix-broker
Message broker for the Actix actor framework
-
actix-mqtt-client
A MQTT client based on the actix framework
-
zipit
Create and stream zip archives on the fly
-
wait-for-me
Async CountDownLatch
-
sansio-executor
sansio executor
-
gradio_client_rs
Async Rust client for Gradio apps
-
unsync-pipe
Ringbuffer-backed !Send !Sync binary safe repr(C) AsyncWrite/AsyncRead pair
-
auto-future
For quickly making a struct into a future via an async fn
-
prestige-cli
CLI interface for manually fetching and reading Prestige-parquet files
-
teloxide-ng
An elegant Telegram bots framework for Rust
-
traitclaw-strategies
Built-in reasoning strategies (ReAct, MCTS, CoT) for the TraitClaw AI agent framework
-
oxanus-web
Web UI for Oxanus job queue system
-
redis-work-queue
A work queue, on top of a redis database, with implementations in Python, Rust, Go, Node.js (TypeScript) and Dotnet (C#)
-
tokio-splice2
splice(2) in tokio
-
safina-select
Safe async select function, for awaiting multiple futures - ARCHIVED: Code moved to
safinacrate -
act-zero
Ergonomic actor system
-
flows-http
Building blocks for flow-based HTTP requests & responses
-
crb-pipeline
CRB | Composable Runtime Blocks | Pipeline
-
ambush
Task decomposition and plan mode for AI agents - planning the attack
-
brainwires-system
Generic OS-level primitives — filesystem event watching and system service management
-
praxis
High-performance React agent framework for building AI agents with LLM, tool execution, and persistence
-
rust-tg-bot
Complete Telegram Bot API framework for Rust, inspired by python-telegram-bot
-
neuron-types
Core traits for AI agents in Rust — Provider, Tool, and ContextStrategy without the framework buy-in
-
tokio-util
Additional utilities for working with Tokio
-
futuresdr
An Experimental Async SDR Runtime for Heterogeneous Architectures
-
baseten_performance_client_core
High performance HTTP client for Baseten.co and other APIs
-
myexe
Myexe
-
cbsk_socket_rayon
socket callback tool by rayon
-
alchemy-llm
Unified LLM API abstraction layer supporting 10+ providers through a consistent streaming interface
-
nenjo-eventbus
Transport-agnostic event bus for routing agentic AI workflow commands over NATS or custom transports
-
tokio-socketcan
Asynchronous Linux SocketCAN sockets with tokio
-
mixtape-core
An agentic AI framework for Rust
-
compio-ws
WebSocket library for the compio runtime
-
par_io
Parallel, async file I/O library with control over memory usage with no dependencies
-
starweft-store
SQLite-backed persistent storage layer for starweft
-
smol-potat
Proc macro for smol runtime
-
drasi-reaction-application
Application reaction plugin for Drasi
-
deferred-future
模仿 jQuery.Deferred()，允许从 Future 实现类实例的外部对正在 pending 的 Future 对象进行 resolve 或 reject 处理。
-
vkapi2
vk api wrapper for rust
-
agentlib
Modular and extensible framework for building sophisticated AI agents in Rust
-
hojicha-runtime
Event handling and async runtime for Hojicha TUI framework
-
monoio-rustls
Asynchronous TLS streams wrapper for Monoio based on Rustls
-
tokio-scheduler-rs
JobScheduler written with tokio runtime, automatic retry, hook and custom storage supported
-
traitclaw-openai-compat
OpenAI-compatible provider for TraitClaw (covers OpenAI, Ollama, Groq, Mistral, vLLM, Azure)
-
enact-cron
Cron scheduling system for Enact agents
-
chimera-opencode
OpenCode/OpenAI-compatible REST backend for the chimera AI agent SDK
-
armature-azure-functions
Azure Functions runtime adapter for Armature applications
-
async-graphql-warp
async-graphql for warp
-
go-server-rust-sdk
Rust SDK for go-server distributed task scheduler and worker system
-
binary-cookies
BinaryCookies decode and encode
-
rxqlite-tests-common
A distributed sqlite database built upon
openraft,sqlxandsqlite -
rong_child_process
Child process module for RongJS
-
rusty-genius-cord
SpinalCord: Message forwarding layer for rusty-genius
-
mutiny-rs
API wrapper for the Stoat chat platform
-
phoenix_channels_client
async-ready client for Phoenix Channels in Rust
-
circulate
Lightweight PubSub framework that supports both sync and async
-
waterkit-background
Cross-platform background task scheduling and execution hooks
-
deliverust
Easy to use and lightweight async pubsub context
-
futures_cbor_codec
A codec for framing an AsyncRead/AsyncWrite with cbor for all types that are serializable with serde
-
infect
Intent/effect/task - A variation on the Model View Intent (MVI) and State Action Model (SAM) paradigms
-
stream-reconnect
Stream-wrapping traits/structs that automatically recover from potential disconnections/interruptions
-
zino-channel
Cloud events and subscriptions for zino
-
asupersync-conformance
Conformance test suite for async runtime specifications
-
wuhu-compress
Three-tier context compression pipeline for the Wuhu agent framework
-
flows-text
Building blocks for flow-based text processing
-
chimera-claude
Claude Code backend for the chimera AI agent SDK
-
aral
Async Runtime Aggregation Layer
-
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
-
neuromance-cli
Interactive command-line interface for LLM interactions
-
etcdv3client
etcdv3 client
-
murmer
A distributed actor framework for Rust
-
skg-context
Context strategy implementations for skg-turn
-
winctx
A minimal window context for Rust on Windows
-
ceylon-runtime
A Rust-based agent mesh framework for building local and distributed AI agent systems
-
seesaw-memory
In-memory adapter for Seesaw event-driven runtime
-
apalis-mysql
Background task processing for rust using apalis and mysql
-
floxide-timer
Timer node abstractions for the floxide framework
-
tokio-thread-pool
A small wrapper around the tokio runtime supporting max concurrency
-
chimera-codex
Codex backend for the chimera AI agent SDK
-
senders_receivers
Senders/Receivers implementation for Rust
-
iroh-io
async local io
-
oats-framework
Universal architecture pattern for infinite scale across any domain - Objects • Actions • Traits • Systems
-
thespis
The interface of the thespis actor model (contains only traits)
-
merkql-notify
Notification trait and types for merkql event streaming
-
argentor-core
Core types, error handling, and event bus for the Argentor AI agent framework
-
merkql-notify-sns
AWS SNS notification plugin for merkql
-
merkql-notify-sqs
AWS SQS notification plugin for merkql
-
armature-events
Event bus and pub/sub for Armature applications
-
compio-io
IO traits for completion based async IO
-
nenjo-models
LLM provider trait and implementations — OpenAI, Anthropic, Gemini, OpenRouter, Ollama, and any OpenAI-compatible API
-
armature-webhooks
Webhook sending and receiving for Armature
-
peace_cli
Command line interface for the peace automation framework
-
circuit_breaker
Circuit Breaker pattern for building resilient and fault-tolerant systems
-
actix-daemon-utils
Daemon Utilities by actix
-
mixtape-anthropic-sdk
Minimal Anthropic API client for the mixtape agent framework
-
napi-calm-down
N-API bindings
-
grok-rust-sdk
Rust SDK for xAI's Grok API - supporting chat, tools, sessions, and collections
-
cuckoo-runtime
An async runtime that mostly runs inside other multi-threaded applications
-
actix-limitation
Rate limiter using a fixed window counter for arbitrary keys, backed by Redis for Actix Web
-
duende-platform
Platform adapters for the Duende daemon framework (systemd, launchd, container, pepita, WOS)
-
disposition_input_rt
Runtime mutation operations for
dispositioninput diagrams -
openai-agents-rust
Harmony-aligned, OpenAI-compatible agent orchestration in Rust with tools, realtime, and voice
-
zino-extra
Extra utilities for zino
-
poolparty
Added functionality for the
futures::executor::ThreadPoolfutures executor -
zeal-sdk
Rust SDK for Zeal Integration Protocol (ZIP)
-
async-ops
Use std::ops traits with Futures
-
notifier_hub
cannal subscribtion system
-
agnostic-process
Agnostic abstraction layer of
std::processfor any async runtime -
aws-smithy-http-server
Server runtime for Smithy Rust Server Framework
-
tinycoro
rust bindings to minicoro
-
dog-axum
Axum web framework integration for DogRS - HTTP handlers, middleware, and web utilities
-
roux-stream
A streaming API for the roux Reddit client
-
kojin-sqs
AWS SQS broker for the kojin task queue
-
catloaf
core-affine, thread-local, opinionated actor framework
-
neuron-tool
Tool interface and registry for neuron
-
haagenti-streaming
Real-time streaming generation with progressive preview display
-
cloud_terrastodon_hcl_types
Helper types for interacting with HCL for the Cloud Terrastodon project
-
asyncapi-rust-models
Runtime data structures for asyncapi-rust (AsyncAPI 3.0 spec models)
-
coclai
Ergonomic Rust wrapper for codex app-server with runtime safety and release gates
-
rmp-futures
Async Rust MessagePack and MessagePack-RPC
-
veecle-freertos-sys
Rust bindings for FreeRTOS
-
mojentic
An LLM integration framework for Rust
-
wesichain-embeddings
Embedding providers for Wesichain
-
appletheia-application
The Application Layer for Event-Sourcing Architecture
-
kizuna-mem-sdk
Rust SDK for Kizuna-Mem temporal graph memory engine
-
nio-task
async task implementation
-
tokio-stream_wasi
work with
Streamandtokio -
trait-morph
A lightweight procedural macro to transform
async fnin traits into-> impl Futurewith explicit bounds -
irox-threading
Blocking and Asynchronous Threading Tools
-
async-attributes
Experimental language-level polyfills for Async Rust
-
deadpool-fantoccini
Dead simple async session pool for fantoccini
-
uika-ffi
FFI types and API table definitions for uika
-
fcdb-concur
Concurrency primitives and async utilities for FCDB
-
openhelm-github
GitHub skill for openhelm: browse repos, issues, PRs, and files
-
skg-state-memory
In-memory StateStore implementation for skelegent
-
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
-
smooai-smooth-operator
Smooth Operator — Rust-native AI agent framework with built-in checkpointing, tool system, and LLM client
-
nenjo-tools
Tool trait, types, and built-in tool implementations for the Nenjo agent platform
-
zoey-core
ZoeyAI core runtime and types — privacy-first AI agent framework optimized for local models
-
agenda-rs
A lightweight, stateful job queue for Rust backed by PostgreSQL with sqlx. Inspired by AgendaJS.
-
mini_executor
The smallest, simplest Rust task executor using Tokio runtime
-
trale
minimalistic Rust async executor using io_uring for efficient, correct task execution
-
enact-mcp
MCP (Model Context Protocol) client for Enact
-
edeltraud
thread pool for mixed tokio / threaded infrastructure with zero allocations and static dispatching only
-
tokio_tasks_shutdown
Easily manage and gracefully shutdown tokio tasks while monitoring their return results
-
capp
Common things i use to build Rust CLI tools for web crawlers
-
beetry-exec
Internal beetry crate. For the public API, check the beetry crate.
-
wuhu-providers
LLM provider adapters for the Wuhu agent framework (Anthropic, OpenAI)
-
futures-io-preview
The
AsyncReadandAsyncWritetraits for the futures-rs library -
amqp
AMQP/RabbitMQ protocol client
-
bound
Wrap lock guards and other structs along with the locks or other data they are derived by shared reference from, in a struct you can pass around and store anywhere
-
voiceflousion
that provides toolkit for Voiceflow AI bots integrations and pre-built functionality for quick integration with popular messengers
-
lua_actor
Lua Actor for Rust(sync/async)
-
cognate-llm
A modular, extensible LLM framework for Rust with multi-provider support, type-safe tools, and RAG capabilities
-
ng-repo
Repository library of NextGraph, a decentralized, secure and local-first web 3.0 ecosystem based on Semantic Web and CRDTs
-
lbs-core
LBS core
-
traitgate
A zero-dependency authorization mini-library powered by stateless traits and an ergonomic
AuthorizationDecisionenum -
driveshaft
A minimal, high-performance thread pool for running synchronous tasks with per-thread context from async code
-
peace_item_spec_file_download
Manages downloading a file for the peace framework
-
strands-agents
Strands AI Agents SDK
-
dseek
Deepseek cli which utilizy async runtime and can't panic and copy response directly to clipboard
-
openai-agents-core-rs
Core runtime primitives for openai-agents-rust
-
elizaos-plugin-slack
Slack integration plugin for elizaOS agents with Socket Mode support
-
maelstrom-node
Maelstrom Rust node framework
-
peace_item_spec_sh_sync_cmd
Manages a synchronization shell command for the peace framework
-
when2task
high-performance library for executing async tasks with automatic dependency resolution and optimal parallelization
-
noesis-core
Core traits and types for the Tryambakam Noesis consciousness engine platform
-
kioto-serial
Provide serial port I/O using tokio
-
motosan-workflow-runtime
Execution engine for motosan-workflow
-
noveum-ai-gateway
A high-performance AI Gateway proxy for routing requests to various AI providers, offering seamless integration and management of multiple AI providers
-
stream-download-opendal
OpenDAL adapter for stream-download
-
rspl
A stream processor language
-
solana-pump-grpc-sdk
Solana Pump/PumpAmm gRPC event listener SDK
-
plumber-rs
The basic library for Plumber servlet written in Rust
-
smol-cancellation-token
cancellation token implementation for Smol, copied from tokio-util’s cancellation token, and replace the
wakerwithEventListenerto make it cross async runtime compatible -
skg-tool
Tool interface and registry for skelegent
-
rt-gate
A tiny wrapper for async runtimes
-
neuromance-common
Common types and data structures for LLM conversation and tool management
-
zino-amis
UI generator for amis
-
co-actor
Very lightweight actor abstraction over tokio channels
-
fundamentum-sdk-api
HTTP client targeting Fundamentum IoT devices RestAPI
-
ranvier-compliance
Compliance helpers (GDPR, HIPAA) for Ranvier
-
peace_item_spec_sh_cmd
Manages running a shell command for the peace framework
-
task-exec-queue
A asynchronous task execution queue
-
zino-ntex
Integrations with ntex for zino
-
corcovado
Non-blocking IO library
-
measured-tokio
Tokio metrics for measured
-
kal-mux
A lightweight stream multiplexer for merging ordered async streams
-
firecracker-rs-sdk
🧨🦀🚀 The Firecracker Rust SDK. A pure Rust crate for interacting with Firecracker.
-
summer-jaeb
summer-rs plugin for the jaeb snapshot-driven event bus
-
aggligator-monitor
Aggligator link monitor and speed test
-
sumup-rs
A comprehensive, type-safe Rust client for the SumUp API with full async/await support
-
qm-nats
Nats helper functions
-
neuron-context
Context strategy implementations for neuron-turn
-
hyperscan-tokio
High-performance async regex scanning with VectorScan
-
flows-video
Building blocks for flow-based video processing
-
ctxguard
managing contexts
-
flows-math
Building blocks for flow-based mathematical operations
-
resonate-sdk
Durable promises SDK for Rust
-
flows-hash
Building blocks for flow-based cryptographic hashing
-
lazyflow-grpc
gRPC connectors for lazyflow -- tonic Streaming<T> source and server response adapter
-
flows-json
Building blocks for flow-based JSON encoding & decoding
-
flows-io
Building blocks for flow-based I/O readers & writers
-
motosan-chat-line
LINE Messaging API channel adapter for motosan-chat
-
aliyun-dypns-sdk
Async Rust SDK for Aliyun DYPNS SMS verification code APIs
-
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) -
random-access-storage
Abstract interface to implement random-access instances
-
hanabi-cli
CLI utilities from interacting with a Hanabi server
-
flows-audio
Building blocks for flow-based audio processing
-
kojin-redis
Redis broker backend for the kojin task queue
-
pi_async
Based on future (MVP), a universal asynchronous runtime and tool used to provide a foundation for the outside world
-
msq
legacy Master Server Query Protocol
-
flows-mdns
Building blocks for flow-based mDNS discovery
-
polaris_agent
Agent trait for defining reusable behavior patterns in Polaris
-
bp3d-threads
threading library intended to simplify concurrency in BP3D
-
minos
Authorization library
-
tokio-nsq
NSQ client built on Tokio. Tokio NSQ aims to be a feature complete NSQ client implementation.
-
async-ctrlc
Async wrapper of
ctrlc -
riker-patterns
A collection of common actor patterns for Riker
-
logimesh
RPC Microservice 2.0 framework
-
slacktor
extremely fast, bare-bones, low-overhead, supervisorless, no-std actor library
-
turbocharger
Autogenerated async RPC bindings that instantly connect a JS frontend to a Rust backend service via WebSockets and WASM
-
neuron-turn
Shared toolkit for building operators — Provider trait, types, context strategy
-
cloud_terrastodon_azure_types
Types for modelling Azure stuff for the Cloud Terrastodon project
-
webex
Interface to Webex Teams REST and WebSocket APIs
-
rustygram
minimal and blazing fast telegram notification framework for Rust
-
async-time-mock-smol
Mockable time for use in async runtimes (smol compatibility)
-
eventador
lock-free pub/sub event-bus with sync and async APIs
-
v_exchanges_adapters
Implementations of HTTP/HTTPS/WebSocket API methods for some crypto exchanges, using crypto-botters framework
-
neuron-op-react
ReAct operator for neuron — model + tools in a reasoning loop
-
async-promise
Async promise which resolves once and may be read by multiple consumers
-
rasi-spec
The Official RASI Specification Test Suite
-
pegy
A derive based parser generator
-
puteketeke
An asynchronous runtime built on smol
-
smithyq
A high-performance async task worker library for Rust - forge your tasks with type safety
-
tokio-shared-rt
Allow
#[tokio::test]to use a shared runtime -
peace_webi_model
Web interface data types for the peace automation framework
-
rustyflow
A lightweight, high-performance agent framework for Rust, providing elegant abstractions for building complex AI workflows with type safety and async concurrency
-
kraken-api-client
An async Rust client library for the Kraken exchange REST and WebSocket v2 APIs
-
clia-async-openai
OpenAI (with rustls)
-
actix-actor-pool
Pool for Actix actors
-
armature-cron
Scheduled task execution for Armature applications
-
flows-arrow
Building blocks for flow-based data processing with Apache Arrow
-
peace_webi_components
Web interface components for the peace automation framework
-
agentlib-reasoning
Advanced reasoning strategies (ReAct, CoT, etc.) for the AgentLib framework
-
eureka-manager-cli
The official cli for the eureka-mmanager
-
tiny-agent-rs
A lightweight, type-safe Rust agent library for LLM tool calling
-
kafka-threadpool
An async rust threadpool for publishing messages to kafka using SSL (mTLS) or PLAINTEXT protocols
-
tokio-task-manager
Allow an async Tokio application to gracefully shutdown, waiting for all tasks to finish
-
sruim-crewai
A high-performance multi-agent orchestration engine written in Rust
-
cancellation-token
C#'s CancellationToken API
-
pattern-guard
Behavior anomaly guard: observes events, detects patterns, recommends allow/warn/delay/block
-
wuhu-engine
The Wuhu execution engine: streaming loop, concurrent tools, HITL
-
synwire-checkpoint
Checkpoint traits and in-memory implementation for Synwire
-
io-process
Set of I/O-free coroutines and runtimes to manage processes
-
miniactor
Small, simple actor library for Rust
-
voyager
Web crawler and scraper
-
aggligator-transport-usb
Aggligator transport: USB
-
futures-boring
SSL streams for Futures built on top of the BoringSSL
-
tokio-context
Contexts for cancelling asynchronous tasks using tokio
-
t2_bus
An inter- or intra-process message bus supporting publish/subscribe and request/response
-
gpui-tokio-bridge
Tokio bridge for GPUI - allows running tokio async tasks within GPUI context
-
ffi_rpc
Use FFI with RPC
-
aiven_rs
sdk to interact with aiven-cloud apis
-
tokio-io-rewind
rewind tokio::io::AsyncRead and tokio::io::AsyncWrite streams
-
key-stream
async key streaming
-
async-duplex-channel
An asynchronous duplex communication channel between multiple clients and a single responder in different asynchronous blocks
-
task-stream
a global task executor, run in
no_std -
mm1-node
M/M/1! Queueing, do you speak it?!
-
sansio-codec
Protocol codecs for sansio: frame decoders, string codecs, and transport abstractions
-
tokio-immediate-egui
Asynchronous glue for your egui application
-
overclock
A framework for building data-driven distributed systems
-
fluvio-async-tls
Asynchronous TLS/SSL streams using Rustls
-
flows-pubsub
Building blocks for flow-based publish/subscribe
-
peace_item_spec_blank
Copies a number from one resource to another
-
motore-macros
Motore's proc macros
-
tokio-util_wasi
Additional utilities for working with Tokio
-
pierport
Urbit pier import protocol implementation
-
irondash_run_loop
Consistent, platform-independent interface to system run loop
-
plumbing
An async abstraction to pipeline requests through a channel
-
allora-runtime
Allora runtime and DSL implementation (internal crate)
-
synwire-storage
Configurable persistent storage layout, project identity, and migration for Synwire
-
async-cron-scheduler
Runtime-agnostic async task scheduler with cron expression support
-
flarrow-url
flarrow (flow + arrow) is a rust runtime/framework for building dataflow applications
-
futuristic
Extensions to the futures crate
-
futures-sink
The asynchronous
Sinktrait for the futures-rs library -
waitlist
Keep track of an ordered list of Wakers to wake
-
mio-uds
Unix domain socket bindings for mio
-
async_tasks_recorder
A struct for recording execution status of async tasks with async methods
-
scipio
A set of utilities to allow one to write thread per core applications
-
nestforge-schedule
Scheduler support for NestForge
-
skg-orch-local
In-process Orchestrator implementation for skelegent
-
tbot
Make cool Telegram bots with Rust easily
-
tinygame-core
Minimal SDL-based game runtime core with a plugin-driven world
-
orengine
Optimized ring engine for Rust. It is a lighter and faster asynchronous library than tokio-rs, async-std, may, and even smol
-
reactivity
A lightweight library for reactive programming with signals in Rust
-
persway
Sway IPC daemon
-
array__ops
A selection of useful array operations
-
minimal-executor
A minimal executor for asynchronous tasks based on the futures-rs library
-
erlanggen
Erlang generator
-
neuron-runtime
Production runtime for AI agents — sessions, sub-agents, input/output guardrails, permission policies, and durable execution
-
unistore-retry
Retry strategy capability for UniStore
-
fastwebsockets-stream
An adapter that exposes fastwebsockets::WebSocket as a Tokio AsyncRead/AsyncWrite stream
-
hanabi
High perfomance in-memory caching and event streaming
-
smol-executor-trait
executor-trait implementation for smol
-
futures-async-stream
Async stream for Rust and the futures crate
-
skg-orch-kit
Unopinionated wiring kit for composing skelegent systems
-
async-core
A standard for async runtimes
-
haagenti-serverless
Serverless deployment with cold start optimization and GPU memory management
-
tourniquet-celery
Async native round-robin manager for remote services. celery integration.
-
lib3mf-async
Non-blocking async 3MF parsing with tokio - high-throughput manufacturing data processing
-
slim-futures
Asynchronous tools that intends for smaller binary size
-
rtx
zero-cost runtime-abstraction intended for use by Rust libraries to enable the Freedom of Choice between asynchronous runtimes
-
skg-env-local
Local (passthrough) Environment implementation for skelegent
-
stressed
Universal CLI stress tester for competitive programming
-
stackful
Bridge between sync and async
-
openhelm-sdk
Trait definitions and types for building openhelm skills and tools
-
aggligator-transport-websocket
Aggligator transport: WebSocket
-
neuromance-agent
Agent framework for autonomous task execution with LLMs
-
axiom
Implements a highly-scalable and ergonomic actor system for Rust based on the best of Erlang / Elixir and Akka
-
cloud_terrastodon_hcl
Helpers for manipulating TerraStorodon HCL files for the Cloud Terrastodon project
-
enact-skills
Skills system with TOML manifests for Enact
-
tokio-zmq
Futures abstractions for ZeroMQ on the Tokio event-loop
-
vinequeue
High-performance async queue library with disk persistence
-
daimon-provider-bedrock
Amazon Bedrock provider for the Daimon AI agent framework
-
elfo
An asynchronous distributed actor framework with robust observability
-
snowflake-id-generator
snowflake id implementation
-
whorl
was created to teach you how async executors work in Rust
-
armature-messaging
Message broker integrations for the Armature framework - RabbitMQ, Kafka, NATS, and AWS SQS/SNS
-
cloud_terrastodon_azure
Helpers for interacting with Azure for the Cloud Terrastodon project
-
killswitch
used to broadcast a shutdown request
-
rusty-genius
Public facade for rusty-genius
-
skg-op-single-shot
Single-shot operator — one model call, no tools, return immediately
-
skg-hook-security
Security middleware for skelegent — redaction and exfiltration detection
-
ultra-batch
Tokio-based library to batch and cache database queries or other data lookups
-
rustigram
Comprehensive async Rust framework for the Telegram Bot API
-
warp-rate-limit
Rate-limiting middleware for the Warp web framework
-
muxado
stream multiplexing protocol
-
async-shared-timeout
Async timeout that can be reset and shared
-
ksoft
KSoft.SI api wrapper written in pure Rust
-
pcap-async
Async/Stream Extensions for libpcap
-
spawns-compat
Async runtime detections for thread context task spawner
-
wtx-ui
Different user interfaces for WTX
-
async-scgi
Async SCGI Client & Server
-
test_executors
async executors for testing
-
quarlus-events
In-process typed event bus for Quarlus - publish/subscribe with async handlers
-
vesper
A slash-command framework meant to be used with twilight
-
queen
message queue
-
awaitgroup
Wait for a collection of async tasks to finish
-
mio-pidfd
mio support for Linux's pidfd
-
futures-cache
Futures-aware cache backed by sled
-
frappe
Functional Reactive Programming library for Rust
-
qanat
Lock-free channels specially written for asynchronous contexts
-
actm
Tiny async actors framework for rust
-
synwire-llm-ollama
Ollama provider for Synwire
-
elizaos-plugin-gmail-watch
Gmail Pub/Sub watcher plugin for elizaOS - spawns gog gmail watch serve and auto-renews
-
alopex-chirps-mock
Mock implementations for testing Alopex Chirps components
-
progressor
A modern, async-first progress tracking library
-
dbus-async
Asynchronous DBus library
-
open-payments
Open Payments Rust SDK library with types, HTTP client and signature utilities
-
multipart-write
Sink-like interface for writing an object in parts
-
skedgy
asynchronous job scheduler
-
slock
An async mutex that never deadlocks
-
imessage-watcher
Filesystem watcher and database pollers for iMessage chat.db change events
-
flows-dns
Building blocks for flow-based DNS resolution
-
oxidite-queue
Background job queue with cron scheduling, DLQ, and retry logic for Oxidite
-
containerd-snapshots
Remote snapshotter extension for containerd
-
enact-plugins
Plugin discovery and loading for Enact — .enact-plugin/ manifest, namespaced commands/skills
-
haagenti-speculative
Speculative fragment loading based on keystroke intent prediction
-
fure
Retrying futures using different policies
-
actors-rs
Easily build fast, highly concurrent and resilient applications. An Actor Framework for Rust.
-
stund
An SSH tunnel maintenance daemon
-
mfio
Flexible completion I/O primitives
-
conflu-mcp-rs
Model Context Protocol (MCP) server for Confluence
-
neuron-state-memory
In-memory StateStore implementation for neuron
-
tokio-task-scheduler
A non-blocking task scheduler for Rust with fluent API, supporting interval-based and cron-like scheduling
-
polaris_sessions
Session management and orchestration for Polaris agents
-
flows-datafusion
Building blocks for flow-based query processing with Apache DataFusion
-
async-reactor-trait
reactor-trait implementation for async-io
-
kvarn-tokio-uring
io-uring support for the Tokio asynchronous runtime
-
agentic-workflow-mcp
MCP server for AgenticWorkflow — universal LLM access to workflow orchestration
-
moirai-durable
Durable future support for Moirai job system
-
flowbuilder-yaml
YAML/JSON dynamic flow loading for FlowBuilder
-
traitclaw-anthropic
Anthropic provider for TraitClaw (Claude 3.5 Sonnet, Claude 3 Opus, Haiku)
-
task-notify
Notify async tasks when someone mutates data they're interested in
-
event_iterator
Asynchronous lending iterator
-
moduforge-persistence
moduforge 持久化
-
tokio-netem
— pragmatic AsyncRead, AsyncWrite I/O adapters for chaos & network emulation
-
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
-
interlink
Framework for writing async code
-
dasein-agentic-sandbox
Sandboxed code execution: Process, Docker, Firecracker, Gateway
-
orchflow-core
Transport-agnostic orchestration engine for managing terminal sessions, panes, and plugins with an event-driven architecture
-
compio-log
Log of compio
-
co_managed
Create managed sub coroutines. Managed sub coroutines will be cancelled when the parent exit
-
sn_sdkg
Safe Network Synchronous Distributed Key Generation: enables dealerless section key generation
-
knien
Typed RabbitMQ interfacing for async Rust
-
gasket
Staged Event-Driven Architecture (SEDA) framework
-
realhydroper-lsp
Language Server Protocol implementation based on Tower
-
codex-app-server-sdk
Tokio Rust SDK for Codex App Server
-
autoagents-protocol
Agent Framework for Building Autonomous Agents
-
futures-await-test
Async test support for Rust through a procedural macro. This crate defines the
#[async_test]attribute to make writing tests that use async/await easier. -
orchflow-terminal
High-performance terminal I/O management with PTY support, buffering, and stream processing
-
floxide-macros-support
A directed graph workflow system in Rust
-
runq
Macro-based job orchestrator with distributed locking and automatic retries
-
async-compat
Compatibility adapter between tokio and futures
-
global_cell
A thread-safe, async-friendly, performant global cell alternative built on Rust and Tokio primitives
-
merkql-notify-webhook
HTTP webhook notification plugin for merkql
-
synwire-daemon
Singleton background daemon for Synwire — manages embeddings, indexing, and multi-repo state
-
volo-macros
Volo's proc macros
-
fukurow-streaming
Real-time streaming processing for Fukurow reasoning engine
-
service-io
Build your service-server fast, easy (and without hosting!)
-
rusplay_collector
Rugplay application to automatically collect rewards from multiple users
-
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 -
ractor-supervisor
Supervisor module for ractor framework
-
neuron-env-local
Local (passthrough) Environment implementation for neuron
-
cloud_terrastodon_entrypoint
Main entrypoint for the Cloud Terrastodon CLI
-
aiur
Single threaded async executor with structured concurrency
-
quick-protobuf-codec
Asynchronous de-/encoding of Protobuf structs using asynchronous-codec, unsigned-varint and quick-protobuf
-
fharness
Harness library for the fiddlesticks agent harness framework
-
pwner
Process Owner crate that allows ergonomic access to child processes
-
nominatim
Bindings to the reverse geocoding API powered by openstreetmap
-
noop-executor
No-op executors for async tasks
-
must_future
A wrapper future marked must_use - mainly to wrap BoxFutures
-
wookie
Async test/bench toolkit including single stepping executors. No-std compatible.
-
rendezvous
Easier rendezvous channels for thread synchronization
-
synwire-orchestrator
Graph-based orchestration engine for Synwire
-
uint24le_framing
Convert bytes IO into uint24 length prefixed messages
-
tcp-channel-client
Asynchronous tcpclient based on aqueue actor
-
elizaos-plugin-mattermost
Mattermost plugin for elizaOS - Rust implementation
-
zeebe
client for defining, orchestrating, and monitoring business processes across microservices using Zeebe
-
async-ringbuffer
A nonblocking spsc ring buffer with fixed capacity
-
neuron-op-single-shot
Single-shot operator — one model call, no tools, return immediately
-
associated-async-io
Async IO traits that use futures instead of poll
-
avx-events
Event-driven architecture for Avila Experience Fabric - Pub/sub, event bus, and message patterns
-
ultraapi
A FastAPI-inspired Rust web framework with automatic OpenAPI generation
-
async-executor-trait
executor-trait implementation for async-std
-
fut-compat
Offers compatibility between the tokio and async_std runtimes
-
v_exchanges_api_generics
A client for HTTP/HTTPS/WebSocket APIs
-
kube-election
A Kubernetes leader election library using Lease objects that closely mirrors the feature sets of the controller-runtime package in the Go ecosystem
-
elizaos-plugin-whatsapp
WhatsApp Cloud API plugin for elizaOS agents
-
latch
fast and efficent Latch supporting both sync and async modes
-
foreback
Future adapters for running aditional work in the background
-
either-future
Future for Either<impl Future, impl Future>
-
sui-event-stream
Real-time on-chain event streaming for Sui - fills the gRPC SubscribeEvents gap
-
neuron-orch-local
In-process Orchestrator implementation for neuron
-
crossflow_diagram_editor
Frontend for crossflow diagrams
-
kvarn_async
Async utilities used in the Kvarn web server
-
pochta
Addressable channel registry
-
peace_resources
Runtime resources for the peace automation framework
-
misaki-cli
Fast, asynchronous link checker with optional FlareSolverr support
-
asyncron
Executor agnostic task manager and async scheduler for Rust
-
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…
-
xandeum-prpc
Rust client for Xandeum pNode pRPC APIs
-
proxy-scraper
command-line tool for scraping proxy information
-
space-traders
Async SpaceTraders API client for Rust
-
sendblue
that provides an API client for interacting with the SendBlue REST API, enabling businesses to integrate iMessage and SMS services into their applications
-
tower-sessions-seaorm-store
SeaORM session store for
tower-sessions -
acktor-macros
Internal macros for the acktor actor framework
-
duplexify
Combine a reader + writer into a duplex of Read + Write
-
coalescent
High-level AI coordination patterns enabling intelligent agent coalescence
-
hsipc
High-performance inter-process communication framework in Rust
-
isoprenoid-unsend
signals runtime framework backing flourish-unsend
-
peace_flow_rt
Flow runtime types for the peace automation framework
-
peace_webi
Web interface for the peace automation framework
-
openraft-rt-monoio
monoio AsyncRuntime support for Openraft
-
side-futures
Send future for execution on the runtime that may be in a different thread
-
prk_eventbus
A lightweight, WebSocket-based event bus for Rust with SQLite persistence
-
orchflow-mux
Terminal multiplexer abstraction layer supporting tmux, mock backends, and custom implementations
-
futuresdr-remote
Remote interaction library for FutureSDR
-
sodium
FRP (Functional Reactive Programming)
-
replay-channel
A broadcast channel where new receivers replay all past messages before receiving new ones
-
rust-genai
Rust SDK for the Google Gemini API and Vertex AI
-
retry-if
A tokio-compatible attribute-macro for decorating methods and functions with an exponential backoff
-
clia-rcproxy
A lightweight, fast and powerful Redis Cluster Proxy written in Rust
-
rust-genai-types
Shared types for the Rust Gemini SDK
-
peace_cli_model
Command line interface data types for the peace automation framework
-
blynk_io
Blynk.io streaming API integration in Rust
-
tokio-graceful-shutdown-without-anyhow
perform a graceful shutdown on a Tokio based service
-
prism-core
Prism — Reliability layer for agentic AI systems: voting mesh, checkpoint/replay, and Python bindings
-
discord-selfbot
Discord selfbot API library for Rust
-
crux-agentic
Built-in step handlers for crux-script pipelines
-
aeth-task
Tasking system for aeth-rs
-
tenorite
A concurrency abstraction library. Provides a client-server model for asynchronous workers
-
async-raft-ext
An async implementation of the Raft distributed consensus protocol.The ability of raft is enhanced while keeping the access interface unchanged for rnacos
-
anchor-chain
A statically typed async framework for building LLM-based applications
-
csnmp
Community-based async (Tokio) SNMP client library
-
lustre-executor
A blazingly fast, minimal async executor with pluggable ID generation and I/O support
-
awaitable
type with input and output that can be stored in container
-
actix-raft
Raft distributed consensus protocol using the Actix actor framework
-
nostr-gossip
Nostr gossip traits
-
reson-agentic
Agents are just functions - production-grade LLM agent framework
-
shutdown-handler
A shutdown handler that allows all parts of an application to trigger a shutdown
-
strut
Backend in Rust: convenient and configurable with Strut
-
gcal_rs
A blazingly fast, hand written Google calendar API in Rust
-
neuron-provider-anthropic
Anthropic API provider for neuron-turn
-
wd_event
event system
-
async-io-bufpool
Efficient asynchronous I/O operations with minimal idle memory overhead
-
z21_api
Rust API for Roco Z21 model railway control system
-
highroller
high-level rolling index that is thread-safe and guarantees cheap runtime-unique IDs
-
neuron-hooks
Hook registry and composition for neuron
-
neuromance-tools
Tool execution framework for Neuromance LLM library
-
smartpoll
A 'Task' abstraction that simplifies polling futures
-
islabtech-upw-sensor-v1
Rust client library for remote control of the ISLabTech UPW Sensor v1
-
mod-cli
A fully customizable, feature-rich CLI framework for Rust. Define commands, prefixes, styled output, and more—built for flexibility and speed.
-
again
wasm-compatible retry util for std library futures
-
enact-cluster
Distributed worker-node cluster components for Enact
-
debounced
building delayed
Futures and debouncedStreams that wait a given duration before yielding the most recent item -
async_closure
utilizes the nightly-only feature async_fn_in_trait to imitate async_closures
-
async-interval
Async Interval
-
async-mq
Zero-cost async-await abstraction of lapin AMQP client crate
-
rs-obs-signal
observer pattern with variadic template arguments
-
futuresdr-frontend
Web Frontend for an Experimental Async SDR Runtime for Heterogeneous Architectures
-
async_tasks_state_map
A struct for recording execution status of async tasks with async methods
-
flarrow-url-scheme
flarrow (flow + arrow) is a rust runtime/framework for building dataflow applications
-
flarrow-flows
flarrow (flow + arrow) is a rust runtime/framework for building dataflow applications
-
elizaos-plugin-feishu
Feishu/Lark plugin for elizaOS - Rust implementation
-
bufstream
Buffered I/O for streams where each read/write half is separately buffered
-
neuromance-client
client library for interacting with LLM inference providers
-
neuron-provider-openai
OpenAI API provider for neuron-turn
-
borrow_mutex
Async Rust Mutex which does not require wrapping the target structure
-
aide-de-camp
backend agnostic delayed job queue
-
openraft-rt-tokio
Tokio runtime implementation for Openraft
-
veecle-os-runtime
Veecle OS Runtime
-
async-bounds
Attribute to declare bounds on the Future returned by an async fn
-
asynciter
Asynchronous iterator
-
claude-agent
Rust SDK for building AI agents with Anthropic's Claude - Direct API, no CLI dependency
-
nonblock
Read available data from file descriptors without blocking (e.g. sockets, streams, child stdout, named pipes)
-
taskline
distributed task queue for Rust
-
pirates
async RPC lib
-
passivized_vault_client
Vault Client - initialize and monitor Hashicorp Vault nodes
-
switchy_async_cargo
Cargo async linter package
-
roco_z21_driver
Rust API for Roco Z21 model railway control system
-
prost-codec
Asynchronous de-/encoding of Protobuf structs using asynchronous-codec, unsigned-varint and prost
-
tokio-async-drop
macro to enable async drop in a tokio multithreaded runtime
-
rustmcp
Model Context Protocol (MCP) for building AI agent tools
-
tspawn
A thread-safe wrapper around Arc<RwLock<T>> with convenient cloning semantics and async task spawning macros
-
nsq-client
Rust client for the NSQ realtime message processing system
-
riglr-core
Core abstractions and job execution engine for riglr - building resilient AI agents
-
any-mpsc
An mpsc that allows arbitrary types to be passed through
-
rt-local
Thread local asynchronous runtime working with platform-specific event loops
-
raftlog
distributed replicated log based on the Raft algorithm
-
async-time-mock-tokio
Mockable time for use in async runtimes (tokio compatibility)
-
lwactors
Lightweight actors for Rust using futures-rs
-
async-task-ffi
Task abstraction for building executors
-
procsem
Semaphore used to lock thread/task-spanning sequence of operations
-
nr-tracing-layer
Send your logs to New Relic
-
mpm-cli
Modrinth Package Manager
-
forgeai-stream
Streaming protocol types for forgeai-rs
-
async-jsonl
An efficient async Rust library for reading and processing JSON Lines (JSONL) files using Tokio streams
-
async-compatibility-layer
an abstraction layer for using both async-std and tokio
-
meld-core
Core domain types, state, and error model for the Meld framework
-
adk-payments
Protocol-neutral agentic commerce and payment orchestration for ADK-Rust
-
tokio-lxi
LXI protocol abstractions for Tokio
-
sync_executor
An async executor which you can use to execute a future that you know will never return
Pendingwhen you poll it -
dyn-timeout
Dynamic timeout, cancel, add and remove time before a callback execution
-
tokio_based
BASED Async Single-threaded Execution Dispatcher
-
goods
Async assets system
-
flowbuilder-runtime
Advanced runtime features for FlowBuilder
-
toni
Fast and modular web framework for scalable applications
-
stilgar
A lightweight, no-fuss, drop-in replacement for Rudderstack
-
drop-stream
A stream that wraps another stream with a closure that is called once it is dropped
-
tokio-task-supervisor
Tokio TaskTracker with built-in cancellation token management and coordinated shutdown
-
llm-budget
Autonomous cost governance primitives — hard budget enforcement across agent fleets
-
aeth-event
Async based event primitives
-
peace_state_rt
State runtime logic for the peace automation framework
-
armature-graphql-client
GraphQL client with subscription support for Armature
-
praxis-mcp
Model Context Protocol (MCP) client for AI agent tool execution
-
acu
building asynchronous actors
-
pitwall-tauri
Tauri integration for Pitwall telemetry library
-
peace_cmd_ctx
Information such as which profile or flow a command is run for for the Peace framework
-
ebus
Basic Event Bus implementation
-
system-timer
async timers built on SystemTime
-
cyberex_xasync
Cyberex Async
-
blec
cross-platform ble client library based on btleplug
-
async_buf_read
Async Buffer Reader for IO
-
openclaw-core
Core types, configuration, and storage for OpenClaw
-
tactix
Actor Model based on Tokio
-
blocking-permit
Permits and a thread pool for blocking operations
-
neuron-secret-env
Secret resolver that reads from process environment variables
-
synwire-embeddings-local
Local embedding and reranking for Synwire using fastembed
-
synwire-llm-openai
OpenAI provider for Synwire
-
resident-utils
Resident program library
-
wesichain-graph
Rust-native LLM agents & chains with resumable ReAct workflows
-
afast
high-performance async Rust web framework with HTTP, WS, TCP support, automatic client generation, validation, and documentation
-
async-rate-limit
Common traits for rate limiting and implementations in async contexts
-
nestrs-cqrs
CQRS primitives for nestrs
-
axum-realtime-kit
A toolkit for building scalable, real-time applications with Axum, WebSockets, and Redis Pub/Sub
-
rate_limit_wrapper
Async rate limit wrapper to easily manage resources
-
rs_ctx
Context propagation for rs framework
-
flynn-openai
OpenAI
-
signalfut
A future similar to tokio::signal::unix::Signal, but can be used with all the runtimes
-
async-throttle
Asynchronous Rate Limiting
-
mobc-forked
A generic connection pool with async/await support
-
mcp-hub
Fast hub for MCP tools
-
eventsourcing
Event Sourcing for Rust
-
fluxion-merge
Merge multiple Fluxion streams with ordering guarantees
-
horizons-ai
Async Rust SDK for the Horizons REST API
-
snarc
Sendable Non-Atomically Reference Counted
-
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…
-
pistones
An wrapper for the Piston code execution engine
-
lazyflow-macros
Procedural macros for lazyflow -- #[operator], #[pull_operator], #[pipe_fn]
-
rateflow
A declarative, flexible, and high-performance rate limiting library for Rust
-
skulk
MCP (Model Context Protocol) connection manager - sneaking connections to the outside
-
karyon_eventemitter
A lightweight, asynchronous event emitter for Rust
-
handy_async
A handy library for describing asynchronous code declaratively
-
miau
Async aware and extensible layered configuration system
-
hyperbee
Peer to Peer B-tree
-
cb_fut
Call function that return value via callback without a callback
-
hollywood
actor framework
-
kay
Experimental high-performance actor system framework for Rust
-
simple-groq-rs
async Rust client for the Groq API (OpenAPI-compatible)
-
skg-state-fs
Filesystem-backed StateStore implementation for skelegent
-
agentic-workflow
Universal orchestration engine — workflows, pipelines, state machines, batch processing, and every coordination pattern
-
neuron-orch-kit
Unopinionated wiring kit for composing neuron systems
-
monoio-io-wrapper
A read/write wrapper to bridge sync and async io
-
requiem
Actor framework for Rust
-
physxx
Wrapper around the PhysX C++ API that aims to preserve the original API as much as possible
-
tokio-tasker
Lets you stop and join groups of Tokio tasks
-
dasein-agentic-mcp
MCP (Model Context Protocol) client for tool integration
-
elizaos-plugin-blooio
elizaOS Blooio Plugin - messaging via Blooio platform
-
baildon
B+Tree library
-
seams-rs-fake
Deterministic in-memory seams-rs-core implementations: ManualClock, InstantSleeper, CurrentThreadSpawner, MemoryFileSystem
-
alopex-chirps-gossip-swim
SWIM-based gossip protocol implementation for Alopex Chirps
-
qbit-api-rs
A asynchronous Rust wrapper for qBittorrent Web API
-
edfsm-machine
Tasks and Channels for Event Driven Finite State Machines
-
act-zero-ext
Macros for act-zero
-
aidale-plugin
Built-in plugins for Aidale (tool use, etc.)
-
nasu
Command-line utility which poll on remote addresses in order to perform status checks periodically
-
traitclaw-openai
OpenAI provider for TraitClaw with structured output and ergonomic constructors
-
retrier
A wasm-compatible retry library for futures
-
rrq
RRQ orchestrator CLI and worker runtime
-
neuron-state-fs
Filesystem-backed StateStore implementation for neuron
-
mod-events
A high-performance, zero-overhead event dispatcher library for Rust
-
ai-agents-state
State machine for AI Agents framework
-
sonor
controlling sonos speakers
-
backdrop
Drop your large or complex objects in the background with Backdrop! (later, on another thread, or both! Fully customizable! Tokio supported!)
-
kizzasi-inference
Unified autoregressive inference engine for Kizzasi AGSP
-
flarrow-url-default
flarrow (flow + arrow) is a rust runtime/framework for building dataflow applications
-
skg-provider-anthropic
Anthropic API provider for skg-turn
-
axum-typed-websockets
axum::extract::ws with type safe messages
-
libmqm-default
IBM® MQ Interface (MQI), Programmable Command Format (PCF) and MQ Administration Interface (MQAI) structure defaults
-
tarpc-lib
An RPC framework for Rust with a focus on ease of use
-
ai-sdk-provider-utils
functions and helpers for AI SDK providers
-
scoped_spawn
Full structured concurrency for asynchronous programming
-
wesichain-rag
Rust-native LLM agents & chains with resumable ReAct workflows
-
cortexai-agents
Agent runtime for Cortex: execution, memory, persistence and multi-provider routing
-
luis_sys
FFI bindings for Microsoft LUIS API
-
sparkle-convenience
A wrapper over Twilight designed to make it more convenient to use
-
claude-client
client for the Anthropic Claude API
-
ruchei-extend
ExtendPinned utilities for ruchei
-
skg-provider-openai
OpenAI API provider for skg-turn
-
pyridis-api
iridis, with python
-
atticus
A mimimal API to create asynchronous actors
-
xtor
Async Actor framework for Rust which is blazing fast and rock solid
-
signal-gateway-assistant
AI assistant traits and types for signal-gateway
-
screeps-async
Tick-aware Async runtime for Screeps
-
bipe
asynchronous I/O pipe
-
backstage
A framework for building data-driven distributed systems
-
qhook
Lightweight webhook gateway and workflow engine with queue, retry, and signature verification
-
holiday_event_api
The Official Holiday and Event API for Rust
-
ruchei-itertools
async itertools, subproject of ruchei
-
anet_a2a_server
framework for building Agent-to-Agent (A2A) protocol services
-
tokio-async-std
An async-std that can fit into tokio ecosystem straight ahead
-
tokio-stomp-2
Unofficial successor to Asynchronous streaming STOMP client
-
coerce-redis
Redis actor persistence provider for Coerce. Supports event sourcing and snapshots
-
agent-core-temp
A modular Rust execution engine for AI agents
-
feature-extension-for-async-std
Feature extension for async-std
-
streem
creating and consuming streams
-
tokio-btls
SSL streams for Tokio backed by BoringSSL
-
mobc-lapin
RabbitMQ support for the async mobc connection pool
-
north-config
North config is a multi source configuration crate designed as part of the North Microservice Framework
-
mcpx
SDK for the Model Context Protocol (MCP)
-
trinkets
Tool registry and execution system for AI agents - goblin loot and treasures
-
dasein-agentic-llm
LLM adapters for OpenAI, Anthropic, Gemini, Ollama
-
passivized_docker_engine_client
Docker Engine Client - manage and run containers, images, and volumes
-
toki-no
A minimal and fast async runtime, written in pure Rust
-
futures-zmq
Futures abstractions for ZeroMQ on any futures executor
-
wesichain-compat
LangChain 0.3.0 compatibility layer for Wesichain
-
synch
A basic asynchronous timer implementation that uses the cortex-m SysTick peripheral
-
radarcord-rs
An API wrapper for the Radarcord bot list
-
eko-core
A pure state-graph execution engine for building AI agents in Rust
-
snapup
Abstractions for handling snapshots with streams of subsequent updates
-
micro_http_async
A small, lightweight and hassle-free crate using async to serve web pages or web apis with high performance and extremely low overhead
-
agent-io
SDK for building AI agents with multi-provider LLM support
-
hikvision-rs
High-level asynchronous library for controlling cameras from Hikvision using the PTZ API
-
legend
Strict, composable saga VM for sequential workflows with compensation
-
napi_ext
Extends napi-rs with the ability to run local futures
-
tower-resilience-core
Core infrastructure for tower-resilience: events, metrics, and shared utilities
-
i2o2
A io_uring based IO executor for sync and async runtimes
-
tokio-stomp-rs
Asynchronous streaming STOMP client fork
-
distributed-config
A robust configuration management library for Rust applications running in distributed environments
-
stream-future
Implement an async iterator with return value
-
wesichain-mcp
Rust-native LLM agents & chains with resumable ReAct workflows
-
crb-actor
CRB | Composable Runtime Blocks | Actor
-
axum-serveplus
High level server designed to be used with axum framework
-
situwaition
Run a closure continuously, until is succeeds or times out
-
flightradarapi
A modern async Rust SDK for the FlightRadar24 API
-
fb_futures_01_ext
Extensions for future 0.1 crate
-
cloud_terrastodon_ui_ratatui
User interface for the Cloud Terrastodon project leveraging Ratatui
-
structured-json-agent
A typed and extensible library for creating and running Iterative AI Agents that generate structured JSON output
-
async-minecraft-ping
An async Rust client for the Minecraft ServerListPing protocol
-
resonate-sdk-macros
Durable promises SDK for Rust
-
peace_item_sh_sync_cmd
Manages a synchronization shell command for the peace framework
-
maniac
Massively scalable Rust async runtime
-
dndx-fork-tokio-tun
Asynchronous allocation of TUN/TAP devices using tokio
-
colonyos
Rust SDK for ColonyOS - build distributed applications with executors that can run anywhere
-
tonic-arcanyx-fork
A gRPC over HTTP/2 implementation focused on high performance, interoperability, and flexibility
-
selecting
Cross-platform wrapper over select
-
async-event-rs
that mimics C#'s async event model
-
mikrotik_api
& minimal client to connect and interact with Mikrotik RouterOS API, usually exposed on port 8728
-
viaduct
A duplex communication channel between a parent and child process, using unnamed pipes
-
awaken-ext-mcp
Model Context Protocol (MCP) client plugin for Awaken
-
rust-pty
Cross-platform async PTY (pseudo-terminal) library for Rust
-
mio_wasi
Lightweight non-blocking IO
-
synwire-checkpoint-sqlite
SQLite checkpoint backend for Synwire
-
teloxide-core
Core part of the
teloxidelibrary - telegram bot API client -
monoio-native-tls
Asynchronous TLS streams wrapper for Monoio based on NativeTLS
-
syndicate
Syndicated Actor model for Rust, including network communication and Dataspaces
-
mini-tokio
basic asynchronous rust executor
-
background-jobs-core
Core types for implementing an asynchronous jobs processor
-
tokio-rustls-wasi
Asynchronous TLS/SSL streams for Tokio using Rustls
-
rspc-axum
Axum adapter for rspc
-
crb-morph
CRB | Composable Runtime Blocks | Morph
-
dialectic-compiler
Session type macro compiler for the Dialectic crate
-
ctrlc-async
Easy asynchronous Ctrl-C handler for Rust projects
-
completeio
Completion based IO drivers and async runtime
-
timer-kit
A timer toolkit that is generic over the underlying timer implementation
-
agnostic-lite
agnostic-liteis an agnostic abstraction layer for any async runtime -
tor-events
A typed event broadcasting framework for Arti
-
async-pipes
building concurrent data processing pipelines
-
streamtools
Additional stream combinators
-
joyent-tokio-zookeeper
Asynchronous client library for interacting with Apache ZooKeeper
-
pinned
Synchronisation primitives for !Send tasks
-
enact-context
Context window management and compaction for Enact
-
noesis-sdk
Rust SDK for Selemene Engine — typed API client, profile management, credential storage, and report rendering
-
valve-rs
Auto-scale R {plumber} APIs concurrently using Tokio, Axum, and Deadpool
-
charred
char checking
-
versatile-dataloader
An async data loader for Rust
-
tiycore
Unified LLM API and stateful Agent runtime in Rust
-
rstreams
Async Stream-Processing toolkit with actor model flavor
-
smoltimeout
A way to poll a future until it or a timer completes
-
libmqm-constants
IBM® MQ Interface (MQI), Programmable Command Format (PCF) and MQ Administration Interface (MQAI) constant definitions
-
futures-test-preview
Common utilities for testing components built off futures-rs
-
kumoko
asynchronous server/client crate built on tokio for easy two-way streaming
-
enact-memory
Local-first memory backends for Enact
-
crb-supervisor
CRB | Composable Runtime Blocks | Supervisor
-
atedb
Distributed datachain (database) built on an immutable data store with strong encryption and authentication
-
rlua-async
Async support for rlua, via coroutines
-
specta
Easily export your Rust types to other languages
-
oxidite
A modern, batteries-included web framework for Rust inspired by Laravel and Rails - Oxidite
-
spawns-core
Async runtime agnostic thread context task spawner for Rust
-
monoio-quiche
Asynchronous QUIC implementation for Monoio based on Quiche
-
seccomp-stream
tokio adapter for seccomp_unotify
-
webhdfs
Hadoop WebHDFS client library
-
mcprs
Model Context Protocol para Rust - Uma biblioteca unificada para comunicação com diferentes LLMs e APIs de IA
-
tonic
A gRPC over HTTP/2 implementation focused on high performance, interoperability, and flexibility
-
forgeai-adapter-openai
OpenAI adapter for forgeai-rs
-
mlua_actor
Lua Actor for Rust(sync/async)
-
turmoil
Simulation testing framework for distributed systems
-
fluxer-core
Rust API library for building Fluxer bots — high-level client, event system, and structures
-
asyn-retry-policy
Async retry helpers with exponential backoff, jitter, and an ergonomic #[retry] attribute macro
-
async_dag
An async task scheduling utilitiy
-
mondayio
A thread per core runtime based on iouring
-
tracing-actix
Allow tracing actor futures in actix
-
sturgeon
Record async streams with timing, replay deterministically
-
peace_data
Data model for the peace automation framework
-
hreq-h2
An HTTP/2.0 client and server
-
grok-client
Grok api client
-
peace_rt_model_core
Core runtime traits for the peace automation framework
-
cannyls_rpc
RPC library for operating cannyls's devices from remote nodes
-
whirlwind
Collection of thread-safe, asynchronous data structures
-
fws_actors
fastwebsockets clients and servers in actors
-
fusio-core
core trait for Fusio library
-
hypixel_api
Generic wrapper around the hypixel api (automatic rate-limiting on client-side)
-
pawkit-futures
Future utils for PawKit
-
futures-test-sink
Test utilities for futures::sink
-
tower
modular and reusable components for building robust clients and servers
-
lib3h_zombie_actor
lib3h actor request tracking module
-
interruptible_polling
General purpose polling tasks with RAII-driven fast clean exits
-
axum-flash
Web framework that focuses on ergonomics and modularity
-
rust-with-kafka-tls
Rust messaging with a Strimzi Kafka cluster secured with self-signed tls assets for encryption in transit with mTLS for client authentication
-
tk-listen
A set of helper futures allowing to listen TCP (or unix) socket with resource limits and proper error handling
-
async_job
async cron job crate for Rust
-
enact-grpc
gRPC server for Enact runtime service
-
skg-provider-ollama
Ollama local model provider for skg-turn
-
svix-webhook-with-clone
Svix webhooks API client with derive Clone added to Webhook struct
-
bouncing
A flexible async debouncer for Rust with cancellation support, max wait limits, and event hooks
-
limitation
A rate limiter using a fixed window counter for arbitrary keys, backed by Redis
-
jamjet-core
JamJet core execution model — workflow states, node types, retry/timeout policies
-
axum-sessions
🥠 Cookie-based sessions for Axum via async-session
-
ewait
A thread-safe, asynchronous event system for Rust
-
kafka-rs
Native Rust Kafka client, built upon kafka-protocol-rs and Tokio
-
tokio-i2c
I²C API for Tokio
-
ticked_async_executor
Local executor that runs woken async tasks when it is ticked
-
sayiir-d1
Cloudflare D1 (SQLite) persistence backend for Sayiir workflow engine
-
aktors
Driver for derive-aktor
-
buf-read-ext
Trait extending anything that implements BufRead with stream_until_token()
-
releez
run application release-checklist safely
-
hyper-serve
High level server designed to be used with axum framework
-
mentra
An agent runtime for tool-using LLM applications
-
beul
It executes futures
-
axum-tungstenite
WebSocket connections for axum directly using tungstenite
-
codex-client-sdk
Rust SDK for embedding the Codex agent via CLI-over-JSONL transport
-
proxycurl-linkedin-rs
client for the Proxycurl LinkedIn API
-
thoughtchain
Semantic, hash-chained memory for long-running and multi-agent systems
-
cloudillo-core
Core infrastructure for the Cloudillo platform: middleware, extractors, scheduler, rate limiting, and access control
-
apis
Reactive, session-oriented, asynchronous process-calculus framework
-
daemon-base
A flexible and configurable Rust daemon library with lifecycle management, logging, callbacks, and optional async support. Works on Linux, macOS, and Windows.
-
cooper
in-process, async Actor library for Rust
-
tunny
flexible, efficient thread pool library for Rust built to manage and scale concurrent workloads. It enables you to process jobs in parallel across a configurable number of worker threads…
-
metalmq-client
MetalMQ client library (AMQP 0.9)
-
bob-core
Core domain types and port traits for Bob Agent Framework
-
pw-telegram-bot-fork
creating Telegram bots
-
async-http1-lite
Asynchronous http1 stream
-
rasi-mio
a rasi drivers implementation base on mio
-
what-the-async
runtime
-
thread-waker
Waker implementation using current thread token
-
task-executor
A task executor
-
apalis-sql
SQL utilities for background job processing with apalis
-
async-read-progress
Extension traits for inspecting
AsyncReadprogress -
waaa
WebAssembly, Abstracted Away
-
compact
Store objects containing dynamic fields either compactly in consecutive memory or using traditional heap pointers
-
notifsh
Rust SDK for notif.sh - managed pub/sub event hub
-
read-write-ext-tokio
AsyncReadWriteExt trait with
chain_afterandtake_rwfortokio::io::Read + Writestructs -
async-deferred
A lightweight utility for spawning async tasks with fire-and-forget semantics and deferred result retrieval
-
tower-buffer
Buffer requests before dispatching to a
Service -
zino-chatbot
Unified access to chatbot services for zino
-
murray
A minimal actor definition macro using Tokio
-
flowly-core
Flowly is a library of modular and reusable components for building robust pipelines processing audio, video and other
-
async-macros
Macros for async-std
-
gsc-gcra
High-performance GCRA (Generic Cell Rate Algorithm) rate limiting library
-
vox-core
Core implementations: ReliableLink, ReliableAcceptor, Session
-
extern_executor
Async executor which delegates futures polling to external event-loop
-
mio_channel
Provide a wrapper of the standard channel that can be polled with Mio
-
fluxion-exec
Async stream subscribers and execution utilities for fluxion
-
futures-test
Common utilities for testing components built off futures-rs
-
tub
Async Pool
-
skg-provider-codex
OpenAI Codex (Responses API) provider for skg-turn
-
praxis-context
Context management and summarization for AI agent conversations
-
arangoq
An AQL query builder layer and ArangoDb client for rust
-
tokio-buf
Asynchronous stream of byte buffers
-
beetry-macros
Internal beetry crate. For the public API, check the beetry crate.
-
shared-tokio-runtime
Shared tokio runtime
-
graceful-shutdown
Graceful Shutdown for async code
-
tokio-stomp
Asynchronous streaming STOMP client
-
btwo
using the Backblaze B2 API
-
dagrs
follows the concept of Flow-based Programming and is suitable for the execution of multiple tasks with graph-like dependencies. Dagrs has the characteristics of high performance and asynchronous execution…
-
reusable-box-future
A reusable
Pin<Box<dyn Future<Output = T> + Send>> -
celers-core
Core traits and types for CeleRS distributed task queue
-
evalsync
Experiment synchronization library for benchmark coordination via ZeroMQ
-
mioco
Scalable, asynchronous IO coroutine-based handling (aka MIO COroutines)
-
noosphere-into
Transformations of Noosphere content into various target formats
-
peace_core
Low level data types for the peace automation framework
-
async-task-group
Manage groups of
async-stdtasks as a single unit -
zippyst
Resolve zippyshare.com download links
-
meld-server
Single-port REST + gRPC server framework with FastAPI-like DX for Rust
-
synerlogikos
A high-level, generic, abstracted Rust library for building any integration. It is designed to abstract away common patterns found in all integrations multiple times.
-
hl7-mllp-codec
A Tokio codec for HL7 Minimal Lower Layer Message Transport protocol (MLLP)
-
miyabi-llm-anthropic
Anthropic Claude SDK for Miyabi LLM - Unified LLM interface for Rust
-
dcrocky
A Discord bot library for Rust inspired by discord.js - Rocky Edition
-
worst-executor
A spin-loop like executor for async
-
flurx
Create reactive asynchronous data flow
-
polly-scheduler
A robust task scheduling system leveraging Tokio, with built-in fault tolerance, persistence, and recovery capabilities to ensure seamless task management and execution
-
izihawa-common-multipart
multipart/form-data
-
stream-operators
a collection of selected rxjs operators for rust standard Stream
-
fluke-io-uring-async
An abstraction on top of io-uring
-
ruloom
A thin wrapper around 'corosensei' that provides support for stackful coroutines in Rust (like Loom in Java or goroutines in golang)
-
flows-rand
Building blocks for flow-based random number generation
-
misaki-core
Fast, asynchronous link checker with optional FlareSolverr support
-
tigerbeetle-unofficial-core
Safe low level callback-based async bindings to tigerbeetle client library
-
troupe
modelling Rust applications with actors
-
async_msp_cli
Async msp cli for iNav and BetaFlight
-
zonyitoo/coio
Coroutine scheduler with non-blocking I/O support
-
libaio-futures
Straightforward Linux AIO using Futures/async/await
-
there
planning and executing commands on local and remote hosts
-
mini-c-ares-resolver
An asynchronous DNS resolver, backed by mini-c-ares
-
jules-rs
Production-grade Rust client for the Jules API
-
futures-finally
that executes a future after the completion of a future or stream regardless of the value or outcome
-
serial-thread
Asynchronous, multithreaded serial port communication library using mpsc::cjhannels or async-channels for efficient data handling
-
ej-io
Program management utilities for the EJ framework
-
tokio_delayed_queue
Asynchronous delayed queue for Tokio runtime
-
archlinux-repo
Arch Linux repositories parser
-
ticks
ergonomic Rust wrapper for the TickTick Open API
-
aidale-layer
Built-in layers for Aidale (logging, retry, caching, etc.)
-
anthropic_rust
A modern, type-safe Rust SDK for the Anthropic API, providing async-first access to Claude models with comprehensive error handling and streaming support
-
flo-state
Lightweight actor library
-
send-future
Ergonomic and performant fix for https://github.com/rust-lang/rust/issues/96865
-
txrx
take on the C++ unified executors proposal
-
kafka4rs
Pure‑Rust client for Apache Kafka 4.0+ – drop‑in replacement for librdkafka, powered by Tokio and zero‑copy buffers
-
rustfs-rio
Rio is a RustFS component that provides a high-performance, asynchronous I/O framework for building scalable and efficient applications
-
reception
creating TCP listeners that spawns clients providing model abstraction layer
-
bing_client
Async reverse client for Bing copilot
-
pipebuf_websocket
PipeBuf support for websockets
-
fluke-buffet
Buffer management for the
flukecrate -
miku-h2
An HTTP/2 client and server
-
async-watch
Async watch channel
-
tourniquet
Async native round-robin manager for remote services
-
crossflow
Reactive programming and workflow engine in bevy
-
anthropic-sdk
Anthropic Rust SDK
-
signal-gateway-assistant-claude
Claude AI implementation of signal-gateway-assistant
-
futures-executor-preview
Executors for asynchronous tasks based on the futures-rs library
-
job_queue
efficient Rust library for handling asynchronous job processing and task queuing
-
tokio-stdin-stdout
Thread- and future::sync::mpsc-based AsyncRead/AsyncWrite stdin/stdout with little buffering
-
bililive
stream-based bilibili live client library
-
arti-bench
benchmarking utility for Arti
-
actix-postgres
PostgreSQL integration for Actix framework
-
reqwest-eventsource
Helper to build an Eventsource using reqwest
-
request_coalescer
An asynchronous request coalescing library for Rust
-
async-borrow
Async compatible ownership semantics using futures instead of lifetimes
-
yts-api
Access the yts.mx API
-
axum-standardwebhooks
Axum extractor that verifies signature for Standard Webhooks
-
stream-broadcast
Runtime independent broadcast, which only polls it's underlying stream if no pending data is available
-
tokio-simple-fixed-scheduler
scheduler to emit events at a fixed interval with tokio
-
monoio-rustls-fork-shadow-tls
Asynchronous TLS streams wrapper for Monoio based on Rustls
-
wta-reactor
Reactor for the what-the-async runtime
-
stream-ext
An extension trait for Streams that provides a variety of convenient combinator functions
-
riker-cqrs
Command Query Responsibility Separation for Riker applications
-
act-locally
single-threaded async actors with ordinary functions as handlers and plainly typed messages
-
rotor
The mio-based framework for doing I/O in simple and composable way
-
async-i3ipc
Bindings for i3 and async-std allowing async applications to communicate with i3 over it's IPC interface. Contains futures implementations and convenience functions for working with i3.
-
tokio-jsonrpc
JSON RPC 2.0 for tokio
-
laststage
fast, durable, high concurrent HashMap
-
crabler
Web scraper for Crabs
-
veilid-async-tls
Asynchronous TLS/SSL streams using Rustls
-
eventbuzz
A safe, fast, concurrent event publish/subscribe system based on tokio(async), inspired by Spring events
-
tokio-duplex
Combine seperate
AsyncReadandAsyncWritetypes into a singleAsyncRead + AsyncWritetype -
ply_jobs
ability to run background jobs on a schedule
-
register-count
Counting
Registers created by aCounter -
futures-async-combinators
toy futures combinators
-
futures-map
Futures-based and hashmap-based alogrithms
-
tokio-send-fd
A wrapper for tokio::net::UnixStream to send file descriptors
-
slog-scope-futures
slog-scope for
Futures -
quick_crawler
QuickCrawler is a Rust crate that provides a completely async, declarative web crawler with domain-specific request rate-limiting built-in
-
tokio-eld
Histogram-based sampler for recording and analyzing event loop delays
-
tokio-agent
Agents are a simple abstraction around state, inspired by Elixir's Agent
-
elk-mq
A Message Queue implementation in rust, using Redis as a communication medium
-
plctag-async
async wrapper for libplctag
-
coordinator
load balance tasks into task runners
-
deadline
A one-macro crate to ensure assertions meet their deadlines
-
rakhas_logger
Async logging library with batch processing and graceful shutdown
-
hackdose-server
A server to control smart plugs using data from smart meters
-
tokio-uring
io-uring support for the Tokio asynchronous runtime
-
kabuki
Name reservation
-
tobytcp
A little library for sending messages over a tcp stream
-
amqp-manager
Lapin wrapper that encapsulates the use of connections/channels and creation of amqp objects
-
actix-signal
Manage the lifecycle of an actix actor with its address
-
felicia
service for accessing and sharing lists of bad actors
-
wasmind_llm_types
Common LLM API types and structures for AI actors
-
async_io_utilities
An asynchronous IO utilities crate powered by
tokio -
RobotS
Actor framework
-
rip-starttls
Sans I/O implementation of https://duesee.dev/p/avoid-implementing-starttls/
-
message_worker
Message Worker is a low-ish level library for Rust for the creation of event-listeners using futures and streams. Notably MW supports non-sync and non-send (i.e. non-thread-safe) contexts within listeners.
-
async-oncecell
Asynchronous versions of OnceCell and Lazy
-
nolocal-block-on
futures_lite::future::block_on that can run without using thread-locals
-
synwire-vectorstore-lancedb
LanceDB vector store for Synwire semantic search
-
elizaos-plugin-acp
elizaOS ACP Plugin - Agentic Commerce Protocol for checkout and commerce
-
tractor
Actor system modelled after Pony's actors
-
async-compression
Adaptors between compression crates and Rust's modern asynchronous IO types
-
async-graphql-dataloader
A high-performance DataLoader implementation for async-graphql with batching and caching
-
stun-client
async_std based asynchronous STUN client library
-
waaaa
WebAssembly, Abstracted Away
-
raio
A neo4j+bolt driver written in Rust
-
django-query
Tools for mocking Django-style endpoints
-
noosphere-storage
Pluggable backing storage for the Rust Noosphere implementation
-
async-io-map
mapping of async IO operations
-
drama
multitenant scheduler for the komora db project
-
acktor
Pure-Rust actor framework built on top of the Tokio async runtime
-
alopex-chirps-raft-storage
Raft log storage implementation for Alopex Chirps using alopex-core
-
futures-ratelimit
Bounded flavors of futures' FuturesUnordered and FuturesOrdered
-
compio-runtime
High-level runtime for compio
-
tokio-easy-timer
A tokio-based task scheduler, with a user-friendly API
-
metatrait
RPITIT Monads
-
shutdown_signal
catching shutdown signals within select with multiple tasks in rust async tokio
-
async-cuda-npp
Async NVIDIA Performance Primitives for Rust
-
booru-dl
A command line tool to download images and tags txt from booru
-
roam-core
Core implementations: ReliableLink, ReliableAcceptor, Session
-
tower-timeout
Apply a timeout to requests, ensuring completion within a fixed time duration
-
request-channel
Async MPSC request-reponse channel
-
crossword_generator
generating crossword from provided words
-
async-stream-packed
Asynchronous stream packed
-
gentian
proc macro that transforms generators to state machines
-
lmonade-runtime
Actor-based runtime for LLM inference orchestration and resource management
-
tracing-orchestra
Give me more instruments!
-
cyclic_pipe
providing fixed-size, buffer pre-allocated cyclic pipe which support multi-producer and multi-consumer concurrent access
-
coerce-k8s
Kubernetes discovery provider, automatically discover cluster peers hosted in Kubernetes, based on a configurable pod-selection label
-
waker-waiter
async runtimes interoperate with arbitrary futures
-
tokio-io-mock-fork
Enhanced tokio_test::io::Mock
-
ubl-sirp
UBL SIRP: HTTP capsule+receipt, HMAC, idempotency, server for Universal Business Ledger
-
libindigo-sys
Rust FFI bindings for the INDIGO system library generated by bindgen
-
miyabi-llm-openai
OpenAI GPT SDK for Miyabi LLM - Unified LLM interface for Rust
-
async-dispatcher
async runtime based on a pluggable dispatcher
-
allsource-core
High-performance event store core built in Rust
-
tokio-libtls
Tokio bindings for LibreSSL's libtls
-
tokio-snappy
Wrap rust-snappy as a async stream in tokio
-
async_main
Runtime-agnostic async main proc macro
-
enact-redis
Redis-backed InboxStore, StateStore, and SignalBus for Enact
-
cloud_terrastodon_pathing
Well-known paths for the Cloud Terrastodon project
-
cruster
framework for building distributed, stateful entity systems with durable workflows
-
tokio-channel
Channels for asynchronous communication using Tokio
-
negahban
🧐 A simple file watcher, based on
notify, designed to be fast, easy-to-use and async friendly -
async-rev-buf
High-performance async buffered reader for reading lines in reverse order from files and streams
-
agreed
Fork of async-raft, the Tokio-based Rust implementation of the Raft protocol
-
dummy-waker
Get a
core::task::Wakerthat does absolutely nothing -
thetvdb
API async client
-
leaves
Distributed ID Allocator
-
haiyuu
experimental actor-like library
-
fates
creating reactive declarations
-
minima-telegram-notifier
Minimal Telegram notification library for Rust
-
noosphere-collections
Collection data types that are needed by an efficient implementation of Noosphere's IPLD data structures
-
hooch
A small async runtime that's been bootlegged for my projects
-
elizaos-plugin-shell
elizaOS Shell Plugin - Shell command execution with directory restrictions and history tracking
-
kapacitor-udf
creating Kapacitor User Defined Functions (UDFs)
-
bongonet-timeout
Highly efficient async timer and timeout system for Tokio runtimes
-
mail-message
A program for easy, quick, and fault tolerant sending of emails from the command line
-
skg-tool-macro
Proc-macro for deriving ToolDyn from annotated async functions
-
tokio-bitstream-io
Tokio port of bitstream-io: Library for reading/writing un-aligned values from/to streams in big-endian and little-endian formats
-
aeron-rpc
Deadly simple RPC framework built on top of Aeron and Tokio
-
nb-executor
Single-future, #![no_std] executor based on event bitmasks
-
tower-circuitbreaker
A circuit breaker middleware for Tower services
-
shared_cell
Interior mutability between concurrent tasks on the same thread
-
future-utils
Extensions to Rust's Future and Stream traits
-
terminusdm
Terminus Download Manager. Download files, resume interrupted downloads, and keep a history of your downloads - within terminal UI.
-
ai-agents-core
Core types and traits for AI Agents framework
-
akinator-rs
wrapper around the undocumented Akinator API
-
funfsm
An FSM library where the states are functions
-
compio-driver
Low-level driver for compio
-
tower-retry
Retry failed requests
-
orchestral-core
Core abstractions, SPI contracts, configuration, and default in-memory stores for Orchestral runtime
-
linkd
actor model framework that takes inspiration from OTP in the erlang ecosystem
-
async-defer
Asynchronous Deferred Calls
-
daimon-core
Core traits and types for the Daimon AI agent framework — implement Model to add providers
-
genawaiter2-macro
Convenience macros for generators (genawaiter2)
-
parity-runtime
Tokio runtime wrapper
-
euklid
CRDT
-
viz-core
The core traits and types in for Viz
-
adk-tool
Tool system for Rust Agent Development Kit (ADK-Rust) agents (FunctionTool, MCP, Google Search)
-
wasmind_config
Configuration system for Wasmind actors and runtime
-
futures-dagtask
DAG-based Task Queue
-
gcp_access_token
pure rust implimentation to get google cloud access token for servers with service account credentials
-
context-rs
Pass values down the async call stack, with no_std and no_alloc support
-
cruxai-core
Core types, traits, and runtime for the cruxai agentic DSL
-
csv-async
CSV parsing for async
-
alopecosa
Pure rust async Tarantool 1.6+ connector built on tokio
-
arta-tokio
Async abstractions implementation for Tokio
-
latchlm
A provider-agnostic client library for AI models
-
broadcaster
Broadcasting futures mpmc channel
-
vru-cancel
Cancel tokio stream
-
implicit-await
Implicitly await calls returning Future impls
-
supply-demand
functional dependency injection library
-
baichun-framework-rms
A high-performance, extensible message system module for Baichun-Framework, supporting multiple message brokers
-
agner
An actor toolkit inspired by Erlang/OTP
-
xo-api-client
Unofficial crate for accessing Xen Orchestra through its API
-
ai-sdk-rust
Root crate for all AI SDK-related crates
-
tokio-utils
Tools for asynchronous programming in Tokio applications
-
bottle
Actor model framework for Rust
-
epoxy_frp
The Reactive Glue for Frontend Applications
-
maily
easy, quick, and fault tolerant sending of emails
-
baton
channel for receiving updates per field
-
rust-genai-macros
Procedural macros for the Rust Gemini SDK
-
catty
Send and await a value asynchronously
-
retry_fn
retry function with versions for blocking or non-blocking, tokio or async-std
-
extra_result
Add extra methods to
Resultenum -
simple-actor
Helper to write actor-based async code
-
streammap-ext
StreamMap of Tokio with altered
nextthat returns when stream is dropped -
futures-yamux
The yamux protocol implementation, rewritten from the ground up
-
tokitai-core
Tokitai core types - Compile-time tool definitions with zero runtime dependencies
-
redis-asio
Asynchronous Redis driver based on tokio
-
eternal
Framework
-
discern
implementing the Command Query Responsibility Segregation (CQRS) pattern
-
vss
A dead simple library to allow for easily reused shutdown signal handling
-
mediatrix
Strongly typed, extensible event mediator
-
simple-scheduler
Schedule periodic tasks to run asynchronously
-
holidayapi_rust
A HolidayAPI library for Rust
-
pipeworks
Robust data processing pipelines
-
yash-executor
single-threaded concurrent task executor
-
fsdr-blocks
Building blocks for FutureSDR signal processing library for SDR and real-time DSP
-
set_timeout
allows efficiently executing futures after some delay has passed
-
lsp-codec
Tokio-compatible codec implementation for Language Server Protocol
-
async-xml
deserializing XML data asynchronously
-
async_object
Async Object wrapper
-
async-lease
Essentially a futures-oriented Arc<Mutex<Option<T>>>
-
asyncsync
Runtime-agnostic synchronization primitives for asynchronous Rust
-
cs-utils
Common utilities
-
async-io-pipe
Pipe your stdout/stderr together with asynchronous streams
-
agner-sup
An actor toolkit inspired by Erlang/OTP (supervisors)
-
akt
An actors library for Rust and Tokio designed to work with async / await message handlers out of the box
-
taps
taps (Tokio Asynchronous Pub/Sub) is an in-process async message broker that can be used for messaging between spawned tokio tasks
-
tokio_interval
基于Tokio实现了 setInterval(callback, ms) 和 setTimeout(callback, ms) 类似于Javascript的API
-
stream_router
A Future aware router to dynamically route between Streams and Sinks
-
rseip-cip
common industry protocol for rseip
-
ethercat-device-control
A command line utility to control Ethercat devices
-
async_counter
Counter that implements a future to await on specific value
-
pulsehive-core
Core traits and types for PulseHive multi-agent SDK
-
multipart-rfc7578
multipart/form-data (RFC7578)
-
rosrust_async
A native ROS1 client implementation in async Rust
-
async_msp_lib
Async msp library for iNav and BetaFlight
-
termusix
A terminal-based music player with a user-friendly terminal UI, built with Rust
-
tokio-netstring-trait
A trait for tokios AsyncRead to easily read netstrings from streams
-
async-recorder
Store records without waiting for your persistence backend
-
nbchan
Highly optimized non-blocking communication channels
-
moduforge-rules-expression
moduforge 表达式规则
-
swiftide-core
Fast, streaming indexing, query, and agentic LLM applications in Rust
-
io_uring_actor
Near-zero overhead pipelined io_uring api via actor model so you don't have to use Arc<Mutex<IOUring>>
-
ws-gonzale
Naive websocket server implemented using async / await
-
linked-futures
Link futures into a block, which stops all of the included futures when any of the futures complete
-
fibers_inotify
A futures friendly inotify wrapper for fibers crate
-
futures-enum
#[derive(Future, Stream, Sink, AsyncRead, AsyncWrite, AsyncSeek, AsyncBufRead)] for enums
-
git-next
trunk-based development manager
-
xet-runtime
Async runtime, configuration, logging, and utility infrastructure for the Hugging Face Xet client tools
-
napi_async_local
Extends napi-rs with the ability to run local futures
-
string-adapter
String adapter for casbin-rs
-
shared_stream
easily cloneable streams
-
futures-diagnose
Wraps around a Spawn and provides lots of diagnostics
-
rssafecircuit
implements a Circuit Breaker pattern with asynchronous support using Tokio, managing failure states and recovery strategies
-
gritlab
Gitlab rust API sdk
-
wuhu-core
Core traits and types for the Wuhu agent framework
-
ferrotunnel-core
Core tunnel implementation for FerroTunnel
-
hyperfile-cleaner
Segments cleaner implementation for Hyperfile
-
oneshot-handshake
providing a symmetric one time use channel type
-
woven
set of async combinators, usable in a no_std environment
-
uasync
fast, safe, async executor
-
retry-strategy
A better asynchronous retry tool based on Tokio
-
pantry
Temporary storage for reusing values that may decay
-
bubbles
Bubble integration server for powder diffraction
-
motosan-workflow-core
Core library for the motosan-workflow DAG-based agent workflow engine
-
ex-futures
An extension of
futures -
await_state
A minimal, powerful async state coordination map for Rust — wait for state changes, not just values
-
anansi
full-stack web framework for Rust
-
rusty-genius-core
Core types and protocol definitions for rusty-genius
-
aidale
Elegant Rust AI SDK inspired by OpenDAL
-
traitclaw-core
Core traits, types, and runtime for the TraitClaw AI Agent Framework
-
cg-game-server
help build CodeGame game servers
-
gimbal_async_cargo
Cargo async linter package
-
async-reciprocals
asynchronous fallible conversion and reciprocals in Rust
-
futures-rate
easy tools to help Rust applications guide critical resources or code paths from being overwhelmed
-
clamav-client
ClamAV client library with optional support for async-std, smol, and Tokio
-
rad
A type-safe, high-level interface to librados using the low-level C bindings from ceph-rust
-
io2
single threaded async-io library
-
eff
Algebraic Effects Library for Rust
-
peace_static_check_macros
Compile time validation macros for the peace automation framework
-
yeast-rs
Tiny but linear growing unique id generator