Struct mz_persist::client::StreamReadHandle
source · [−]pub struct StreamReadHandle<K, V> { /* private fields */ }Expand description
A handle for a persisted stream of ((Key, Value), Time, i64) updates backed by an crate::indexed::Indexed via a RuntimeClient.
Implementations
sourceimpl<K: Codec, V: Codec> StreamReadHandle<K, V>
impl<K: Codec, V: Codec> StreamReadHandle<K, V>
sourcepub fn stream_name(&self) -> &str
pub fn stream_name(&self) -> &str
Returns the external stream name for this handle.
sourcepub fn snapshot(&self) -> Result<DecodedSnapshot<K, V>, Error>
pub fn snapshot(&self) -> Result<DecodedSnapshot<K, V>, Error>
Returns a consistent snapshot of all previously persisted stream data.
sourcepub fn listen(
&self,
sender: Sender<ListenEvent>
) -> Result<DecodedSnapshot<K, V>, Error>
pub fn listen(
&self,
sender: Sender<ListenEvent>
) -> Result<DecodedSnapshot<K, V>, Error>
Registers a callback to be invoked on successful writes and seals.
Also returns a snapshot so that users can, if they choose, perform their logic on everything that was previously persisted before registering the listener, and all writes and seals that happen after registration without duplicating or dropping data.
Trait Implementations
sourceimpl<K, V> Clone for StreamReadHandle<K, V>
impl<K, V> Clone for StreamReadHandle<K, V>
Auto Trait Implementations
impl<K, V> !RefUnwindSafe for StreamReadHandle<K, V>
impl<K, V> Send for StreamReadHandle<K, V> where
K: Send,
V: Send,
impl<K, V> Sync for StreamReadHandle<K, V> where
K: Sync,
V: Sync,
impl<K, V> Unpin for StreamReadHandle<K, V> where
K: Unpin,
V: Unpin,
impl<K, V> !UnwindSafe for StreamReadHandle<K, V>
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> FutureExt for T
impl<T> FutureExt for T
sourcefn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
sourcefn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
sourcefn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message T in a tonic::Request
sourceimpl<T> ProgressEventTimestamp for T where
T: Data + Debug + Any,
impl<T> ProgressEventTimestamp for T where
T: Data + Debug + Any,
sourceimpl<T> ToOwned for T where
T: Clone,
impl<T> ToOwned for T where
T: Clone,
type Owned = T
type Owned = T
The resulting type after obtaining ownership.
sourcefn clone_into(&self, target: &mut T)
fn clone_into(&self, target: &mut T)
toowned_clone_into)Uses borrowed data to replace owned data, usually by cloning. Read more
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
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
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber to this type, returning a
WithDispatch wrapper. Read more