Struct mz_stash::Memory

source · [−]

pub struct Memory<S> { /* private fields */ }

Expand description

An in-memory Stash that is backed by another Stash but serves read requests from its memory. Write requests are propogated to the other Stash.

Implementations

source

impl<S: Stash> Memory<S>

source

pub fn new(stash: S) -> Self

Trait Implementations

source

impl<S: Append> Append for Memory<S>

source

fn append<'life0, 'async_trait, I>(
 &'life0 mut self,
 batches: I
) -> Pin<Box<dyn Future<Output = Result<(), StashError>> + Send + 'async_trait>> where
 I: IntoIterator<Item = AppendBatch> + Send + 'static,
 I::IntoIter: Send,
 I: 'async_trait,
 'life0: 'async_trait,
 Self: 'async_trait,

Atomically adds entries, seals, and compacts multiple collections. Read more

source

impl<S: Debug> Debug for Memory<S>

source

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more

source

impl<S: Stash> Stash for Memory<S>

source

fn collection<'life0, 'life1, 'async_trait, K, V>(
 &'life0 mut self,
 name: &'life1 str
) -> Pin<Box<dyn Future<Output = Result<StashCollection<K, V>, StashError>> + Send + 'async_trait>> where
 K: Data,
 V: Data,
 K: 'async_trait,
 V: 'async_trait,
 'life0: 'async_trait,
 'life1: 'async_trait,
 Self: 'async_trait,

Loads or creates the named collection. Read more

source

fn iter<'life0, 'async_trait, K, V>(
 &'life0 mut self,
 collection: StashCollection<K, V>
) -> Pin<Box<dyn Future<Output = Result<Vec<((K, V), Timestamp, Diff )>, StashError>> + Send + 'async_trait>> where
 K: Data,
 V: Data,
 K: 'async_trait,
 V: 'async_trait,
 'life0: 'async_trait,
 Self: 'async_trait,

Iterates over all entries in the stash. Read more

source

fn iter_key<'life0, 'life1, 'async_trait, K, V>(
 &'life0 mut self,
 collection: StashCollection<K, V>,
 key: &'life1 K
) -> Pin<Box<dyn Future<Output = Result<Vec<(V, Timestamp, Diff )>, StashError>> + Send + 'async_trait>> where
 K: Data,
 V: Data,
 K: 'async_trait,
 V: 'async_trait,
 'life0: 'async_trait,
 'life1: 'async_trait,
 Self: 'async_trait,

Iterates over entries in the stash for the given key. Read more

source

fn update_many<'life0, 'async_trait, K, V, I>(
 &'life0 mut self,
 collection: StashCollection<K, V>,
 entries: I
) -> Pin<Box<dyn Future<Output = Result<(), StashError>> + Send + 'async_trait>> where
 K: Data,
 V: Data,
 I: IntoIterator<Item = ((K, V), Timestamp, Diff )> + Send,
 I::IntoIter: Send,
 K: 'async_trait,
 V: 'async_trait,
 I: 'async_trait,
 'life0: 'async_trait,
 Self: 'async_trait,

Atomically adds multiple entries to the arrangement. Read more

source

fn seal<'life0, 'life1, 'async_trait, K, V>(
 &'life0 mut self,
 collection: StashCollection<K, V>,
 new_upper: AntichainRef<'life1, Timestamp>
) -> Pin<Box<dyn Future<Output = Result<(), StashError>> + Send + 'async_trait>> where
 K: Data,
 V: Data,
 K: 'async_trait,
 V: 'async_trait,
 'life0: 'async_trait,
 'life1: 'async_trait,
 Self: 'async_trait,

Atomically advances the upper frontier to the specified value. Read more

source

fn seal_batch<'life0, 'life1, 'async_trait, K, V>(
 &'life0 mut self,
 seals: &'life1 [(StashCollection<K, V>, Antichain<Timestamp>)]
) -> Pin<Box<dyn Future<Output = Result<(), StashError>> + Send + 'async_trait>> where
 K: Data,
 V: Data,
 K: 'async_trait,
 V: 'async_trait,
 'life0: 'async_trait,
 'life1: 'async_trait,
 Self: 'async_trait,

Performs multiple seals at once, potentially in a more performant way than performing the individual seals one by one. Read more

source

fn compact<'a, 'async_trait, K, V>(
 &'a mut self,
 collection: StashCollection<K, V>,
 new_since: AntichainRef<'a, Timestamp>
) -> Pin<Box<dyn Future<Output = Result<(), StashError>> + Send + 'async_trait>> where
 K: Data,
 V: Data,
 'a: 'async_trait,
 K: 'async_trait,
 V: 'async_trait,
 Self: 'async_trait,

Atomically advances the since frontier to the specified value. Read more

