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 drain_events(
        &self,
    ) -> impl Future<Output = Result<Vec<ExecutionGuardEvent>, Self::Error>> + Send { ... }
    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 drain_events( &self, ) -> impl Future<Output = Result<Vec<ExecutionGuardEvent>, Self::Error>> + Send

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".

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>

async fn drain_events(&self) -> Result<Vec<ExecutionGuardEvent>, 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