Struct tempest_source_mock::MockSourceBuilder

pub struct MockSourceBuilder { /* fields omitted */ }

Methods

impl MockSourceBuilder

pub fn read_msg_count(self, count: usize) -> Self

pub fn poll_interval(self, ms: u64) -> Self

pub fn ack_policy(self, policy: SourceAckPolicy) -> Self

pub fn max_backoff(self, ms: u64) -> Self

pub fn prime(self, f: fn(mock: &mut MockSource)) -> Self

Trait Implementations

impl Default for MockSourceBuilder

fn default() -> MockSourceBuilder

Returns the "default value" for a type.

impl SourceBuilder for MockSourceBuilder

type Source = MockSource

fn build(&self) -> Self::Source

fn parse_config_value(&mut self, _cfg: Value)

Given a Topology.toml for a [source.config] config::Value override the options for the source.