Struct fluvio::metadata::topic::PartitionMaps[]

pub struct PartitionMaps { /* fields omitted */ }

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

impl Debug for PartitionMaps

impl Decoder for PartitionMaps

impl Default for PartitionMaps

impl Display for PartitionMaps

impl Encoder for PartitionMaps

impl From<Vec<(i32, Vec<i32, Global>), Global>> for PartitionMaps

impl From<Vec<PartitionMap, Global>> for PartitionMaps

impl PartialEq<PartitionMaps> for PartitionMaps

impl StructuralPartialEq for PartitionMaps

Auto Trait Implementations

Blanket Implementations

impl<T> Any for T where
    T: 'static + ?Sized
[src]

impl<T> Borrow<T> for T where
    T: ?Sized
[src]

impl<T> BorrowMut<T> for T where
    T: ?Sized
[src]

impl<T> Erased for T

impl<T> From<T> for T[src]

impl<T> Instrument for T[src]

impl<T> Instrument for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, 
[src]

impl<T> ToOwned for T where
    T: Clone
[src]

type Owned = T

The resulting type after obtaining ownership.

impl<T> ToString for T where
    T: Display + ?Sized
[src]

impl<T, U> TryFrom<U> for T where
    U: Into<T>, 
[src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, 
[src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

impl<T> WithSubscriber for T[src]