input

Documentation

Index

• type Input
  • func New(opts ...Option) (input *Input, err error)
  • func (r *Input) Closed() chan struct{}
  • func (r *Input) Run(ctx context.Context) (err error)
• type Option
  • func OptionsNodeName(name string) Option
  • func OptionsPipeName(name string) Option
• type Options

Types

type Input

type Input struct {
	OutChan chan *message.Message
	Options *Options
	// contains filtered or unexported fields
}

Input read binlog event from mysql

func New

func New(opts ...Option) (input *Input, err error)

New returns a new Input

func (*Input) Closed

func (r *Input) Closed() chan struct{}

func (*Input) Run

func (r *Input) Run(ctx context.Context) (err error)

Run Input start working

type Option

type Option func(options *Options)

Option is function of configure Options

func OptionsNodeName

func OptionsNodeName(name string) Option

OptionsNodeName sets Options pipeline node name

func OptionsPipeName

func OptionsPipeName(name string) Option

OptionsPipeName sets Options pipeline name

type Options

type Options struct {
	PipeName string
	NodeName string
}

Options for Input Options