Struct atrium_api::client::com::atproto::sync::Service

pub struct Service<T>
where
    T: XrpcClient + Send + Sync,
{ /* private fields */ }

Implementations

impl<T> Service<T>

where T: XrpcClient + Send + Sync,

pub async fn get_blob(&self, params: Parameters) -> Result<Vec<u8>, Error>

Get a blob associated with a given account. Returns the full blob as originally uploaded. Does not require auth; implemented by PDS.

pub async fn get_blocks(&self, params: Parameters) -> Result<Vec<u8>, Error>

Get data blocks from a given repo, by CID. For example, intermediate MST nodes, or records. Does not require auth; implemented by PDS.

pub async fn get_checkout(&self, params: Parameters) -> Result<Vec<u8>, Error>

DEPRECATED - please use com.atproto.sync.getRepo instead

pub async fn get_head(&self, params: Parameters) -> Result<Output, Error>

DEPRECATED - please use com.atproto.sync.getLatestCommit instead

pub async fn get_latest_commit( &self, params: Parameters, ) -> Result<Output, Error>

Get the current commit CID & revision of the specified repo. Does not require auth.

pub async fn get_record(&self, params: Parameters) -> Result<Vec<u8>, Error>

Get data blocks needed to prove the existence or non-existence of record in the current version of repo. Does not require auth.

pub async fn get_repo(&self, params: Parameters) -> Result<Vec<u8>, Error>

Download a repository export as CAR file. Optionally only a ‘diff’ since a previous revision. Does not require auth; implemented by PDS.

pub async fn get_repo_status(&self, params: Parameters) -> Result<Output, Error>

Get the hosting status for a repository, on this server. Expected to be implemented by PDS and Relay.

pub async fn list_blobs(&self, params: Parameters) -> Result<Output, Error>

List blob CIDs for an account, since some repo revision. Does not require auth; implemented by PDS.

pub async fn list_repos(&self, params: Parameters) -> Result<Output, Error>

Enumerates all the DID, rev, and commit CID for all repos hosted by this service. Does not require auth; implemented by PDS and Relay.

pub async fn notify_of_update(&self, input: Input) -> Result<(), Error>

Notify a crawling service of a recent update, and that crawling should resume. Intended use is after a gap between repo stream events caused the crawling service to disconnect. Does not require auth; implemented by Relay.

pub async fn request_crawl(&self, input: Input) -> Result<(), Error>

Request a service to persistently crawl hosted repos. Expected use is new PDS instances declaring their existence to Relays. Does not require auth.