Struct KernelMessageHandler 

pub struct KernelMessageHandler { /* private fields */ }

Handler implementation that wires the call executor into the MXP handler trait.

Implementations

impl KernelMessageHandler

pub fn new( adapter: Arc<dyn ModelAdapter>, tools: Arc<ToolRegistry>, sink: Arc<dyn CallOutcomeSink>, ) -> Self

Creates a new handler using the provided adapter and registry.

pub fn builder( adapter: Arc<dyn ModelAdapter>, sink: Arc<dyn CallOutcomeSink>, ) -> KernelMessageHandlerBuilder

Creates a builder that automates tool registration and optional components.

pub fn with_memory(self, memory: Arc<MemoryBus>) -> Self

Configures the memory bus used to persist call transcripts.

pub fn set_memory(&mut self, memory: Arc<MemoryBus>)

Installs or replaces the memory bus after construction.

pub fn with_policy(self, policy: Arc<dyn PolicyEngine>) -> Self

Configures the policy engine used to guard tool execution and model inference.

pub fn set_policy(&mut self, policy: Arc<dyn PolicyEngine>)

Installs or replaces the policy engine after construction.

pub fn with_policy_observer(self, observer: Arc<dyn PolicyObserver>) -> Self

Configures the policy observer used to record governance decisions.

pub fn set_policy_observer(&mut self, observer: Arc<dyn PolicyObserver>)

Installs or replaces the policy observer after construction.

pub fn policy_observer(&self) -> Option<&Arc<dyn PolicyObserver>>

Returns the configured policy observer, if any.

pub fn memory(&self) -> Option<&Arc<MemoryBus>>

Returns the configured memory bus, if any.

pub fn executor(&self) -> &CallExecutor

Returns the underlying executor for advanced scenarios.

Trait Implementations

impl AgentMessageHandler for KernelMessageHandler

fn handle_call<'life0, 'async_trait>( &'life0 self, ctx: HandlerContext, ) -> Pin<Box<dyn Future<Output = HandlerResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Called for Call messages.

fn handle_agent_register<'life0, 'async_trait>( &'life0 self, ctx: HandlerContext, ) -> Pin<Box<dyn Future<Output = HandlerResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Called for AgentRegister messages.

fn handle_agent_discover<'life0, 'async_trait>( &'life0 self, ctx: HandlerContext, ) -> Pin<Box<dyn Future<Output = HandlerResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Called for AgentDiscover messages.

fn handle_agent_heartbeat<'life0, 'async_trait>( &'life0 self, ctx: HandlerContext, ) -> Pin<Box<dyn Future<Output = HandlerResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Called for AgentHeartbeat messages.

fn handle_response<'life0, 'async_trait>( &'life0 self, ctx: HandlerContext, ) -> Pin<Box<dyn Future<Output = HandlerResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Called for Response messages.

fn handle_event<'life0, 'async_trait>( &'life0 self, ctx: HandlerContext, ) -> Pin<Box<dyn Future<Output = HandlerResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Called for Event messages.

fn handle_stream_open<'life0, 'async_trait>( &'life0 self, ctx: HandlerContext, ) -> Pin<Box<dyn Future<Output = HandlerResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Called for StreamOpen messages.

fn handle_stream_chunk<'life0, 'async_trait>( &'life0 self, ctx: HandlerContext, ) -> Pin<Box<dyn Future<Output = HandlerResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Called for StreamChunk messages.

fn handle_stream_close<'life0, 'async_trait>( &'life0 self, ctx: HandlerContext, ) -> Pin<Box<dyn Future<Output = HandlerResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Called for StreamClose messages.

fn handle_ack<'life0, 'async_trait>( &'life0 self, ctx: HandlerContext, ) -> Pin<Box<dyn Future<Output = HandlerResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Called for Ack messages.

fn handle_error<'life0, 'async_trait>( &'life0 self, ctx: HandlerContext, ) -> Pin<Box<dyn Future<Output = HandlerResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Called for protocol-level error responses.

fn handle_unhandled<'life0, 'async_trait>( &'life0 self, ctx: HandlerContext, message_type: MessageType, ) -> Pin<Box<dyn Future<Output = HandlerResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Fallback invoked when a specialized handler is not implemented.