normalize

Documentation

Overview

Rewrites passing flows with all sampling rate affected fields normalized.

Index

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

Types

type Normalize

type Normalize struct {
	segments.BaseSegment
	Fallback uint64 // optional, default is no fallback, determines a assumed sampling rate of flows if none is found in a given flow
}

func (Normalize) New

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

func (*Normalize) Run

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