pub struct DbState { /* private fields */ }Expand description
Per-database state hosted by a node.
Implementations§
Source§impl DbState
impl DbState
Sourcepub fn basis_watch(&self) -> Receiver<u64>
pub fn basis_watch(&self) -> Receiver<u64>
Watch channel following the commit basis.
Sourcepub fn stream_items(&self) -> Receiver<Item>
pub fn stream_items(&self) -> Receiver<Item>
Subscribes to live stream items (reports, index announcements, heartbeats).
Sourcepub fn index_basis(&self) -> u64
pub fn index_basis(&self) -> u64
Basis of the newest published index root.
Sourcepub fn handshake_snapshot(&self) -> (Vec<u8>, KeywordInterner)
pub fn handshake_snapshot(&self) -> (Vec<u8>, KeywordInterner)
Encoded schema/ident handshake payload plus a consistent basis and interner snapshot for backfill encoding.
Auto Trait Implementations§
impl !Freeze for DbState
impl !RefUnwindSafe for DbState
impl !UnwindSafe for DbState
impl Send for DbState
impl Sync for DbState
impl Unpin for DbState
impl UnsafeUnpin for DbState
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
Mutably borrows from an owned value. Read more
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>
Wrap the input message
T in a tonic::Request