Struct TensogramFile 

pub struct TensogramFile { /* private fields */ }

A handle for reading/writing Tensogram message files.

Supports local files, memory-mapped files (mmap feature), and remote object stores (remote feature) via a unified API.

Implementations

impl TensogramFile

pub fn open(path: impl AsRef<Path>) -> Result<TensogramFile, TensogramError>

pub fn open_source( source: impl AsRef<str>, ) -> Result<TensogramFile, TensogramError>

Open a local file or remote URL.

Auto-detects remote URLs (s3://, s3a://, gs://, az://, azure://, http://, https://) when the remote feature is enabled; otherwise treats the source as a local path.

pub fn create(path: impl AsRef<Path>) -> Result<TensogramFile, TensogramError>

Create a new local file for writing (truncates if exists).

pub fn message_count(&self) -> Result<usize, TensogramError>

pub fn append( &mut self, global_metadata: &GlobalMetadata, descriptors: &[(&DataObjectDescriptor, &[u8])], options: &EncodeOptions, ) -> Result<(), TensogramError>

pub fn read_message(&self, index: usize) -> Result<Vec<u8>, TensogramError>

pub fn messages(&self) -> Result<Vec<Vec<u8>>, TensogramError>

👎Deprecated:

Use message_count() + read_message(index) for lazy access

pub fn decode_message( &self, index: usize, options: &DecodeOptions, ) -> Result<(GlobalMetadata, Vec<(DataObjectDescriptor, Vec<u8>)>), TensogramError>

pub fn iter(&self) -> Result<FileMessageIter, TensogramError>

pub fn path(&self) -> Option<&Path>

pub fn source(&self) -> String

pub fn invalidate_offsets(&mut self)

pub fn decode_metadata( &self, msg_idx: usize, ) -> Result<GlobalMetadata, TensogramError>

pub fn decode_descriptors( &self, msg_idx: usize, ) -> Result<(GlobalMetadata, Vec<DataObjectDescriptor>), TensogramError>

pub fn decode_object( &self, msg_idx: usize, obj_idx: usize, options: &DecodeOptions, ) -> Result<(GlobalMetadata, DataObjectDescriptor, Vec<u8>), TensogramError>

pub fn decode_range( &self, msg_idx: usize, obj_idx: usize, ranges: &[(u64, u64)], options: &DecodeOptions, ) -> Result<(DataObjectDescriptor, Vec<Vec<u8>>), TensogramError>

pub fn is_remote(&self) -> bool