Struct CanonicalKernelHost 

pub struct CanonicalKernelHost { /* private fields */ }

The typed prepare → append → commit host boundary for one operation.

Implementations

impl CanonicalKernelHost

pub fn new( kernel: CanonicalKernel, journal: Arc<dyn KernelJournal>, operation_id: impl Into<String>, ) -> Result<Self>

pub fn operation_id(&self) -> &str

pub fn journal(&self) -> &Arc<dyn KernelJournal>

pub fn lifecycle(&self) -> OperationLifecycle

pub fn pending_effects(&self) -> Vec<KernelEffect>

pub fn terminal(&self) -> Option<KernelTerminal>

pub fn attempt_id(&self, task_id: &str) -> Option<String>

pub fn turn(&self) -> u32

pub fn recovery_content_bytes(&self) -> Option<usize>

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

pub fn count_tokens(&self, text: &str) -> Option<u32>

pub fn local_subagents_spawned(&self) -> usize

pub fn new_messages(&self) -> Vec<Message>

pub async fn transition( &self, envelope: WireEnvelope, ) -> Result<CanonicalTransition>

Stage the exact serialized typed envelope before attempting its durable append.

pub async fn drain_outbound_envelope( &self, ) -> Result<Option<CanonicalTransition>>

Replays an append-window envelope byte-for-byte after a wake.

pub async fn restore(&self) -> Result<()>

Restore the typed kernel solely from the durable journal.

pub async fn checkpoint(&self) -> Result<InstalledCheckpoint>

Execute the install → acknowledge → reclaim checkpoint boundary.

pub fn next_observed_at_ms() -> u64

pub async fn transition_input( &self, input: Value, ) -> Result<CanonicalTransition>

Build a typed envelope from a JSON wire input object (the five-class taxonomy).

pub async fn transition_input_correlated( &self, input: Value, input_id: impl Into<String>, observed_at_ms: u64, ) -> Result<CanonicalTransition>

Build a typed envelope with caller-owned identity and observation time.

Durable hosts use this entry point when the input already has a stable delivery identity. Retrying the same input must reuse both values so core can distinguish replay from conflict.