Skip to main content

PlanCache

hrx::plan_cache

Struct PlanCache 

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

Concurrent bounded preparation. Returned Arcs pin values. The additional idle predicate protects work whose output or completion outlives that Arc. Failed or panicking loaders release capacity and wake waiters for retry.

Implementations§

Source§

impl<K: Clone + Eq + Hash, V> PlanCache<K, V>

Source

pub fn new(capacity: usize, idle: fn(&V) -> bool) -> Result<Self>

Set the maximum number of resident/preparing plans, never zero.

Source

pub fn get_or_prepare( &self, key: K, load: impl FnOnce() -> Result<V>, ) -> Result<Arc<V>>

Reuse or prepare a value. Concurrent requests for the same key share one outcome; other keys may prepare concurrently. Returns Busy when all capacity is pinned or preparing. No loader executes under the cache lock.

Source

pub fn statistics(&self) -> CacheStatistics

Snapshot cache counters without waiting for preparation.

Auto Trait Implementations§

§

impl<K, V> !Freeze for PlanCache<K, V>

§

impl<K, V> RefUnwindSafe for PlanCache<K, V>
where fn(&V) -> bool: RefUnwindSafe, Mutex<State<K, V>>: RefUnwindSafe,

§

impl<K, V> Send for PlanCache<K, V>
where fn(&V) -> bool: Send, Mutex<State<K, V>>: Send,

§

impl<K, V> Sync for PlanCache<K, V>
where fn(&V) -> bool: Sync, Mutex<State<K, V>>: Sync,

§

impl<K, V> Unpin for PlanCache<K, V>
where fn(&V) -> bool: Unpin, Mutex<State<K, V>>: Unpin,

§

impl<K, V> UnsafeUnpin for PlanCache<K, V>
where fn(&V) -> bool: UnsafeUnpin, Mutex<State<K, V>>: UnsafeUnpin,

§

impl<K, V> UnwindSafe for PlanCache<K, V>
where fn(&V) -> bool: UnwindSafe, Mutex<State<K, V>>: UnwindSafe,

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<T> DropFlavorWrapper<T> for T

Source§

type Flavor = MayDrop

The DropFlavor that wraps T into Self
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, W> HasTypeWitness<W> for T
where W: MakeTypeWitness<Arg = T>, T: ?Sized,

Source§

const WITNESS: W = W::MAKE

A constant of the type witness
Source§

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

Source§

const TYPE_EQ: TypeEq<T, <T as Identity>::Type> = TypeEq::NEW

Proof that Self is the same type as Self::Type, provides methods for casting between Self and Self::Type.
Source§

type Type = T

The same type as Self, used to emulate type equality bounds (T == U) with associated type equality constraints (T: Identity<Type = U>).
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> PolicyExt for T
where T: ?Sized,

Source§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more
Source§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more
Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
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