Struct MockSourceBuilder

pub struct MockSourceBuilder { /* private fields */ }

Mock source builder for constructing a simple source for testing topologies

Implementations

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

Prime takes a closure which is called to push messages into the mock source queue.

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.