pub struct StreamDescriptor {
pub scope: StreamScope,
pub name: String,
pub retention: StreamRetention,
pub head_offset: u64,
pub tail_offset: u64,
pub event_count: usize,
}Expand description
Public-facing descriptor for stream discovery — what an
introspection surface (e.g. a future red.streams virtual
table) would emit per stream.
Fields§
§scope: StreamScope§name: String§retention: StreamRetention§head_offset: u64Offset of the oldest event still retained, or 0 if the
stream is empty.
tail_offset: u64Offset of the most recent event, or 0 if the stream is
empty. The next append will receive tail_offset + 1.
event_count: usizeTrait Implementations§
Source§impl Clone for StreamDescriptor
impl Clone for StreamDescriptor
Source§fn clone(&self) -> StreamDescriptor
fn clone(&self) -> StreamDescriptor
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for StreamDescriptor
impl Debug for StreamDescriptor
Source§impl PartialEq for StreamDescriptor
impl PartialEq for StreamDescriptor
Source§fn eq(&self, other: &StreamDescriptor) -> bool
fn eq(&self, other: &StreamDescriptor) -> bool
Tests for
self and other values to be equal, and is used by ==.impl Eq for StreamDescriptor
impl StructuralPartialEq for StreamDescriptor
Auto Trait Implementations§
impl Freeze for StreamDescriptor
impl RefUnwindSafe for StreamDescriptor
impl Send for StreamDescriptor
impl Sync for StreamDescriptor
impl Unpin for StreamDescriptor
impl UnsafeUnpin for StreamDescriptor
impl UnwindSafe for StreamDescriptor
Blanket Implementations§
Source§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
Source§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
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
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key and return true if they are equal.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> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
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 moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
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 moreSource§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>
Wrap the input message
T in a tonic::Request