Struct ExecutionTrackingService 

pub struct ExecutionTrackingService { /* private fields */ }

Implementations

impl ExecutionTrackingService

pub const fn new(repository: Arc<ExecutionStepRepository>) -> Self

pub async fn track( &self, task_id: TaskId, content: StepContent, ) -> Result<ExecutionStep>

pub async fn track_async( &self, task_id: TaskId, content: StepContent, ) -> Result<(TrackedStep, ExecutionStep)>

pub async fn complete( &self, tracked: TrackedStep, result: Option<Value>, ) -> Result<()>

pub async fn complete_planning( &self, tracked: TrackedStep, reasoning: Option<String>, planned_tools: Option<Vec<PlannedTool>>, ) -> Result<ExecutionStep>

pub async fn fail(&self, tracked: &TrackedStep, error: String) -> Result<()>

pub async fn fail_step( &self, step_id: &StepId, started_at: DateTime<Utc>, error: String, ) -> Result<()>

pub async fn get_steps_by_task( &self, task_id: &TaskId, ) -> Result<Vec<ExecutionStep>>

pub async fn get_step(&self, step_id: &StepId) -> Result<Option<ExecutionStep>>

pub async fn fail_in_progress_steps( &self, task_id: &TaskId, error: &str, ) -> Result<u64>

pub async fn track_understanding( &self, task_id: TaskId, ) -> Result<ExecutionStep>

pub async fn track_planning( &self, task_id: TaskId, reasoning: Option<String>, planned_tools: Option<Vec<PlannedTool>>, ) -> Result<ExecutionStep>

pub async fn track_planning_async( &self, task_id: TaskId, reasoning: Option<String>, planned_tools: Option<Vec<PlannedTool>>, ) -> Result<(TrackedStep, ExecutionStep)>

pub async fn track_skill_usage( &self, task_id: TaskId, skill_id: SkillId, skill_name: impl Into<String>, ) -> Result<ExecutionStep>

pub async fn track_tool_execution( &self, task_id: TaskId, tool_name: impl Into<String>, tool_arguments: Value, ) -> Result<(TrackedStep, ExecutionStep)>

pub async fn track_completion(&self, task_id: TaskId) -> Result<ExecutionStep>

Trait Implementations

impl Clone for ExecutionTrackingService

fn clone(&self) -> ExecutionTrackingService

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ExecutionTrackingService

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

Formats the value using the given formatter.