Trait ExecutionGuard 

pub trait ExecutionGuard {
    type Error: Error + Send + Sync + 'static;

    // Required methods
    fn acquire(
        &self,
        slot: ExecutionSlot,
    ) -> impl Future<Output = Result<ExecutionGuardAcquire, Self::Error>> + Send;
    fn renew(
        &self,
        lease: &ExecutionLease,
    ) -> impl Future<Output = Result<ExecutionGuardRenewal, Self::Error>> + Send;
    fn release(
        &self,
        lease: &ExecutionLease,
    ) -> impl Future<Output = Result<(), Self::Error>> + Send;

    // Provided methods
    fn classify_error(_error: &Self::Error) -> ExecutionGuardErrorKind
       where Self: Sized { ... }
    fn renew_interval(&self, _lease: &ExecutionLease) -> Option<Duration> { ... }
}

Required Associated Types

type Error: Error + Send + Sync + 'static

Required Methods

fn acquire( &self, slot: ExecutionSlot, ) -> impl Future<Output = Result<ExecutionGuardAcquire, Self::Error>> + Send

fn renew( &self, lease: &ExecutionLease, ) -> impl Future<Output = Result<ExecutionGuardRenewal, Self::Error>> + Send

fn release( &self, lease: &ExecutionLease, ) -> impl Future<Output = Result<(), Self::Error>> + Send

Provided Methods

fn classify_error(_error: &Self::Error) -> ExecutionGuardErrorKind

where Self: Sized,

fn renew_interval(&self, _lease: &ExecutionLease) -> Option<Duration>

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementations on Foreign Types

impl<T> ExecutionGuard for Arc<T>

where T: ExecutionGuard + Send + Sync,

type Error = <T as ExecutionGuard>::Error

async fn acquire( &self, slot: ExecutionSlot, ) -> Result<ExecutionGuardAcquire, Self::Error>

async fn renew( &self, lease: &ExecutionLease, ) -> Result<ExecutionGuardRenewal, Self::Error>

async fn release(&self, lease: &ExecutionLease) -> Result<(), Self::Error>

fn classify_error(error: &Self::Error) -> ExecutionGuardErrorKind

where Self: Sized,

fn renew_interval(&self, lease: &ExecutionLease) -> Option<Duration>

Implementors

impl ExecutionGuard for NoopExecutionGuard

type Error = Infallible

impl ExecutionGuard for ValkeyExecutionGuard

type Error = ValkeyExecutionGuardError