Struct fluvio::metadata::topic::PartitionMaps [−]
Hack: field instead of new type to get around encode and decode limitations
Implementations
impl PartitionMaps
pub fn maps(&self) -> &Vec<PartitionMap, Global>
pub fn maps_owned(self) -> Vec<PartitionMap, Global>
pub fn unique_spus_in_partition_map(&self) -> Vec<i32, Global>
Generate a vector with all spu ids represented by all partitions (no duplicates)
pub fn partition_map_to_replica_map(&self) -> BTreeMap<i32, Vec<i32, Global>>
Convert partition map into replica map
pub fn valid_partition_map(&self) -> Result<(), Error>
Validate partition map for assigned topics
Trait Implementations
impl Clone for PartitionMaps
pub fn clone(&self) -> PartitionMaps
pub fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Debug for PartitionMaps
impl Decoder for PartitionMaps
pub fn decode<T>(&mut self, src: &mut T, version: i16) -> Result<(), Error> where
T: Buf,
T: Buf,
pub fn decode_from<T>(src: &mut T, version: i16) -> Result<Self, Error> where
Self: Default,
T: Buf,
Self: Default,
T: Buf,
impl Default for PartitionMaps
pub fn default() -> PartitionMaps
impl Display for PartitionMaps
impl Encoder for PartitionMaps
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
pub fn as_bytes(&self, version: i16) -> Result<Bytes, Error>
impl From<Vec<(i32, Vec<i32, Global>), Global>> for PartitionMaps
impl From<Vec<PartitionMap, Global>> for PartitionMaps
pub fn from(maps: Vec<PartitionMap, Global>) -> PartitionMaps
impl PartialEq<PartitionMaps> for PartitionMaps
pub fn eq(&self, other: &PartitionMaps) -> bool
pub fn ne(&self, other: &PartitionMaps) -> bool
impl StructuralPartialEq for PartitionMaps
Auto Trait Implementations
impl RefUnwindSafe for PartitionMaps
impl Send for PartitionMaps
impl Sync for PartitionMaps
impl Unpin for PartitionMaps
impl UnwindSafe for PartitionMaps
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> Erased for T
impl<T> From<T> for T
[src]
impl<T> Instrument for T
[src]
pub fn instrument(self, span: Span) -> Instrumented<Self>
[src]
pub fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T> Instrument for T
[src]
pub fn instrument(self, span: Span) -> Instrumented<Self>
[src]
pub fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
pub fn to_owned(&self) -> T
[src]
pub fn clone_into(&self, target: &mut T)
[src]
impl<T> ToString for T where
T: Display + ?Sized,
[src]
T: Display + ?Sized,
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<T> WithSubscriber for T
[src]
pub fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
[src]
S: Into<Dispatch>,