High-throughput Solana transaction ledger streaming and plugin framework suitable for research and backfilling
Set of utilities and extensions for the JetStream NATS of the async-nats crate
Support crate for Jetstreamer containing firehose ingestion engine and core abstractions
NATS JetStream EventSink for CellOS — durable, ordered CloudEvent delivery with 90-day retention floor (FC-74).
HTTP control plane for CellOS — admission, projection over JetStream, WebSocket fan-out of CloudEvents. Pure event-sourced architecture.
AT Protocol Jetstream event consumer library with WebSocket streaming and compression support
A fully typed async wrapper for NATS with JetStream support
Jetstream is a RPC framework for Rust, based on the 9P protocol and QUIC.
Jetstream is a RPC framework for Rust, based on the 9P protocol and QUIC.
Jetstream is a RPC framework for Rust, based on the 9P protocol and QUIC.
Jetstream is a RPC framework for Rust, based on the 9P protocol and QUIC.
Jetstream is a RPC framework for Rust, based on the 9P protocol and QUIC.
Production-ready publishers/consumers for NATS JetStream with app-scoped subjects, overlap guards, DLQ routing, retries/backoff, and optional inbox/outbox patterns. Includes health checks, auto-reconnection, graceful shutdown, topology setup helpers, and Rails generators.
A production-ready pub/sub library for NATS JetStream with Rails integration. Features declarative subscribers, auto-discovery, middleware support, Web UI for monitoring Inbox/Outbox events, and production-ready patterns including Inbox/Outbox, DLQ, and automatic retries with backoff.
Drop-in workers for Rails (app/workers) that consume NATS JetStream streams via pull-based subscriptions, using nats-pure.
Turbocable publishes messages to NATS JetStream on the TURBOCABLE.* subject tree, for fan-out by turbocable-server to WebSocket subscribers. It targets Rails and any pure-Ruby process that needs to broadcast without owning the delivery path. (RubyGems package name: turbocable_nats.)