Struct Executor 

pub struct Executor {
    pub max_parallel: usize,
    pub max_retry_attempts: u32,
    pub retry_base_delay: Duration,
    pub retry_max_delay: Duration,
    pub strict_exports: bool,
}

Deterministic DAG scheduler. Side effects remain owned by the injected port.

Fields

max_parallel: usize

max_retry_attempts: u32

retry_base_delay: Duration

retry_max_delay: Duration

strict_exports: bool

Implementations

impl Executor

pub fn new() -> Executor

pub fn with_max_parallel(self, max: usize) -> Executor

pub fn with_retry_policy( self, max_retry_attempts: u32, retry_base_delay: Duration, retry_max_delay: Duration, ) -> Executor

pub fn with_export_contract(self, strict_exports: bool) -> Executor

pub async fn execute( &self, dag: &mut ExecutionDag, ctx: &ExecutorContext, ) -> ExecutionResult

Trait Implementations

impl Default for Executor

fn default() -> Executor

Returns the “default value” for a type.