mask

README

Keep fields plugin

Mask plugin matches event with regular expression and substitutions successfully matched symbols via asterix symbol. You could set regular expressions and submatch groups.

Example:

pipelines:
  example_pipeline:
    ...
    actions:
    - type: mask
      metric_subsystem_name: "some_name"
      masks:
      - mask:
        re: "\b(\d{1,4})\D?(\d{1,4})\D?(\d{1,4})\D?(\d{1,4})\b"
        groups: [1,2,3]
    ...

Config params

metric_subsystem_name *string

If set counterMetric with this name would be sent on metric_subsystem_name.mask_plugin

masks []Mask

List of masks.

re string required

Regular expression for masking

groups []int required

Numbers of masking groups in expression, zero for mask all expression

Generated using insane-doc

Documentation

Index

• Variables
• type Config
• type Mask
• type Plugin
  • func (p *Plugin) Do(event *pipeline.Event) pipeline.ActionResult
  • func (p *Plugin) Start(config pipeline.AnyConfig, params *pipeline.ActionPluginParams)
  • func (p *Plugin) Stop()

Variables

var MaskPromCounter = prometheus.NewCounter(prometheus.CounterOpts{})

Types

type Config

type Config struct {
	//> @3@4@5@6
	//>
	//> If set counterMetric with this name would be sent on metric_subsystem_name.mask_plugin
	MetricSubsystemName *string `json:"metric_subsystem_name" required:"false"` //*

	//> @3@4@5@6
	//>
	//> List of masks.
	Masks []Mask `json:"masks"` //*
}

! config-params ^ config-params

type Mask

type Mask struct {
	//> @3@4@5@6
	//>
	//> Regular expression for masking
	Re  string `json:"re" default:"" required:"true"` //*
	Re_ *regexp.Regexp

	//> @3@4@5@6
	//>
	//> Numbers of masking groups in expression, zero for mask all expression
	Groups []int `json:"groups" required:"true"` //*
}

type Plugin

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

func (*Plugin) Do

func (p *Plugin) Do(event *pipeline.Event) pipeline.ActionResult

func (*Plugin) Start

func (p *Plugin) Start(config pipeline.AnyConfig, params *pipeline.ActionPluginParams)

func (*Plugin) Stop

func (p *Plugin) Stop()