Struct FarmerCaches 

pub struct FarmerCaches { /* private fields */ }

Collection of FarmerCache instances for load balancing

Implementations

impl FarmerCaches

pub async fn get_piece<Key>(&self, key: Key) -> Option<Piece>

where RecordKey: From<Key>,

Get piece from cache

pub async fn get_pieces<'a, PieceIndices>( &'a self, piece_indices: PieceIndices, ) -> impl Stream<Item = (PieceIndex, Option<Piece>)> + Send + Unpin + 'a

where PieceIndices: IntoIterator<Item = PieceIndex, IntoIter: Send + 'a> + Send + 'a,

Get pieces from cache.

Number of elements in returned stream is the same as number of unique piece_indices.

pub async fn has_pieces( &self, piece_indices: Vec<PieceIndex>, ) -> Vec<PieceIndex>

Returns a filtered list of pieces that were found in farmer cache, order is not guaranteed

pub async fn maybe_store_additional_piece( &self, piece_index: PieceIndex, piece: &Piece, ) -> bool

Try to store a piece in additional downloaded pieces, if there is space for it. Returns true if the piece was added to one or more caches, and false if it was already stored, or there was no space.

Trait Implementations

impl Clone for FarmerCaches

fn clone(&self) -> FarmerCaches

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for FarmerCaches

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl From<Arc<[FarmerCache]>> for FarmerCaches

fn from(caches: Arc<[FarmerCache]>) -> Self

Converts to this type from the input type.

impl From<FarmerCache> for FarmerCaches

fn from(cache: FarmerCache) -> Self

Converts to this type from the input type.