Struct BlobRouter 

pub struct BlobRouter { /* private fields */ }

One adaptive read router. Routes remain opaque and own any peer sets behind them; the router only orders route identities and bounds route attempts.

Implementations

impl BlobRouter

pub fn new( routes: Vec<BlobRouteEntry>, cache: Option<Arc<dyn Store>>, config: BlobRouterConfig, ) -> Result<Self, StoreError>

pub async fn set_routes( &self, routes: Vec<BlobRouteEntry>, ) -> Result<(), StoreError>

Replace the route set. Outcome state survives only when both identity and the exact route allocation are unchanged; provider replacement is therefore immediately eligible for recovery.

pub async fn route_count(&self) -> usize

pub async fn outcomes( &self, ) -> HashMap<BlobRouteIdentity, BlobRouteOutcomeSnapshot>

pub async fn get( &self, hash: &Hash, preferred: Option<&[BlobRouteIdentity]>, ) -> Result<Option<Vec<u8>>, StoreError>

pub async fn get_request( &self, request: BlobRequest, preferred: Option<&[BlobRouteIdentity]>, outer_context: Option<BlobRouteContext>, ) -> Result<Option<Vec<u8>>, StoreError>

Trait Implementations

impl BlobRoute for BlobRouter

fn route<'life0, 'async_trait>( &'life0 self, request: BlobRequest, ) -> Pin<Box<dyn Future<Output = Result<BlobReply, StoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn route_with_context<'life0, 'async_trait>( &'life0 self, request: BlobRequest, context: BlobRouteContext, ) -> Pin<Box<dyn Future<Output = Result<BlobReply, StoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,