Struct ChunkStorage 

pub struct ChunkStorage { /* private fields */ }

Chunk storage manager.

Implementations

impl ChunkStorage

pub async fn new( base_path: PathBuf, max_bytes: u64, ) -> Result<Self, StorageError>

Create a new chunk storage.

pub fn base_path(&self) -> &Path

Get the storage path.

pub fn used_bytes(&self) -> u64

Get current storage usage.

pub fn max_bytes(&self) -> u64

Get maximum storage quota.

pub fn available_bytes(&self) -> u64

Get available storage.

pub fn is_pinned(&self, cid: &str) -> bool

Check if a content is pinned.

pub fn get_pinned_info(&self, cid: &str) -> Option<&PinnedContentInfo>

Get pinned content info.

pub fn list_pinned(&self) -> Vec<&str>

List all pinned content CIDs.

pub async fn pin_content( &mut self, cid: &str, chunks: &[Vec<u8>], key: &EncryptionKey, nonce: &EncryptionNonce, ) -> Result<PinnedContentInfo, StorageError>

Pin new content (store all chunks).

pub async fn get_chunk( &self, cid: &str, chunk_index: u64, ) -> Result<Vec<u8>, StorageError>

Retrieve and decrypt a chunk.

pub async fn get_chunk_verified( &self, cid: &str, chunk_index: u64, ) -> Result<(Vec<u8>, [u8; 32]), StorageError>

Get chunk with verification (returns hash too).

pub async fn get_chunks_batch( &self, cid: &str, chunk_indices: &[u64], ) -> Result<Vec<Vec<u8>>, StorageError>

Batch retrieve multiple chunks concurrently for improved performance.

pub async fn get_chunks_batch_verified( &self, cid: &str, chunk_indices: &[u64], ) -> Result<Vec<(Vec<u8>, [u8; 32])>, StorageError>

Batch retrieve and verify multiple chunks concurrently.

pub async fn unpin_content(&mut self, cid: &str) -> Result<(), StorageError>

Unpin content (remove all chunks).

pub fn stats(&self) -> StorageStats

Get storage statistics.

pub async fn health_check(&self) -> Result<StorageHealthReport, StorageError>

Perform storage health check to verify integrity.

pub async fn repair(&mut self, cid: &str) -> Result<RepairResult, StorageError>

Repair corrupted or missing chunks (requires re-download from network).

pub fn update_health_metrics(&mut self)

Update storage health metrics.

This should be called periodically to track storage health and detect issues early.

pub fn health(&self) -> &StorageHealth

Get current storage health.

pub fn record_io_error(&mut self)

Record an I/O error.

pub fn record_slow_operation(&mut self, latency_ms: u64)

Record a slow operation.

pub fn reset_health_counters(&mut self)

Reset health metrics (typically called after a health check period).

pub fn is_health_concerning(&self) -> bool

Check if storage health is concerning.

impl ChunkStorage

pub fn get_chunk_dir(&self, cid: &str) -> PathBuf

Get chunk directory path (exposed for transactions).

pub async fn write_chunks_for_transaction( &mut self, cid: &str, chunks: &[Vec<u8>], key: &EncryptionKey, nonce: &EncryptionNonce, ) -> Result<Vec<(u64, PathBuf, PathBuf, u64)>, StorageError>

Write chunks for a transaction.

Returns list of (chunk_index, chunk_path, meta_path, size_bytes) for each written chunk.

pub fn decrease_used_bytes(&mut self, bytes: u64)

Decrease used bytes (for transaction rollback).