Skip to main content

Module sync

Module sync 

Source

StructsΒ§

SubscribeParams πŸ”’
What a subscribeRepos connection asked for.

ConstantsΒ§

CAR πŸ”’
The content type a repository, a proof or a bag of blocks goes out as.
MAX_CONSUMER_MESSAGE πŸ”’
The largest message, and the largest frame, a subscribeRepos consumer may send.
SINCE πŸ”’
What a getRepo answer says about the since it was asked for.

FunctionsΒ§

flag πŸ”’
Reads a boolean query parameter.
get_blocks πŸ”’
GET /xrpc/com.atproto.sync.getBlocks
get_latest_commit πŸ”’
GET /xrpc/com.atproto.sync.getLatestCommit
get_repo πŸ”’
GET /xrpc/com.atproto.sync.getRepo
get_repo_status πŸ”’
GET /xrpc/com.atproto.sync.getRepoStatus
list_repos πŸ”’
GET /xrpc/com.atproto.sync.listRepos
pump_repos πŸ”’
Writes one consumer’s frames onto its socket until either end stops.
repo_not_served πŸ”’
Why a com.atproto.sync.* route serves no repository for did.
since_header πŸ”’
The SINCE value for one answer, or None when no since was asked.
subscribe_repos πŸ”’
GET /xrpc/com.atproto.sync.subscribeRepos
subscriber_slot πŸ”’
The slot a never-ending stream holds for as long as it is open, or None when this deployment is already holding as many as it will.
sync_error πŸ”’
Maps a failure onto the error name com.atproto.sync.* declares for it.
sync_get_record πŸ”’
GET /xrpc/com.atproto.sync.getRecord
too_many_subscribers πŸ”’
What a caller past the subscriber bound is told.