Struct Race 

pub struct Race<DS> {
    instance_name: String,
    services: Vec<DS>,
}

Holds references to multiple directory services. Read requests try services in parallel. The first positive response is returned (Ok(None) does only bubble up if all backends return this) Write requests are not implemented.

Fields

instance_name: String

services: Vec<DS>

Implementations

impl<DS> Race<DS>

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

Construct from an iterator of services.

pub fn add(&mut self, svc: DS)

Add another sevice to the list.

Trait Implementations

impl<DS> DirectoryService for Race<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.