line

README

Rk Processor Plugin

The rk processor plugin replaces an event routing key with a new one, depending on a current value.

Configuration

[[processors]]
  # "mapping" is a "new key -> old keys" map
  # event routing key will be replaced with a new value 
  # if current key matches one in a list
  [processors.rk.mapping]
    "events.topic.0" = [ "/http", "input.queue" ]
    "events.topic.1" = [ "/push" ]

Documentation

Index

• type Rk
  • func (p *Rk) Close() error
  • func (p *Rk) Init() error
  • func (p *Rk) Run()

Types

type Rk

type Rk struct {
	*core.BaseProcessor `mapstructure:"-"`
	Mapping             map[string][]string `mapstructure:"mapping"`
	// contains filtered or unexported fields
}

func (*Rk) Close

func (p *Rk) Close() error

func (*Rk) Init

func (p *Rk) Init() error

func (*Rk) Run

func (p *Rk) Run()