CleanupHandlerDefault handles CTRL-C and SIGTERM.

GetCleanupHandlerWithChannelsFunc returns a function that waits for a CTRL-C etc and/or a stop signal on chanShutdown.

GetPanicHandlerWithChannelsFunc will create a func that can be deferred to handle recovery and send the final TransformStatus{} error info to channel chanStatus.

LaunchTransform will start all transform groups and their steps found in TransformDefinition t.

LaunchTransformJson validates the supplied TransformDefinition and launches the transform.

LaunchTransformWithControlChannels launches a transform that can be stopped by sending to chanStop.

NewMetadataInjection will launch transform group T after replacing variables with values found in cfg.ReplacementVariableWithFieldNameCSV.

NewStepGroupManager constructs a new stepGroup{}, which satisfies interface StepGroupManager{}.

NewTransformManager sets up a new top-level transform manager - consider this for global use.

StartStepGroup will launch all steps defined in StepGroup sg.

TransformDefinition Manager to wrap a map[string]StepGroupManager with locking, via Load() and Store() methods.

Transform struct to manage consumers of the channels created by transform nodes.

TransformCloser tracks the channels used to maintain transform status and whether it is shutdown or not.

TransformDefinition contains groupings of transform steps.

StatsManager abstracts stats capture for transform group steps.

StepGroupManager used to track individual transform step groups.

TransformManager that can spawn child managers of type StepGroupManager used to track individual transform step groups.

TODO: combine StepStatus and Status (at the transform level) if possible.