dropfields

Documentation

Overview

Drops fields from any passing flow.

Index

• Variables
• type DropFields
  • func (segment *DropFields) New(config map[string]string) segments.Segment
  • func (segment *DropFields) Run(wg *sync.WaitGroup)
• type Policy

Variables

var (
	FieldSplitRegex = regexp.MustCompile(`[\s,;:]+`)
)

Types

type DropFields

type DropFields struct {
	segments.BaseSegment
	Policy Policy   // required, determines whether to keep or drop fields
	Fields []string // required, determines which fields are kept/dropped
}

func (*DropFields) New

func (segment *DropFields) New(config map[string]string) segments.Segment

func (*DropFields) Run

func (segment *DropFields) Run(wg *sync.WaitGroup)

type Policy

type Policy int

const (
	PolicyDrop Policy = iota
	PolicyKeep
)