Struct AdminView 

pub struct AdminView<'a>(/* private fields */);

Admin operations: statistics, compaction, maintenance, and agent management.

Implementations

impl<'a> AdminView<'a>

pub fn mutation_write_contracts(&self) -> &'static [MutationWriteContract]

Return the product-level write guarantee table used by diagnostics and docs.

pub async fn stats(&self) -> HirnResult<DbStats>

Get aggregate database statistics.

pub async fn count(&self) -> HirnResult<LayerCounts>

Get per-layer record counts.

pub fn consolidate(&self) -> ConsolidateBuilder<'a>

Start building a consolidation operation.

pub fn lifecycle_compact(&self) -> LifecycleCompactBuilder<'a>

Start building a lifecycle compaction operation.

pub async fn apply_resource_retention_policy( &self, policy: &ResourceRetentionPolicy, ) -> HirnResult<ResourceRetentionApplyResult>

Apply a specific resource retention policy to active resource heads.

pub async fn apply_configured_resource_retention( &self, ) -> HirnResult<ResourceRetentionApplyResult>

Apply the configured resource retention policy from HirnConfig.

pub async fn audit_log( &self, after: Option<&Timestamp>, before: Option<&Timestamp>, ) -> HirnResult<Vec<AuditEntry>>

Query the audit log.

pub async fn cross_agent_consolidate( &self, target_namespace: &Namespace, auto_merge_threshold: f32, ) -> HirnResult<CrossAgentConsolidationResult>

Consolidate semantic records across agents in a namespace.

pub async fn purge_agent(&self, agent_id: &AgentId) -> HirnResult<PurgeReport>

Purge all data associated with an agent (GDPR Right to Erasure).

pub async fn schedule_offline_job( &self, job: CognitiveJob, ) -> HirnResult<OfflineJobId>

Queue a budgeted offline cognition job.

pub fn offline_job_status( &self, job_id: OfflineJobId, ) -> Option<OfflineJobStatus>

Inspect the latest in-memory status for an offline cognition job.

pub async fn inspect_offline_job( &self, job_id: OfflineJobId, ) -> HirnResult<Option<OfflineJobInspection>>

Inspect durable audit history and latest state for an offline cognition job.

pub async fn retry_offline_job( &self, job_id: OfflineJobId, ) -> HirnResult<OfflineJobId>

Retry a failed offline cognition job using the configured retry backoff policy.

pub async fn replay_offline_job( &self, job_id: OfflineJobId, ) -> HirnResult<OfflineJobId>

Replay a terminal offline cognition job as a new attempt immediately.

pub fn offline_scheduler_metrics(&self) -> OfflineSchedulerMetrics

Inspect the scheduler counters for queued offline cognition jobs.

pub async fn close(&self) -> HirnResult<()>

Close the database, flushing pending writes.

pub async fn get_memory(&self, id: MemoryId) -> HirnResult<MemoryRecord>

Retrieve a memory record from any layer by ID.

pub async fn get_memories_batch( &self, ids: &[MemoryId], ) -> HirnResult<HashMap<MemoryId, MemoryRecord>>

Batch-retrieve memory records from any layer by IDs.

pub async fn validate_semantic_revisions( &self, ) -> HirnResult<SemanticRevisionIntegrityReport>

Validate semantic revision chains and the runtime semantic head cache.

pub async fn repair_semantic_revisions( &self, ) -> HirnResult<SemanticRevisionRepairReport>

Rebuild the runtime semantic head cache from authoritative semantic storage state.