source

fn compact_batch<'life0, 'life1, 'async_trait, K, V>(
 &'life0 mut self,
 compactions: &'life1 [(StashCollection<K, V>, Antichain<Timestamp>)]
) -> Pin<Box<dyn Future<Output = Result<(), StashError>> + Send + 'async_trait>> where
 K: Data,
 V: Data,
 K: 'async_trait,
 V: 'async_trait,
 'life0: 'async_trait,
 'life1: 'async_trait,
 Self: 'async_trait,

Performs multiple compactions at once, potentially in a more performant way than performing the individual compactions one by one. Read more

source

fn consolidate<'a, 'async_trait, K, V>(
 &'a mut self,
 collection: StashCollection<K, V>
) -> Pin<Box<dyn Future<Output = Result<(), StashError>> + Send + 'async_trait>> where
 K: Data,
 V: Data,
 'a: 'async_trait,
 K: 'async_trait,
 V: 'async_trait,
 Self: 'async_trait,

Atomically consolidates entries less than the since frontier. Read more

source

fn consolidate_batch<'life0, 'life1, 'async_trait, K, V>(
 &'life0 mut self,
 collections: &'life1 [StashCollection<K, V>]
) -> Pin<Box<dyn Future<Output = Result<(), StashError>> + Send + 'async_trait>> where
 K: Data,
 V: Data,
 K: 'async_trait,
 V: 'async_trait,
 'life0: 'async_trait,
 'life1: 'async_trait,
 Self: 'async_trait,

Performs multiple consolidations at once, potentially in a more performant way than performing the individual consolidations one by one. Read more

source

fn since<'life0, 'async_trait, K, V>(
 &'life0 mut self,
 collection: StashCollection<K, V>
) -> Pin<Box<dyn Future<Output = Result<Antichain<Timestamp>, StashError>> + Send + 'async_trait>> where
 K: Data,
 V: Data,
 K: 'async_trait,
 V: 'async_trait,
 'life0: 'async_trait,
 Self: 'async_trait,

Reports the current since frontier.

source

fn upper<'life0, 'async_trait, K, V>(
 &'life0 mut self,
 collection: StashCollection<K, V>
) -> Pin<Box<dyn Future<Output = Result<Antichain<Timestamp>, StashError>> + Send + 'async_trait>> where
 K: Data,
 V: Data,
 K: 'async_trait,
 V: 'async_trait,
 'life0: 'async_trait,
 Self: 'async_trait,

Reports the current upper frontier.

source

fn peek_timestamp<'life0, 'async_trait, K, V>(
 &'life0 mut self,
 collection: StashCollection<K, V>
) -> Pin<Box<dyn Future<Output = Result<Timestamp, StashError>> + Send + 'async_trait>> where
 K: Data,
 V: Data,
 K: 'async_trait,
 V: 'async_trait,
 'life0: 'async_trait,
 Self: 'async_trait,

Returns the most recent timestamp at which sealed entries can be read.

source

fn peek<'life0, 'async_trait, K, V>(
 &'life0 mut self,
 collection: StashCollection<K, V>
) -> Pin<Box<dyn Future<Output = Result<Vec<(K, V, Diff )>, StashError>> + Send + 'async_trait>> where
 K: Data,
 V: Data,
 K: 'async_trait,
 V: 'async_trait,
 'life0: 'async_trait,
 Self: 'async_trait,

Returns the current value of sealed entries. Read more

source

fn peek_one<'life0, 'async_trait, K, V>(
 &'life0 mut self,
 collection: StashCollection<K, V>
) -> Pin<Box<dyn Future<Output = Result<BTreeMap<K, V>, StashError>> + Send + 'async_trait>> where
 K: Data + Hash,
 V: Data,
 K: 'async_trait,
 V: 'async_trait,
 'life0: 'async_trait,
 Self: 'async_trait,

Returns the current k,v pairs of sealed entries, erroring if there is more than one entry for a given key or the multiplicity is not 1 for each key. Read more

source

fn peek_key_one<'life0, 'life1, 'async_trait, K, V>(
 &'life0 mut self,
 collection: StashCollection<K, V>,
 key: &'life1 K
) -> Pin<Box<dyn Future<Output = Result<Option<V>, StashError>> + Send + 'async_trait>> where
 K: Data,
 V: Data,
 K: 'async_trait,
 V: 'async_trait,
 'life0: 'async_trait,
 'life1: 'async_trait,
 Self: 'async_trait,

Returns the current sealed value for the given key, erroring if there is more than one entry for the key or its multiplicity is not 1. Read more

source

