output

Documentation

Index

• type Option
  • func OptionMysqlMode(mode pipeline.Mode) Option
  • func OptionOutput(val *pipeline.Output) Option
  • func OptionPipeName(name string) Option
• type Options
• type Output
  • func New(opts ...Option) (out *Output, err error)
  • func (o *Output) Closed() chan struct{}
  • 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 OptionMysqlMode

func OptionMysqlMode(mode pipeline.Mode) Option

OptionPipeMode sets mysql mode

func OptionOutput

func OptionOutput(val *pipeline.Output) Option

OptionOutput sets Output

func OptionPipeName

func OptionPipeName(name string) Option

OptionPipeName sets pipeline name

type Options

type Options struct {
	Output       *pipeline.Output
	PipelineName string
	MysqlMode    pipeline.Mode
}

Options for configure output

type Output

type Output struct {
	InChan  chan *message.Message
	Sender  sender.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) Closed

func (o *Output) Closed() chan struct{}

func (*Output) Run

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

Run start Output to send message