Struct ClusterPieceCache 

pub struct ClusterPieceCache { /* private fields */ }

Cluster cache implementation

Implementations

impl ClusterPieceCache

pub fn new( piece_cache_id: PieceCacheId, max_num_elements: u32, nats_client: NatsClient, ) -> ClusterPieceCache

Create a new instance using information from previously received ClusterCacheIdentifyBroadcast

Trait Implementations

impl Debug for ClusterPieceCache

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

Formats the value using the given formatter.

impl PieceCache for ClusterPieceCache

fn id(&self) -> &PieceCacheId

ID of this cache

fn max_num_elements(&self) -> u32

Max number of elements in this cache

fn contents<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn Stream<Item = Result<(PieceCacheOffset, Option<PieceIndex>), FarmError>> + Unpin + Send + '_>, FarmError>> + Send + 'async_trait>>

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

Contents of this piece cache.

fn write_piece<'life0, 'life1, 'async_trait>( &'life0 self, offset: PieceCacheOffset, piece_index: PieceIndex, piece: &'life1 Piece, ) -> Pin<Box<dyn Future<Output = Result<(), FarmError>> + Send + 'async_trait>>

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

Store piece in cache at specified offset, replacing existing piece if there is one.

fn read_piece_index<'life0, 'async_trait>( &'life0 self, offset: PieceCacheOffset, ) -> Pin<Box<dyn Future<Output = Result<Option<PieceIndex>, FarmError>> + Send + 'async_trait>>

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

Read piece index from cache at specified offset.

fn read_piece<'life0, 'async_trait>( &'life0 self, offset: PieceCacheOffset, ) -> Pin<Box<dyn Future<Output = Result<Option<(PieceIndex, Piece)>, FarmError>> + Send + 'async_trait>>

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

Read piece from cache at specified offset.

fn read_pieces<'life0, 'async_trait>( &'life0 self, offsets: Box<dyn Iterator<Item = PieceCacheOffset> + Send>, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn Stream<Item = Result<(PieceCacheOffset, Option<(PieceIndex, Piece)>), FarmError>> + Send + Unpin + '_>, FarmError>> + Send + 'async_trait>>

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

Read pieces from cache at specified offsets.