Struct Priority 

pub struct Priority<DS> {
    instance_name: String,
    services: BTreeMap<Prio, DS>,
}

Holds references to many different directory services, each with an associated priority. Read requests try services sequentially, sorted by their priority, ascending. Any error in a service bubbles up. Write requests are not implemented.

Fields

instance_name: String

services: BTreeMap<Prio, DS>

The services, keyed by their priority.

Implementations

impl<DS> Priority<DS>

pub fn new<I: IntoIterator<Item = (Prio, DS)>>( instance_name: String, iter: I, ) -> Priority<DS>

Construct from an iterator of priorities and services. Services with the same priority are converted to a race combinator.

Trait Implementations

impl<DS> DirectoryService for Priority<DS>

where DS: DirectoryService,

fn get<'life0, 'life1, 'async_trait>( &'life0 self, digest: &'life1 B3Digest, ) -> Pin<Box<dyn Future<Output = Result<Option<Directory>, Error>> + Send + 'async_trait>>

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

Looks up a single Directory message by its digest. The returned Directory message must be valid. In case the directory is not found, Ok(None) is returned.

fn get_recursive( &self, root_directory_digest: &B3Digest, ) -> BoxStream<'_, Result<Directory, Error>>

Looks up a closure of Directory. Ideally this would be a impl Stream<Item = Result<Directory, Error>>, and we’d be able to add a default implementation for it here, but we can’t have that yet.

fn put<'life0, 'async_trait>( &'life0 self, _directory: Directory, ) -> Pin<Box<dyn Future<Output = Result<B3Digest, Error>> + Send + 'async_trait>>

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

Uploads a single Directory message, and returns the calculated digest, or an error. An error must also be returned if the message is not valid.

fn put_multiple_start(&self) -> Box<dyn DirectoryPutter + '_>

Allows persisting a closure of Directory, which is a graph of connected Directory messages.