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 repo.

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

Gets blocks from a given repo.

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

Gets the current commit CID & revision of the repo.

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

Gets blocks needed for existence or non-existence of record.

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

Gets the did’s repo, optionally catching up from a specific revision.

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

List blob cids since some revision

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

List dids and root cids of hosted repos

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

Notify a crawling service of a recent update. Often when a long break between updates causes the connection with the crawling service to break.

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

Request a service to persistently crawl hosted repos.