pub struct DurableCache<C: DurableCacheCodec> {
pub(crate) write: WriteHandle<C::KeyCodec, C::ValCodec, u64, i64>,
pub(crate) subscribe: Subscribe<C::KeyCodec, C::ValCodec, u64, i64>,
pub(crate) local: BTreeMap<C::Key, LocalVal<C>>,
pub(crate) local_progress: u64,
}
Fields§
§write: WriteHandle<C::KeyCodec, C::ValCodec, u64, i64>
§subscribe: Subscribe<C::KeyCodec, C::ValCodec, u64, i64>
§local: BTreeMap<C::Key, LocalVal<C>>
§local_progress: u64
Implementations§
Source§impl<C: DurableCacheCodec> DurableCache<C>
impl<C: DurableCacheCodec> DurableCache<C>
Sourcepub async fn new(
persist: &PersistClient,
shard_id: ShardId,
purpose: &str,
) -> Self
pub async fn new( persist: &PersistClient, shard_id: ShardId, purpose: &str, ) -> Self
Opens a DurableCache
using shard shard_id
.
pub(crate) async fn sync_to(&mut self, progress: Option<u64>) -> u64
Sourcepub fn get_local(&self, key: &C::Key) -> Option<&C::Val>
pub fn get_local(&self, key: &C::Key) -> Option<&C::Val>
Get and return the value associated with key
if it exists, without syncing with the
durable store.
Sourcepub async fn get(
&mut self,
key: &C::Key,
val_fn: impl FnOnce() -> C::Val,
) -> &C::Val
pub async fn get( &mut self, key: &C::Key, val_fn: impl FnOnce() -> C::Val, ) -> &C::Val
Get and return the value associated with key
, syncing with the durable store if
necessary. If key
does not exist, then a value is computed via val_fn
and durably
stored in the cache.
Sourcepub fn entries_local(&self) -> impl Iterator<Item = (&C::Key, &C::Val)>
pub fn entries_local(&self) -> impl Iterator<Item = (&C::Key, &C::Val)>
Return all entries stored in the cache, without syncing with the durable store.
Sourcepub async fn set(&mut self, key: &C::Key, value: Option<&C::Val>)
pub async fn set(&mut self, key: &C::Key, value: Option<&C::Val>)
Durably set key
to value
. A value
of None
deletes the entry from the cache.
Failures will update the cache and retry until the cache is written successfully.
Sourcepub async fn set_many(&mut self, entries: &[(&C::Key, Option<&C::Val>)])
pub async fn set_many(&mut self, entries: &[(&C::Key, Option<&C::Val>)])
Durably set multiple key-value pairs in entries
. Values of None
deletes the
corresponding entries from the cache.
Failures will update the cache and retry until the cache is written successfully.
Sourcepub async fn try_set(
&mut self,
key: &C::Key,
value: Option<&C::Val>,
) -> Result<(), Error>
pub async fn try_set( &mut self, key: &C::Key, value: Option<&C::Val>, ) -> Result<(), Error>
Tries to durably set key
to value
. A value
of None
deletes the entry from the cache.
On both successes and failures, the cache will update its contents with the most recent updates from the durable store.
Sourcepub async fn try_set_many(
&mut self,
entries: &[(&C::Key, Option<&C::Val>)],
) -> Result<(), Error>
pub async fn try_set_many( &mut self, entries: &[(&C::Key, Option<&C::Val>)], ) -> Result<(), Error>
Tries to durably set multiple key-value pairs in entries
. Values of None
deletes the
corresponding entries from the cache.
On both successes and failures, the cache will update its contents with the most recent updates from the durable store.
Trait Implementations§
Auto Trait Implementations§
impl<C> Freeze for DurableCache<C>
impl<C> !RefUnwindSafe for DurableCache<C>
impl<C> Send for DurableCache<C>where
<C as DurableCacheCodec>::Key: Send,
<C as DurableCacheCodec>::KeyCodec: Send,
<C as DurableCacheCodec>::Val: Send,
<C as DurableCacheCodec>::ValCodec: Send,
impl<C> Sync for DurableCache<C>where
<C as DurableCacheCodec>::Key: Sync,
<C as DurableCacheCodec>::KeyCodec: Sync,
<C as DurableCacheCodec>::Val: Sync,
<C as DurableCacheCodec>::ValCodec: Sync,
impl<C> Unpin for DurableCache<C>
impl<C> !UnwindSafe for DurableCache<C>
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
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> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T
in a tonic::Request
Source§impl<T> Pointable for T
impl<T> Pointable for T
Source§impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
Source§fn into_rust(self) -> Result<R, TryFromProtoError>
fn into_rust(self) -> Result<R, TryFromProtoError>
RustType::from_proto
.Source§fn from_rust(rust: &R) -> P
fn from_rust(rust: &R) -> P
RustType::into_proto
.Source§impl<'a, S, T> Semigroup<&'a S> for Twhere
T: Semigroup<S>,
impl<'a, S, T> Semigroup<&'a S> for Twhere
T: Semigroup<S>,
Source§fn plus_equals(&mut self, rhs: &&'a S)
fn plus_equals(&mut self, rhs: &&'a S)
std::ops::AddAssign
, for types that do not implement AddAssign
.