Struct SessionStoreV2 

pub struct SessionStoreV2 { /* private fields */ }

Implementations

impl SessionStoreV2

pub fn create(root: impl AsRef<Path>, max_segment_bytes: u64) -> Result<Self>

pub fn segment_file_path(&self, segment_seq: u64) -> PathBuf

pub fn index_file_path(&self) -> PathBuf

pub fn append_entry( &mut self, entry_id: impl Into<String>, parent_entry_id: Option<String>, entry_type: impl Into<String>, payload: Value, ) -> Result<OffsetIndexEntry>

pub fn read_segment(&self, segment_seq: u64) -> Result<Vec<SegmentFrame>>

pub fn read_index(&self) -> Result<Vec<OffsetIndexEntry>>

pub fn lookup_entry( &self, target_entry_seq: u64, ) -> Result<Option<SegmentFrame>>

Seek to a specific entry by entry_seq using the offset index. Returns None if the entry is not found.

pub fn read_entries_from( &self, from_entry_seq: u64, ) -> Result<Vec<SegmentFrame>>

Read all entries with entry_seq >= from_entry_seq (tail reading).

pub fn read_all_entries(&self) -> Result<Vec<SegmentFrame>>

Read all entries across all segments in entry_seq order.

pub fn read_tail_entries(&self, count: u64) -> Result<Vec<SegmentFrame>>

Read the last count entries by entry_seq using the offset index.

pub fn read_active_path(&self, leaf_entry_id: &str) -> Result<Vec<SegmentFrame>>

Read entries on the active branch from leaf_entry_id back to root. Returns frames in root→leaf order.

pub const fn entry_count(&self) -> u64

Total number of entries appended so far.

pub fn head(&self) -> Option<StoreHead>

Current head position, or None if the store is empty.

pub fn create_checkpoint( &self, checkpoint_seq: u64, reason: &str, ) -> Result<Checkpoint>

Create a checkpoint snapshot at the current head.

pub fn read_checkpoint(&self, checkpoint_seq: u64) -> Result<Option<Checkpoint>>

Read a checkpoint by sequence number.

pub fn append_migration_event(&self, event: MigrationEvent) -> Result<()>

pub fn read_migration_events(&self) -> Result<Vec<MigrationEvent>>

pub fn rollback_to_checkpoint( &mut self, checkpoint_seq: u64, migration_id: impl Into<String>, correlation_id: impl Into<String>, ) -> Result<MigrationEvent>

pub fn write_manifest( &self, session_id: impl Into<String>, source_format: impl Into<String>, ) -> Result<Manifest>

pub fn read_manifest(&self) -> Result<Option<Manifest>>

pub fn chain_hash(&self) -> &str

pub const fn total_bytes(&self) -> u64

pub fn index_summary(&self) -> Result<Option<IndexSummary>>

pub fn rebuild_index(&mut self) -> Result<u64>

Rebuild the offset index by scanning all segment files. This is the recovery path when the index is missing or corrupted.

pub fn validate_integrity(&self) -> Result<()>

Trait Implementations

impl Clone for SessionStoreV2

fn clone(&self) -> SessionStoreV2

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SessionStoreV2

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.