fn update<'life0, 'async_trait, K, V>(
 &'life0 mut self,
 collection: StashCollection<K, V>,
 data: (K, V),
 time: Timestamp,
 diff: Diff
) -> Pin<Box<dyn Future<Output = Result<(), StashError>> + Send + 'async_trait>> where
 K: Data,
 V: Data,
 K: 'async_trait,
 V: 'async_trait,
 'life0: 'async_trait,
 Self: 'async_trait,

Atomically adds a single entry to the arrangement. Read more

Auto Trait Implementations

impl<S> RefUnwindSafe for Memory<S> where
S: RefUnwindSafe,

impl<S> Send for Memory<S> where
S: Send,

impl<S> Sync for Memory<S> where
S: Sync,

impl<S> Unpin for Memory<S> where
S: Unpin,

impl<S> UnwindSafe for Memory<S> where
S: 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,

const: unstable · source

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

source

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

const: unstable · source

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

Mutably borrows from an owned value. Read more

source

impl<T> From<T> for T

const: unstable · 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 for T where
U: From<T>,

const: unstable · 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> IntoRequest<T> for T

source

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request

source

impl<T> Same<T> for T

type Output = T

Should always be Self

source

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

type Error = Infallible

The type returned in the event of a conversion error.

const: unstable · source

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

Performs the conversion.

source

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

type Error = >::Error

The type returned in the event of a conversion error.

const: unstable · source

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

Performs the conversion.

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

Struct mz_stash::Memory

Implementations

impl<S: Stash> Memory<S>

pub fn new(stash: S) -> Self

Trait Implementations

impl<S: Append> Append for Memory<S>

