network.bsky.jetstream

Submodules

• network.bsky.jetstream.get_block
  • Params
    • Params.block_index
    • Params.segment
  • ParamsDict
    • ParamsDict.block_index
    • ParamsDict.segment
  • Response
• network.bsky.jetstream.get_import_status
  • Params
    • Params.job
  • ParamsDict
    • ParamsDict.job
  • Response
    • Response.bucketed
    • Response.error
    • Response.finished_at
    • Response.job
    • Response.phase
    • Response.rows_corrupt_offset
    • Response.rows_matched_all_versions
    • Response.rows_matched_specific
    • Response.rows_mutated
    • Response.rows_rejected
    • Response.rows_total
    • Response.rows_valid
    • Response.segments_applied
    • Response.segments_examined
    • Response.segments_patched
    • Response.segments_to_apply
    • Response.specific_cids_unmatched
    • Response.state
    • Response.submitted_at
• network.bsky.jetstream.get_segment
  • Params
    • Params.name
  • ParamsDict
    • ParamsDict.name
  • Response
• network.bsky.jetstream.get_zstd_dictionary
  • Params
    • Params.id
  • ParamsDict
    • ParamsDict.id
  • Response
• network.bsky.jetstream.import_timestamps
  • Data
    • Data.path
  • DataDict
    • DataDict.path
  • Response
    • Response.job
• network.bsky.jetstream.list_segments
  • Params
    • Params.cursor
    • Params.limit
  • ParamsDict
    • ParamsDict.cursor
    • ParamsDict.limit
  • Response
    • Response.cursor
    • Response.segments
  • Segment
    • Segment.checksum
    • Segment.event_count
    • Segment.index
    • Segment.max_seq
    • Segment.max_witnessed_at
    • Segment.min_seq
    • Segment.min_witnessed_at
    • Segment.name
    • Segment.py_type
    • Segment.size_bytes
• network.bsky.jetstream.plan_snapshot
  • BlockRange
    • BlockRange.first
    • BlockRange.last
    • BlockRange.py_type
  • Data
    • Data.after_seq
    • Data.before_seq
    • Data.collections
    • Data.dids
    • Data.kinds
  • DataDict
    • DataDict.after_seq
    • DataDict.before_seq
    • DataDict.collections
    • DataDict.dids
    • DataDict.kinds
  • Response
    • Response.planned_through_seq
    • Response.sealed_tip_seq
    • Response.segments
    • Response.stats
  • Segment
    • Segment.blocks
    • Segment.checksum
    • Segment.index
    • Segment.max_seq
    • Segment.min_seq
    • Segment.mode
    • Segment.name
    • Segment.py_type
  • Stats
    • Stats.blocks_matched
    • Stats.entries
    • Stats.py_type
    • Stats.segments_examined
    • Stats.segments_matched
• network.bsky.jetstream.subscribe_events
  • Account
    • Account.account
    • Account.did
    • Account.py_type
    • Account.seq
    • Account.time
  • Commit
    • Commit.cid
    • Commit.collection
    • Commit.did
    • Commit.operation
    • Commit.py_type
    • Commit.record
    • Commit.rev
    • Commit.rkey
    • Commit.seq
    • Commit.time
  • Identity
    • Identity.did
    • Identity.identity
    • Identity.py_type
    • Identity.seq
    • Identity.time
  • Info
    • Info.message
    • Info.name
    • Info.py_type
  • Params
    • Params.collections
    • Params.cursor
    • Params.dids
    • Params.kinds
    • Params.max_message_size_bytes
    • Params.zstd_dictionary
  • ParamsDict
    • ParamsDict.collections
    • ParamsDict.cursor
    • ParamsDict.dids
    • ParamsDict.kinds
    • ParamsDict.max_message_size_bytes
    • ParamsDict.zstd_dictionary
  • Sync
    • Sync.did
    • Sync.py_type
    • Sync.seq
    • Sync.sync
    • Sync.time