Struct fluvio_controlplane_metadata::topic::TopicSpec
source · [−]pub struct TopicSpec { /* private fields */ }
Implementations
sourceimpl TopicSpec
impl TopicSpec
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 replicas(&self) -> &ReplicaSpec
pub fn set_cleanup_policy(&mut self, policy: CleanupPolicy)
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)
sourcepub fn retention_secs(&self) -> u32
pub fn retention_secs(&self) -> u32
get retention secs that can be displayed
sourcepub fn validate_config(&self) -> Option<String>
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
sourceimpl Deref for TopicSpec
impl Deref for TopicSpec
type Target = ReplicaSpec
type Target = ReplicaSpec
The resulting type after dereferencing.
sourceimpl From<(i32, i32, bool)> for TopicSpec
impl From<(i32, i32, bool)> for TopicSpec
sourcefn from(spec: (PartitionCount, ReplicationFactor, IgnoreRackAssignment)) -> Self
fn from(spec: (PartitionCount, ReplicationFactor, IgnoreRackAssignment)) -> Self
Converts to this type from the input type.
sourceimpl From<(i32, i32)> for TopicSpec
impl From<(i32, i32)> for TopicSpec
convert from tuple with partition and replication with rack off
sourcefn from(spec: (PartitionCount, ReplicationFactor)) -> Self
fn from(spec: (PartitionCount, ReplicationFactor)) -> Self
Converts to this type from the input type.
sourceimpl From<ReplicaSpec> for TopicSpec
impl From<ReplicaSpec> for TopicSpec
sourcefn from(replicas: ReplicaSpec) -> Self
fn from(replicas: ReplicaSpec) -> Self
Converts to this type from the input type.
sourceimpl SpecExt for TopicSpec
impl SpecExt for TopicSpec
const OBJECT_TYPE: ObjectType
impl Creatable for TopicSpec
impl StructuralPartialEq for TopicSpec
Auto Trait Implementations
impl RefUnwindSafe for TopicSpec
impl Send for TopicSpec
impl Sync for TopicSpec
impl Unpin for TopicSpec
impl UnwindSafe for TopicSpec
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<T> ToOwned for T where
T: Clone,
impl<T> ToOwned for T where
T: Clone,
type Owned = T
type Owned = T
The resulting type after obtaining ownership.
sourcefn clone_into(&self, target: &mut T)
fn clone_into(&self, target: &mut T)
🔬 This is a nightly-only experimental API. (
toowned_clone_into
)Uses borrowed data to replace owned data, usually by cloning. Read more
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more