Module tempest::rt::test

Multi-threaded test runtime for running Topologies and aggregating metrics.

This runtime works like this:

• You'll probably use the TopologyBuilder.test_builder method for initializing the runtime.
• Topology and Tasks runtimes are launched as threads.
• An Agent is spawned on a thread which collects aggregated metrics sent from the topology and tasks.
• The aggregated metrics are prefixed as Topology.name or Task.name.
• A TestRun is configurable with timeouts for initiating topology shutdowns (in order to kill the threads).
• The Agent flushes the aggregated metrics to disk so we can read and output them as TestMetrics from the completion of this runtime.
• Test assertions can be written using the aggregated metrics.

Structs

TestRun

Data structure for testing topology code