Skip to main content

VarTypedShard

Struct VarTypedShard 

Source
pub struct VarTypedShard<'tree, K: Key, T: Send + Sync, C: Codec<T> + Clone, H: TypedWriteHook<K, T>> { /* private fields */ }
Expand description

Handle for atomic multi-key operations within a single shard. Obtained via VarTypedTree::atomic. The shard lock is held for the lifetime of this struct — keep the closure short.

Implementations§

Source§

impl<K: Key, T: Send + Sync, C: Codec<T> + Clone, H: TypedWriteHook<K, T>> VarTypedShard<'_, K, T, C, H>

Source

pub fn put(&mut self, key: &K, value: &T) -> DbResult<bool>

Insert or overwrite key. Returns true if the key already existed (overwrite), false for a fresh insert.

Source

pub fn insert(&mut self, key: &K, value: &T) -> DbResult<()>

Source

pub fn delete(&mut self, key: &K) -> DbResult<bool>

Source

pub fn try_get(&self, key: &K) -> DbResult<Option<T>>

Source

pub fn get_or_err(&self, key: &K) -> DbResult<T>

Source

pub fn try_contains(&self, key: &K) -> DbResult<bool>

Source

pub fn update( &mut self, key: &K, f: impl FnOnce(&T) -> T, ) -> DbResult<Option<T>>

Atomically read-modify-write within the shard. Returns Some(new_value) if the key existed, None if absent.

Source

pub fn fetch_update( &mut self, key: &K, f: impl FnOnce(&T) -> T, ) -> DbResult<Option<T>>

Like update, but returns Some(old_value) instead of the new one.

Source

pub fn upsert<U: IntoUpsert<T>>( &mut self, key: &K, f: impl FnOnce(Option<&T>) -> U, ) -> DbResult<U::Out>

Decide-and-write within the shard. The closure must be short — shard lock is held.

Trait Implementations§

Source§

impl<K: Key, T: Send + Sync, C: Codec<T> + Clone, H: TypedWriteHook<K, T>> Send for VarTypedShard<'_, K, T, C, H>

Auto Trait Implementations§

§

impl<'tree, K, T, C, H> !RefUnwindSafe for VarTypedShard<'tree, K, T, C, H>

§

impl<'tree, K, T, C, H> !Sync for VarTypedShard<'tree, K, T, C, H>

§

impl<'tree, K, T, C, H> !UnwindSafe for VarTypedShard<'tree, K, T, C, H>

§

impl<'tree, K, T, C, H> Freeze for VarTypedShard<'tree, K, T, C, H>
where &'tree VarTypedTree<K, T, C, H>: Freeze,

§

impl<'tree, K, T, C, H> Unpin for VarTypedShard<'tree, K, T, C, H>
where &'tree VarTypedTree<K, T, C, H>: Unpin,

§

impl<'tree, K, T, C, H> UnsafeUnpin for VarTypedShard<'tree, K, T, C, H>
where &'tree VarTypedTree<K, T, C, H>: UnsafeUnpin,

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

Source§

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self> ⓘ

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self> ⓘ

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = !

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, !>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more