Struct GuardedRunner 

pub struct GuardedRunner<G> { /* private fields */ }

Implementations

impl<G> GuardedRunner<G>

where G: ExecutionGuard + Send + Sync + 'static,

pub fn new(guard: G) -> Self

pub fn with_observer<O>(guard: G, observer: O) -> Self

where O: SchedulerObserver,

pub async fn run<F, Fut, T>( &self, slot: ExecutionSlot, run: F, ) -> Result<GuardedRunResult<T>, ExecutionGuardError>

where F: FnOnce() -> Fut, Fut: Future<Output = T>,

pub async fn run_with_metadata<F, Fut, T>( &self, slot: ExecutionSlot, catch_up: bool, trigger_count: u32, run: F, ) -> Result<GuardedRunResult<T>, ExecutionGuardError>

where F: FnOnce() -> Fut, Fut: Future<Output = T>,

pub async fn acquire( &self, slot: ExecutionSlot, ) -> Result<Option<GuardedSession<G>>, ExecutionGuardError>

Trait Implementations

impl<G: Clone> Clone for GuardedRunner<G>

fn clone(&self) -> GuardedRunner<G>

Returns a duplicate of the value.

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

Performs copy-assignment from source.