Enum fluvio_controlplane_metadata::topic::ReplicaSpec

pub enum ReplicaSpec {
    Assigned(PartitionMaps),
    Computed(TopicReplicaParam),
    Mirror(MirrorConfig),
}

Variants

Assigned(PartitionMaps)

Computed(TopicReplicaParam)

Mirror(MirrorConfig)

Implementations

impl ReplicaSpec

pub fn new_assigned<J>(partition_map: J) -> Self

where J: Into<PartitionMaps>,

pub fn new_computed( partitions: PartitionCount, replication: ReplicationFactor, ignore_rack: Option<IgnoreRackAssignment> ) -> Self

pub fn is_computed(&self) -> bool

pub fn partitions(&self) -> PartitionCount

pub fn replication_factor(&self) -> Option<ReplicationFactor>

pub fn ignore_rack_assignment(&self) -> IgnoreRackAssignment

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: &PartitionCount) -> Result<()>

Validate partitions

pub fn valid_replication_factor(replication: &ReplicationFactor) -> Result<()>

Validate replication factor

Trait Implementations

impl Clone for ReplicaSpec

fn clone(&self) -> ReplicaSpec

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ReplicaSpec

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Decoder for ReplicaSpec

fn decode<T>(&mut self, src: &mut T, version: Version) -> Result<(), Error>

where T: Buf,

fn decode_from<T>(src: &mut T, version: i16) -> Result<Self, Error>

where T: Buf,

decode Fluvio compliant protocol values from buf

impl Default for ReplicaSpec

fn default() -> Self

Returns the “default value” for a type.

impl Display for ReplicaSpec

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Encoder for ReplicaSpec

fn encode<T>(&self, dest: &mut T, version: Version) -> Result<(), Error>

where T: BufMut,

encoding contents for buffer

fn write_size(&self, version: Version) -> usize

size of this object in bytes

fn as_bytes(&self, version: i16) -> Result<Bytes, Error>

impl From<ReplicaSpec> for TopicSpec

fn from(replicas: ReplicaSpec) -> Self

Converts to this type from the input type.

impl PartialEq for ReplicaSpec

fn eq(&self, other: &ReplicaSpec) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for ReplicaSpec

impl StructuralPartialEq for ReplicaSpec