#event-store #queue #cli

bin+lib cross-stream

An event stream store for personal, local-first use, specializing in event sourcing

24 releases (11 breaking)

new 0.12.0 Apr 13, 2026
0.11.0 Mar 2, 2026
0.10.0 Feb 13, 2026
0.6.5 Nov 11, 2025
0.0.9 Nov 1, 2024

#471 in Embedded development

Download history 46/week @ 2026-01-01 42/week @ 2026-01-08 56/week @ 2026-01-15 60/week @ 2026-01-22 49/week @ 2026-01-29 111/week @ 2026-02-12 58/week @ 2026-02-19 57/week @ 2026-02-26 33/week @ 2026-03-26 90/week @ 2026-04-02 13/week @ 2026-04-09

136 downloads per month
Used in http-nu

MIT and maybe CC-PDDC

455KB
11K SLoC

Logo

cross.stream

Local-first event streaming for building reactive workflows and automation.
About · Documentation · Connect · Built with

CI Discord Crates Docs.rs

What's an event streaming store?

If you think of an "event" like a frame in a movie—a small package on a timeline—an event streaming store is a database designed to record these frames in strict order, append-only, so they can be replayed or reacted to later.

For example, you might append a frame every time a message is posted in a specific Discord channel. You can then .cat the stream to review all captured messages, and—if you're in a Nushell session—use pipelines to filter, aggregate, or process them with a CLI tool.

Quick Start

See the installation guide to get started.

Features

  • Reactive Workflows: Build actors that automatically respond to events as they flow through the stream
  • CLI Integration: Turn any command-line tool into a streaming component with services
  • Nushell Native: First-class integration with Nushell for powerful data processing pipelines
  • Real-time Streaming: Subscribe to live event feeds and build responsive applications
  • Content Addressable: Efficient storage and deduplication of large payloads
  • Local-first: Your data stays on your machine, no cloud dependencies required

Connect

Join our Discord to ask questions or share ideas.

Built with 🙏💚

  • fjall: for indexing and metadata
  • cacache: for content (CAS)
  • hyper: provides an HTTP/1.1 API over a local Unix domain socket for subscriptions, etc.
  • Nushell: for scripting and interop
  • iroh: QUIC-based P2P transport for exposing and accessing streams

Dependencies

~140–185MB
~3.5M SLoC