MCPcopy Index your code
hub / github.com/cablehead/xs

github.com/cablehead/xs @v0.13.4

Chat with this repo
repository ↗ · DeepWiki ↗ · release v0.13.4 ↗ · + Follow
646 symbols 2,589 edges 66 files 93 documented · 14% updated 15d agov0.13.4 · 2026-06-20★ 21212 open issues
What it actually does AI analysis from the code graph — generated when you open this
loading…
README

Logo cross.stream

Local-first event streaming for building reactive workflows and automation.



<a href="#about">About</a>
·
<a href="https://cablehead.github.io/xs/">Documentation</a>
·
<a href="https://discord.com/invite/YNbScHBHrh">Connect</a>
·
<a href="#built-with-">Built with</a>

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

Extension points exported contracts — how you extend this code

AsyncReadWrite (Interface)
(no doc) [1 implementers]
src/listener.rs

Core symbols most depended-on inside this repo

append
called by 322
src/store/mod.rs
read
called by 133
src/store/mod.rs
recv
called by 118
src/processor/mod.rs
cas_insert
called by 105
src/store/mod.rs
spawn
called by 60
src/processor/service/service.rs
get
called by 49
src/store/mod.rs
empty
called by 45
src/client/commands.rs
apply
called by 30
src/processor/lifecycle/slots.rs

Shape

Function 391
Method 171
Class 58
Enum 25
Interface 1

Languages

Rust98%
TypeScript2%

Modules by API surface

src/store/mod.rs64 symbols
src/store/tests.rs47 symbols
src/main.rs43 symbols
src/processor/actor/tests.rs37 symbols
src/processor/service/tests.rs32 symbols
src/api.rs28 symbols
src/processor/lifecycle/tests.rs24 symbols
src/nu/test_commands.rs24 symbols
src/listener.rs23 symbols
src/trace.rs20 symbols
src/nu/engine.rs19 symbols
src/processor/service/service.rs18 symbols

For agents

$ claude mcp add xs \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact

Ask about this repo answers extend the page