Struct CommitSources 

pub struct CommitSources { /* private fields */ }

Ordered labelled sources tried until one returns bytes. A miss or error moves to the next source; the set errors only when every source errored. The error table is locked only to read or write, never across a fetch.

Implementations

impl CommitSources

pub fn new(chain: Chain) -> Self

pub fn push( &mut self, label: String, source: Box<dyn CommitSource + Send + Sync>, )

pub fn is_empty(&self) -> bool

pub fn probe(&self) -> Result<(), Error>

Run each source’s own rate-limited, bounded liveness check and record the outcome. The maintenance thread calls this; status never does.

pub fn status(&self) -> Result<Vec<CommitSourceStatus>, Error>

Recorded outcomes of the latest lookups and probes; no I/O.

Trait Implementations

impl CommitSource for CommitSources

fn chain(&self) -> Chain

fn fetch( &self, txid: Txid, cancelled: &AtomicBool, ) -> Result<Option<Vec<u8>>, Error>

fn probe(&self) -> Option<Result<(), Error>>

A bounded liveness check, rate-limited by the source itself and run by the maintenance thread, never by status. None when no fresh check ran (or the source has none); otherwise its result.