src/internal · stream · Tangled

zat.dev / stream

jetstream v2 in zig stream.waow.tech

stream src internal

3 folders · 44 files

at commit e57731bb

zzstoatzz · bootstrap: break the batch submit/consume deadlock · 3mo ago

bootstrap: break the batch submit/consume deadlock

fail closed on compaction watermark corruption

status: surface durable lifecycle timing; timestamp metadata fails closed

resume active archive segments safely

match upstream cold block cache

cold replay: never step over an unreadable sealed segment

live ingest: isolate unencodable records instead of dying on them

powerloss: cut power at the durability-ordering seam

fail closed on lifecycle metadata corruption

measure archive capacity and seal latency

environment.zig

preserve upstream oracle environment namespace

match encoded filters and archive HTTP semantics

plan backfill from resident metadata

status: bring the field report to upstream's information set

match upstream archive preconditions

ingest: make the disconnect regression deterministic

inspect_all.zig

match upstream database inspection command

match upstream logging controls

verify: LRU key cache (ported from zlay)

match upstream cold block cache

fail closed on merge restart state

metrics: make backfill progress restart-stable, and stop mislabelling it

observability.zig

close OTLP client TLS parity

operational.zig

match upstream segment inspection commands

metrics: expose bootstrap pipeline health

process_metrics.zig

adapt dashboard to honest process metrics

repair_integration_test.zig

fail closed on lifecycle metadata corruption

match upstream backfill worker admission

repo_action_limiter.zig

close account diagnostics parity

repo_export.zig

close account diagnostics parity

segment_fixture_test.zig

verify jss block checksums

segment_footer.zig

compaction slice 2: watermark store + atomic sealed-segment rewrite

close segment storage fault parity

segment_patch.zig

prove compaction power-loss parity

segment_rewrite.zig

prove compaction power-loss parity

segment_writer.zig

match upstream async backfill flush

planBackfill: one-sided planning and no silent short plans

metrics: emit durable repo gauges for an empty store

status_page.zig

status: add the segments and collections operator views

match upstream subscriber read batching

close compaction parity

tracing_integration_test.zig

match upstream production trace boundaries

close upstream adversarial ingest parity

serve: /subscribe-v2 — the strict superset wire

listSegments: answer on encode failure instead of dropping the request

build: vendor zstd + xxHash sources — no system libraries

verify jss block checksums