Struct fluvio_sc_schema::partition::PartitionSpec

pub struct PartitionSpec {
    pub leader: i32,
    pub replicas: Vec<i32>,
    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: i32

replicas: Vec<i32>

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: i32, replicas: Vec<i32>) -> PartitionSpec

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

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

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

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

follower replicas

pub fn mirror_string(&self) -> String

Trait Implementations

impl AdminSpec for PartitionSpec

fn convert_from<C: MetadataItem>( obj: &MetadataStoreObject<Self, C>, ) -> Metadata<Self>

where Metadata<Self>: From<MetadataStoreObject<Self, C>>, Self::Status: Encoder + Decoder + Debug,

convert metadata object to list type object

fn summary(self) -> Self

return summary version of myself

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<(), Error>

Formats the value using the given formatter.

impl Decoder for PartitionSpec

fn decode<T>(&mut self, src: &mut T, version: i16) -> 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<'de> Deserialize<'de> for PartitionSpec

fn deserialize<__D>( __deserializer: __D, ) -> Result<PartitionSpec, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Encoder for PartitionSpec

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

where T: BufMut,

encoding contents for buffer

fn write_size(&self, version: i16) -> 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<i32>) -> PartitionSpec

Converts to this type from the input type.

impl K8ExtendedSpec for PartitionSpec

const FINALIZER: Option<&'static str> = _

type K8Spec = PartitionSpec

fn convert_from_k8( k8_obj: K8Obj<<PartitionSpec as K8ExtendedSpec>::K8Spec>, multi_namespace_context: bool, ) -> Result<MetadataStoreObject<PartitionSpec, K8MetaItem>, K8ConvertError<<PartitionSpec as K8ExtendedSpec>::K8Spec>>

fn convert_status_from_k8( status: <PartitionSpec as Spec>::Status, ) -> <PartitionSpec as Spec>::Status

fn into_k8(self) -> <PartitionSpec as K8ExtendedSpec>::K8Spec

const DELETE_WAIT_DEPENDENTS: bool = false

impl PartialEq for PartitionSpec

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

Tests for self and other values to be equal, and is used by ==.

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

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

impl Serialize for PartitionSpec

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Spec for PartitionSpec

type Header = DefaultHeader

type Status = PartitionStatus

fn metadata() -> &'static Crd

return uri for single instance

const NAME_SPACED: bool = true

if true, spec is namespaced

fn label() -> &'static str

fn api_version() -> String

fn kind() -> String

fn make_same(&mut self, _other: &Self)

in case of applying, we have some fields that are generated or override. So need to special logic to reset them so we can do proper comparison

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