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 ofFlowPacket
s 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
All Methods Static Methods Instance Methods Concrete Methods 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()
-
-
-
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)
-
-