Struct fluvio_controlplane_metadata::partition::PartitionSpec

pub struct PartitionSpec {
    pub leader: SpuId,
    pub replicas: Vec<SpuId>,
    pub cleanup_policy: Option<CleanupPolicy>,
    pub storage: Option<TopicStorageConfig>,
    pub compression_type: CompressionAlgorithm,
    pub deduplication: Option<Deduplication>,
    pub system: bool,
    pub mirror: Option<PartitionMirrorConfig>,
}

Spec for Partition Each partition has replicas spread among SPU one of replica is leader which is duplicated in the leader field

Fields

leader: SpuId

replicas: Vec<SpuId>

cleanup_policy: Option<CleanupPolicy>

storage: Option<TopicStorageConfig>

compression_type: CompressionAlgorithm

deduplication: Option<Deduplication>

system: bool

mirror: Option<PartitionMirrorConfig>

Implementations

impl PartitionSpec

pub fn new(leader: SpuId, replicas: Vec<SpuId>) -> Self

pub fn from_replicas( replicas: Vec<SpuId>, topic: &TopicSpec, mirror: Option<&PartitionMirrorConfig> ) -> Self

Create new partition spec from replica mapping with topic spec. This assume first replica is leader

pub fn has_spu(&self, spu: &SpuId) -> bool

pub fn followers(&self) -> Vec<SpuId>

follower replicas

pub fn mirror_string(&self) -> String

Trait Implementations

impl Clone for PartitionSpec

fn clone(&self) -> PartitionSpec

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for PartitionSpec

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

Formats the value using the given formatter.

impl Decoder for PartitionSpec

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 PartitionSpec

fn default() -> PartitionSpec

Returns the “default value” for a type.

impl Encoder for PartitionSpec

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<Vec<i32>> for PartitionSpec

fn from(replicas: Vec<SpuId>) -> Self

Converts to this type from the input type.

impl PartialEq for PartitionSpec

fn eq(&self, other: &PartitionSpec) -> 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 Spec for PartitionSpec

const LABEL: &'static str = "Partition"

type IndexKey = ReplicaKey

type Status = PartitionStatus

type Owner = TopicSpec

impl SpecExt for PartitionSpec

const OBJECT_TYPE: ObjectType = ObjectType::Partition

impl Eq for PartitionSpec

impl StructuralPartialEq for PartitionSpec