Struct PollMessagesCmd 

pub struct PollMessagesCmd { /* private fields */ }

Implementations

impl PollMessagesCmd

pub fn new( stream_id: Identifier, topic_id: Identifier, partition_id: u32, message_count: u32, auto_commit: bool, offset: Option<u64>, first: bool, last: bool, next: bool, consumer: Identifier, show_headers: bool, output_file: Option<String>, ) -> Self

Trait Implementations

impl CliCommand for PollMessagesCmd

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