Struct RunCfg 

pub struct RunCfg<EH: FnMut(ClusterNodeId, &State, &Event) -> RunDecision, AH: 'static + Send + FnMut(ClusterNodeId, &State, &NodeTestingService, &ActionWithMeta) -> bool> {
    timeout: Duration,
    handle_event: EH,
    exit_if_action: AH,
    advance_time: Option<RunCfgAdvanceTime>,
}

Fields

timeout: Duration

handle_event: EH

exit_if_action: AH

advance_time: Option<RunCfgAdvanceTime>

Implementations

impl<EH, AH> RunCfg<EH, AH>

where EH: FnMut(ClusterNodeId, &State, &Event) -> RunDecision, AH: 'static + Send + FnMut(ClusterNodeId, &State, &NodeTestingService, &ActionWithMeta) -> bool,

pub fn timeout(self, dur: Duration) -> Self

Set timeout for the whole run function.

run function will time out, unless event_handler or action_handler causes it to end before the timeout duration elapses.

Default: 60s

pub fn advance_time<T>(self, by: T) -> Self

where T: Into<RunCfgAdvanceTime>,

By default run function won’t advance time.

pub fn event_handler<NewEh>(self, handler: NewEh) -> RunCfg<NewEh, AH>

where NewEh: FnMut(ClusterNodeId, &State, &Event) -> RunDecision,

Set function control execution of events based on decision that it will return. It might exec event, skip it, and/or end the execution of the run function.

pub fn action_handler<NewAH>(self, handler: NewAH) -> RunCfg<EH, NewAH>

where NewAH: 'static + Send + FnMut(ClusterNodeId, &State, &NodeTestingService, &ActionWithMeta) -> bool,

Set function using which run function can be stopped based on the passed predicate. It can also be used to gather some data based on actions to be used in tests.

Trait Implementations

impl Default for RunCfg<fn(ClusterNodeId, &State, &Event) -> RunDecision, fn(ClusterNodeId, &State, &NodeTestingService, &ActionWithMeta) -> bool>

fn default() -> Self

Returns the “default value” for a type.