Struct SkillExecutor 

pub struct SkillExecutor<P: LlmProvider> { /* private fields */ }

Skill 执行器

根据 Skill 的执行模式分发到不同的执行方法。

类型参数

• P - 实现 LlmProvider trait 的类型，用于 LLM API 调用

执行模式

• Prompt: 单次对话，注入 System Prompt
• Workflow: 多步骤工作流
• Agent: 多轮迭代探索（未实现）

示例

use aster::skills::executor::{SkillExecutor, LlmProvider, NoopCallback};
use aster::skills::error::SkillError;
use async_trait::async_trait;

struct MyProvider;

#[async_trait]
impl LlmProvider for MyProvider {
    async fn chat(
        &self,
        system_prompt: &str,
        user_message: &str,
        model: Option<&str>,
    ) -> Result<String, SkillError> {
        Ok("响应".to_string())
    }
}

let executor = SkillExecutor::new(MyProvider);
// let result = executor.execute(&skill, "输入", None).await;

Implementations

impl<P: LlmProvider> SkillExecutor<P>

pub fn new(provider: P) -> Self

创建新的执行器

Arguments

• provider - 实现 LlmProvider trait 的 LLM 提供者

Returns

新的 SkillExecutor 实例

示例

let executor = SkillExecutor::new(my_provider);

pub fn provider(&self) -> &P

获取 Provider 的引用

Returns

Provider 的不可变引用

pub async fn execute( &self, skill: &SkillDefinition, input: &str, callback: Option<&dyn ExecutionCallback>, ) -> Result<SkillExecutionResult, SkillError>

执行 Skill

根据 Skill 的执行模式分发到不同的执行方法：

• Prompt 模式：调用 execute_prompt_mode
• Workflow 模式：调用 execute_workflow_mode
• Agent 模式：返回 NotImplemented 错误

Arguments

• skill - Skill 定义
• input - 用户输入
• callback - 可选的执行回调，用于进度通知

Returns

执行结果或错误

Errors

• SkillError::NotImplemented: Agent 模式尚未实现
• SkillError::InvalidConfig: Workflow 模式缺少 workflow 定义
• SkillError::ProviderError: LLM API 调用失败
• SkillError::ExecutionFailed: 执行过程中发生错误

示例

let result = executor.execute(&skill, "分析这段代码", None).await?;
if result.success {
    println!("输出: {}", result.output.unwrap_or_default());
}