It provides an API to test pipelines and other plugins.
No config params
In(sourceID pipeline.SourceID, sourceName string, offset int64, bytes []byte)
It sends a test event into the pipeline.
SetCommitFn(fn func(event *pipeline.Event))
It sets up a hook to make sure the test event has been successfully committed.
SetInFn(fn func())
It sets up a hook to make sure the test event has been passed to the plugin.
Generated using insane-doc