[−]Enum fluvio::metadata::topic::TopicSpec
Variants
Assigned(PartitionMaps)
Computed(TopicReplicaParam)
Implementations
impl TopicSpec
pub fn new_assigned<J>(partition_map: J) -> TopicSpec where
J: Into<PartitionMaps>,
J: Into<PartitionMaps>,
pub fn new_computed(
partitions: i32,
replication: i32,
ignore_rack: Option<bool>
) -> TopicSpec
partitions: i32,
replication: i32,
ignore_rack: Option<bool>
) -> TopicSpec
pub fn is_computed(&self) -> bool
pub fn partitions(&self) -> Option<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>
pub fn valid_partition(partitions: &i32) -> Result<(), Error>
Validate partitions
pub fn valid_replication_factor(replication: &i32) -> Result<(), Error>
Validate replication factor
Trait Implementations
impl Clone for TopicSpec
fn clone(&self) -> TopicSpec
fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Creatable for TopicSpec
impl Debug for TopicSpec
impl Decoder for TopicSpec
fn decode<T>(&mut self, src: &mut T, version: i16) -> Result<(), Error> where
T: Buf,
T: Buf,
fn decode_from<T>(src: &mut T, version: i16) -> Result<Self, Error> where
Self: Default,
T: Buf,
Self: Default,
T: Buf,
impl Default for TopicSpec
impl DeleteSpec for TopicSpec
[src]
fn into_request<K>(key: K) -> DeleteRequest where
K: Into<<TopicSpec as Removable>::DeleteKey>,
[src]
K: Into<<TopicSpec as Removable>::DeleteKey>,
impl Display for TopicSpec
impl Encoder for TopicSpec
fn write_size(&self, version: i16) -> usize
fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
fn as_bytes(&self, version: i16) -> Result<Bytes, Error>
impl From<(i32, i32, bool)> for TopicSpec
impl From<(i32, i32)> for TopicSpec
convert from tuple with partition and replication with rack off
impl From<TopicSpec> for AllCreatableSpec
[src]
fn from(spec: TopicSpec) -> AllCreatableSpec
[src]
impl ListSpec for TopicSpec
[src]
type Filter = String
filter type
fn into_list_request(
filters: Vec<<TopicSpec as ListSpec>::Filter>
) -> ListRequest
[src]
filters: Vec<<TopicSpec as ListSpec>::Filter>
) -> ListRequest
impl PartialEq<TopicSpec> for TopicSpec
impl Removable for TopicSpec
impl Spec 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
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> Erased for T
impl<T> From<T> for T
[src]
impl<T> Instrument for T
[src]
fn instrument(self, span: Span) -> Instrumented<Self>
[src]
fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T> Instrument for T
[src]
fn instrument(self, span: Span) -> Instrumented<Self>
[src]
fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
fn to_owned(&self) -> T
[src]
fn clone_into(&self, target: &mut T)
[src]
impl<T> ToString for T where
T: Display + ?Sized,
[src]
T: Display + ?Sized,
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<T> WithSubscriber for T
[src]
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
[src]
S: Into<Dispatch>,