Struct CreateTopicCmd 

pub struct CreateTopicCmd { /* private fields */ }

Implementations

impl CreateTopicCmd

pub fn new( stream_id: Identifier, partitions_count: u32, compression_algorithm: CompressionAlgorithm, name: String, message_expiry: IggyExpiry, max_topic_size: MaxTopicSize, replication_factor: u8, ) -> Self

Trait Implementations

impl CliCommand for CreateTopicCmd

fn explain(&self) -> String

fn execute_cmd<'life0, 'life1, 'async_trait>( &'life0 mut self, client: &'life1 dyn Client, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn use_tracing(&self) -> bool

fn login_required(&self) -> bool

fn connection_required(&self) -> bool

impl Display for CreateTopicCmd

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.