[−]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>
pub fn maps_owned(self) -> Vec<PartitionMap>
pub fn unique_spus_in_partition_map(&self) -> Vec<i32>
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>>
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
fn clone(&self) -> PartitionMaps
fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Debug for PartitionMaps
impl Decoder for PartitionMaps
fn decode<T>(&mut self, src: &mut T, version: i16) -> Result<(), Error> where
T: Buf,
T: Buf,
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
fn default() -> PartitionMaps
impl Display for PartitionMaps
impl Encoder for PartitionMaps
fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
fn write_size(&self, version: i16) -> usize
fn as_bytes(&self, version: i16) -> Result<Bytes, Error>
impl From<Vec<(i32, Vec<i32>)>> for PartitionMaps
impl From<Vec<PartitionMap>> for PartitionMaps
fn from(maps: Vec<PartitionMap>) -> PartitionMaps
impl PartialEq<PartitionMaps> for PartitionMaps
fn eq(&self, other: &PartitionMaps) -> bool
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,
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]
fn instrument(self, span: Span) -> Instrumented<Self>
[src]
fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T> Instrument for T
[src]
fn instrument(self, span: Span) -> Instrumented<Self>
[src]
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.
fn to_owned(&self) -> T
[src]
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.
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.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<T> WithSubscriber for T
[src]
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
[src]
S: Into<Dispatch>,