//go:generate ../../../tools/readme_config_includer/generator package ipset import ( "bufio" "bytes" _ "embed" "fmt" "os/exec" "strconv" "strings" "time" "github.com/influxdata/telegraf" "github.com/influxdata/telegraf/config" "github.com/influxdata/telegraf/internal" "github.com/influxdata/telegraf/plugins/inputs" ) //go:embed sample.conf var sampleConfig string var defaultTimeout = config.Duration(time.Second) const measurement = "ipset" type Ipset struct { IncludeUnmatchedSets bool `toml:"include_unmatched_sets"` UseSudo bool `toml:"use_sudo"` Timeout config.Duration `toml:"timeout"` CountPerIPEntries bool lister setLister entriesParser ipsetEntries } type setLister func(Timeout config.Duration, UseSudo bool) (*bytes.Buffer, error) func (*Ipset) SampleConfig() string { return sampleConfig } func (*Ipset) Init() error { _, err := exec.LookPath("ipset") if err != nil { return err } return nil } func (i *Ipset) Gather(acc telegraf.Accumulator) error { out, e := i.lister(i.Timeout, i.UseSudo) if e != nil { acc.AddError(e) } scanner := bufio.NewScanner(out) for scanner.Scan() { line := scanner.Text() if i.CountPerIPEntries { acc.AddError(i.entriesParser.addLine(line, acc)) } // Ignore sets created without the "counters" option nocomment := strings.Split(line, "\"")[0] if !strings.Contains(nocomment, "packets") || !strings.Contains(nocomment, "bytes") { continue } data := strings.Fields(line) if len(data) < 7 { acc.AddError(fmt.Errorf("error parsing line (expected at least 7 fields): %s", line)) continue } if data[0] == "add" && (data[4] != "0" || i.IncludeUnmatchedSets) { tags := map[string]string{ "set": data[1], "rule": data[2], } fields := make(map[string]interface{}, 3) for i, field := range data { switch field { case "timeout": val, err := strconv.ParseUint(data[i+1], 10, 64) if err != nil { acc.AddError(err) } fields["timeout"] = val case "packets": val, err := strconv.ParseUint(data[i+1], 10, 64) if err != nil { acc.AddError(err) } fields["packets_total"] = val case "bytes": val, err := strconv.ParseUint(data[i+1], 10, 64) if err != nil { acc.AddError(err) } fields["bytes_total"] = val } } acc.AddCounter(measurement, fields, tags) } } i.entriesParser.commit(acc) return nil } func setList(timeout config.Duration, useSudo bool) (*bytes.Buffer, error) { // Is ipset installed ? ipsetPath, err := exec.LookPath("ipset") if err != nil { return nil, err } var args []string cmdName := ipsetPath if useSudo { cmdName = "sudo" args = append(args, ipsetPath) } args = append(args, "save") cmd := exec.Command(cmdName, args...) var out bytes.Buffer cmd.Stdout = &out err = internal.RunTimeout(cmd, time.Duration(timeout)) if err != nil { return &out, fmt.Errorf("error running ipset save: %w", err) } return &out, nil } func init() { inputs.Add("ipset", func() telegraf.Input { return &Ipset{ lister: setList, Timeout: defaultTimeout, } }) }