telegraf/plugins/inputs/system/net.go

125 lines
2.6 KiB
Go
Raw Permalink Normal View History

2015-05-18 23:01:42 +00:00
package system
import (
"fmt"
"net"
"strings"
2015-05-18 23:01:42 +00:00
"github.com/influxdata/telegraf"
"github.com/influxdata/telegraf/filter"
2016-01-20 18:57:35 +00:00
"github.com/influxdata/telegraf/plugins/inputs"
2015-05-18 23:01:42 +00:00
)
type NetIOStats struct {
filter filter.Filter
ps PS
2015-05-18 23:01:42 +00:00
skipChecks bool
IgnoreProtocolStats bool
Interfaces []string
2015-05-18 23:01:42 +00:00
}
func (_ *NetIOStats) Description() string {
return "Read metrics about network interface usage"
}
var netSampleConfig = `
## By default, telegraf gathers stats from any up interface (excluding loopback)
## Setting interfaces will tell it to gather these explicit interfaces,
## regardless of status.
##
# interfaces = ["eth0"]
##
## On linux systems telegraf also collects protocol stats.
## Setting ignore_protocol_stats to true will skip reporting of protocol metrics.
##
# ignore_protocol_stats = false
##
2015-05-18 23:01:42 +00:00
`
func (_ *NetIOStats) SampleConfig() string {
return netSampleConfig
}
func (s *NetIOStats) Gather(acc telegraf.Accumulator) error {
2015-05-18 23:01:42 +00:00
netio, err := s.ps.NetIO()
if err != nil {
return fmt.Errorf("error getting net io info: %s", err)
}
if s.filter == nil {
if s.filter, err = filter.Compile(s.Interfaces); err != nil {
return fmt.Errorf("error compiling filter: %s", err)
}
}
2015-05-18 23:01:42 +00:00
for _, io := range netio {
if len(s.Interfaces) != 0 {
var found bool
if s.filter.Match(io.Name) {
found = true
2015-05-18 23:01:42 +00:00
}
if !found {
continue
}
2015-05-27 05:14:55 +00:00
} else if !s.skipChecks {
2015-05-18 23:01:42 +00:00
iface, err := net.InterfaceByName(io.Name)
if err != nil {
continue
}
if iface.Flags&net.FlagLoopback == net.FlagLoopback {
continue
}
if iface.Flags&net.FlagUp == 0 {
continue
}
}
tags := map[string]string{
"interface": io.Name,
}
2015-12-11 20:07:32 +00:00
fields := map[string]interface{}{
"bytes_sent": io.BytesSent,
"bytes_recv": io.BytesRecv,
"packets_sent": io.PacketsSent,
"packets_recv": io.PacketsRecv,
"err_in": io.Errin,
"err_out": io.Errout,
"drop_in": io.Dropin,
"drop_out": io.Dropout,
}
acc.AddCounter("net", fields, tags)
2015-05-18 23:01:42 +00:00
}
// Get system wide stats for different network protocols
// (ignore these stats if the call fails)
if !s.IgnoreProtocolStats {
netprotos, _ := s.ps.NetProto()
fields := make(map[string]interface{})
for _, proto := range netprotos {
for stat, value := range proto.Stats {
name := fmt.Sprintf("%s_%s", strings.ToLower(proto.Protocol),
strings.ToLower(stat))
fields[name] = value
}
}
tags := map[string]string{
"interface": "all",
}
acc.AddFields("net", fields, tags)
}
2015-05-18 23:01:42 +00:00
return nil
}
func init() {
inputs.Add("net", func() telegraf.Input {
2017-04-18 18:42:58 +00:00
return &NetIOStats{ps: newSystemPS()}
2015-05-18 23:01:42 +00:00
})
}