Struct fluvio::metadata::objects::MetadataUpdate [−][src]
pub struct MetadataUpdate<S> where
S: Spec + Debug + Encoder + Decoder,
<S as Spec>::Status: Debug,
<S as Spec>::Status: Encoder,
<S as Spec>::Status: Decoder, { pub epoch: i64, pub changes: Vec<Message<Metadata<S>>, Global>, pub all: Vec<Metadata<S>, Global>, }
updates on metadata
Fields
epoch: i64
changes: Vec<Message<Metadata<S>>, Global>
all: Vec<Metadata<S>, Global>
Implementations
impl<S> MetadataUpdate<S> where
S: Spec + Debug + Encoder + Decoder,
<S as Spec>::Status: Debug,
<S as Spec>::Status: Encoder,
<S as Spec>::Status: Decoder,
[src]
impl<S> MetadataUpdate<S> where
S: Spec + Debug + Encoder + Decoder,
<S as Spec>::Status: Debug,
<S as Spec>::Status: Encoder,
<S as Spec>::Status: Decoder,
[src]pub fn with_changes(
epoch: i64,
changes: Vec<Message<Metadata<S>>, Global>
) -> MetadataUpdate<S>
[src]
epoch: i64,
changes: Vec<Message<Metadata<S>>, Global>
) -> MetadataUpdate<S>
pub fn with_all(epoch: i64, all: Vec<Metadata<S>, Global>) -> MetadataUpdate<S>
[src]
Trait Implementations
impl<S> Clone for MetadataUpdate<S> where
S: Clone + Spec + Debug + Encoder + Decoder,
<S as Spec>::Status: Debug,
<S as Spec>::Status: Encoder,
<S as Spec>::Status: Decoder,
[src]
impl<S> Clone for MetadataUpdate<S> where
S: Clone + Spec + Debug + Encoder + Decoder,
<S as Spec>::Status: Debug,
<S as Spec>::Status: Encoder,
<S as Spec>::Status: Decoder,
[src]pub fn clone(&self) -> MetadataUpdate<S>
[src]
pub fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl<S> Debug for MetadataUpdate<S> where
S: Debug + Spec + Encoder + Decoder,
<S as Spec>::Status: Debug,
<S as Spec>::Status: Encoder,
<S as Spec>::Status: Decoder,
[src]
impl<S> Debug for MetadataUpdate<S> where
S: Debug + Spec + Encoder + Decoder,
<S as Spec>::Status: Debug,
<S as Spec>::Status: Encoder,
<S as Spec>::Status: Decoder,
[src]impl<S> Decoder for MetadataUpdate<S> where
S: Spec + Debug + Encoder + Decoder,
<S as Spec>::Status: Debug,
<S as Spec>::Status: Encoder,
<S as Spec>::Status: Decoder,
[src]
impl<S> Decoder for MetadataUpdate<S> where
S: Spec + Debug + Encoder + Decoder,
<S as Spec>::Status: Debug,
<S as Spec>::Status: Encoder,
<S as Spec>::Status: Decoder,
[src]impl<S> Default for MetadataUpdate<S> where
S: Default + Spec + Debug + Encoder + Decoder,
<S as Spec>::Status: Debug,
<S as Spec>::Status: Encoder,
<S as Spec>::Status: Decoder,
[src]
impl<S> Default for MetadataUpdate<S> where
S: Default + Spec + Debug + Encoder + Decoder,
<S as Spec>::Status: Debug,
<S as Spec>::Status: Encoder,
<S as Spec>::Status: Decoder,
[src]pub fn default() -> MetadataUpdate<S>
[src]
impl<S> Encoder for MetadataUpdate<S> where
S: Spec + Debug + Encoder + Decoder,
<S as Spec>::Status: Debug,
<S as Spec>::Status: Encoder,
<S as Spec>::Status: Decoder,
[src]
impl<S> Encoder for MetadataUpdate<S> where
S: Spec + Debug + Encoder + Decoder,
<S as Spec>::Status: Debug,
<S as Spec>::Status: Encoder,
<S as Spec>::Status: Decoder,
[src]impl From<MetadataUpdate<PartitionSpec>> for WatchResponse
[src]
impl From<MetadataUpdate<PartitionSpec>> for WatchResponse
[src]pub fn from(update: MetadataUpdate<PartitionSpec>) -> WatchResponse
[src]
impl From<MetadataUpdate<SpuGroupSpec>> for WatchResponse
[src]
impl From<MetadataUpdate<SpuGroupSpec>> for WatchResponse
[src]pub fn from(update: MetadataUpdate<SpuGroupSpec>) -> WatchResponse
[src]
impl From<MetadataUpdate<SpuSpec>> for WatchResponse
[src]
impl From<MetadataUpdate<SpuSpec>> for WatchResponse
[src]pub fn from(update: MetadataUpdate<SpuSpec>) -> WatchResponse
[src]
impl From<MetadataUpdate<TopicSpec>> for WatchResponse
[src]
impl From<MetadataUpdate<TopicSpec>> for WatchResponse
[src]pub fn from(update: MetadataUpdate<TopicSpec>) -> WatchResponse
[src]
impl TryInto<MetadataUpdate<PartitionSpec>> for WatchResponse
[src]
impl TryInto<MetadataUpdate<PartitionSpec>> for WatchResponse
[src]type Error = Error
The type returned in the event of a conversion error.
pub fn try_into(
self
) -> Result<MetadataUpdate<PartitionSpec>, <WatchResponse as TryInto<MetadataUpdate<PartitionSpec>>>::Error>
[src]
self
) -> Result<MetadataUpdate<PartitionSpec>, <WatchResponse as TryInto<MetadataUpdate<PartitionSpec>>>::Error>
impl TryInto<MetadataUpdate<SpuGroupSpec>> for WatchResponse
[src]
impl TryInto<MetadataUpdate<SpuGroupSpec>> for WatchResponse
[src]type Error = Error
The type returned in the event of a conversion error.
pub fn try_into(
self
) -> Result<MetadataUpdate<SpuGroupSpec>, <WatchResponse as TryInto<MetadataUpdate<SpuGroupSpec>>>::Error>
[src]
self
) -> Result<MetadataUpdate<SpuGroupSpec>, <WatchResponse as TryInto<MetadataUpdate<SpuGroupSpec>>>::Error>
impl TryInto<MetadataUpdate<SpuSpec>> for WatchResponse
[src]
impl TryInto<MetadataUpdate<SpuSpec>> for WatchResponse
[src]type Error = Error
The type returned in the event of a conversion error.
pub fn try_into(
self
) -> Result<MetadataUpdate<SpuSpec>, <WatchResponse as TryInto<MetadataUpdate<SpuSpec>>>::Error>
[src]
self
) -> Result<MetadataUpdate<SpuSpec>, <WatchResponse as TryInto<MetadataUpdate<SpuSpec>>>::Error>
impl TryInto<MetadataUpdate<TopicSpec>> for WatchResponse
[src]
impl TryInto<MetadataUpdate<TopicSpec>> for WatchResponse
[src]type Error = Error
The type returned in the event of a conversion error.
pub fn try_into(
self
) -> Result<MetadataUpdate<TopicSpec>, <WatchResponse as TryInto<MetadataUpdate<TopicSpec>>>::Error>
[src]
self
) -> Result<MetadataUpdate<TopicSpec>, <WatchResponse as TryInto<MetadataUpdate<TopicSpec>>>::Error>
Auto Trait Implementations
impl<S> RefUnwindSafe for MetadataUpdate<S> where
S: RefUnwindSafe,
<S as Spec>::Status: RefUnwindSafe,
impl<S> RefUnwindSafe for MetadataUpdate<S> where
S: RefUnwindSafe,
<S as Spec>::Status: RefUnwindSafe,
impl<S> UnwindSafe for MetadataUpdate<S> where
S: UnwindSafe,
<S as Spec>::Status: UnwindSafe,
impl<S> UnwindSafe for MetadataUpdate<S> where
S: UnwindSafe,
<S as Spec>::Status: UnwindSafe,
Blanket Implementations
impl<T> Instrument for T
[src]
impl<T> Instrument for T
[src]