pipeline

package module

v1.0.0 Latest Latest Go to latest Published: Mar 13, 2021 License: NCSA Imports: 5 Imported by: 4

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

func (o *Options) ChannelBuffer() int

func (o *Options) Context() context.Context

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)