elephant

Documentation

Overview

Filters out the bulky average of flows.

Index

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

Types

type Elephant

type Elephant struct {
	segments.BaseFilterSegment
	Aspect     string  // optional, one of "bytes", "bps", "packets", or "pps", default is "bytes", determines which aspect qualifies a flow as an elephant
	Percentile float64 // optional, default is 99.00, determines the cutoff percentile for flows being dropped by this segment, i.e. 95.00 corresponds to outputting the top 5% only
	// TODO: add option to get bottom percent?
	Exact      bool // optional, default is false, determines whether to use percentiles that are exact or generated using the P-square estimation algorithm
	Window     int  // optional, default is 300, sets the number of seconds used as a sliding window size
	RampupTime int  // optional, default is 0, sets the time to wait for analyzing flows. All flows within this Timerange are dropped.
}

func (Elephant) New

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

func (*Elephant) Run

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