[−]Struct fluvio::metadata::partition::PartitionSpec
Spec for Partition Each partition has replicas spread among SPU one of replica is leader which is duplicated in the leader field
Fields
leader: i32
replicas: Vec<i32>
Implementations
impl PartitionSpec
pub fn new(leader: i32, replicas: Vec<i32>) -> PartitionSpec
pub fn has_spu(&self, spu: &i32) -> bool
pub fn followers(&self) -> Vec<i32>
follower replicas
Trait Implementations
impl Clone for PartitionSpec
fn clone(&self) -> PartitionSpec
fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Debug for PartitionSpec
impl Decoder for PartitionSpec
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 PartitionSpec
fn default() -> PartitionSpec
impl Encoder for PartitionSpec
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>> for PartitionSpec
fn from(replicas: Vec<i32>) -> PartitionSpec
impl ListSpec for PartitionSpec
[src]
type Filter = String
filter type
fn into_list_request(
filters: Vec<<PartitionSpec as ListSpec>::Filter>
) -> ListRequest
[src]
filters: Vec<<PartitionSpec as ListSpec>::Filter>
) -> ListRequest
impl PartialEq<PartitionSpec> for PartitionSpec
fn eq(&self, other: &PartitionSpec) -> bool
fn ne(&self, other: &PartitionSpec) -> bool
impl Spec for PartitionSpec
const LABEL: &'static str
type IndexKey = ReplicaKey
type Status = PartitionStatus
type Owner = TopicSpec
impl StructuralPartialEq for PartitionSpec
Auto Trait Implementations
impl RefUnwindSafe for PartitionSpec
impl Send for PartitionSpec
impl Sync for PartitionSpec
impl Unpin for PartitionSpec
impl UnwindSafe for PartitionSpec
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, 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>,