Tempest源模拟队列

此源实现了一个基本的模拟消息轮询队列。大多数tempest拓扑测试都使用此Source

安装

Cargo.toml

[dependencies]
tempest-source-mock = "0.1.0"

用法

use tempest_source_mock::prelude::*;

// create a type alias to the MockSourceBuilder
type Source = MockSourceBuilder;

// configure a topology with this source
struct MyTopology {}
impl Topology<Source> for MyTopology {
    // implementation code here
}