pub enum ReplicaSpec {
Assigned(PartitionMaps),
Computed(TopicReplicaParam),
}
Variants
Assigned(PartitionMaps)
Computed(TopicReplicaParam)
Implementations
sourceimpl ReplicaSpec
impl ReplicaSpec
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 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>
sourcepub fn valid_partition(partitions: &PartitionCount) -> Result<(), Error>
pub fn valid_partition(partitions: &PartitionCount) -> Result<(), Error>
Validate partitions
sourcepub fn valid_replication_factor(
replication: &ReplicationFactor
) -> Result<(), Error>
pub fn valid_replication_factor(
replication: &ReplicationFactor
) -> Result<(), Error>
Validate replication factor
Trait Implementations
sourceimpl Clone for ReplicaSpec
impl Clone for ReplicaSpec
sourcefn clone(&self) -> ReplicaSpec
fn clone(&self) -> ReplicaSpec
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 ReplicaSpec
impl Debug for ReplicaSpec
sourceimpl Decoder for ReplicaSpec
impl Decoder for ReplicaSpec
sourceimpl Default for ReplicaSpec
impl Default for ReplicaSpec
sourceimpl Display for ReplicaSpec
impl Display for ReplicaSpec
sourceimpl Encoder for ReplicaSpec
impl Encoder for ReplicaSpec
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 PartialEq<ReplicaSpec> for ReplicaSpec
impl PartialEq<ReplicaSpec> for ReplicaSpec
sourcefn eq(&self, other: &ReplicaSpec) -> bool
fn eq(&self, other: &ReplicaSpec) -> bool
This method tests for self
and other
values to be equal, and is used
by ==
. Read more
sourcefn ne(&self, other: &ReplicaSpec) -> bool
fn ne(&self, other: &ReplicaSpec) -> bool
This method tests for !=
.
impl StructuralPartialEq for ReplicaSpec
Auto Trait Implementations
impl RefUnwindSafe for ReplicaSpec
impl Send for ReplicaSpec
impl Sync for ReplicaSpec
impl Unpin for ReplicaSpec
impl UnwindSafe for ReplicaSpec
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