tempest 0.1.1

Realtime message handling framework inspired by Apache Storm and built with Actix
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41

use tempest::prelude::*;
use tempest::rt::test;

mod topology;

#[test]
fn simple() {
    topology::setup();

    let builder = topology::simple::SimpleTopology::test_builder;
    let metrics = test::TestRun::new(builder)
        .duration_secs(5)
        .graceful_shutdown_secs(5)
        .agent_port(6336)
        .run();

    assert_eq!(
        metrics.get("SimpleTopology.source.msg.read"),
        Some(&1000isize)
    );
    assert_eq!(
        metrics.get("SimpleTopology.source.msg.acked.success"),
        Some(&1000isize)
    );
    assert_eq!(
        metrics.get("SimpleTopology.topology.msg.moved"),
        Some(&1000isize)
    );
    assert_eq!(
        metrics.get("SimpleTopology.topology.source.msg.ack"),
        Some(&1000isize)
    );
    assert_eq!(
        metrics.get("SimpleTopology.pipeline.task.available"),
        Some(&1000isize)
    );
    assert_eq!(
        metrics.get("SimpleTopology.T1.task.msg.outflow"),
        Some(&1000isize)
    );
}