TypeScript client for the Durable Streams protocol
State change event protocol for Durable Streams
Node.js reference server implementation for Durable Streams
TypeScript client for the Durable Streams protocol
State change event protocol for Durable Streams
Vercel AI SDK transport adapters for Durable Streams
Node.js reference server implementation for Durable Streams
Conformance test suite for Durable Streams server implementations
CLI tool for working with Durable Streams
TanStack AI adapters for Durable Streams
Yjs provider for Durable Streams - sync Yjs documents over append-only streams
Conformance test suite for Durable Streams client implementations (producer and consumer)
Stream-scoped Durable Streams client for TypeScript.
Electric agent runtime — behavioral stack for agent entities over durable streams
Performance benchmark suite for Durable Streams server implementations
Core durable-streams protocol for Cloudflare Workers + Durable Objects
Just a placeholder
Subscription service for durable-streams on Cloudflare Workers + Durable Objects
Transport/runtime layer for synchronizing CRDT state over Durable Streams.
CLI for scaffolding, deploying, and managing Durable Streams on Cloudflare
`@tisyn/durable-streams` provides the append-only event stream abstraction that underpins durable execution in Tisyn. It defines how execution events are persisted, read back, and indexed for replay so workflows can resume deterministically after interrup
Admin dashboard for durable-streams core on Cloudflare Workers
Admin dashboard for durable-streams subscription service on Cloudflare Workers
Single-node SQLite-backed Durable Streams dev server for local CRDT development.
Durable Streams protocol server in Rust, built with axum and tokio
Ursula durable-stream server: thread-per-core, multi-Raft, HTTP front door.
Benchmark client for Durable Streams servers: drives multi-stream write, SSE fan-out, and catch-up replay workloads against Ursula, the Durable Streams reference, and S2 Lite.
Shared protobuf wire types for Ursula (stream commands, cold chunk refs, Raft RPC payloads).
OpenRaft integration for Ursula's per-group multi-Raft replication: network, log store, and snapshot transport.
Per-core actor runtime for Ursula: hot ring, cold-tier flush, and the replaceable group-engine boundary.
Shard placement primitives for Ursula's thread-per-core multi-Raft runtime.
Durable Streams state machine for Ursula: bucket and stream commands, events, and offset bookkeeping.
A maintained Ruby client for the Durable Streams protocol — persistent, resumable event streams over HTTP. Based on the upstream reference client with manual review, testing, and ongoing maintenance.
Stream State Protocol events from Active Record models with the same DX as Turbo Broadcasts — declarative streaming, automatic callbacks, and async jobs — but with offset-based resumability and persistent event logs over HTTP.
Ruby binding for Honker — a SQLite-native task runtime. Queues, streams, pub/sub, time-trigger scheduler, results, locks, rate limits, all in one .db file. Thin wrapper around the Honker SQLite loadable extension; no Redis, no external broker.
Sinatra-free core for running Opal-compiled Ruby on Cloudflare Workers: Rack handler, D1/KV/R2/AI/Queue/Durable Object adapters, multipart/streaming, and Opal corelib patches. Use with the `opal` gem and a Module Worker (`runtime/worker.mjs` in this gem).
A production-ready Action Cable subscription adapter that uses MongoDB (via Mongoid) as a durable, cross-process broadcast backend with Change Streams support
No description provided.
No description provided.
No description provided.