tests · stream · Tangled

zat.dev / stream

jetstream v2 in zig stream.waow.tech

stream tests

2 folders · 29 files

zzstoatzz · ingest: reconnect when the relay delivers below --upstream-slow-min-rate · 1d ago

segment: jss format v1 reader, differentially verified

upstream_oracle

re-pin to v0.2.0 (the Jetstream v2 release) and port kinds filtering

admission_contract.py

admission: bind one receipt to one image digest

archive_client_e2e.py

re-pin to v0.2.0 (the Jetstream v2 release) and port kinds filtering

backfill_api.py

v2: port the proposal-0015 wire — re-pin upstream to d4dd2f0

backfill_batch_contract.py

bootstrap: delete the in-flight byte budget

compaction_config_contract.py

match upstream compaction controls

cursor_lookback_contract.py

gate suites: finish the 0015 frame port (powerloss time assertions, lookback error envelope)

differential_oracle.py

re-pin to v0.2.0 (the Jetstream v2 release) and port kinds filtering

v2: port the proposal-0015 wire — re-pin upstream to d4dd2f0

environment_contract.py

ingest: reconnect when the relay delivers below --upstream-slow-min-rate

frontend-layout.py

site: form crisp colored splinters within the live glass

glass-current.test.cjs

site: form crisp colored splinters within the live glass

homepage-layout.html

site: fit endpoint text at one consistent size

http_metrics_contract.py

match upstream archive cache policy

listener_contract.py

listener contract: startup-gate wait for the legacy mode too

logging_contract.py

logging contract: wait for the ERROR record, not a fixed slice after listen

oracle: reap on expected-exit timeout so a hung case cannot leak a port squatter

plan_config_contract.py

status + plan-config contracts: wait past the startup gate

powerloss_oracle.py

gate suites: finish the 0015 frame port (powerloss time assertions, lookback error envelope)

powerloss.Dockerfile

prove lifecycle power-loss parity

process_metrics_contract.py

process metrics contract: wait past the startup gate before counting store ops

retry_config_contract.py

retry-config-contract: correct the flakiness note

site: preserve the dense ASCII river while animating arrivals

seam_handoff_contract.py

tests: seam contract simulator gets its own data dir and process group

shutdown_contract.py

shutdown contract: wait_ready waits for the gates, not just the listener

status_contract.py

status + plan-config contracts: wait past the startup gate

prove lifecycle power-loss parity

subscribe_read_batch_contract.py

v2: port the proposal-0015 wire — re-pin upstream to d4dd2f0

test_dashboard_contract.py

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

timestamp-import.csv

prove compaction power-loss parity