Struct CsvHandleResolver 

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

Available on crate features csv and std only.

A CSV file resolver from ASIMOV handles to peer IDs.

The format of the CSV file is simply handle,peer_id. The records should be sorted for efficient resolution. The file is read line-by-line, so it can be very large.

Implementations

impl CsvHandleResolver

pub async fn open(path: &str) -> Result<Self>

Opens a CSV file for resolving ASIMOV handles.

pub fn handles(&mut self) -> impl Stream<Item = Result<Handle>> + Send

pub fn records(&mut self) -> impl Stream<Item = Result<(Handle, PeerId)>> + Send

Trait Implementations

impl From<AsyncReader<File>> for CsvHandleResolver

fn from(reader: AsyncReader<File>) -> Self

Converts to this type from the input type.

impl ResolveHandle for CsvHandleResolver

fn resolve_handle( &mut self, handle: impl Into<Handle>, ) -> impl Stream<Item = Result<PeerId>> + Send

Resolves a handle into a set of endpoint IDs.

type Error = Error

fn resolve_random( &mut self, id: impl Into<Id>, ) -> impl Future<Output = Result<Option<PeerId>, Self::Error>>

Resolves an ASIMOV ID and yields a random known peer ID. Ignores any erroneous results, sampling from only successful results.

fn resolve_first( &mut self, id: impl Into<Id>, ) -> impl Future<Output = Result<Option<PeerId>, Self::Error>>

Resolves an ASIMOV ID and yields only the first known peer ID. Ignores any initial erroneous results, returning the first successful result.

fn resolve_all( &mut self, id: impl Into<Id>, ) -> impl Stream<Item = Result<PeerId, Self::Error>> + Send

Resolves an ASIMOV ID into a stream of all known peer IDs.