Struct fluvio_sc_schema::topic::TopicSpec
source · [−]pub struct TopicSpec { /* private fields */ }
Implementations
sourceimpl TopicSpec
impl TopicSpec
pub fn new_assigned<J>(partition_map: J) -> TopicSpec where
J: Into<PartitionMaps>,
pub fn new_computed(
partitions: i32,
replication: i32,
ignore_rack: Option<bool>
) -> TopicSpec
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) -> i32
pub fn replication_factor(&self) -> Option<i32>
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
sourceimpl AdminSpec for TopicSpec
impl AdminSpec for TopicSpec
type ListFilter = String
type ListType = Metadata<TopicSpec>
type WatchResponseType = TopicSpec
sourcefn convert_from<C: MetadataItem>(
obj: &MetadataStoreObject<Self, C>
) -> Self::ListType where
<Self as AdminSpec>::ListType: From<MetadataStoreObject<Self, C>>,
fn convert_from<C: MetadataItem>(
obj: &MetadataStoreObject<Self, C>
) -> Self::ListType where
<Self as AdminSpec>::ListType: From<MetadataStoreObject<Self, C>>,
convert metadata object to list type object
sourceimpl CreatableAdminSpec for TopicSpec
impl CreatableAdminSpec for TopicSpec
const CREATE_TYPE: u8 = 0u8
sourceimpl DeletableAdminSpec for TopicSpec
impl DeletableAdminSpec for TopicSpec
sourceimpl From<(i32, i32)> for TopicSpec
impl From<(i32, i32)> for TopicSpec
convert from tuple with partition and replication with rack off
sourceimpl From<ReplicaSpec> for TopicSpec
impl From<ReplicaSpec> for TopicSpec
sourcefn from(replicas: ReplicaSpec) -> TopicSpec
fn from(replicas: ReplicaSpec) -> TopicSpec
Converts to this type from the input type.
sourceimpl SpecExt for TopicSpec
impl SpecExt for TopicSpec
const OBJECT_TYPE: ObjectType = ObjectType::Topic
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