template

package

v1.16.2 Latest Latest Go to latest Published: Jul 10, 2026 License: Apache-2.0 Imports: 10 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 ¶

Template Processor Plugin

The template processor uses Golang templates to modify/create event Id, routing key, labels and fields. Slim-sprig functions available!

Plugin uses wrapped events.

If template execution or field setting fails, event is marked as failed, but other templates execution continues.

Configuration

[[processors]]
  [processors.template]
    # routing key template
    routing_key = '{{ .RoutingKey }}-{{ .Timestamp.Format "2006-01-02" }}'

    # id template
    id = '{{ .GetLabel "message_id" }}'

    # "label name <- template" map
    [processors.template.labels]
      host = '{{ .GetField "client.host" }}:{{ .GetField "client.port" }}'

    # "field path <- template" map
    [processors.template.fields]
      "metadata.full_address" = '{{ .GetField "address.street" }}, {{ .GetField "address.building" }}'

Documentation ¶

Index ¶

type Template

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Template ¶

type Template struct {
	*core.BaseProcessor `mapstructure:"-"`
	Id                  string            `mapstructure:"id"`
	RoutingKey          string            `mapstructure:"routing_key"`
	Labels              map[string]string `mapstructure:"labels"`
	Fields              map[string]string `mapstructure:"fields"`
	// contains filtered or unexported fields
}

func (*Template) Close ¶

func (p *Template) Close() error

func (*Template) Init ¶

func (p *Template) Init() error

func (*Template) Run ¶

func (p *Template) Run()

Source Files ¶

View all Source files

template.go

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