Struct tempest::topology::DefaultSource

pub struct DefaultSource {}

Trait Implementations

impl Source for DefaultSource

fn name(&self) -> &'static str

return the name of this source

fn healthy(&mut self) -> SourceResult<()>

fn validate(&mut self) -> SourceResult<()>

fn setup(&mut self) -> SourceResult<()>

fn drain(&mut self) -> SourceResult<()>

fn teardown(&mut self) -> SourceResult<()>

fn connect(&mut self) -> SourceResult<()>

fn poll(&mut self) -> SourcePollResult

Poll for new message from the source

fn monitor(&mut self) -> SourceResult<()>

fn ack(&mut self, _msg_id: MsgId) -> SourceResult<(i32, i32)>

fn batch_ack(&mut self, msgs: Vec<MsgId>) -> SourceResult<(i32, i32)>

fn max_backoff(&self) -> SourceResult<&u64>

fn max_pending(&self) -> SourceResult<&SourcePollPending>

fn poll_interval(&self) -> SourceResult<&SourceInterval>

fn monitor_interval(&self) -> SourceResult<&SourceInterval>

fn ack_policy(&self) -> SourceResult<&SourceAckPolicy>

fn ack_interval(&self) -> SourceResult<&SourceInterval>

Configures how often the source should check for new messages to ack

fn msg_error(&mut self, _msg: Msg)

A message generated an error while being handled by the topology. Implement clean up code here.

fn msg_timeout(&mut self, _msg: Msg)

A message timed out while being handled by the topology. Implement clean up code here.

fn flush_metrics(&mut self)

Called to flush source.metrics