Struct fluvio_sc_schema::partition::PartitionStatus [−][src]
pub struct PartitionStatus { pub resolution: PartitionResolution, pub leader: ReplicaStatus, pub lsr: u32, pub replicas: Vec<ReplicaStatus, Global>, pub is_being_deleted: bool, }
Fields
resolution: PartitionResolution
leader: ReplicaStatus
lsr: u32
replicas: Vec<ReplicaStatus, Global>
is_being_deleted: bool
Implementations
impl PartitionStatus
[src]
impl PartitionStatus
[src]pub fn leader(leader: impl Into<ReplicaStatus>) -> PartitionStatus
[src]
pub fn new(
leader: impl Into<ReplicaStatus>,
replicas: Vec<ReplicaStatus, Global>
) -> PartitionStatus
[src]
leader: impl Into<ReplicaStatus>,
replicas: Vec<ReplicaStatus, Global>
) -> PartitionStatus
pub fn new2(
leader: impl Into<ReplicaStatus>,
replicas: Vec<ReplicaStatus, Global>,
resolution: PartitionResolution
) -> PartitionStatus
[src]
leader: impl Into<ReplicaStatus>,
replicas: Vec<ReplicaStatus, Global>,
resolution: PartitionResolution
) -> PartitionStatus
pub fn is_online(&self) -> bool
[src]
pub fn is_offline(&self) -> bool
[src]
pub fn lsr(&self) -> u32
[src]
pub fn replica_iter(&self) -> Iter<'_, ReplicaStatus>
[src]
pub fn live_replicas(&self) -> Vec<i32, Global>
[src]
pub fn offline_replicas(&self) -> Vec<i32, Global>
[src]
pub fn has_live_replicas(&self) -> bool
[src]
pub fn set_to_delete(self) -> PartitionStatus
[src]
pub fn set_to_delete(self) -> PartitionStatus
[src]set to being deleted
pub fn candidate_leader<P>(
&self,
online: &HashSet<i32, RandomState>,
policy: &P
) -> Option<i32> where
P: ElectionPolicy,
[src]
pub fn candidate_leader<P>(
&self,
online: &HashSet<i32, RandomState>,
policy: &P
) -> Option<i32> where
P: ElectionPolicy,
[src]Fnd best candidate from online replicas If there are multiple matches, find with best score (lowest lag)
pub fn merge(&mut self, other: PartitionStatus)
[src]
pub fn merge(&mut self, other: PartitionStatus)
[src]merge status from spu ignore changes from spu = -1 or offsets = -1
Trait Implementations
impl Clone for PartitionStatus
[src]
impl Clone for PartitionStatus
[src]pub fn clone(&self) -> PartitionStatus
[src]
pub fn clone(&self) -> PartitionStatus
[src]Returns a copy of the value. Read more
fn clone_from(&mut self, source: &Self)
1.0.0[src]
fn clone_from(&mut self, source: &Self)
1.0.0[src]Performs copy-assignment from source
. Read more
impl Debug for PartitionStatus
[src]
impl Debug for PartitionStatus
[src]impl Decoder for PartitionStatus
[src]
impl Decoder for PartitionStatus
[src]impl Default for PartitionStatus
[src]
impl Default for PartitionStatus
[src]pub fn default() -> PartitionStatus
[src]
pub fn default() -> PartitionStatus
[src]Returns the “default value” for a type. Read more
impl Display for PartitionStatus
[src]
impl Display for PartitionStatus
[src]impl Encoder for PartitionStatus
[src]
impl Encoder for PartitionStatus
[src]impl PartialEq<PartitionStatus> for PartitionStatus
[src]
impl PartialEq<PartitionStatus> for PartitionStatus
[src]pub fn eq(&self, other: &PartitionStatus) -> bool
[src]
pub fn eq(&self, other: &PartitionStatus) -> bool
[src]This method tests for self
and other
values to be equal, and is used
by ==
. Read more
pub fn ne(&self, other: &PartitionStatus) -> bool
[src]
pub fn ne(&self, other: &PartitionStatus) -> bool
[src]This method tests for !=
.
impl Status for PartitionStatus
[src]
impl StructuralPartialEq for PartitionStatus
[src]
Auto Trait Implementations
impl RefUnwindSafe for PartitionStatus
impl Send for PartitionStatus
impl Sync for PartitionStatus
impl Unpin for PartitionStatus
impl UnwindSafe for PartitionStatus
Blanket Implementations
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]pub fn borrow_mut(&mut self) -> &mut T
[src]
pub fn borrow_mut(&mut self) -> &mut T
[src]Mutably borrows from an owned value. Read more
impl<T> Instrument for T
[src]
impl<T> Instrument for T
[src]fn instrument(self, span: Span) -> Instrumented<Self>
[src]
fn instrument(self, span: Span) -> Instrumented<Self>
[src]Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
fn in_current_span(self) -> Instrumented<Self>
[src]
fn in_current_span(self) -> Instrumented<Self>
[src]impl<T> ToOwned for T where
T: Clone,
[src]
impl<T> ToOwned for T where
T: Clone,
[src]type Owned = T
type Owned = T
The resulting type after obtaining ownership.
pub fn to_owned(&self) -> T
[src]
pub fn to_owned(&self) -> T
[src]Creates owned data from borrowed data, usually by cloning. Read more
pub fn clone_into(&self, target: &mut T)
[src]
pub fn clone_into(&self, target: &mut T)
[src]🔬 This is a nightly-only experimental API. (toowned_clone_into
)
recently added
Uses borrowed data to replace owned data, usually by cloning. Read more