pub struct ScannerActivityResponse {
pub instance_id: String,
pub namespace_generation: u64,
pub maintenance_generation: u64,
pub protocol_version: u32,
pub topology_digest: Bytes,
pub data_movement_active: bool,
pub response_proof: Bytes,
pub dirty_usage_generation: u64,
pub dirty_usage_pending: bool,
pub movement_generation: Option<u64>,
pub publication_blocked: Option<bool>,
}Fields§
§instance_id: String§namespace_generation: u64§maintenance_generation: u64§protocol_version: u32§topology_digest: Bytes§data_movement_active: bool§response_proof: Bytes§dirty_usage_generation: u64§dirty_usage_pending: bool§movement_generation: Option<u64>v7 fields. They are optional so v6 peers can continue to decode the response shape while newer readers fail closed when they are absent.
publication_blocked: Option<bool>Implementations§
Source§impl ScannerActivityResponse
impl ScannerActivityResponse
Sourcepub fn movement_generation(&self) -> u64
pub fn movement_generation(&self) -> u64
Returns the value of movement_generation, or the default value if movement_generation is unset.
Sourcepub fn publication_blocked(&self) -> bool
pub fn publication_blocked(&self) -> bool
Returns the value of publication_blocked, or the default value if publication_blocked is unset.
Trait Implementations§
Source§impl Clone for ScannerActivityResponse
impl Clone for ScannerActivityResponse
Source§impl Debug for ScannerActivityResponse
impl Debug for ScannerActivityResponse
Source§impl Default for ScannerActivityResponse
impl Default for ScannerActivityResponse
impl Eq for ScannerActivityResponse
Source§impl Hash for ScannerActivityResponse
impl Hash for ScannerActivityResponse
Source§impl Message for ScannerActivityResponse
impl Message for ScannerActivityResponse
Source§fn encoded_len(&self) -> usize
fn encoded_len(&self) -> usize
Returns the encoded length of the message without a length delimiter.
Source§fn encode(&self, buf: &mut impl BufMut) -> Result<(), EncodeError>where
Self: Sized,
fn encode(&self, buf: &mut impl BufMut) -> Result<(), EncodeError>where
Self: Sized,
Encodes the message to a buffer. Read more
Source§fn encode_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
fn encode_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
Encodes the message to a newly allocated buffer.
Source§fn encode_length_delimited(
&self,
buf: &mut impl BufMut,
) -> Result<(), EncodeError>where
Self: Sized,
fn encode_length_delimited(
&self,
buf: &mut impl BufMut,
) -> Result<(), EncodeError>where
Self: Sized,
Encodes the message with a length-delimiter to a buffer. Read more
Source§fn encode_length_delimited_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
fn encode_length_delimited_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
Encodes the message with a length-delimiter to a newly allocated buffer.
Source§fn decode(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
fn decode(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
Decodes an instance of the message from a buffer. Read more
Source§fn decode_length_delimited(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
fn decode_length_delimited(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
Decodes a length-delimited instance of the message from the buffer.
Source§fn merge(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
fn merge(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
Decodes an instance of the message from a buffer, and merges it into
self. Read moreSource§fn merge_length_delimited(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
fn merge_length_delimited(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
Decodes a length-delimited instance of the message from buffer, and
merges it into
self.Source§impl PartialEq for ScannerActivityResponse
impl PartialEq for ScannerActivityResponse
impl StructuralPartialEq for ScannerActivityResponse
Auto Trait Implementations§
impl !Freeze for ScannerActivityResponse
impl RefUnwindSafe for ScannerActivityResponse
impl Send for ScannerActivityResponse
impl Sync for ScannerActivityResponse
impl Unpin for ScannerActivityResponse
impl UnsafeUnpin for ScannerActivityResponse
impl UnwindSafe for ScannerActivityResponse
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> 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§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> 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