Struct TopicSpec 

pub struct TopicSpec { /* private fields */ }

Implementations

impl TopicSpec

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

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

pub fn new_mirror(mirror: MirrorConfig) -> Self

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) -> 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>

Trait Implementations

impl Clone for TopicSpec

fn clone(&self) -> TopicSpec

Returns a duplicate 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

Formats the value using the given formatter.

impl Decoder for TopicSpec

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 TopicSpec

fn default() -> TopicSpec

Returns the “default value” for a type.

impl Deref for TopicSpec

type Target = ReplicaSpec

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl Encoder for TopicSpec

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

convert from tuple with partition and replication with rack off

fn from(spec: (PartitionCount, ReplicationFactor)) -> Self

Converts to this type from the input type.

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

fn from(spec: (PartitionCount, ReplicationFactor, IgnoreRackAssignment)) -> Self

Converts to this type from the input type.

impl From<ReplicaSpec> for TopicSpec

fn from(replicas: ReplicaSpec) -> Self

Converts to this type from the input type.

impl From<TopicConfig> for TopicSpec

fn from(config: TopicConfig) -> Self

Converts to this type from the input type.

impl PartialEq for TopicSpec

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

type DeleteKey = String

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 StructuralPartialEq for TopicSpec