Package collection contains different StepFn functions to do different pipeline actions.

IsContextCancelErr check that input error is caused by a context cancellation.

NewGroup return a new prepared Group.

Log implement Logrus logger for debug logging.

Group store a Source and Target storage's and pipeline configuration.

ObjectError contain a pointer to an Object that failed with error.

PipelineError implement wrapper for pipeline errors.

Step contain configuration of pipeline step and it's internal structure.

StepConfigurationError raises when step have interface typing error.

StepInfo is used to represent step information, statistic and the step configuration interface.

StepStats to keep basic step statistics.

StepFn implement the type of pipeline Step function.