Struct sp_runtime::offchain::storage_lock::StorageLock
source · pub struct StorageLock<'a, L = Time> { /* private fields */ }
Expand description
Storage based lock.
A lock that is persisted in the DB and provides the ability to guard against
concurrent access in an off-chain worker, with a defined expiry deadline
based on the concrete Lockable
implementation.
Implementations§
source§impl<'a, L: Lockable + Default> StorageLock<'a, L>
impl<'a, L: Lockable + Default> StorageLock<'a, L>
source§impl<'a, L: Lockable> StorageLock<'a, L>
impl<'a, L: Lockable> StorageLock<'a, L>
sourcepub fn with_lockable(key: &'a [u8], lockable: L) -> Self
pub fn with_lockable(key: &'a [u8], lockable: L) -> Self
Create a new storage lock with an explicit instance of a lockable L
.
sourcepub fn try_lock(
&mut self
) -> Result<StorageLockGuard<'a, '_, L>, <L as Lockable>::Deadline>
pub fn try_lock(
&mut self
) -> Result<StorageLockGuard<'a, '_, L>, <L as Lockable>::Deadline>
A single attempt to lock using the storage entry.
Returns a lock guard on success, otherwise an error containing the
<Self::Lockable>::Deadline
in for the currently active lock
by another task Err(<L as Lockable>::Deadline)
.
sourcepub fn lock(&mut self) -> StorageLockGuard<'a, '_, L>
pub fn lock(&mut self) -> StorageLockGuard<'a, '_, L>
Repeated lock attempts until the lock is successfully acquired.
If one uses fn forget(..)
, it is highly likely fn try_lock(..)
is the correct API to use instead of fn lock(..)
, since that might
never unlock in the anticipated span i.e. when used with BlockAndTime
during a certain block number span.
source§impl<'a> StorageLock<'a, Time>
impl<'a> StorageLock<'a, Time>
sourcepub fn with_deadline(key: &'a [u8], expiration_duration: Duration) -> Self
pub fn with_deadline(key: &'a [u8], expiration_duration: Duration) -> Self
Explicitly create a time based storage lock with a non-default expiration timeout.
source§impl<'a, B> StorageLock<'a, BlockAndTime<B>>where
B: BlockNumberProvider,
impl<'a, B> StorageLock<'a, BlockAndTime<B>>where
B: BlockNumberProvider,
sourcepub fn with_block_and_time_deadline(
key: &'a [u8],
expiration_block_number_offset: u32,
expiration_duration: Duration
) -> Self
pub fn with_block_and_time_deadline(
key: &'a [u8],
expiration_block_number_offset: u32,
expiration_duration: Duration
) -> Self
Explicitly create a time and block number based storage lock with a non-default expiration duration and block number offset.
sourcepub fn with_block_deadline(
key: &'a [u8],
expiration_block_number_offset: u32
) -> Self
pub fn with_block_deadline(
key: &'a [u8],
expiration_block_number_offset: u32
) -> Self
Explicitly create a time and block number based storage lock with the default expiration duration and a non-default block number offset.
Auto Trait Implementations§
impl<'a, L> RefUnwindSafe for StorageLock<'a, L>where
L: RefUnwindSafe,
impl<'a, L> Send for StorageLock<'a, L>where
L: Send,
impl<'a, L> Sync for StorageLock<'a, L>where
L: Sync,
impl<'a, L> Unpin for StorageLock<'a, L>where
L: Unpin,
impl<'a, L> UnwindSafe for StorageLock<'a, L>where
L: UnwindSafe,
Blanket Implementations§
source§impl<T> CheckedConversion for T
impl<T> CheckedConversion for T
§impl<T> Downcast for Twhere
T: Any,
impl<T> Downcast for Twhere
T: Any,
§fn into_any(self: Box<T, Global>) -> Box<dyn Any + 'static, Global>
fn into_any(self: Box<T, Global>) -> Box<dyn Any + 'static, Global>
Box<dyn Trait>
(where Trait: Downcast
) to Box<dyn Any>
. Box<dyn Any>
can
then be further downcast
into Box<ConcreteType>
where ConcreteType
implements Trait
.§fn into_any_rc(self: Rc<T>) -> Rc<dyn Any + 'static>
fn into_any_rc(self: Rc<T>) -> Rc<dyn Any + 'static>
Rc<Trait>
(where Trait: Downcast
) to Rc<Any>
. Rc<Any>
can then be
further downcast
into Rc<ConcreteType>
where ConcreteType
implements Trait
.§fn as_any(&self) -> &(dyn Any + 'static)
fn as_any(&self) -> &(dyn Any + 'static)
&Trait
(where Trait: Downcast
) to &Any
. This is needed since Rust cannot
generate &Any
’s vtable from &Trait
’s.§fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
&mut Trait
(where Trait: Downcast
) to &Any
. This is needed since Rust cannot
generate &mut Any
’s vtable from &mut Trait
’s.source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T, Outer> IsWrappedBy<Outer> for Twhere
Outer: AsRef<T> + AsMut<T> + From<T>,
T: From<Outer>,
impl<T, Outer> IsWrappedBy<Outer> for Twhere
Outer: AsRef<T> + AsMut<T> + From<T>,
T: From<Outer>,
source§impl<T> SaturatedConversion for T
impl<T> SaturatedConversion for T
source§fn saturated_from<T>(t: T) -> Selfwhere
Self: UniqueSaturatedFrom<T>,
fn saturated_from<T>(t: T) -> Selfwhere
Self: UniqueSaturatedFrom<T>,
source§fn saturated_into<T>(self) -> Twhere
Self: UniqueSaturatedInto<T>,
fn saturated_into<T>(self) -> Twhere
Self: UniqueSaturatedInto<T>,
T
. Read moresource§impl<S, T> UncheckedInto<T> for Swhere
T: UncheckedFrom<S>,
impl<S, T> UncheckedInto<T> for Swhere
T: UncheckedFrom<S>,
source§fn unchecked_into(self) -> T
fn unchecked_into(self) -> T
unchecked_from
.source§impl<T, S> UniqueSaturatedInto<T> for Swhere
T: Bounded,
S: TryInto<T>,
impl<T, S> UniqueSaturatedInto<T> for Swhere
T: Bounded,
S: TryInto<T>,
source§fn unique_saturated_into(self) -> T
fn unique_saturated_into(self) -> T
T
.