Struct ReconciliationController 

pub struct ReconciliationController { /* private fields */ }

Reconciliation controller: desired state vs actual state.

Registered as a SystemService with ServiceType::Core. Runs a background tick every interval to detect and correct drift between desired and actual process states.

Implementations

impl ReconciliationController

pub fn new( process_table: Arc<ProcessTable>, interval: Duration, ) -> ReconciliationController

Create a new reconciliation controller.

pub fn set_chain_manager(&mut self, cm: Arc<ChainManager>)

Attach a chain manager for exochain audit logging.

pub fn interval(&self) -> Duration

Get the tick interval.

pub fn set_desired(&self, key: String, state: DesiredAgentState)

Set desired state for an agent.

pub fn remove_desired(&self, key: &str) -> Option<DesiredAgentState>

Remove desired state for an agent.

pub fn list_desired(&self) -> Vec<DesiredAgentState>

Get all desired states.

pub async fn recent_drifts(&self) -> Vec<DriftEvent>

Get recent drift events.

pub async fn tick(&self) -> Vec<DriftEvent>

Run a single reconciliation tick.

Compares desired state against process table and returns detected drifts. Does NOT take corrective action (that requires a supervisor reference and governance gate).

pub async fn record_action(&self, event: DriftEvent)

Record a corrective action in drift history.

pub fn clear_desired(&self)

Clear all desired state (used during shutdown).

pub fn desired_count(&self) -> usize

Get the number of desired agent entries.