pipeline

README

pipeline

Documentation

Index

• func New(opts ...Option) *pipeline
• type Option
  • func ChannelBuffer(c int) Option
  • func Context(ctx context.Context) Option
• type Options
  • func NewOptions(opts ...Option) *Options
  • func (o *Options) ChannelBuffer() int
  • func (o *Options) Context() context.Context
• type Step
• type StepFunction
  • func (p StepFunction) Close() error
  • func (p StepFunction) Info() string
  • func (p StepFunction) Run(ctx context.Context, in <-chan interface{}, out chan interface{}, ...)

Functions

func New

func New(opts ...Option) *pipeline

Types

type Option

type Option func(*Options)

func ChannelBuffer

func ChannelBuffer(c int) Option

func Context

func Context(ctx context.Context) Option

type Options

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

func NewOptions

func NewOptions(opts ...Option) *Options

func (*Options) ChannelBuffer

func (o *Options) ChannelBuffer() int

func (*Options) Context

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

type Step

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

type StepFunction

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

func (StepFunction) Close

func (p StepFunction) Close() error

func (StepFunction) Info

func (p StepFunction) Info() string

func (StepFunction) Run

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