atrium_api::client::com::atproto::sync

Struct Service

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

Implementations§

Source §

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

Source

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.

Source

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.

Source

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

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

Source

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

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

Source

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

Returns information about a specified upstream host, as consumed by the server. Implemented by relays.

Source

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.

Source

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.

Source

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.

Source

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.

Source

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.

Source

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

Enumerates upstream hosts (eg, PDS or relay instances) that this service consumes from. Implemented by relays.

Source

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.

Source

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

Enumerates all the DIDs which have records with the given collection NSID.

Source

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. DEPRECATED: just use com.atproto.sync.requestCrawl

Source