output

Documentation

Index

• type Controller
• type Option
  • func OptionOutput(val *pipeline.Output) Option
• type Options
• type Output
  • func New(opts ...Option) (out *Output, err error)
  • func (o *Output) Context() context.Context
  • func (o *Output) Run(ctx context.Context) (err error)

Types

type Controller

type Controller struct {
}

type Option

type Option func(options *Options)

func OptionOutput

func OptionOutput(val *pipeline.Output) Option

type Options

type Options struct {
	Output *pipeline.Output
}

type Output

type Output struct {
	InChan  chan *message2.Message
	Sender  sender2.Sender
	Options *Options
	// contains filtered or unexported fields
}

func New

func New(opts ...Option) (out *Output, err error)

func (*Output) Context

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

func (*Output) Run

func (o *Output) Run(ctx context.Context) (err error)