Struct RedPandaClient

pub struct RedPandaClient { /* private fields */ }

Implementations

impl RedPandaClient

pub fn new( http_client: &mut Box<dyn RedPandaHttpClient>, inital_url: &str, group: &str, ) -> Result<RedPandaClient, RedPandaError>

pub fn register_topic( &mut self, client: &mut Box<dyn RedPandaHttpClient>, topics: Vec<&str>, ) -> Result<(), RedPandaError>

pub fn poll( &mut self, client: &mut Box<dyn RedPandaHttpClient>, bytecount: i32, ) -> Result<Vec<Record>, RedPandaError>

pub fn commit_state( &mut self, client: &mut Box<dyn RedPandaHttpClient>, state: &CommitState, ) -> Result<(), RedPandaError>

pub fn instance_id(&self) -> Option<String>

Trait Implementations

impl Clone for RedPandaClient

fn clone(&self) -> RedPandaClient

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.