Struct InfraApi 

pub struct InfraApi { /* private fields */ }

Infrastructure system calls.

Implementations

impl InfraApi

pub fn new( git_layer: Arc<GitLayer>, scheduler: Arc<AgentScheduler>, cron_scheduler: Arc<CronScheduler>, resource_monitor: Arc<ResourceMonitor>, event_bus: EventBus, config: OxiosConfig, start_time: Instant, ) -> Self

Create a new InfraApi.

pub fn git(&self) -> &GitLayer

Get a reference to the GitLayer.

pub fn git_log(&self, max: usize) -> Result<Vec<LogEntry>>

Get commit log.

pub fn git_tag(&self, name: &str, message: &str) -> Result<()>

Tag current state.

pub fn git_restore(&self, path: &str, hash: &str) -> Result<()>

Restore file from commit.

pub fn git_verify(&self) -> Result<bool>

Verify git repository integrity.

pub fn git_tags(&self) -> Result<Vec<String>>

List git tags.

pub fn scheduler_stats(&self) -> SchedulerStats

Get scheduler stats.

pub fn queued_tasks(&self) -> Vec<ScheduledTask>

Get queued tasks.

pub fn running_tasks(&self) -> Vec<ScheduledTask>

Get running tasks.

pub async fn add_cron(&self, job: CronJob) -> Result<Uuid>

Add a cron job.

pub fn get_cron(&self, id: Uuid) -> Option<CronJob>

Get a cron job by ID.

pub async fn update_cron(&self, id: Uuid, update: CronJobUpdate) -> Result<()>

Update a cron job.

pub async fn remove_cron(&self, id: Uuid) -> Result<()>

Remove a cron job by ID.

pub fn trigger_cron(&self, id: Uuid) -> Result<CronJob>

Trigger a cron job manually.

pub async fn complete_cron(&self, id: Uuid, success: bool, summary: String)

Mark cron job completed.

pub fn list_crons(&self) -> Vec<CronJob>

List all cron jobs.

pub fn resource_snapshot(&self) -> ResourceSnapshot

Get resource snapshot.

pub fn resource_history(&self, last_n: usize) -> Vec<ResourceSnapshot>

Get resource history snapshots.

pub fn is_overloaded(&self) -> bool

Check if system is overloaded.

pub fn subscribe(&self) -> Receiver<KernelEvent>

Subscribe to kernel events.

pub fn publish(&self, event: KernelEvent) -> Result<()>

Publish a kernel event.

pub fn config(&self) -> &OxiosConfig

Get config reference.

pub fn scheduler(&self) -> &Arc<AgentScheduler>

Scheduler reference — for hot-reload config propagation.

pub fn resource_monitor(&self) -> &Arc<ResourceMonitor>

Resource monitor reference — for hot-reload config propagation.

pub fn update_orchestrator_config(&self, config: OrchestratorConfig)

Hot-reload orchestrator config (stored in InfraApi for propagation).

pub fn uptime(&self) -> Duration

Get system uptime.