output

Documentation

Index

• 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 Option

type Option func(options *Options)

Option is a function for configure Options

func OptionOutput

func OptionOutput(val *pipeline.Output) Option

OptionOutput sets Output

type Options

type Options struct {
	Output *pipeline.Output
}

Options for configure output

type Output

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

Output handle message output depends pipeline config, send message to stdout、kafka, etc.

func New

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

New return a Output object

func (*Output) Context

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

Context return Output's context

func (*Output) Run

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

Run start Output to send message