jetstream client
atproto jetstream client
Something went wrong. Try again.
12345678910111213141516171819202122232425262728293031323334//! jetstream — the zig SDK for Jetstream v2 services//! (Bluesky Protocol Services' hosted instances, stream.waow.tech, and any//! upstream-compatible server).//!//! this repo is the service-SDK side of the line zat draws at the protocol://! zat speaks atproto (identity, repos, CAR/CBOR/MST, com.atproto.sync.*);//! this SDK speaks network.bsky.jetstream.* — the derived convenience feed//! and its archive/replay API — and depends on zat for everything protocol.//! the same split Bluesky drew between @atproto/api and @bsky/sdk.//!//! the client mirrors the official Go client's shape — one subscribe covers//! the live tail (subscribeEvents lexicon frames, seq cursors, dict-zstd),//! filtered archive replay (planSnapshot → getBlock/getSegment → jss v1),//! and the gapless replay→live cutover. zat.JetstreamClient (the v1//! /subscribe wire) remains in zat until consumers migrate.
pub const ArchiveBackfill = @import("archive_backfill.zig");pub const livedecode = @import("livedecode.zig");pub const live = @import("live.zig");pub const LiveClient = live.LiveClient;pub const client = @import("client.zig");pub const subscribe = client.subscribe;pub const SubscribeOptions = client.Options;pub const Event = livedecode.Event;pub const Kind = livedecode.Kind;
test { _ = @import("archive_backfill.zig"); _ = @import("livedecode.zig"); _ = @import("live.zig"); _ = @import("client.zig"); _ = @import("loopback_test.zig");}