Struct Subscriber 

pub struct Subscriber { /* private fields */ }

Implementations

impl Subscriber

pub fn new( http_client: Box<dyn SimpleHttpClient>, inital_url: &str, group: &str, name: Option<&str>, ) -> Result<Self, RedPandaError>

pub fn register_topic( &mut self, topics: Vec<(&str, u16)>, ) -> Result<(), RedPandaError>

pub fn process_record(&mut self, record: &Record)

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

pub fn commit_state(&mut self) -> Result<(), RedPandaError>

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