Function New

internal/pipe/pipeline.go:54–62

NewPipeline returns a Pipeline struct with all of the `options` applied.

(options ...Option)

// NewPipeline returns a Pipeline struct with all of the `options`
// applied.
func New(options ...Option) *Pipeline {
	p := &Pipeline{}

	for _, option := range options {
		option(p)
	}

	return p
}

// Option is a type alias for Pipeline functional options.
type Option func(*Pipeline)