[−]Struct fluvio::metadata::topic::TopicStatus
Fields
resolution: TopicResolution
replica_map: BTreeMap<i32, Vec<i32>>
reason: String
Implementations
impl TopicStatus
pub fn new<S>(
resolution: TopicResolution,
replica_map: Vec<Vec<i32>>,
reason: S
) -> TopicStatus where
S: Into<String>,
resolution: TopicResolution,
replica_map: Vec<Vec<i32>>,
reason: S
) -> TopicStatus where
S: Into<String>,
pub fn resolution(&self) -> &TopicResolution
pub fn replica_map_cnt(&self) -> i32
pub fn set_replica_map(&mut self, replica_map: BTreeMap<i32, Vec<i32>>)
pub fn spus_in_replica(&self) -> Vec<i32>
pub fn replica_map_str(&self) -> String
pub fn replica_map_cnt_str(&self) -> String
pub fn reason_str(&self) -> &String
pub fn is_resolution_initializing(&self) -> bool
pub fn need_replica_map_recal(&self) -> bool
need to update the replic map
pub fn is_resolution_pending(&self) -> bool
pub fn is_resolution_transient(&self) -> bool
pub fn is_resolution_provisioned(&self) -> bool
pub fn next_resolution_provisioned() -> (TopicResolution, String)
pub fn next_resolution_pending() -> (TopicResolution, String)
set to pending mode which means it is waiting for spu resources to be allocated
pub fn next_resolution_invalid_config<S>(reason: S) -> (TopicResolution, String) where
S: Into<String>,
S: Into<String>,
pub fn set_resolution_no_resource<S>(reason: S) -> (TopicResolution, String) where
S: Into<String>,
S: Into<String>,
pub fn set_next_resolution(&mut self, next: (TopicResolution, String))
Trait Implementations
impl Clone for TopicStatus
fn clone(&self) -> TopicStatus
fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Debug for TopicStatus
impl Decoder for TopicStatus
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 TopicStatus
fn default() -> TopicStatus
impl Display for TopicStatus
impl Encoder for TopicStatus
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 PartialEq<TopicStatus> for TopicStatus
fn eq(&self, other: &TopicStatus) -> bool
fn ne(&self, other: &TopicStatus) -> bool
impl Status for TopicStatus
impl StructuralPartialEq for TopicStatus
Auto Trait Implementations
impl RefUnwindSafe for TopicStatus
impl Send for TopicStatus
impl Sync for TopicStatus
impl Unpin for TopicStatus
impl UnwindSafe for TopicStatus
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>,