Struct ReposControl 

pub struct ReposControl(/* private fields */);

control over which repositories are tracked and access to their state.

in filter mode, a repo is only indexed if it either matches a signal or is explicitly tracked via ReposControl::track. in full mode all repos are indexed and tracking is implicit.

tracking a DID that hydrant has never seen enqueues an immediate backfill. tracking a DID that hydrant already knows about (but has marked untracked) re-enqueues it for backfill.

Implementations

impl ReposControl

pub async fn resync( &self, dids: impl IntoIterator<Item = Did<'_>>, ) -> Result<Vec<Did<'static>>>

request one or more repositories to be resynced.

note that they may not immediately start backfilling if:

• other repos already filled the backfill concurrency limit,
• or there are many repos pending already.

this will also clear any error state the repo may have been in, allowing it to resync again.

pub async fn track( &self, dids: impl IntoIterator<Item = Did<'_>>, ) -> Result<Vec<Did<'static>>>

explicitly track one or more repositories, enqueuing them for backfill if needed.

• if a repo is new, a fresh [RepoState] is created and backfill is queued.
• if a repo is already known but untracked, it is marked tracked and re-enqueued.
• if a repo is already tracked, this is a no-op.

pub async fn untrack( &self, dids: impl IntoIterator<Item = Did<'_>>, ) -> Result<Vec<Did<'static>>>

stop tracking one or more repositories. hydrant will stop processing new events for them and remove them from the pending/resync queues, but existing indexed records are not deleted.

impl ReposControl

pub fn iter( &self, cursor: Option<&Did<'_>>, ) -> impl Iterator<Item = Result<RepoInfo>>

iterates through all repositories, returning their state.

pub fn get<'i>(&self, did: &Did<'i>) -> RepoHandle<'i>

gets a handle for a repository to read from it.

pub async fn resolve( &self, repo: &AtIdentifier<'_>, ) -> Result<RepoHandle<'static>>

same as ReposControl::get but allows you to pass in an identifier that can be either a handle or a DID.

pub async fn info(&self, did: &Did<'_>) -> Result<Option<RepoInfo>>

fetch the current state of a repository. returns None if hydrant has never seen this repository.

Trait Implementations

impl Clone for ReposControl

fn clone(&self) -> ReposControl

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.