output

package

v2.0.0-...-73bef05 Latest Latest Go to latest Published: Aug 10, 2024 License: MIT Imports: 20 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

type Option func(options *Options)

Option is a function for configure Options

func OptionMysqlMode(mode pipeline.Mode) Option

OptionPipeMode sets mysql mode

func OptionOutput(val *pipeline.Output) Option

OptionOutput sets Output

func OptionPipeName(name string) Option

OptionPipeName sets pipeline name

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

Options for configure 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(opts ...Option) (out *Output, err error)

New return a Output object

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

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

Run start Output to send message