fn append<'life0, 'async_trait, I>( &'life0 mut self, batches: I) -> Pin<Box<dyn Future<Output = Result<(), StashError>> + Send + 'async_trait>> where I: IntoIterator<Item = AppendBatch> + Send + 'static, I::IntoIter: Send, I: 'async_trait, 'life0: 'async_trait, Self: 'async_trait,

impl<S: Debug> Debug for Memory<S>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

impl<S: Stash> Stash for Memory<S>

fn iter<'life0, 'async_trait, K, V>( &'life0 mut self, collection: StashCollection<K, V>) -> Pin<Box<dyn Future<Output = Result<Vec<((K, V), Timestamp, Diff)>, StashError>> + Send + 'async_trait>> where K: Data, V: Data, K: 'async_trait, V: 'async_trait, 'life0: 'async_trait, Self: 'async_trait,

fn compact<'a, 'async_trait, K, V>( &'a mut self, collection: StashCollection<K, V>, new_since: AntichainRef<'a, Timestamp>) -> Pin<Box<dyn Future<Output = Result<(), StashError>> + Send + 'async_trait>> where K: Data, V: Data, 'a: 'async_trait, K: 'async_trait, V: 'async_trait, Self: 'async_trait,

fn consolidate<'a, 'async_trait, K, V>( &'a mut self, collection: StashCollection<K, V>) -> Pin<Box<dyn Future<Output = Result<(), StashError>> + Send + 'async_trait>> where K: Data, V: Data, 'a: 'async_trait, K: 'async_trait, V: 'async_trait, Self: 'async_trait,

fn since<'life0, 'async_trait, K, V>( &'life0 mut self, collection: StashCollection<K, V>) -> Pin<Box<dyn Future<Output = Result<Antichain<Timestamp>, StashError>> + Send + 'async_trait>> where K: Data, V: Data, K: 'async_trait, V: 'async_trait, 'life0: 'async_trait, Self: 'async_trait,

fn upper<'life0, 'async_trait, K, V>( &'life0 mut self, collection: StashCollection<K, V>) -> Pin<Box<dyn Future<Output = Result<Antichain<Timestamp>, StashError>> + Send + 'async_trait>> where K: Data, V: Data, K: 'async_trait, V: 'async_trait, 'life0: 'async_trait, Self: 'async_trait,

fn peek_timestamp<'life0, 'async_trait, K, V>( &'life0 mut self, collection: StashCollection<K, V>) -> Pin<Box<dyn Future<Output = Result<Timestamp, StashError>> + Send + 'async_trait>> where K: Data, V: Data, K: 'async_trait, V: 'async_trait, 'life0: 'async_trait, Self: 'async_trait,

fn peek<'life0, 'async_trait, K, V>( &'life0 mut self, collection: StashCollection<K, V>) -> Pin<Box<dyn Future<Output = Result<Vec<(K, V, Diff)>, StashError>> + Send + 'async_trait>> where K: Data, V: Data, K: 'async_trait, V: 'async_trait, 'life0: 'async_trait, Self: 'async_trait,

fn peek_one<'life0, 'async_trait, K, V>( &'life0 mut self, collection: StashCollection<K, V>) -> Pin<Box<dyn Future<Output = Result<BTreeMap<K, V>, StashError>> + Send + 'async_trait>> where K: Data + Hash, V: Data, K: 'async_trait, V: 'async_trait, 'life0: 'async_trait, Self: 'async_trait,

Auto Trait Implementations

impl<S> RefUnwindSafe for Memory<S> where S: RefUnwindSafe,

impl<S> Send for Memory<S> where S: Send,

impl<S> Sync for Memory<S> where S: Sync,

impl<S> Unpin for Memory<S> where S: Unpin,

impl<S> UnwindSafe for Memory<S> where S: UnwindSafe,

Blanket Implementations

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

fn type_id(&self) -> TypeId

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

fn borrow(&self) -> &T

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

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

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> FutureExt for T

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

fn with_current_context(self) -> WithContext<Self>

impl<T> Instrument for T

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

fn in_current_span(self) -> Instrumented<Self>

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

fn into(self) -> U

impl<T> IntoRequest<T> for T

fn into_request(self) -> Request<T>

impl<T> Same<T> for T

type Output = T

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

type Error = Infallible

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

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

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

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

impl<V, T> VZip<V> for T where V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

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

fn with_current_subscriber(self) -> WithDispatch<Self>

fn append<'life0, 'async_trait, I>(
&'life0 mut self,
batches: I
) -> Pin<Box<dyn Future<Output = Result<(), StashError>> + Send + 'async_trait>> where
I: IntoIterator<Item = AppendBatch> + Send + 'static,
I::IntoIter: Send,
I: 'async_trait,
'life0: 'async_trait,
Self: 'async_trait,

fn iter<'life0, 'async_trait, K, V>(
&'life0 mut self,
collection: StashCollection<K, V>
) -> Pin<Box<dyn Future<Output = Result<Vec<((K, V), Timestamp, Diff )>, StashError>> + Send + 'async_trait>> where
K: Data,
V: Data,
K: 'async_trait,
V: 'async_trait,
'life0: 'async_trait,
Self: 'async_trait,

fn consolidate<'a, 'async_trait, K, V>(
&'a mut self,
collection: StashCollection<K, V>
) -> Pin<Box<dyn Future<Output = Result<(), StashError>> + Send + 'async_trait>> where
K: Data,
V: Data,
'a: 'async_trait,
K: 'async_trait,
V: 'async_trait,
Self: 'async_trait,

fn since<'life0, 'async_trait, K, V>(
&'life0 mut self,
collection: StashCollection<K, V>
) -> Pin<Box<dyn Future<Output = Result<Antichain<Timestamp>, StashError>> + Send + 'async_trait>> where
K: Data,
V: Data,
K: 'async_trait,
V: 'async_trait,
'life0: 'async_trait,
Self: 'async_trait,

fn upper<'life0, 'async_trait, K, V>(
&'life0 mut self,
collection: StashCollection<K, V>
) -> Pin<Box<dyn Future<Output = Result<Antichain<Timestamp>, StashError>> + Send + 'async_trait>> where
K: Data,
V: Data,
K: 'async_trait,
V: 'async_trait,
'life0: 'async_trait,
Self: 'async_trait,

fn peek_timestamp<'life0, 'async_trait, K, V>(
&'life0 mut self,
collection: StashCollection<K, V>
) -> Pin<Box<dyn Future<Output = Result<Timestamp, StashError>> + Send + 'async_trait>> where
K: Data,
V: Data,
K: 'async_trait,
V: 'async_trait,
'life0: 'async_trait,
Self: 'async_trait,

fn peek<'life0, 'async_trait, K, V>(
&'life0 mut self,
collection: StashCollection<K, V>
) -> Pin<Box<dyn Future<Output = Result<Vec<(K, V, Diff )>, StashError>> + Send + 'async_trait>> where
K: Data,
V: Data,
K: 'async_trait,
V: 'async_trait,
'life0: 'async_trait,
Self: 'async_trait,

fn peek_one<'life0, 'async_trait, K, V>(
&'life0 mut self,
collection: StashCollection<K, V>
) -> Pin<Box<dyn Future<Output = Result<BTreeMap<K, V>, StashError>> + Send + 'async_trait>> where
K: Data + Hash,
V: Data,
K: 'async_trait,
V: 'async_trait,
'life0: 'async_trait,
Self: 'async_trait,

impl<S> RefUnwindSafe for Memory<S> where
S: RefUnwindSafe,

impl<S> Send for Memory<S> where
S: Send,

impl<S> Sync for Memory<S> where
S: Sync,

impl<S> Unpin for Memory<S> where
S: Unpin,

impl<S> UnwindSafe for Memory<S> where
S: UnwindSafe,

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

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

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

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

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

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

impl<V, T> VZip<V> for T where
V: MultiLane<T>,

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