toptalkers

Documentation

Index

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

Types

type Record

type Record struct {
	DstIp   string
	Bytes   *rolling.TimePolicy
	Packets *rolling.TimePolicy
}

type TopTalkers

type TopTalkers struct {
	segments.BaseSegment

	Window         int    // optional, default is 60, sets the number of seconds used as a sliding window size
	ReportInterval int    // optional, default is 10, sets the number of seconds between report printing
	FileName       string // optional, default is "" (stdout), where to put the toptalker logs
	LogPrefix      string // optional, default is "", a prefix for each log line, useful in case multiple segments log to the same file
	ThresholdBps   uint64 // optional, default is 0, only log talkers with an average bits per second rate higher than this value
	ThresholdPps   uint64 // optional, default is 0, only log talkers with an average packets per second rate higher than this value
	TopN           uint64 // optional, default is 10, sets the number of top talkers per report
	// contains filtered or unexported fields
}

func (TopTalkers) New

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

func (*TopTalkers) Run

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