Struct AgentKernel 

pub struct AgentKernel<H>
where
    H: AgentMessageHandler + 'static,
{ /* private fields */ }

Core runtime that wires lifecycle, scheduler, and MXP handlers.

Implementations

impl<H> AgentKernel<H>

where H: AgentMessageHandler + 'static,

pub fn new(agent_id: AgentId, handler: Arc<H>, scheduler: TaskScheduler) -> Self

Creates a new agent kernel with the provided handler and scheduler.

pub fn set_registry<R>( &mut self, registry: Arc<R>, manifest: AgentManifest, config: RegistrationConfig, )

where R: AgentRegistry + 'static,

Provides registry integration for mesh discovery and heartbeat management.

pub const fn agent_id(&self) -> AgentId

Returns the identifier associated with this agent.

pub fn state(&self) -> AgentState

Returns the current lifecycle state.

pub fn transition(&mut self, event: LifecycleEvent) -> KernelResult<AgentState>

Applies a lifecycle event, returning the new state on success.

Errors

Returns LifecycleError when the transition is not permitted from the current state.

pub async fn handle_message(&self, message: Message) -> HandlerResult

Handles an MXP message immediately on the current task.

Errors

Propagates any error returned by the message handler implementation.

pub fn schedule_message( &self, message: Message, ) -> SchedulerResult<JoinHandle<HandlerResult>>

Enqueues an MXP message for asynchronous processing via the scheduler.

Errors

Returns SchedulerError when the scheduler has been closed.

pub fn scheduler(&self) -> &TaskScheduler

Returns a reference to the underlying scheduler.

Trait Implementations

impl<H> Debug for AgentKernel<H>

where H: AgentMessageHandler + 'static + Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.