Struct SequentialExecutionStrategy 

pub struct SequentialExecutionStrategy { /* private fields */ }

Sequential execution strategy for deterministic, single-threaded execution

Implementations

impl SequentialExecutionStrategy

pub fn new() -> Self

Create a new sequential execution strategy

pub fn builder() -> SequentialStrategyBuilder

Create a builder for sequential strategy

Trait Implementations

impl Debug for SequentialExecutionStrategy

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

Formats the value using the given formatter.

impl Default for SequentialExecutionStrategy

fn default() -> Self

Returns the “default value” for a type.

impl ExecutionStrategy for SequentialExecutionStrategy

fn name(&self) -> &'static str

Get strategy name

fn description(&self) -> &'static str

Get strategy description

fn config(&self) -> &StrategyConfig

Get strategy configuration

fn configure( &mut self, config: StrategyConfig, ) -> Pin<Box<dyn Future<Output = SklResult<()>> + Send + '_>>

Configure the strategy

fn initialize( &mut self, ) -> Pin<Box<dyn Future<Output = SklResult<()>> + Send + '_>>

Initialize the strategy

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, _task: &ExecutionTask) -> bool

Check if strategy can handle the given task

fn estimate_execution_time(&self, _task: &ExecutionTask) -> Option<Duration>

Estimate execution time for a task

fn health_status(&self) -> StrategyHealth

Get current strategy health status

fn metrics(&self) -> StrategyMetrics

Get strategy metrics

fn shutdown( &mut self, ) -> Pin<Box<dyn Future<Output = SklResult<()>> + Send + '_>>

Shutdown the strategy gracefully

fn pause(&mut self) -> SklResult<()>

Pause strategy execution

fn resume(&mut self) -> SklResult<()>

Resume strategy execution

fn scale( &mut self, _scale_factor: f64, ) -> Pin<Box<dyn Future<Output = SklResult<()>> + Send + '_>>

Scale strategy resources

fn get_resource_requirements(&self, task: &ExecutionTask) -> TaskRequirements

Get resource requirements for a task

fn validate_task(&self, task: &ExecutionTask) -> SklResult<()>

Validate task compatibility