each

README

each - Input Duplicator

Arguments

- some-pipeline:
    each:
        - pipeline-1
        - pipeline-2
        - pipeline-3:
            args:
                additional: value

Documentation

Overview

The `each` middleware copies some input into several child pipes running simultaneously

Index

• type EachMiddleware
  • func NewEachMiddleware() EachMiddleware
  • func (eachMiddleware EachMiddleware) Apply(run *pipeline.Run, next func(*pipeline.Run), ...)
  • func (_ EachMiddleware) String() string

Types

type EachMiddleware

type EachMiddleware struct {
}

Input Duplicator

func NewEachMiddleware

func NewEachMiddleware() EachMiddleware

func (EachMiddleware) Apply

func (eachMiddleware EachMiddleware) Apply(
	run *pipeline.Run,
	next func(*pipeline.Run),
	executionContext *middleware.ExecutionContext,
)

func (EachMiddleware) String

func (_ EachMiddleware) String() string