Package org.opennms.smoketest.telemetry

Class FlowTester

java.lang.Object

org.opennms.smoketest.telemetry.FlowTester

public class FlowTester
extends Object

Simple helper which sends a defined set of FlowPackets to OpenNMS or Minion and afterwards verifies the data at the elastic endpoints. Optionally it can also run verifications before sending flows or check the results at the OpenNMS ReST endpoint as well.

Author:

mvrueden

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	FlowTester.Block
static class	FlowTester.Delivery

Constructor Summary

Constructors

Constructor	Description
FlowTester(InetSocketAddress elasticAddress, InetSocketAddress opennmsWebAddress, List<FlowTester.Delivery> deliveries)

Method Summary

Modifier and Type	Method	Description
io.searchbox.client.JestClient	getJestClient()
void	setRunAfter(List<java.util.function.Consumer<FlowTester>> runAfter)
void	setRunBefore(List<java.util.function.Consumer<FlowTester>> runBefore)
static void	verify(FlowTester.Block verifyCallback)
void	verifyFlows()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FlowTester

public FlowTester(InetSocketAddress elasticAddress,
                  InetSocketAddress opennmsWebAddress,
                  List<FlowTester.Delivery> deliveries)

Method Detail

verifyFlows

public void verifyFlows()
                 throws IOException

Throws:

IOException

setRunBefore

public void setRunBefore(List<java.util.function.Consumer<FlowTester>> runBefore)

setRunAfter

public void setRunAfter(List<java.util.function.Consumer<FlowTester>> runAfter)

getJestClient

public io.searchbox.client.JestClient getJestClient()

verify

public static void verify(FlowTester.Block verifyCallback)