count

Documentation

Overview

Counts the number of passing flows and prints the result on termination. Typically used to test flow counts before and after a filter segment, best used with `prefix: pre` and `prefix: post`.

Index

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

Types

type Count

type Count struct {
	segments.BaseSegment

	Prefix string // optional, default is empty, a string which is printed along with the result
	// contains filtered or unexported fields
}

func (Count) New

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

func (*Count) Run

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