Stream every archived and live Jetstream event in seq order, framed per the xrpc.v1.json subprotocol. The kinds, dids, and collections filters are independent predicates ANDed together; each is match-all when omitted. See the parameter and error descriptions for cursor, filtering, and compression semantics.
Parameters
collections
array
Optional
Collection NSIDs or '<prefix>.*' patterns; constrains which commit events are delivered. Non-commit kinds are unaffected — combine with kinds=commit for a commits-only collection stream. Rejected pre-upgrade with HTTP 400 (InvalidRequest) when kinds is set and excludes commit, since the filter could never apply. Omitted or empty: all collections.
cursor
integer
Optional
Resume position, inclusive: the server replays events with seq >= cursor and the client dedups the overlap. Values >= 1e15 are interpreted as a unix-microseconds timestamp instead of a seq and translated to the first seq witnessed at or after that instant; a timestamp below the retention floor clamps up to the floor and an #info OutdatedCursor frame is sent. Omitted: start at the live tip.
dids
array
Optional
Repo DIDs to receive events for; applies to every event kind. Omitted or empty: all repos.
kinds
array
Optional
Event kinds to receive; values are the message $type fragment names. Omitted or empty: all kinds. A value outside the enum is rejected pre-upgrade with HTTP 400 (InvalidRequest) rather than silently never matching.
maxMessageSizeBytes
integer
Optional
Skip events whose uncompressed frame (envelope included) exceeds this many bytes. 0 (default) means no limit.
zstdDictionary
integer
Optional
Jetstream extension: opt into dict-zstd frame compression with the given zstd dictionary ID (obtained via network.bsky.jetstream.getZstdDictionary). Frames then arrive as binary websocket messages, each one zstd frame whose decompressed bytes are exactly the xrpc.v1.json text frame. An unknown or retired ID is rejected pre-upgrade with HTTP 400 carrying the current ID.
Message Types
Errors
ConsumerTooSlow
The client is far behind the live tip AND reading below the server's floor rate for a sustained window; the server drops adversarially-slow readers. A merely-slow-but-progressing reader is never dropped. CursorTooOld
Rejected pre-upgrade with HTTP 400, never as a stream error frame: the requested seq cursor is below the server's retention floor. The message carries the floor seq; archive-backfilling clients re-enter backfill from their last durable seq. UnknownZstdDictionary
Rejected pre-upgrade with HTTP 400, never as a stream error frame: the zstdDictionary ID is unknown or retired. The message carries the current dictionary ID; re-fetch via network.bsky.jetstream.getZstdDictionary. View raw schema
{
"description": "Stream every archived and live Jetstream event in seq order, framed per the xrpc.v1.json subprotocol. The kinds, dids, and collections filters are independent predicates ANDed together; each is match-all when omitted. See the parameter and error descriptions for cursor, filtering, and compression semantics.",
"errors": [
{
"description": "The client is far behind the live tip AND reading below the server's floor rate for a sustained window; the server drops adversarially-slow readers. A merely-slow-but-progressing reader is never dropped.",
"name": "ConsumerTooSlow"
},
{
"description": "Rejected pre-upgrade with HTTP 400, never as a stream error frame: the requested seq cursor is below the server's retention floor. The message carries the floor seq; archive-backfilling clients re-enter backfill from their last durable seq.",
"name": "CursorTooOld"
},
{
"description": "Rejected pre-upgrade with HTTP 400, never as a stream error frame: the zstdDictionary ID is unknown or retired. The message carries the current dictionary ID; re-fetch via network.bsky.jetstream.getZstdDictionary.",
"name": "UnknownZstdDictionary"
}
],
"message": {
"schema": {
"refs": [
"#commit",
"#identity",
"#account",
"#sync",
"#info"
],
"type": "union"
}
},
"parameters": {
"properties": {
"collections": {
"description": "Collection NSIDs or '<prefix>.*' patterns; constrains which commit events are delivered. Non-commit kinds are unaffected — combine with kinds=commit for a commits-only collection stream. Rejected pre-upgrade with HTTP 400 (InvalidRequest) when kinds is set and excludes commit, since the filter could never apply. Omitted or empty: all collections.",
"items": {
"type": "string"
},
"maxLength": 100,
"type": "array"
},
"cursor": {
"description": "Resume position, inclusive: the server replays events with seq >= cursor and the client dedups the overlap. Values >= 1e15 are interpreted as a unix-microseconds timestamp instead of a seq and translated to the first seq witnessed at or after that instant; a timestamp below the retention floor clamps up to the floor and an #info OutdatedCursor frame is sent. Omitted: start at the live tip.",
"type": "integer"
},
"dids": {
"description": "Repo DIDs to receive events for; applies to every event kind. Omitted or empty: all repos.",
"items": {
"format": "did",
"type": "string"
},
"maxLength": 10000,
"type": "array"
},
"kinds": {
"description": "Event kinds to receive; values are the message $type fragment names. Omitted or empty: all kinds. A value outside the enum is rejected pre-upgrade with HTTP 400 (InvalidRequest) rather than silently never matching.",
"items": {
"enum": [
"commit",
"identity",
"account",
"sync"
],
"type": "string"
},
"maxLength": 4,
"type": "array"
},
"maxMessageSizeBytes": {
"default": 0,
"description": "Skip events whose uncompressed frame (envelope included) exceeds this many bytes. 0 (default) means no limit.",
"maximum": 4294967295,
"minimum": 0,
"type": "integer"
},
"zstdDictionary": {
"description": "Jetstream extension: opt into dict-zstd frame compression with the given zstd dictionary ID (obtained via network.bsky.jetstream.getZstdDictionary). Frames then arrive as binary websocket messages, each one zstd frame whose decompressed bytes are exactly the xrpc.v1.json text frame. An unknown or retired ID is rejected pre-upgrade with HTTP 400 carrying the current ID.",
"minimum": 1,
"type": "integer"
}
},
"type": "params"
},
"subprotocol": "xrpc.v1.json",
"type": "subscription"
}