pipeline

package

v0.0.0-...-ffe269a Latest Latest Go to latest Published: Nov 7, 2022 License: Apache-2.0 Imports: 1 Imported by: 0

Details

View Source

const SKIP_ALL = -1

This section is empty.

This section is empty.

type Collect struct {
}

func (self Collect) Run(input, output Pipe)

type Filter struct {
	FilterFunc func(item interface{}) bool
}

func (self Filter) Run(input, output Pipe)

type LastValue struct {
	// contains filtered or unexported fields
}

func (self *LastValue) Last() interface{}

func (self *LastValue) Run(input, output Pipe)

type Nonblocking struct {
}

func (self Nonblocking) Run(input, output Pipe)

type Pipe chan interface{}

Pipeline basic block element

func Pipeline(input Pipe, processors ...Processor) Pipe

func (p Pipe) Clone(n int) []Pipe

func (p Pipe) Destination(pipes ...Pipe)

func (p Pipe) Next(proc Processor) Pipe

Next sets up following pipeline chain element It returns last Pipe in Pipeline

type Processor interface {
	Run(input, output Pipe)
}

Pipeline processing interface

type Skip struct {
	Count int
}

func (self Skip) Run(input, output Pipe)

type StringContains struct {
	Str string
}

func (self StringContains) Run(input, output Pipe)

type WaitForCompletion struct {
}

func (w WaitForCompletion) Run(input, output Pipe)