otelmw

Documentation

Index

• func WithProcessor(pluginName, recipeName string) func(plugins.Processor) plugins.Processor
• func WithSink(pluginName, recipeName string) func(plugins.Syncer) plugins.Syncer
• type Processor
  • func (mw *Processor) Info() plugins.Info
  • func (mw *Processor) Init(ctx context.Context, cfg plugins.Config) error
  • func (mw *Processor) Process(ctx context.Context, src models.Record) (dst models.Record, err error)
  • func (mw *Processor) Validate(cfg plugins.Config) error
• type Sinks
  • func (mw *Sinks) Close() error
  • func (mw *Sinks) Info() plugins.Info
  • func (mw *Sinks) Init(ctx context.Context, cfg plugins.Config) error
  • func (mw *Sinks) Sink(ctx context.Context, batch []models.Record) (err error)
  • func (mw *Sinks) Validate(cfg plugins.Config) error

Functions

func WithProcessor

func WithProcessor(pluginName, recipeName string) func(plugins.Processor) plugins.Processor

func WithSink

func WithSink(pluginName, recipeName string) func(plugins.Syncer) plugins.Syncer

Types

type Processor

type Processor struct {
	// contains filtered or unexported fields
}

func (*Processor) Info

func (mw *Processor) Info() plugins.Info

func (*Processor) Init

func (mw *Processor) Init(ctx context.Context, cfg plugins.Config) error

func (*Processor) Process

func (mw *Processor) Process(ctx context.Context, src models.Record) (dst models.Record, err error)

func (*Processor) Validate

func (mw *Processor) Validate(cfg plugins.Config) error

type Sinks

type Sinks struct {
	// contains filtered or unexported fields
}

func (*Sinks) Close

func (mw *Sinks) Close() error

func (*Sinks) Info

func (mw *Sinks) Info() plugins.Info

func (*Sinks) Init

func (mw *Sinks) Init(ctx context.Context, cfg plugins.Config) error

func (*Sinks) Sink

func (mw *Sinks) Sink(ctx context.Context, batch []models.Record) (err error)

func (*Sinks) Validate

func (mw *Sinks) Validate(cfg plugins.Config) error