Struct StorageChunkManager 

pub struct StorageChunkManager {
    pub objects: HashMap<u64, ChunkedObject>,
    pub next_object_id: u64,
    pub chunk_size_bytes: u64,
}

Manages splitting large data objects into fixed-size chunks and tracking their metadata for streaming reads and writes.

Fields

objects: HashMap<u64, ChunkedObject>

Map from object_id to its chunked representation.

next_object_id: u64

Counter for assigning monotonically increasing object IDs.

chunk_size_bytes: u64

Default chunk size in bytes (1 MB).

Implementations

impl StorageChunkManager

pub fn new(chunk_size_bytes: u64) -> Self

Creates a new StorageChunkManager with the given chunk size.

pub fn create_object(&mut self, total_size_bytes: u64) -> u64

Splits a data object of total_size_bytes into chunks and registers it.

Returns the assigned object_id.

pub fn mark_written(&mut self, object_id: u64, chunk_index: u32) -> bool

Sets the specified chunk to Written. Returns false if not found.

pub fn mark_verified(&mut self, object_id: u64, chunk_index: u32) -> bool

Sets the specified chunk to Verified. Returns false if not found.

pub fn mark_failed(&mut self, object_id: u64, chunk_index: u32) -> bool

Sets the specified chunk to Failed. Returns false if not found.

pub fn get_object(&self, object_id: u64) -> Option<&ChunkedObject>

Returns a reference to the ChunkedObject if it exists.

pub fn pending_chunks(&self, object_id: u64) -> Vec<&Chunk>

Returns all Pending chunks for the given object, sorted by chunk_index.

pub fn delete_object(&mut self, object_id: u64) -> bool

Removes the object from the manager. Returns true if it existed.

pub fn stats(&self) -> ChunkManagerStats

Returns aggregate statistics over all tracked objects.