Struct ValkeyExecutionGuard 

pub struct ValkeyExecutionGuard { /* private fields */ }

Implementations

impl ValkeyExecutionGuard

pub async fn new( url: impl AsRef<str>, lease_config: ValkeyLeaseConfig, ) -> Result<Self, ExecutionGuardError>

pub async fn with_prefix( url: impl AsRef<str>, key_prefix: impl Into<String>, lease_config: ValkeyLeaseConfig, ) -> Result<Self, ExecutionGuardError>

Trait Implementations

impl Clone for ValkeyExecutionGuard

fn clone(&self) -> ValkeyExecutionGuard

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ValkeyExecutionGuard

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl ExecutionGuard for ValkeyExecutionGuard

type Error = ValkeyExecutionGuardError

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>