Struct MessageProcessor 

pub struct MessageProcessor { /* private fields */ }

Implementations

impl MessageProcessor

pub async fn handle_message( &self, message: Message, agent_name: &str, context: &RequestContext, ) -> Result<Task>

impl MessageProcessor

pub fn new(db_pool: DbPool, ai_service: Arc<dyn AiProvider>) -> Result<Self>

pub async fn load_agent_runtime( &self, agent_name: &str, ) -> Result<AgentRuntimeInfo>

pub async fn persist_completed_task( &self, task: &Task, user_message: &Message, agent_message: &Message, context: &RequestContext, _agent_name: &str, artifacts_already_published: bool, ) -> Result<Task>

pub async fn process_message_stream( &self, a2a_message: &Message, agent_runtime: &AgentRuntimeInfo, agent_name: &str, context: &RequestContext, task_id: TaskId, ) -> Result<UnboundedReceiver<StreamEvent>>

Trait Implementations

impl Debug for MessageProcessor

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

Formats the value using the given formatter.