Enum fluvio::metadata::topic::TopicSpec [−]
pub enum TopicSpec {
Assigned(PartitionMaps),
Computed(TopicReplicaParam),
}
Variants
Assigned(PartitionMaps)
Tuple Fields of Assigned
Computed(TopicReplicaParam)
Tuple Fields of Computed
Implementations
impl TopicSpec
impl TopicSpec
pub fn new_assigned<J>(partition_map: J) -> TopicSpec where
J: Into<PartitionMaps>,
pub fn is_computed(&self) -> bool
pub fn partitions(&self) -> i32
pub fn replication_factor(&self) -> Option<i32>
pub fn ignore_rack_assignment(&self) -> bool
pub fn type_label(&self) -> &'static str
pub fn partitions_display(&self) -> String
pub fn replication_factor_display(&self) -> String
pub fn ignore_rack_assign_display(&self) -> &'static str
pub fn partition_map_str(&self) -> Option<String>
pub fn valid_partition(partitions: &i32) -> Result<(), Error>
pub fn valid_partition(partitions: &i32) -> Result<(), Error>
Validate partitions
pub fn valid_replication_factor(replication: &i32) -> Result<(), Error>
pub fn valid_replication_factor(replication: &i32) -> Result<(), Error>
Validate replication factor
Trait Implementations
pub fn into_request<K>(key: K) -> DeleteRequest where
K: Into<<TopicSpec as Removable>::DeleteKey>,
pub fn into_request<K>(key: K) -> DeleteRequest where
K: Into<<TopicSpec as Removable>::DeleteKey>,
convert delete key into request
convert from tuple with partition and replication with rack off
Performs the conversion.
pub fn into_list_request(
filters: Vec<<TopicSpec as ListSpec>::Filter, Global>
) -> ListRequest
pub fn into_list_request(
filters: Vec<<TopicSpec as ListSpec>::Filter, Global>
) -> ListRequest
convert to list request with filters
impl SpecExt for TopicSpec
impl SpecExt for TopicSpec
pub const OBJECT_TYPE: ObjectType
impl StructuralPartialEq for TopicSpec
Auto Trait Implementations
impl RefUnwindSafe for TopicSpec
impl UnwindSafe for TopicSpec
Blanket Implementations
Mutably borrows from an owned value. Read more
Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more