Struct DiskPieceCache 

pub struct DiskPieceCache { /* private fields */ }

Dedicated piece cache stored on one disk, is used both to accelerate DSN queries and to plot faster.

Implementation is backed by a file on disk.

Implementations

impl DiskPieceCache

pub fn open( directory: &Path, capacity: NonZeroU32, id: Option<PieceCacheId>, registry: Option<&mut Registry>, ) -> Result<Self, DiskPieceCacheError>

Open cache, capacity is measured in elements of DiskPieceCache::element_size() size

pub const fn element_size() -> u32

Size of a single piece cache element

Trait Implementations

impl Clone for DiskPieceCache

fn clone(&self) -> DiskPieceCache

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DiskPieceCache

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

Formats the value using the given formatter.

impl PieceCache for DiskPieceCache

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.