Struct Archive 

pub struct Archive { /* private fields */ }

Archive for reading/writing AGC data

Implementations

impl Archive

pub fn new_reader() -> Self

Create a new archive in input (read) mode

pub fn new_writer() -> Self

Create a new archive in output (write) mode

pub fn open<P: AsRef<Path>>(&mut self, path: P) -> Result<()>

Open an archive file

pub fn close(&mut self) -> Result<()>

Close the archive (writes footer in write mode)

pub fn register_stream(&mut self, stream_name: &str) -> usize

Register a new stream and return its ID

pub fn get_stream_id(&self, stream_name: &str) -> Option<usize>

Get stream ID by name (returns None if not found)

pub fn get_stream_names(&self) -> Vec<String>

Get list of all stream names

pub fn add_part( &mut self, stream_id: usize, data: &[u8], metadata: u64, ) -> Result<()>

Add a part to a stream

pub fn add_part_buffered( &mut self, stream_id: usize, data: Vec<u8>, metadata: u64, )

Buffer a part for later writing (C++ AGC: AddPartBuffered) This allows parallel compression while maintaining deterministic write order. Call flush_buffers() after all parts are buffered to write in sorted stream_id order.

pub fn flush_buffers(&mut self) -> Result<()>

Flush all buffered parts to disk in sorted stream_id order (C++ AGC: flush_out_buffers) This ensures deterministic output regardless of which thread buffered the data.

pub fn set_raw_size(&mut self, stream_id: usize, raw_size: u64)

Set raw (uncompressed) size for a stream

pub fn get_raw_size(&self, stream_id: usize) -> u64

Get raw size for a stream

pub fn get_packed_size(&self, stream_id: usize) -> u64

Get packed (compressed) size for a stream

pub fn get_packed_data_size(&self, stream_id: usize) -> u64

Get packed data size (compressed data only, without metadata)

pub fn get_stream_name(&self, stream_id: usize) -> Option<&str>

Get stream name by ID

pub fn get_num_streams(&self) -> usize

Get number of streams

pub fn get_num_parts(&self, stream_id: usize) -> usize

Get number of parts in a stream

pub fn get_part(&mut self, stream_id: usize) -> Result<Option<(Vec<u8>, u64)>>

Get the next part from a stream (sequential reading)

pub fn get_part_by_id( &mut self, stream_id: usize, part_id: usize, ) -> Result<(Vec<u8>, u64)>

Get a specific part by ID from a stream (random access)

Trait Implementations

impl Drop for Archive

fn drop(&mut self)

Executes the destructor for this type.