-
async-nats
A async Rust NATS client
-
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.
-
nkeys
NATS nkeys library
-
kanade
Admin CLI for the kanade endpoint-management system. Deploy YAML manifests, schedule cron jobs, kill running jobs, revoke commands, publish new agent releases — over NATS + HTTP
-
rumqttd
high performance MQTT broker written in Rust which is light weight and embeddable
-
wrpc-transport-nats
wRPC NATS transport
-
wasmcloud-secrets-types
Types, traits, and structs for interacting with secrets in wasmCloud
-
velo
Velo distributed-systems runtime: active messaging, peer discovery, streaming, rendezvous, and queue backends
-
rsigma
CLI for parsing, validating, linting and evaluating Sigma detection rules
-
wrpc
WebAssembly component-native RPC framework based on WIT
-
wasmcloud-test-util
testing wasmCloud hosts, providers, and components
-
mq-bridge
An asynchronous message bridging library connecting Kafka, MQTT, AMQP, NATS, MongoDB, HTTP, and more
-
mq-bridge-app
A message queue bridge application written in Rust, designed to connect different messaging systems like RabbitMQ, Kafka, and NATS
-
watermelon
High level actor based implementation NATS Core and NATS Jetstream client implementation
-
nats-wasip3
NATS client for wasm32-wasip3 — native Component Model async I/O
-
greentic-oauth-sdk
Client SDK and WIT host bindings for interacting with the Greentic OAuth broker
-
nexo-rs
Nexo — multi-agent Rust framework: NATS event bus, pluggable LLM providers, channels (WhatsApp, Telegram, Email, Browser), memory, MCP, skills, and TaskFlow
-
nexo-plugin-manifest
TOML manifest schema + 4-tier validator for native Rust nexo plugins (Phase 81.1)
-
jetstream-extra
Set of utilities and extensions for the JetStream NATS of the async-nats crate
-
lattice-db-client
Typed Rust client SDK for lattice-db — wraps the NATS request/reply protocol
-
helr
Generic HTTP API log collector: polls APIs and emits NDJSON to stdout
-
mq-bridge-mcp
MCP Server for mq-bridge
-
object_transfer
An object transfer library for various message broker and/or protocols
-
kanade-backend
axum + SQLite projection backend for the kanade endpoint-management system. Hosts /api/* and the embedded SPA dashboard, projects JetStream streams into SQLite, drives the cron scheduler
-
kcr_jetstream_nats_io
Kubernetes Custom Resource Bindings
-
nexo-config
YAML configuration loader with env var resolution for Nexo agents
-
nexo-agent-registry
Live registry of in-flight driver goals (Phase 67.B). Persists to SQLite for reattach across daemon restarts.
-
nexo-webhook-receiver
Phase 80.12 — generic per-source webhook verification + event extraction primitives
-
gsm-core
Core types and platform abstractions for the Greentic messaging runtime
-
trellis-sdk-auth
Generated Rust SDK crate for trellis-sdk-auth
-
crabbyq
A declarative async Rust framework for message-driven microservices
-
moleculer
Progressive microservices framework for Rust, based on and compatible with moleculerjs/moleculer
-
lattice-sql-client
Typed Rust client SDK for lattice-sql — SQL frontend for lattice-db
-
trellis-auth
Authentication flows and session helpers for Trellis clients
-
nusy-kanban
Arrow-native kanban engine — SHACL shapes, graph-native PRs, dual boards, NATS multi-agent collaboration
-
nexo-driver-types
Types and traits for the Nexo driver subsystem (CLI/process orchestration under verifiable goals)
-
pg-tide-relay
Bidirectional relay binary for pg_tide — bridges outboxes/inboxes with NATS, Kafka, HTTP webhooks, Redis, SQS, RabbitMQ, and more
-
qm
quick microservices in Rust
-
greentic-messaging-test
Interactive tool to run MessageCard fixtures across Teams/Webex/Slack/WebChat/Telegram/WhatsApp translations
-
nexo-project-tracker
Parses PHASES.md / FOLLOWUPS.md and exposes them as agent tools (Phase 67.A)
-
eventbus-nats
Production-grade event bus for Rust — NATS JetStream with effectively-once semantics
-
nexo-llm
LLM provider clients (MiniMax, OpenAI-compat, Anthropic, Gemini) with rate limiter and tool registry
-
rz-agent
Universal messaging for AI agents — terminal, HTTP, NATS, or anywhere
-
nats-handling
async NATS client library
-
sockudo-delta
Delta compression for Sockudo WebSocket messages
-
noesis-ship
Rust NATS communication platform for multi-agent AI systems
-
nexo-core
Agent runtime: event bus, sessions, plugin trait, heartbeat, A2A delegation
-
nexo-poller-ext
Extension integration for the Nexo poller runtime
-
nexo-resilience
Circuit breaker, retry, and rate limiter primitives for Nexo agents
-
nexo-webhook-server
Phase 82.2 — axum-based HTTP server hosting webhook routes with 5-gate defense pipeline
-
trellis-generate-runner
Version-pinned launcher for the Trellis contract generator
-
nexo-extensions
Extension manifest, discovery, lifecycle, and stdio/NATS runtimes for Nexo
-
cf-nats-ws
A WASM-compatible NATS client for Cloudflare Workers using WebSocket transport
-
nexo-poller-tools
Built-in tools and builders for the Nexo poller (LLM turn, channel ops)
-
nexo-broker
Async NATS broker abstraction with local fallback and disk queue for Nexo
-
turbocable-server
High-performance WebSocket gateway for TurboCable (1M+ connections)
-
trellis-client
Client transport and session primitives for Trellis services
-
nexo-plugin-google
Google APIs (Gmail, Calendar, Drive) tool plugin for Nexo agents
-
greentic-oauth-broker
Multi-tenant OAuth broker exposing HTTP, NATS, and discovery APIs for Greentic integrations
-
market2nats
WebSocket market data → NATS JetStream relay
-
kanade-agent
Windows-side resident daemon for the kanade endpoint-management system. Subscribes to commands.* over NATS, runs scripts, publishes WMI inventory + heartbeats, watches for self-updates
-
nexo-auth
Per-agent credential resolver and gauntlet validation for Nexo channels
-
sockudo-queue
Queue manager implementations for Sockudo
-
nexo-memory
Short-term, long-term (SQLite), and vector (sqlite-vec) memory layers for Nexo agents
-
trellis-server
Server-side transport and handler primitives for Trellis services
-
nexo-mcp
MCP (Model Context Protocol) client and server runtime for Nexo agents
-
trellis-sdk-core
Generated Rust SDK crate for trellis-sdk-core
-
sockudo-adapter
Connection adapters and horizontal scaling for Sockudo
-
kanade-shared
Shared wire types, NATS subject helpers, KV constants, YAML manifest schema, and teravars-backed config loader for the kanade endpoint-management system
-
bus-nats
NATS JetStream backend for eventbus-rs
-
nexo-persona-installer
Install / list / remove v2 persona packs from GitHub Releases (cody-cli-install Phase F3)
-
code0-flow
managing the code0-flows inside of the Flow Queue & FlowStore
-
intercom-rs
A fully typed async wrapper for NATS with JetStream support
-
gsm-bus
Bus client trait with NATS and in-memory implementations for Greentic messaging
-
stormchaser-agent
A robust, distributed workflow engine for event-driven and human-triggered workflows
-
wasmcloud-secrets-client
Client library for interacting with wasmCloud secrets backends
-
gsm-gateway
Greentic messaging gateway: ingress normalization and worker forwarding
-
nexo-poller
Generic polling runtime: cron schedules, retries, ack semantics
-
nenjo-worker
Agent worker for the Nenjo platform
-
watermelon-net
Low-level NATS Core network implementation
-
trellis-cli
CLI for generating, validating, and operating Trellis contracts and services
-
nats-io-jwt
Generate JWTs signed using NKEYs for use with https://nats.io
-
greentic-demo
NATS-to-Greentic runner bridge that powers the greentic-demo messaging flow
-
watermelon-mini
Minimal NATS Core client implementation
-
nexo-setup
Setup wizard, capability inventory, and doctor command for Nexo
-
velo-messenger
Active messaging layer for Velo distributed systems
-
nexo-tunnel
Tunneling helpers for Nexo agents (Termux and local exposure)
-
gsm-idempotency
Shared idempotency guard and storage interfaces for Greentic messaging workflows
-
wasmcloud-host
wasmCloud host library
-
nexo-persona-manifest
TOML manifest schema + validator for v2 persona packs (cody-cli-install Phase F2)
-
lnmp-transport
Transport bindings for LNMP protocol (HTTP, Kafka, gRPC)
-
gsm-runner
Greentic messaging package: runner
-
freshblu-proto
Shared protocol types and NATS subject helpers for FreshBlu
-
nexo-dispatch-tools
Phase 67.D — agent-loop tools that dispatch / control / chain driver goals through DispatchGate
-
gsm-egress
Greentic messaging egress worker: consumes normalized envelopes and delivers platform-specific payloads
-
rsigma-runtime
Streaming runtime for rsigma — event sources, sinks, and log processing pipeline
-
dink-sdk
Rust SDK for Dink edge mesh platform — JSON-over-NATS RPC for IoT and edge computing
-
wrpc-wasmtime-nats-cli
wRPC Wasmtime NATS CLI
-
klieo-bus-nats
Production NATS JetStream + KV impls of klieo-core's bus traits
-
watermelon-proto
#[no_std] NATS Core Sans-IO protocol implementation
-
freshblu-router
NATS-based event router for FreshBlu horizontal scaling
-
watermelon-nkeys
Minimal NKeys implementation for NATS client authentication
-
nexo-driver-loop
Goal orchestrator + LlmDecider + Unix socket bridge for the nexo-rs driver subsystem. Phase 67.4.
-
varpulis-connectors
Connector implementations for Varpulis (MQTT, Kafka, NATS, HTTP, etc.)
-
nexo-driver-permission
MCP
permission_prompttool used by the nexo-rs driver to gate Claude Code tool calls. Phase 67.3. -
apalis-nats
Background task processing for rust using apalis and nats jetstream
-
rmqtt-bridge-ingress-nats
Bridge remote NATS in ingress mode
-
nexo-assistant
Phase 80.15 — per-binding assistant-mode runtime
-
nusy-kanban-server
NATS server + client bridge for the Arrow-native kanban engine
-
wasmcloud-provider-sdk
wasmCloud provider SDK
-
wrpc-wasmtime-cli
wRPC Wasmtime CLI
-
tokio-nats
Async-await ready NATS library
-
nexo-ext-registry
Phase 31.0 — ext-registry index format types + parser + validation. The catalog of installable nexo plugins (out-of-tree subprocess plugins authored against nexo-plugin-contract.md).
-
nexo-pairing
Setup-code pairing store and DM-challenge gate for Nexo channel plugins
-
klieo-a2a
Durable A2A v1.0 protocol layer atop klieo-bus traits
-
rmqtt-bridge-egress-nats
Bridge remote NATS in egress mode
-
nexo-driver-claude
Spawn the
claudeCLI under nexo-rs, parse stream-json events, and resume sessions across turns. Phase 67.1 of the agent framework. -
smith-config
Unified configuration management for agent services
-
ratsio
client library for NATS messaging system and NATS Event Streaming
-
nats_test_server
An intentionally buggy NATS server that facilitates fault injection for testing error paths in NATS-based libraries
-
klieo
Open-source Rust agent framework — typed agents, durable inter-agent comms, local-first
-
rumqttlog
kafka inspired rumqtt's mqtt commitlog
-
barrzen-axum-infra
Infrastructure integrations for Barrzen Axum: database, cache, search, broker
-
stormchaser-model
A robust, distributed workflow engine for event-driven and human-triggered workflows
-
wrpc-transport-ants
wRPC NATS.io transport via
ants -
nexo-taskflow
Long-running multi-step task orchestration runtime for Nexo agents
-
rants
An async NATS client library
-
nexo-web-search
Multi-provider web search client (Brave, Serper, etc.) for Nexo agents
-
varpulis-connector-nats
NATS connector for Varpulis CEP engine
-
nats-jwt
JWT library for creating NATS JWTs
-
nexo-ext-installer
Phase 31.1 — fetch + resolve + download + sha256-verify nexo plugin tarballs against the ext-registry index. Building block for
nexo plugin install <id>(CLI integration in 31.1.c). -
rofr
Framework for building robotics APIs that use NATS messaging
-
opentelemetry-nats
Convenience functions for propagating OpenTelemetry traces on NATS messages
-
wasmcloud-runtime
wasmCloud runtime library
-
wasmcloud-provider-blobstore-nats
A capability provider that satisfies the 'wasi:blobstore' interface using NATS object store as a backend
-
nenjo-eventbus
Transport-agnostic event bus for routing agentic AI workflow commands over NATS or custom transports
-
wrpc-test
wRPC test utilities
-
stormchaser-engine
A robust, distributed workflow engine for event-driven and human-triggered workflows
-
mesh-sdk
Mesh Protocol Rust SDK — facade crate re-exporting mesh-client, mesh-dataplane, mesh-session and mesh-types
-
stormchaser-api
A robust, distributed workflow engine for event-driven and human-triggered workflows
-
qm-nats
Nats helper functions
-
stormchaser-cli
A robust, distributed workflow engine for event-driven and human-triggered workflows
-
armature-messaging
Message broker integrations for the Armature framework - RabbitMQ, Kafka, NATS, and AWS SQS/SNS
-
stormchaser-runner-docker
A robust, distributed workflow engine for event-driven and human-triggered workflows
-
hadb-manifest-nats
NATS JetStream KV manifest store for hadb
-
stormchaser-runner-k8s
A robust, distributed workflow engine for event-driven and human-triggered workflows
-
nusy-conductor
Agent orchestration conductor — reads kanban state via NATS, decomposes expeditions, tracks agent availability
-
messaging-egress
Greentic messaging egress worker: consumes normalized envelopes and delivers platform-specific payloads
-
ame-bus
Modern microservices framework based on NATS
-
ratsio_fork_040
Fork of ratsio to avoid duplicate error conversion. Ratsio is a Rust client library for NATS messaging system and NATS Event Streaming.
-
nats-counters
NATS JetStream counters API
-
fukurow-streaming
Real-time streaming processing for Fukurow reasoning engine
-
nats-extra
Set of utilities and extensions for the Core NATS of the async-nats crate
-
mqcat
CLI pub/sub client (supports zenoh/nats/mqtt/centrifuge)
-
secrets-nats-kv
A secrets backend for wasmCloud that uses NATS as a key-value store
-
transmit
Transmission scheduler of delayed and periodic messages
-
shizuku
Modern microservices framework based on NATS
-
noetl-worker
NoETL Worker Pool - Executes workflow commands via NATS
-
sockudo-core
Core traits, types, error handling, and configuration for Sockudo
-
wasmcloud-core
wasmCloud core functionality shared throughout the ecosystem
-
trellis-cli-participant
Generated participant facade used by the Trellis CLI
-
nitox
tokio-based client for NATS -
revoke-mq
Message queue abstractions supporting Redis, Kafka, RabbitMQ, and NATS
-
putex
process mutex
-
smith-bus
NATS JetStream helpers for intent execution
-
natsclient
NATS client designed for both an ergonomic API and performance
-
nats-types
Enumerations and types for representing NATS protocol messages
-
mesh-client
Control-plane client for the Mesh Protocol: NATS pub/sub, Registry HTTP API, request/listen/heartbeat
-
async-nats-wrpc
A fork of
async-natscrate with lower-level async support -
feventbus
eventbus is implemented using nats,kafaka and rabbitmq client
-
noleader
A small leader election package using NATS keyvalue store as the distributed locking mechanism. Does not require a min / max set of nodes
-
chump-coord
NATS-backed atomic coordination layer for multi-agent Chump sessions. Phase 1: KV claim store + JetStream event bus alongside the existing file-based lease system.
-
mq-bridge-app-core
Shared core library for mq-bridge-app
-
wascc-nats
NATS capability provider for the waSCC host runtime
-
nats-jwt-rs
A port of the NATS jwt.go package to Rust
-
eventsourced-nats
NATS implementation for EventSourced EventLog and SnapshotStore
-
svc-nats-client
Async nats client
-
hadb-lease-nats
NATS JetStream KV lease store for hadb
-
ants
Low-level async NATS.io client
-
sophon
a game framework,support micro service
-
hwhkit-integration-nats
HwhKit NATS integration
-
wasmcloud-provider-messaging-nats
A capability provider that satisfies the 'wasmcloud:messaging' contract using NATS as a backend
-
tea-actor-utility
WasCC Tool - Supporting Binary and Sorted Vector Key-Value Pair and Macros to Build Nats Message Actor Handler
-
vil_mq_nats
VIL NATS Adapter — Core pub/sub, JetStream, KV Store, Tri-Lane bridge
-
nu_plugin_nuts
Blazingly fast Nats client as a nushell plugin
-
smith-logging
Structured logging infrastructure with NATS integration
-
adapter-nats
NATS messaging adapter for Rohas event-driven applications
-
printnanny-nats-client
PrintNanny.ai edge/cloud NATS clients
-
printnanny-nats-apps
Edge NATS applications
-
stan
NATS Streaming client based on official NATS rust client
-
nightly-async-nats
A async Rust NATS client
-
async-nats-flyradar
(patched for flyradar) A async Rust NATS client
-
pico-lang
JSON Logic like language
-
autoschematic-connector-nats
An Autoschematic connector for NATS.io
-
naps
NATS server proxy service to relay and forward custom topics and subjects
Try searching with DuckDuckGo.