Struct InMemoryBackend 

pub struct InMemoryBackend;

No-op storage backend — all writes succeed, all loads return empty. Used when no DATABASE_URL is configured (development/testing).

Implementations

impl InMemoryBackend

pub fn new() -> Self

Trait Implementations

impl StorageBackend for InMemoryBackend

async fn save_trace(&self, _trace: &TraceRow) -> Result<(), StorageError>

async fn load_traces( &self, _limit: usize, _offset: usize, ) -> Result<Vec<TraceRow>, StorageError>

async fn get_trace( &self, _trace_id: u64, ) -> Result<Option<TraceRow>, StorageError>

async fn delete_traces(&self, _ids: &[u64]) -> Result<u64, StorageError>

async fn save_session(&self, _entry: &SessionRow) -> Result<(), StorageError>

async fn load_sessions( &self, _scope: &str, ) -> Result<Vec<SessionRow>, StorageError>

async fn delete_session( &self, _scope: &str, _key: &str, ) -> Result<bool, StorageError>

async fn save_daemon(&self, _daemon: &DaemonRow) -> Result<(), StorageError>

async fn load_daemons(&self) -> Result<Vec<DaemonRow>, StorageError>

async fn delete_daemon(&self, _name: &str) -> Result<bool, StorageError>

async fn append_audit(&self, _entry: &AuditRow) -> Result<(), StorageError>

async fn query_audit( &self, _limit: usize, ) -> Result<Vec<AuditRow>, StorageError>

async fn save_axon_store( &self, _store: &AxonStoreRow, ) -> Result<(), StorageError>

async fn load_axon_stores(&self) -> Result<Vec<AxonStoreRow>, StorageError>

async fn delete_axon_store(&self, _name: &str) -> Result<bool, StorageError>

async fn save_dataspace(&self, _ds: &DataspaceRow) -> Result<(), StorageError>

async fn load_dataspaces(&self) -> Result<Vec<DataspaceRow>, StorageError>

async fn delete_dataspace(&self, _name: &str) -> Result<bool, StorageError>

async fn save_hibernation( &self, _session: &HibernationRow, ) -> Result<(), StorageError>

async fn load_hibernations(&self) -> Result<Vec<HibernationRow>, StorageError>

async fn append_event(&self, _event: &EventRow) -> Result<(), StorageError>

async fn query_events( &self, _topic: Option<&str>, _limit: usize, ) -> Result<Vec<EventRow>, StorageError>

async fn save_cache_entry(&self, _entry: &CacheRow) -> Result<(), StorageError>

async fn load_cache_entries(&self) -> Result<Vec<CacheRow>, StorageError>

async fn evict_expired_cache(&self) -> Result<u64, StorageError>

async fn record_cost(&self, _cost: &CostRow) -> Result<(), StorageError>

async fn query_costs( &self, _flow: Option<&str>, _limit: usize, ) -> Result<Vec<CostRow>, StorageError>

async fn save_schedule( &self, _schedule: &ScheduleRow, ) -> Result<(), StorageError>

async fn load_schedules(&self) -> Result<Vec<ScheduleRow>, StorageError>

async fn delete_schedule(&self, _name: &str) -> Result<bool, StorageError>

async fn is_healthy(&self) -> bool