pipeline

package module

v0.0.0-...-78ece54 Latest Latest Go to latest Published: Nov 19, 2018 License: NCSA Imports: 5 Imported by: 3

Details

This section is empty.

This section is empty.

func New(opts ...Option) *pipeline

type Option func(*Options)

func ChannelBuffer(c int) Option

func Context(ctx context.Context) Option

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

func NewOptions(opts ...Option) *Options

type Step interface {
	Info() string
	Run(ctx context.Context, in <-chan interface{}, out chan interface{}, opts ...Option)
	io.Closer
}

type StepFunction func(ctx context.Context, in interface{}, opts *Options) interface{}

func (p StepFunction) Close() error

func (p StepFunction) Info() string

func (p StepFunction) Run(ctx context.Context, in <-chan interface{}, out chan interface{}, opts ...Option)