Trait ExecutionStrategy 

pub trait ExecutionStrategy:
    Send
    + Sync
    + Debug {
    // Required methods
    fn name(&self) -> &str;
    fn execute_task(
        &self,
        task: ExecutionTask,
    ) -> Pin<Box<dyn Future<Output = SklResult<TaskResult>> + Send + '_>>;
    fn execute_batch(
        &self,
        tasks: Vec<ExecutionTask>,
    ) -> Pin<Box<dyn Future<Output = SklResult<Vec<TaskResult>>> + Send + '_>>;
    fn can_handle(&self, requirements: &TaskRequirements) -> bool;
    fn config(&self) -> &StrategyConfig;
    fn update_config(&mut self, config: StrategyConfig) -> SklResult<()>;
    fn health_check(&self) -> Health;
    fn get_metrics(&self) -> StrategyMetrics;
}

Core execution strategy trait that all strategies must implement

Required Methods

fn name(&self) -> &str

Get the strategy name

fn execute_task( &self, task: ExecutionTask, ) -> Pin<Box<dyn Future<Output = SklResult<TaskResult>> + Send + '_>>

Execute a single task

fn execute_batch( &self, tasks: Vec<ExecutionTask>, ) -> Pin<Box<dyn Future<Output = SklResult<Vec<TaskResult>>> + Send + '_>>

Execute multiple tasks in batch

fn can_handle(&self, requirements: &TaskRequirements) -> bool

Check if strategy can handle the given task requirements

fn config(&self) -> &StrategyConfig

Get strategy configuration

fn update_config(&mut self, config: StrategyConfig) -> SklResult<()>

Update strategy configuration

fn health_check(&self) -> Health

Get strategy health status

fn get_metrics(&self) -> StrategyMetrics

Get strategy metrics

Implementors