dropfields

Documentation

Overview

Drops fields from any passing flow.

Index

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

Types

type DropFields

type DropFields struct {
	segments.BaseSegment
	Policy string // required, options are 'keep' or 'drop'
	Fields string // optional, default is empty, 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)