jetstream
jetstream client
atproto jetstream client
Star
Fork
Watch

Commits on main
agents: restore shared skill discovery in Claude
committed
docs: add shared agent instructions
committed
release: v0.1.7 v0.1.7 release/v0.1.7
committed
ci: verify and use patched Go 1.27.3
committed
fix: handle terminal frames and filter large subscriptions correctly
committed
deps: adopt eMudhra distrust and release v0.1.6 v0.1.6
committed
live: read and write the stall progress counter atomically
committed
live: tail inline when the stall watchdog cannot get a concurrent task
committed
client: propagate error.Canceled from the dictionary fetch
committed
pin zat v0.6.0-alpha.3 and websocket.zig v0.2.0-alpha.3
committed
zig 0.17: port to the 0.17.0 release
committed
ci: trigger full verification from release branches
committed
ci: gate Jetstream releases on local client checks and benchmarks
committed
docs: distinguish compression history from v0.1.5 behavior
committed
release: v0.1.5 v0.1.5
committed
fix: resume live failover with timestamp cursors
committed
fix: decode archive frames with omitted content size
committed
fix: align live resume filtering and dictionary error callbacks
committed
release: v0.1.4 v0.1.4
committed
release: v0.1.3 v0.1.3
committed
fix: align live frame sequences and window limits with upstream
committed
fix: decode live zstd frames with omitted content size
committed
fix: enable live compression with dictionary rotation recovery
committed
skills: document Jetstream client integration workflow
committed
release: v0.1.2 v0.1.2
committed
examples: authenticate Streamplace archive replay
committed
skills: add Jetstream client release workflow
committed
client: align archive recovery, pagination, and filtering with upstream
committed
archive: decode_records option; segment-export skips record CBOR
committed
examples: segment-export — one local jss segment to TSV rows
committed
dep-bump
deps: zat v0.4.4
committed
failover: live tail only — archive-sweep errors are terminal
committed
slice_sync: "-" actor = network-wide collection slice (used for the retrieval benchmarks)
committed
archive: bytes_fetched in Result; slice_sync reports fetches + wire bytes
committed
plan-level kinds pruning + live-dial auth; slice_sync example; release 0.1.1 v0.1.1
committed
sweep: enforce the exact (after_seq, before_seq] window per row v0.1.0
committed
rename fallback_hosts -> hosts: the family contract
committed
README: overview + usage + links; API detail moves to docs/client.md; MIT license
committed
release: recut v0.1.0 with record parity folded in
committed
records: canonical DAG-CBOR parity with upstream Event.RecordCBOR
committed
release: v0.1.0
committed
example: live failover smoke — dead primary rotates to a real fallback
committed
loopback e2e: fake v2 instances drive failover, stall rotation, and clean stop
committed
live: event-based stall detection; fix live-phase clean stop
committed
client: multi-host failover — time re-anchored rotation over per-instance seq spaces
committed
the unified v2 client: live subscribeEvents + replay cutover (Go client parity)
committed
gitignore zig-pkg (the local package cache was committed by accident)
committed
pin zat at v0.4.0 (the release, not a main hash)
committed
example: zat.Datetime replaces the hand-rolled 45-line datetime parser
committed
pin zat at the post-split main
committed
ArchiveBackfill moves in from zat; the service-SDK split begins
committed