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

pub struct Service<T>where
    T: XrpcClient + Send + Sync,{
    pub xrpc: Arc<T>,
}

Fields

xrpc: Arc<T>

Implementations

impl<T> Service<T>where T: XrpcClient + Send + Sync,

pub fn new(xrpc: Arc<T>) -> Self

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

Gets the repo state.

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

Gets the path of repo commits

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

Gets the current HEAD CID of a 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 repo state.

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

List blob cids for some range of commits

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.