copy

README

Clone Processor Plugin

The clone processor creates clone of each event with new routing key and extra labels (if configured).

Configuration

[[processors]]
  [processors.clone]
    # new routing key for an event copy
    routing_key = "rabbit.events.out.2"

    # if true, new event will be created with origin event timestamp
    save_timestamp = false

    # "labels" is a "label name -> label value" map
    # if label does not exists, it will be added
    # if label already exists, it will be overwritten
    [processors.clone.labels]
      shard_key = "1984"

Documentation

Index

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

Types

type Clone

type Clone struct {
	*core.BaseProcessor `mapstructure:"-"`
	RoutingKey          string            `mapstructure:"routing_key"`
	SaveTimestamp       bool              `mapstructure:"save_timestamp"`
	Labels              map[string]string `mapstructure:"labels"`
}

func (*Clone) Close

func (p *Clone) Close() error

func (*Clone) Init

func (p *Clone) Init() error

func (*Clone) Run

func (p *Clone) Run()