Struct StorageManager 

pub struct StorageManager {
    pub meta: PouchMeta,
    pub index: FragmentIndex,
    /* private fields */
}

Manages on-disk storage for a single Pouch service instance.

One StorageManager exists per active Pouch service. It is held inside DaemonState (wrapped in Arc<RwLock<StorageManager>>) alongside the service registry.

Fields

meta: PouchMeta

Persistent quota and usage tracking.

index: FragmentIndex

In-memory fragment index (rebuilt from disk on load).

Implementations

impl StorageManager

pub fn init( network_id: String, service_id: String, storage_bytes_bid: u64, ) -> BpResult<Self>

Initialise a brand-new Pouch storage directory.

Creates the directory structure, writes meta.json, and returns a manager with an empty fragment index.

Errors

Fails if disk I/O fails or the XDG base directory cannot be resolved.

pub fn load(network_id: &str, service_id: &str) -> BpResult<Self>

Load an existing Pouch storage directory from disk.

Reads meta.json and rebuilds the fragment index by scanning the fragments/ subdirectory.

pub fn store_fragment(&mut self, fragment: &EncodedFragment) -> BpResult<()>

Persist an encoded fragment to disk and update the index.

Returns an error if the Pouch does not have enough remaining capacity.

pub fn load_fragment( &self, chunk_id: &str, fragment_id: &str, ) -> BpResult<EncodedFragment>

Load a fragment from disk by chunk_id and fragment_id.

pub fn remove_fragment( &mut self, chunk_id: &str, fragment_id: &str, ) -> BpResult<()>

Remove a fragment from disk and update the index.

pub fn recode_chunk( &self, chunk_id: &str, count: usize, ) -> BpResult<Vec<EncodedFragment>>

Generate count new fragments for chunk_id by recoding the local ones.

This is the key operation for filling new Pouches: no decoding is performed, no original data is required.

Returns an error if this Pouch holds no fragments for the given chunk.

pub fn has_capacity(&self, bytes: u64) -> bool

Whether this Pouch has remaining capacity for bytes more data.

pub fn root(&self) -> &Path

Root directory of this Pouch’s storage.

pub fn purge(&self) -> BpResult<()>

Permanently delete all on-disk storage for this Pouch.

Removes the entire storage directory (fragments/, meta.json, etc.). Call only after the service has been removed from ServiceRegistry.

pub fn storage_summary(&self) -> (usize, usize, u64)

Summary of what is stored: (chunk_count, fragment_count, total_bytes).