Durable Streams protocol server in Rust, built with axum and tokio
Durable Streams state machine for Ursula: bucket and stream commands, events, and offset bookkeeping.
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.
Ursula durable-stream server: thread-per-core, multi-Raft, HTTP front door.
Embedded SQLite store for FACTSTR with append, query, streams, and durable streams.
PostgreSQL store for FACTSTR with append, query, streams, and durable streams.
Rust event store contract for append-only facts, streams, and command context consistency.
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.
In-memory FACTSTR store for tests, examples, and local development.
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.
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.
Alias for durable_streams — install that instead.
Alias for durable_streams-rails — install that instead.
No description provided.
No description provided.
No description provided.