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<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<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<Error>>

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

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

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

pub async fn get_latest_commit( &self, params: Parameters ) -> Result<Output, Error<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<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<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 list_blobs( &self, params: Parameters ) -> Result<Output, Error<Error>>

List blob CIDso 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<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<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<Error>>

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