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, Global>
Implementations
impl PartitionSpec
pub fn new(leader: i32, replicas: Vec<i32, Global>) -> PartitionSpec
pub fn has_spu(&self, spu: &i32) -> bool
pub fn followers(&self) -> Vec<i32, Global>
follower replicas
Trait Implementations
impl Clone for PartitionSpec
pub fn clone(&self) -> PartitionSpec
pub fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Debug for PartitionSpec
impl Decoder for PartitionSpec
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 PartitionSpec
pub fn default() -> PartitionSpec
impl Encoder for PartitionSpec
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, Global>> for PartitionSpec
pub fn from(replicas: Vec<i32, Global>) -> PartitionSpec
impl ListSpec for PartitionSpec
[src]
type Filter = String
filter type
pub fn into_list_request(
filters: Vec<<PartitionSpec as ListSpec>::Filter, Global>
) -> ListRequest
[src]
filters: Vec<<PartitionSpec as ListSpec>::Filter, Global>
) -> ListRequest
impl PartialEq<PartitionSpec> for PartitionSpec
pub fn eq(&self, other: &PartitionSpec) -> bool
pub fn ne(&self, other: &PartitionSpec) -> bool
impl Spec for PartitionSpec
pub const LABEL: &'static str
type IndexKey = ReplicaKey
type Status = PartitionStatus
type Owner = TopicSpec
impl SpecExt for PartitionSpec
pub const OBJECT_TYPE: ObjectType
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,
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, 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>,