-
pact_consumer
Pact-Rust module that provides support for writing consumer pact tests
-
ractor
A actor framework for Rust
-
kameo
Fault-tolerant Async Actors Built on Tokio
-
batch-aint-one
I got 99 problems, but a batch ain't one
-
crosstown_bus
Event Bus with RabbitMQ for Rust
-
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.
-
rsactor
Efficient In-Process Actor Model Implementation for Rust
-
teloxide_tests
Test suite for teloxide bots
-
agent-memory
Memory bus and vector store integration for MXP agents
-
grapevine
A modern, asynchronous peer-to-peer gossip protocol library and application
-
agent-kernel
Agent lifecycle kernel for MXP: registration, discovery, heartbeat, and message handling
-
source2-demo
Dota 2 / Deadlock / CS2 replay parser written in Rust
-
airs-mcp
Model Context Protocol implementation with JSON-RPC 2.0 foundation
-
cobalt-aws
collection of wrappers around the aws-sdk-rust and lambda_runtime packages
-
up-transport-mqtt5
The Eclipse uProtocol MQTT 5 Transport Library
-
ractor-supervisor
Supervisor module for ractor framework
-
picokafka
Kafka library for tarantool-module based on librdkafka
-
kincir
message streaming library inspired by Watermill
-
airsprotocols-mcp
Model Context Protocol implementation with JSON-RPC 2.0 foundation
-
hexput-runtime
WebSocket runtime server for Hexput AST processing
-
network-protocol
Secure, high-performance protocol core with backpressure control, structured logging, timeout handling, TLS support, and comprehensive benchmarking for robust Rust networked applications and services
-
broccoli_queue
Broccoli is a simple, fast, and reliable job queue for Rust
-
shakespeare
An actor framework
-
rustycord
A fast, lightweight, and feature-rich Discord bot library written in Rust
-
axum-messages
🛎️ One-time notification messages for Axum
-
nsq-async-rs
An asynchronous Rust NSQ client library with support for concurrent message processing
-
actix
Actor framework for Rust
-
rust_rubka
interacting with Rubika Bot API
-
ocpp-client
OCPP Client Implementation. Use this library to implement an OCPP charge point
-
rio-rs
Distributed stateful service framework
-
black-box
A minimal actor framework
-
deribit-websocket
WebSocket client for Deribit trading platform real-time data
-
ollie
An abstraction layer on top of lapin, to align with traditional HTTP API routing
-
tapaculo
Lightweight Rust server for real-time and turn-based multiplayer communication
-
tiny-tokio-actor
tiny actor library on top of tokio
-
spark-channel
A generic channel listener implementation for Spark Rust SDK
-
mboxlabs-mailbox
A lightweight, pluggable mailbox/queue kernel inspired by the Erlang Actor Model
-
hyperapp_macro
The macro for async, handler-based Hyperware Hyperapps
-
teloxide-plugins
Smart plugin system for Teloxide bots
-
rabbitmq-worker
A generic RabbitMQ worker library with built-in retry and dead-letter queue (DLQ) logic
-
http_api
Declare modular HTTP client/server APIS using XHR, WebSocket and SSE
-
unison-protocol
🎵 Unison Protocol - KDL-based type-safe communication framework
-
wasmcloud-provider-messaging-websocket
A capability provider that satisfies the 'wasmcloud:messaging' contract using WebSocket as a backend
-
f1-nexus-mcp
Model Context Protocol (MCP) server for F1 Nexus
-
rs-sqs-receiver
An asynchronous AWS SQS message receiver framework with trait-based handlers and shared resource support
-
flo_scene
Entity-messaging system for composing large programs from small programs
-
pptr
Type-Driven Asynchronous Actor Runtime
-
robomotion
Official Rust SDK for building Robomotion RPA packages
-
messages
Runtime-agnostic actor library
-
ghakuf
parsing/building SMF (Standard MIDI File)
-
spaad
Zero boilerplate actor systems with xtra
-
darwin-webkit
Bindings to some of the WebKit's API on MacOS for Rust
-
rocketmq-client-v4
rocket mq rust client for remote protocol. works on rocket mq V4
-
actix-interop
Use async/await syntax with actix actors
-
lowbulls
lowbull is a Rust crate facilitating message handling and event monitoring
-
vinezombie
A modular IRCv3 framework
-
quickwit-actors
Actor framework used in quickwit
-
axum-realtime-kit
A toolkit for building scalable, real-time applications with Axum, WebSockets, and Redis Pub/Sub
-
aimds-detection
Fast-path detection layer for AIMDS with pattern matching and anomaly detection
-
memfault-ssf
Supporting crate for the Memfault memfaultd embedded Linux agent
-
slacktor
extremely fast, bare-bones, low-overhead, supervisorless, no-std actor library
-
credibil-dwn
Decentralized Web Node (DWN)
-
teleser
Telegram TMProto bot frame
-
c2-logs
Capture, filter and analyze logs from Chatterino without restarting the application
-
woab
Widgets on Actors Bridge - a GUI microframework for combining GTK with Actix
-
puniyu_handler
puniyu 的事件处理器模块
-
botx-api-framework
Фреймворк для реализации ботов под платформу eXpress
-
tap-wasm
WebAssembly bindings for the Transaction Authorization Protocol
-
combadge
makes Rust Web Workers easy
-
wasi-worker
WASM/WASI interface for browser service workers
-
ump-ng-server
Server message dispatch loop for ump-ng
-
nx-request-handler
streamlining messaging between Skyline Plugins and WebSessions
-
d2-stampede
Dota 2 replay parser written in Rust
-
actix_async_handler
Support for async syntax for Actix
-
requiem
Actor framework for Rust
-
xtor
Async Actor framework for Rust which is blazing fast and rock solid
-
vampirc-io
asynchronous, non-blocking, UCI protocol–based communication between chess UIs and chess engines
-
ab-code-gen
Functions to generate boilerplate code for objects implementing the 'Actor' pattern. Used by the abcgen crate.
-
palkia
Entity Component Message architecture a la Caves of Qud
-
romp
STOMP server and WebSockets platform
-
math_repl
REPL for all different kinds of math
-
redis-stream
Stream and consume data from redis streams
-
swapper
Swap ownership between threads
-
mooeye
A small UI library designed on top of the ggez game library. WORK IN PROGRESS
-
mlpa
Plugin API for mailing-list
-
ump-server
Server message dispatch loop for ump
-
async_message_dispatcher
dispatching messages to asynchronous handlers easier
-
act-locally
single-threaded async actors with ordinary functions as handlers and plainly typed messages
-
network_helpers_sv2
Networking utils for SV2 roles
-
datacake-rpc
A zero-copy, actor-like RPC framework using rkyv
-
linkd
actor model framework that takes inspiration from OTP in the erlang ecosystem
-
matrix_bot_api
API for writing a bot for the Matrix messaging protocol
-
akt
An actors library for Rust and Tokio designed to work with async / await message handlers out of the box
-
roundabout
An message oriented concurrent runtime
-
rbot-messages
The
rbot-messagescrate serves as the message handler for the Bot Beats game, containing all the message types to and from the game -
tea-actor-utility
WasCC Tool - Supporting Binary and Sorted Vector Key-Value Pair and Macros to Build Nats Message Actor Handler
-
teleborg
A Telegram bot API
-
legacytranslate
Internationalization library of legacylisten
-
handlers_sv2
Sv2 Message handlers
-
aspartam
Minimalistic actor framework based on tokio, inspired by actix
-
quartz-contract-core
A CosmWasm framework for securely interacting with Intel SGX enclaves
-
kraken-wasm
WASM bindings for Kraken orderbook engine
-
ismp
interoperable state machine protocol
-
kraken-types
Shared types for Kraken WebSocket API v2
-
wasmcloud-actor-core
wasmCloud Core Actor Interface
-
EasyDist
A non-blocking IO and easy-to-use Rust crate for constructing simple distributed preject. The crate contains several building blocks that can be use to construct a distributed system program.
-
handler_map
Map from types to functions that receive them
-
simple-kafka
easier to use kafka message
-
hidmon
Lightweight, callback-based keyboard/mouse monitoring
-
ixc
Interchain SDK
-
SQUICD
Squicd is a Domain-Specific Language (DSL) in Rust designed to simplify the creation of QUIC-based servers and clients for message passing
-
salish
Messaging Library
-
chatbot
An extensible chatbot
-
tari_comms_dht
Tari comms DHT module
-
flow-bot
An onebot-11 SDK that simplifies bot creation
-
meows
pattern for async service messaging over WebSockets
-
futuresdr-macros
Macros for FutureSDR
-
haveno
secure P2P trading software with Monero integration
-
rmilter
A rust-only crate for connecting and using milter functionality
-
shakespeare-macro
A support crate for the shakespeare actor framework
-
wasmcloud-actor-messaging
Messaging wasmCloud Actor Interface
-
dtbh_interface
Interface library for the automated scanner
-
fiadtui
TUI event loop for ratatui with tokio and crossterm
Try searching with DuckDuckGo or on crates.io.