Struct DaemonStorage 

pub struct DaemonStorage { /* private fields */ }

Main storage wrapper for the daemon.

Implementations

impl DaemonStorage

pub fn open(storage_path: &PathBuf) -> Result<Self>

Open or create the storage database.

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

Clear all data (for testing or reset).

pub fn save_test_node(&self, node: &TestNode) -> Result<()>

Save a test node to inventory.

pub fn save_test_nodes_batch(&self, nodes: &[TestNode]) -> Result<()>

Save multiple test nodes to inventory in a batch (much faster than individual saves).

pub fn load_test_node(&self, node_id: &str) -> Result<Option<TestNode>>

Load a test node from inventory.

pub fn get_all_inventory(&self) -> Result<Vec<TestNode>>

Get all test nodes in inventory.

pub fn inventory_count(&self) -> usize

Get inventory count.

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

Clear inventory.

pub fn save_native_test(&self, node: &NativeTestNode) -> Result<()>

Save a native test node.

pub fn save_native_tests_batch(&self, nodes: &[NativeTestNode]) -> Result<()>

Save multiple native test nodes in a batch (much faster than individual saves).

pub fn load_native_test(&self, node_id: &str) -> Result<Option<NativeTestNode>>

Load a native test node.

pub fn get_all_native_tests(&self) -> Result<Vec<NativeTestNode>>

Get all native tests.

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

Clear native tests.

pub fn save_flakiness_record(&self, record: &FlakinessRecord) -> Result<()>

Save flakiness record.

pub fn load_flakiness_record( &self, node_id: &str, ) -> Result<Option<FlakinessRecord>>

Load flakiness record.

pub fn get_all_flakiness(&self) -> Result<Vec<FlakinessRecord>>

Get all flakiness records.

pub fn delete_flakiness_record(&self, node_id: &str) -> Result<()>

Delete flakiness record.

pub fn save_fixture( &self, context_id: &str, fixture: &FixtureState, ) -> Result<()>

Save fixture state.

pub fn load_fixture( &self, context_id: &str, name: &str, ) -> Result<Option<FixtureState>>

Load fixture state.

pub fn get_context_fixtures( &self, context_id: &str, ) -> Result<Vec<FixtureState>>

Get all fixtures for a context.

pub fn delete_fixture(&self, context_id: &str, name: &str) -> Result<()>

Delete fixture.

pub fn clear_context_fixtures(&self, context_id: &str) -> Result<()>

Clear all fixtures for a context.

pub fn save_duration_history( &self, node_id: &str, durations: &[u64], ) -> Result<()>

Save duration history for a test.

pub fn load_duration_history(&self, node_id: &str) -> Result<Option<Vec<u64>>>

Load duration history for a test.

pub fn get_average_duration(&self, node_id: &str) -> Result<Option<u64>>

Get average duration for a test.

pub fn save_duration_history_batch( &self, histories: &[(&str, &[u64])], ) -> Result<()>

Save duration history for multiple tests in a batch (much faster than individual saves).

pub fn save_scheduled_test(&self, test: &ScheduledTest) -> Result<()>

Save scheduled test.

pub fn get_all_scheduled_tests(&self) -> Result<Vec<ScheduledTest>>

Load all scheduled tests.

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

Clear scheduler.

pub fn save_context(&self, context_id: &str, data: &Value) -> Result<()>

Save context metadata (simple string map).

pub fn load_context(&self, context_id: &str) -> Result<Option<Value>>

Load context metadata.

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

Get all context IDs.

pub fn delete_context(&self, context_id: &str) -> Result<()>

Delete context.

pub fn save_config(&self, key: &str, value: &Value) -> Result<()>

Save config value.

pub fn load_config(&self, key: &str) -> Result<Option<Value>>

Load config value.

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

Flush to disk.

pub fn evict_old_data(&self, _max_age_days: u32) -> Result<usize>

Evict old data that hasn’t been accessed in max_age_days. Returns the number of records removed.

pub fn compact_async(&self)

Trigger background compaction to reclaim disk space.

pub fn db(&self) -> &Db

Get the internal database for advanced operations.

Trait Implementations

impl Clone for DaemonStorage

fn clone(&self) -> DaemonStorage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DaemonStorage

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

Formats the value using the given formatter.