pub struct PartitionSpec {
pub leader: SpuId,
pub replicas: Vec<SpuId>,
pub cleanup_policy: Option<CleanupPolicy>,
pub storage: Option<TopicStorageConfig>,
pub compression_type: CompressionAlgorithm,
}
Expand description
Spec for Partition Each partition has replicas spread among SPU one of replica is leader which is duplicated in the leader field
Fields
leader: SpuId
replicas: Vec<SpuId>
cleanup_policy: Option<CleanupPolicy>
storage: Option<TopicStorageConfig>
compression_type: CompressionAlgorithm
Implementations
sourceimpl PartitionSpec
impl PartitionSpec
Trait Implementations
sourceimpl Clone for PartitionSpec
impl Clone for PartitionSpec
sourcefn clone(&self) -> PartitionSpec
fn clone(&self) -> PartitionSpec
Returns a copy of the value. Read more
1.0.0 · sourcefn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from source
. Read more
sourceimpl Debug for PartitionSpec
impl Debug for PartitionSpec
sourceimpl Decoder for PartitionSpec
impl Decoder for PartitionSpec
sourceimpl Default for PartitionSpec
impl Default for PartitionSpec
sourcefn default() -> PartitionSpec
fn default() -> PartitionSpec
Returns the “default value” for a type. Read more
sourceimpl Encoder for PartitionSpec
impl Encoder for PartitionSpec
sourceimpl PartialEq<PartitionSpec> for PartitionSpec
impl PartialEq<PartitionSpec> for PartitionSpec
sourcefn eq(&self, other: &PartitionSpec) -> bool
fn eq(&self, other: &PartitionSpec) -> bool
This method tests for self
and other
values to be equal, and is used
by ==
. Read more
sourcefn ne(&self, other: &PartitionSpec) -> bool
fn ne(&self, other: &PartitionSpec) -> bool
This method tests for !=
.
sourceimpl Spec for PartitionSpec
impl Spec for PartitionSpec
const LABEL: &'static str = "Partition"
type IndexKey = ReplicaKey
type Status = PartitionStatus
type Owner = TopicSpec
sourceimpl SpecExt for PartitionSpec
impl SpecExt for PartitionSpec
const OBJECT_TYPE: ObjectType = ObjectType::Partition
impl StructuralPartialEq for PartitionSpec
Auto Trait Implementations
impl RefUnwindSafe for PartitionSpec
impl Send for PartitionSpec
impl Sync for PartitionSpec
impl Unpin for PartitionSpec
impl UnwindSafe for PartitionSpec
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> 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