A local-first event pipeline for independent agents, built on Jazz.
thought-stream public docs architecture.md
1.2 kB

Architecture #

thought stream is organized as a set of narrow processes joined by durable Jazz records.

Ingress #

Connectors observe sources and append canonical events with source-local sequence, idempotency, privacy, and lineage. Observation never grants authority to act on a source.

Consumers #

Consumers subscribe through bounded Jazz queries. A consumer receives a bounded context packet, runs a deterministic rule or isolated model cell, validates its declared output contract, and settles output, lifecycle evidence, and progress together.

Projections #

Projections rebuild query-oriented views from canonical events. They make the stream inspectable without becoming a second source of truth.

Egress #

Dispatchers independently select eligible completed work, enforce destination policy, perform one narrow action, and append started, delivered, or failed receipts. A completed model run is not evidence that anything was sent.

Recovery #

Connector cursors advance only after durable events. Consumer progress advances only after terminal settlement. Interrupted attempts remain visible and retries preserve their evidence rather than rewriting history.