Struct fluvio_sc_schema::topic::TopicStatus [−][src]
pub struct TopicStatus { pub resolution: TopicResolution, pub replica_map: BTreeMap<i32, Vec<i32, Global>>, pub reason: String, }
Fields
resolution: TopicResolution
replica_map: BTreeMap<i32, Vec<i32, Global>>
reason: String
Implementations
impl TopicStatus
[src]
impl TopicStatus
[src]pub fn new<S>(
resolution: TopicResolution,
replica_map: Vec<Vec<i32, Global>, Global>,
reason: S
) -> TopicStatus where
S: Into<String>,
[src]
resolution: TopicResolution,
replica_map: Vec<Vec<i32, Global>, Global>,
reason: S
) -> TopicStatus where
S: Into<String>,
pub fn resolution(&self) -> &TopicResolution
[src]
pub fn replica_map_cnt(&self) -> i32
[src]
pub fn set_replica_map(&mut self, replica_map: BTreeMap<i32, Vec<i32, Global>>)
[src]
pub fn spus_in_replica(&self) -> Vec<i32, Global>
[src]
pub fn replica_map_str(&self) -> String
[src]
pub fn replica_map_cnt_str(&self) -> String
[src]
pub fn reason_str(&self) -> &String
[src]
pub fn is_resolution_initializing(&self) -> bool
[src]
pub fn need_replica_map_recal(&self) -> bool
[src]
need to update the replic map
pub fn is_resolution_pending(&self) -> bool
[src]
pub fn is_resolution_transient(&self) -> bool
[src]
pub fn is_resolution_provisioned(&self) -> bool
[src]
pub fn next_resolution_provisioned() -> (TopicResolution, String)
[src]
pub fn next_resolution_pending() -> (TopicResolution, String)
[src]
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>,
[src]
S: Into<String>,
pub fn set_resolution_no_resource<S>(reason: S) -> (TopicResolution, String) where
S: Into<String>,
[src]
S: Into<String>,
pub fn set_next_resolution(&mut self, next: (TopicResolution, String))
[src]
Trait Implementations
impl Clone for TopicStatus
[src]
impl Clone for TopicStatus
[src]pub fn clone(&self) -> TopicStatus
[src]
pub fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Decoder for TopicStatus
[src]
impl Decoder for TopicStatus
[src]impl Default for TopicStatus
[src]
impl Default for TopicStatus
[src]pub fn default() -> TopicStatus
[src]
impl Encoder for TopicStatus
[src]
impl Encoder for TopicStatus
[src]impl PartialEq<TopicStatus> for TopicStatus
[src]
impl PartialEq<TopicStatus> for TopicStatus
[src]pub fn eq(&self, other: &TopicStatus) -> bool
[src]
pub fn ne(&self, other: &TopicStatus) -> bool
[src]
impl Status for TopicStatus
[src]
impl Status for TopicStatus
[src]impl StructuralPartialEq for TopicStatus
[src]
impl StructuralPartialEq for TopicStatus
[src]Auto Trait Implementations
impl RefUnwindSafe for TopicStatus
impl RefUnwindSafe for TopicStatus
impl Send for TopicStatus
impl Send for TopicStatus
impl Sync for TopicStatus
impl Sync for TopicStatus
impl Unpin for TopicStatus
impl Unpin for TopicStatus
impl UnwindSafe for TopicStatus
impl UnwindSafe for TopicStatus
Blanket Implementations
impl<T> Instrument for T
[src]
impl<T> Instrument for T
[src]