clone

package

v1.16.2 Latest Latest Go to latest Published: Jul 10, 2026 License: Apache-2.0 Imports: 4 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/gekatateam/neptunus

Links

Open Source Insights

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

    # clones count
    count = 1

    # "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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Clone ¶

type Clone struct {
	*core.BaseProcessor `mapstructure:"-"`
	RoutingKey          string            `mapstructure:"routing_key"`
	SaveTimestamp       bool              `mapstructure:"save_timestamp"`
	Count               int               `mapstructure:"count"`
	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()

Source Files ¶

View all Source files

clone.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL