# Functions
RegisterTestNodeTypes registers every source and node type in this file so that they're ready to be used in tests.
# Variables
AsyncFilteredEvents collects messages filtered out by AsyncFilterNode.
AsyncPassedEvents collects messages passed through by AsyncFilterNode.
ErrorEvents collects events that return errors in ErrorNode.
ErrorHandlerEvents collects events that return errors in ErrorHandlerNode.
FilteredEvents collects events that are filtered out by FilterNode.
FilterNodeMessages collects messages received by FilterNode.
ResultsNodeMessages collects messages received by ResultsNode.
SuccessEvents collects events that successfully reach ResultsNode.
# Structs
AsyncFilterNode is a AsyncNode version of FilterNode that sleeps for 1s while processing each message.
ErrorHandlerNode is a Node used as `error_handler` that simply puts the events it gets on a channel.
ErrorNode is a Node that returns an error for any events starting with 'error'.
FilterNode is a Node that filters out any events starting with 'filter'.
IndexRequestBuilderNode is a Node that converts strings to elasticsearch IndexRequests.
ResultsNode is a Node that writes all result data to an array for inspection & assertions.
SimpleSource is a source for testing that produces test records and exits.
SlowNode is a Node that sleeps for 5s while processing each message.
StringToProduceRequestNode is a Node that converts strings to `firebolt.ProduceRequest`.