steps

func AddMeta(opts pipeline.PipelineOptions, metaCfg string) (pipeline.Step[JSON, JSON], error)

func Context(opts pipeline.PipelineOptions, countBefore, countAfter int) pipeline.Step[JSON, JSON]

func DistinctBy(opts pipeline.PipelineOptions, property string) pipeline.Step[JSON, JSON]

func ExcludeRegexp(opts pipeline.PipelineOptions, regexps []string) (pipeline.Step[string, string], error)

func ExcludeSubstringsAny(opts pipeline.PipelineOptions, substrings []string) pipeline.Step[string, string]

func Expand(opts pipeline.PipelineOptions, properties []string) pipeline.Step[JSON, JSON]

func FilterByJq(opts pipeline.PipelineOptions, filter string) (pipeline.Step[JSON, JSON], error)

func FilterByKQL(opts pipeline.PipelineOptions, filter string) (pipeline.Step[JSON, JSON], error)

func First(opts pipeline.PipelineOptions, count int) pipeline.Step[JSON, JSON]

func Hide(opts pipeline.PipelineOptions, properties []string) pipeline.Step[JSON, JSON]

func IncludeRegexp(opts pipeline.PipelineOptions, regexps []string) (pipeline.Step[string, string], error)

func IncludeSubstringsAny(opts pipeline.PipelineOptions, substrings []string) pipeline.Step[string, string]

func JsonToStr(opts pipeline.PipelineOptions) pipeline.Step[JSON, string]

func JsonToText(
	opts pipeline.PipelineOptions,
	headProps []string,
	orderProps []string,
	noNewLine,
	noProp bool,
	textDelim string,
	highlights []string) pipeline.Step[JSON, string]

func Last(opts pipeline.PipelineOptions, count int) pipeline.Step[JSON, JSON]

func Merge(
	opts pipeline.PipelineOptions,
	properties []string,
	in []pipeline.Seq[JSON]) pipeline.Seq[JSON]

func Noop[V any]() pipeline.Step[V, V]

func OpenFile(fileName string) (close func() error, reader io.Reader, err error)

func ReadByLines(fileName string, r io.Reader) pipeline.Seq[string]

func RemovePrefix(opts pipeline.PipelineOptions) pipeline.Step[string, string]

func Select(opts pipeline.PipelineOptions, properties []string) pipeline.Step[JSON, JSON]

func StrToJson(opts pipeline.PipelineOptions, durationMs []string) pipeline.Step[string, JSON]

func WriteLines(w io.Writer, showErrors bool, lines pipeline.Seq[string]) error