Struct fluvio::metadata::topic::TopicSpec

pub struct TopicSpec { /* private fields */ }

Implementations

impl TopicSpec

pub fn new_assigned(partition_map: impl Into<PartitionMaps>) -> TopicSpec

pub fn new_computed( partitions: u32, replication: u32, ignore_rack: Option<bool> ) -> TopicSpec

pub fn new_mirror(mirror: MirrorConfig) -> TopicSpec

pub fn replicas(&self) -> &ReplicaSpec

pub fn set_replicas(&mut self, replicas: ReplicaSpec)

pub fn set_cleanup_policy(&mut self, policy: CleanupPolicy)

pub fn get_partition_mirror_map(&self) -> Option<PartitionMaps>

pub fn get_clean_policy(&self) -> Option<&CleanupPolicy>

pub fn set_compression_type(&mut self, compression: CompressionAlgorithm)

pub fn get_compression_type(&self) -> &CompressionAlgorithm

pub fn get_storage(&self) -> Option<&TopicStorageConfig>

pub fn get_storage_mut(&mut self) -> Option<&mut TopicStorageConfig>

pub fn set_storage(&mut self, storage: TopicStorageConfig)

pub fn get_deduplication(&self) -> Option<&Deduplication>

pub fn set_deduplication(&mut self, deduplication: Option<Deduplication>)

pub fn is_system(&self) -> bool

pub fn set_system(&mut self, system: bool)

pub fn retention_secs(&self) -> u32

get retention secs that can be displayed

pub fn validate_config(&self) -> Option<String>

validate configuration, return string with errors

Methods from Deref<Target = ReplicaSpec>

pub fn is_computed(&self) -> bool

pub fn partitions(&self) -> u32

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

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>

Trait Implementations

impl AdminSpec for TopicSpec

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

where C: MetadataItem, 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 TopicSpec

fn clone(&self) -> TopicSpec

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for TopicSpec

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

Formats the value using the given formatter.

impl Decoder for TopicSpec

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 TopicSpec

fn default() -> TopicSpec

Returns the “default value” for a type.

impl DeletableAdminSpec for TopicSpec

type DeleteKey = String

impl Deref for TopicSpec

type Target = ReplicaSpec

The resulting type after dereferencing.

fn deref(&self) -> &<TopicSpec as Deref>::Target

Dereferences the value.

impl<'de> Deserialize<'de> for TopicSpec

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Encoder for TopicSpec

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<(u32, u32)> for TopicSpec

convert from tuple with partition and replication with rack off

fn from(spec: (u32, u32)) -> TopicSpec

Converts to this type from the input type.

impl From<(u32, u32, bool)> for TopicSpec

fn from(spec: (u32, u32, bool)) -> TopicSpec

Converts to this type from the input type.

impl From<ReplicaSpec> for TopicSpec

fn from(replicas: ReplicaSpec) -> TopicSpec

Converts to this type from the input type.

impl From<TopicConfig> for TopicSpec

fn from(config: TopicConfig) -> TopicSpec

Converts to this type from the input type.

impl K8ExtendedSpec for TopicSpec

type K8Spec = TopicSpec

const DELETE_WAIT_DEPENDENTS: bool = true

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

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

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

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

impl PartialEq for TopicSpec

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

type DeleteKey = String

impl Serialize for TopicSpec

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 TopicSpec

type Status = TopicStatus

type Header = DefaultHeader

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 TopicSpec

const LABEL: &'static str = "Topic"

type IndexKey = String

type Status = TopicStatus

type Owner = TopicSpec

impl SpecExt for TopicSpec

const OBJECT_TYPE: ObjectType = ObjectType::Topic

impl Creatable for TopicSpec

impl CreatableAdminSpec for TopicSpec

impl StructuralPartialEq for TopicSpec