atproto_firehose.firehose¶
- class atproto_firehose.firehose.AsyncFirehoseSubscribeLabelsClient(params: dict | Params | None = None, base_uri: str | None = 'wss://mod.bsky.app/xrpc')¶
Bases:
_AsyncWebsocketClient
Async firehose subscribe labels client.
- Parameters:
params – Parameters model.
base_uri – Base websocket URI. Example: wss://bsky.social/xrpc.
- class atproto_firehose.firehose.AsyncFirehoseSubscribeReposClient(params: dict | Params | None = None, base_uri: str | None = 'wss://bsky.network/xrpc')¶
Bases:
_AsyncWebsocketClient
Async firehose subscribe repos client.
- Parameters:
params – Parameters model.
base_uri – Base websocket URI. Example: wss://bsky.social/xrpc.
- class atproto_firehose.firehose.FirehoseSubscribeLabelsClient(params: dict | Params | None = None, base_uri: str | None = 'wss://mod.bsky.app/xrpc')¶
Bases:
_WebsocketClient
Firehose subscribe labels client.
- Parameters:
params – Parameters model.
base_uri – Base websocket URI. Example: wss://bsky.social/xrpc.
- class atproto_firehose.firehose.FirehoseSubscribeReposClient(params: dict | Params | None = None, base_uri: str | None = 'wss://bsky.network/xrpc')¶
Bases:
_WebsocketClient
Firehose subscribe repos client.
- Parameters:
params – Parameters model.
base_uri – Base websocket URI. Example: wss://bsky.social/xrpc.
- atproto_firehose.firehose.SubscribeLabelsMessage¶
Subscribe Labels Message
- atproto_firehose.firehose.SubscribeReposMessage¶
Subscribe Repos Message
alias of
Union
[Commit
,Handle
,Migrate
,Tombstone
,Info
,Identity
]
- atproto_firehose.firehose.parse_subscribe_labels_message(message: MessageFrame) Labels | Info ¶
Parse Firehose labels message to the corresponding model.
- Parameters:
message – Message frame.
- Returns:
Corresponding message model.
- Return type:
- atproto_firehose.firehose.parse_subscribe_repos_message(message: MessageFrame) Commit | Handle | Migrate | Tombstone | Info | Identity ¶
Parse Firehose repositories message to the corresponding model.
Note
Use decode_inner_cbor only when required to increase performance.
- Parameters:
message – Message frame.
- Returns:
Corresponding message model.
- Return type: