Struct fluvio::metadata::topic::TopicStatus [−]
Fields
resolution: TopicResolution
replica_map: BTreeMap<i32, Vec<i32, Global>>
reason: String
Implementations
impl TopicStatus
pub fn new<S>(
resolution: TopicResolution,
replica_map: Vec<Vec<i32, Global>, Global>,
reason: S
) -> TopicStatus where
S: Into<String>,
resolution: TopicResolution,
replica_map: Vec<Vec<i32, Global>, Global>,
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, Global>>)
pub fn spus_in_replica(&self) -> Vec<i32, Global>
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
pub fn clone(&self) -> TopicStatus
pub fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Debug for TopicStatus
impl Decoder for TopicStatus
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 TopicStatus
pub fn default() -> TopicStatus
impl Display for TopicStatus
impl Encoder for TopicStatus
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 PartialEq<TopicStatus> for TopicStatus
pub fn eq(&self, other: &TopicStatus) -> bool
pub 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,
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> 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.
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>,