Struct FarmerPieceGetter 

pub struct FarmerPieceGetter<FarmIndex, PV, NC> { /* private fields */ }

Farmer-specific piece getter.

Implements PieceGetter for plotting purposes, but useful outside of that as well.

Implementations

impl<FarmIndex, PV, NC> FarmerPieceGetter<FarmIndex, PV, NC>

where FarmIndex: Hash + Eq + Copy + Debug + Send + Sync + 'static, usize: From<FarmIndex>, PV: PieceValidator + Send + 'static, NC: NodeClient,

pub fn new( piece_provider: PieceProvider<PV>, farmer_caches: FarmerCaches, node_client: NC, plotted_pieces: Arc<AsyncRwLock<PlottedPieces<FarmIndex>>>, dsn_cache_retry_policy: DsnCacheRetryPolicy, ) -> Self

Create a new instance

pub async fn get_piece_fast(&self, piece_index: PieceIndex) -> Option<Piece>

Fast way to get piece using various caches

pub async fn get_piece_slow(&self, piece_index: PieceIndex) -> Option<Piece>

Slow way to get piece using archival storage

pub fn downgrade(&self) -> WeakFarmerPieceGetter<FarmIndex, PV, NC>

Downgrade to WeakFarmerPieceGetter in order to break reference cycles with internally used Arc

Trait Implementations

impl<FarmIndex, PV, NC> Clone for FarmerPieceGetter<FarmIndex, PV, NC>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<FarmIndex, PV, NC> Debug for FarmerPieceGetter<FarmIndex, PV, NC>

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

Formats the value using the given formatter.

impl<FarmIndex, PV, NC> PieceGetter for FarmerPieceGetter<FarmIndex, PV, NC>

where FarmIndex: Hash + Eq + Copy + Debug + Send + Sync + 'static, usize: From<FarmIndex>, PV: PieceValidator + Send + 'static, NC: NodeClient,

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

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

Get piece by index.

fn get_pieces<'a, 'async_trait>( &'a self, piece_indices: Vec<PieceIndex>, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn Stream<Item = (PieceIndex, Result<Option<Piece>>)> + Send + Unpin + 'a>>> + Send + 'async_trait>>

where Self: 'async_trait, 'a: 'async_trait,

Get pieces with provided indices.