Directories
¶
| Path | Synopsis |
|---|---|
|
Package crashpoint defines named test-only crash checkpoints at durable lifecycle boundaries.
|
Package crashpoint defines named test-only crash checkpoints at durable lifecycle boundaries. |
|
Package format provides shared human-readable formatters used by the CLI renderers, the load-test client, and the web status page.
|
Package format provides shared human-readable formatters used by the CLI renderers, the load-test client, and the web status page. |
|
package identity persists atmos identity.Cache resolutions in pebble.
|
package identity persists atmos identity.Cache resolutions in pebble. |
|
Package importer is the operator-facing job manager for timestamp import (design §8, milestone M6).
|
Package importer is the operator-facing job manager for timestamp import (design §8, milestone M6). |
|
Package ingest owns the active-segment writer for jetstream.
|
Package ingest owns the active-segment writer for jetstream. |
|
backfill
Package backfill drives Jetstream's direct-PDS initial network backfill (docs/README.md §4.1).
|
Package backfill drives Jetstream's direct-PDS initial network backfill (docs/README.md §4.1). |
|
live
package live: consumer.go owns Consumer, the firehose-to- segments pump.
|
package live: consumer.go owns Consumer, the firehose-to- segments pump. |
|
orchestrator
Package orchestrator owns the ingestion-lifecycle state machine for jetstream.
|
Package orchestrator owns the ingestion-lifecycle state machine for jetstream. |
|
syncstate
Package syncstate persists atmos sync.StateStore in pebble.
|
Package syncstate persists atmos sync.StateStore in pebble. |
|
Package jetstreamd builds and runs the jetstream service graph used by cmd/jetstream and integration tests.
|
Package jetstreamd builds and runs the jetstream service graph used by cmd/jetstream and integration tests. |
|
Package lifecycle owns the persistent process-lifecycle markers that gate which subsystems jetstream starts on a given run.
|
Package lifecycle owns the persistent process-lifecycle markers that gate which subsystems jetstream starts on a given run. |
|
Package manifest materializes docs/README.md §3.5's "segment manifest" concept in memory: an authoritative slice of bounds (MinSeq, MaxSeq, MinWitnessedAt, MaxWitnessedAt) for every sealed segment, plus a small LRU of per-segment block indices for callers that need to seek inside a segment.
|
Package manifest materializes docs/README.md §3.5's "segment manifest" concept in memory: an authoritative slice of bounds (MinSeq, MaxSeq, MinWitnessedAt, MaxWitnessedAt) for every sealed segment, plus a small LRU of per-segment block indices for callers that need to seek inside a segment. |
|
Package obs: observe.go provides the canonical tracing helpers used throughout jetstream.
|
Package obs: observe.go provides the canonical tracing helpers used throughout jetstream. |
|
observe_innertest
Package observe_innertest exists solely to provide an obs.Span call site in a different package from internal/obs's own tests, so the tracer-scoping test can exercise cross-package behavior.
|
Package observe_innertest exists solely to provide an obs.Span call site in a different package from internal/obs's own tests, so the tracer-scoping test can exercise cross-package behavior. |
|
Package oracle is jetstream's end-to-end correctness harness.
|
Package oracle is jetstream's end-to-end correctness harness. |
|
Package repoexport reconstructs local atproto repo snapshots from Jetstream segment files.
|
Package repoexport reconstructs local atproto repo snapshots from Jetstream segment files. |
|
Package seqspace owns the shared Jetstream sequence-number namespace and the immutable set of durable, explicitly-authorized sequence vacancies.
|
Package seqspace owns the shared Jetstream sequence-number namespace and the immutable set of durable, explicitly-authorized sequence vacancies. |
|
Package server owns the HTTP listeners for the jetstream process.
|
Package server owns the HTTP listeners for the jetstream process. |
|
Package simulator is the parent of jetstream's local atproto network simulator.
|
Package simulator is the parent of jetstream's local atproto network simulator. |
|
fanout
Package fanout owns the in-memory pub/sub that the simulator's traffic generator broadcasts to and the websocket subscribeRepos handler reads from.
|
Package fanout owns the in-memory pub/sub that the simulator's traffic generator broadcasts to and the websocket subscribeRepos handler reads from. |
|
http
Package http hosts the simulator's HTTP surface: PLC, PDS, and relay endpoints under a single mux at production paths.
|
Package http hosts the simulator's HTTP surface: PLC, PDS, and relay endpoints under a single mux at production paths. |
|
world
Package world owns the simulator's on-disk state: the pebble db, the global RNG, the deterministic account roster, and the live commit generator.
|
Package world owns the simulator's on-disk state: the pebble db, the global RNG, the deterministic account roster, and the live commit generator. |
|
Package status gathers the data shown by the public /status page.
|
Package status gathers the data shown by the public /status page. |
|
Package store owns the lifecycle of the metadata pebble database at <data-dir>/meta.pebble (docs/README.md §3.4 / §3.5).
|
Package store owns the lifecycle of the metadata pebble database at <data-dir>/meta.pebble (docs/README.md §3.4 / §3.5). |
|
Package subscribe owns the websocket fan-out behind the public /subscribe (legacy v1) and /xrpc/network.bsky.jetstream.subscribeEvents (v2, atproto proposal 0015) endpoints: the shared pull loop and cursor replay, plus each endpoint's wire framing, filtering dialect, and error contract.
|
Package subscribe owns the websocket fan-out behind the public /subscribe (legacy v1) and /xrpc/network.bsky.jetstream.subscribeEvents (v2, atproto proposal 0015) endpoints: the shared pull loop and cursor replay, plus each endpoint's wire framing, filtering dialect, and error contract. |
|
Package timestamp implements the operator timestamp-import pipeline (docs/README.md §8, design specs/notes/2026-07-01-timestamp-import-design.md).
|
Package timestamp implements the operator timestamp-import pipeline (docs/README.md §8, design specs/notes/2026-07-01-timestamp-import-design.md). |
|
Package tombstone maintains the live in-memory delete/update tombstone set consumed by the delete compactor.
|
Package tombstone maintains the live in-memory delete/update tombstone set consumed by the delete compactor. |
|
Package version exposes build metadata that is injected at link time via -ldflags.
|
Package version exposes build metadata that is injected at link time via -ldflags. |
|
Package web renders the public /status page from a status.Snapshot.
|
Package web renders the public /status page from a status.Snapshot. |
|
Package xrpcapi exposes jetstream's sealed segment files over XRPC (atproto's HTTP RPC framework).
|
Package xrpcapi exposes jetstream's sealed segment files over XRPC (atproto's HTTP RPC framework). |
|
Package zstddict parses the header of a structured zstd dictionary (RFC 8878 §5).
|
Package zstddict parses the header of a structured zstd dictionary (RFC 8878 §5). |
Click to show internal directories.
Click to hide internal directories.