Skip to main content

ValueCache

Struct ValueCache 

Source
pub struct ValueCache<K, V> { /* private fields */ }
Expand description

A concurrent cache with efficient eviction and single-allocation guarantees.

Backed by quick_cache (S3-FIFO eviction) for bounded hot-path caching, plus a lock-free papaya::HashMap weak index for deduplication. Together they guarantee that at most one Arc<V> allocation exists per key at any time.

A background task periodically sweeps dead Weak entries from the index to prevent unbounded memory growth.

Implementations§

Source§

impl<K, V> ValueCache<K, V>
where K: Hash + Eq + Clone + Send + Sync + 'static, V: Send + Sync + 'static,

Source

pub fn new(name: &'static str, size: usize, cleanup_interval_secs: u64) -> Self

Creates a new ValueCache with the given instance name (used as the cache metric label), bounded-cache capacity, and cleanup interval for the weak-reference index.

Source

pub fn name(&self) -> &'static str

Returns the instance name of this cache.

Source

pub fn len(&self) -> usize

Returns the number of entries currently held in the bounded cache.

This is the live occupancy (excludes the weak dedup index), and is periodically sampled as the value_cache_entries gauge for the occupancy-vs-capacity diagnosis.

Source

pub fn is_empty(&self) -> bool

Returns true if the bounded cache currently holds no entries.

Source

pub fn insert(&self, key: &K, value: V) -> Arc<V>

Inserts a value into the cache, returning the canonical crate::Arc.

The value is wrapped in Arc internally. If a live Arc for this key already exists (held by another consumer), the existing allocation is reused and the new value is dropped.

Source

pub fn remove(&self, key: &K) -> Option<Arc<V>>

Removes a value from the bounded cache.

The weak index entry is intentionally kept — another consumer may still hold an Arc to this value, and the weak index must be able to deduplicate against it. Dead weak entries are cleaned up by the background task.

Source

pub fn get(&self, key: &K) -> Option<Arc<V>>

Returns an crate::Arc to the value, checking both the bounded cache and the weak index.

Source

pub fn contains(&self, key: &K) -> bool

Returns true if the value exists in either the bounded cache or the weak index (with a live allocation).

Source§

impl<V: Clone + Send + Sync + 'static> ValueCache<CryptoHash, V>

Source

pub fn insert_hashed<T>(&self, value: Cow<'_, Hashed<T>>) -> Arc<V>
where T: Clone, V: From<Hashed<T>>,

Inserts a value constructed from a Hashed<T> into the cache, keyed by its hash, returning the canonical Arc<V>.

The value is wrapped in a Cow so that it is only cloned if it needs to be inserted in the cache.

Auto Trait Implementations§

§

impl<K, V> !RefUnwindSafe for ValueCache<K, V>

§

impl<K, V> !UnwindSafe for ValueCache<K, V>

§

impl<K, V> Freeze for ValueCache<K, V>

§

impl<K, V> Send for ValueCache<K, V>
where K: Send + Sync, V: Sync + Send,

§

impl<K, V> Sync for ValueCache<K, V>
where K: Send + Sync, V: Sync + Send,

§

impl<K, V> Unpin for ValueCache<K, V>

§

impl<K, V> UnsafeUnpin for ValueCache<K, V>

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<_INNER> AutoTraits for _INNER
where _INNER: Send + Sync + 'static,

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<Choices> CoproductSubsetter<CNil, HNil> for Choices

Source§

type Remainder = Choices

Source§

fn subset( self, ) -> Result<CNil, <Choices as CoproductSubsetter<CNil, HNil>>::Remainder>

Extract a subset of the possible types in a coproduct (or get the remaining possibilities) Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> FutureExt for T

Source§

fn with_context(self, otel_cx: Context) -> WithContext<Self>

Attaches the provided Context to this type, returning a WithContext wrapper. Read more
Source§

fn with_current_context(self) -> WithContext<Self>

Attaches the current Context to this type, returning a WithContext wrapper. Read more
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> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

impl<T, U, I> LiftInto<U, I> for T
where U: LiftFrom<T, I>,

Source§

fn lift_into(self) -> U

Performs the indexed conversion.
Source§

impl<T> MaybeSend for T
where T: Send,

Source§

impl<T> MaybeSync for T
where T: Sync,

Source§

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

Source§

impl<M, I> RuntimeMemory<&mut I> for M
where M: RuntimeMemory<I>,

Source§

fn read<'instance>( &self, instance: &'instance &mut I, location: GuestPointer, length: u32, ) -> Result<Cow<'instance, [u8]>, RuntimeError>

Reads length bytes from memory from the provided location.

Source§

fn write( &mut self, instance: &mut &mut I, location: GuestPointer, bytes: &[u8], ) -> Result<(), RuntimeError>

Writes the bytes to memory at the provided location.

Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<Source> Sculptor<HNil, HNil> for Source

Source§

type Remainder = Source

Source§

fn sculpt(self) -> (HNil, <Source as Sculptor<HNil, HNil>>::Remainder)

Consumes the current HList and returns an HList with the requested shape. Read more
Source§

impl<AnyTail> Split<HNil> for AnyTail

Source§

type Remainder = AnyTail

The tail of remaining elements after splitting up the list.
Source§

fn split(self) -> (HNil, <AnyTail as Split<HNil>>::Remainder)

Splits the current heterogeneous list in two.
Source§

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

Source§

type Error = Infallible

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

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

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<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

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