44 lines
1.3 KiB
Go
44 lines
1.3 KiB
Go
|
package sflow
|
||
|
|
|
||
|
|
import (
|
||
|
|
"strconv"
|
||
|
|
"time"
|
||
|
|
|
||
|
|
"github.com/influxdata/telegraf"
|
||
|
|
"github.com/influxdata/telegraf/metric"
|
||
|
|
)
|
||
|
|
|
||
|
|
func makeMetrics(p *v5Format) []telegraf.Metric {
|
||
|
|
now := time.Now()
|
||
|
|
metrics := make([]telegraf.Metric, 0)
|
||
|
|
tags := map[string]string{
|
||
|
|
"agent_address": p.agentAddress.String(),
|
||
|
|
}
|
||
|
|
fields := make(map[string]interface{}, 2)
|
||
|
|
for _, sample := range p.samples {
|
||
|
|
tags["input_ifindex"] = strconv.FormatUint(uint64(sample.smplData.inputIfIndex), 10)
|
||
|
|
tags["output_ifindex"] = strconv.FormatUint(uint64(sample.smplData.outputIfIndex), 10)
|
||
|
|
tags["sample_direction"] = sample.smplData.sampleDirection
|
||
|
|
tags["source_id_index"] = strconv.FormatUint(uint64(sample.smplData.sourceIDIndex), 10)
|
||
|
|
tags["source_id_type"] = strconv.FormatUint(uint64(sample.smplData.sourceIDType), 10)
|
||
|
|
fields["drops"] = sample.smplData.drops
|
||
|
|
fields["sampling_rate"] = sample.smplData.samplingRate
|
||
|
|
|
||
|
|
for _, flowRecord := range sample.smplData.flowRecords {
|
||
|
|
if flowRecord.flowData != nil {
|
||
|
|
tags2 := flowRecord.flowData.getTags()
|
||
|
|
fields2 := flowRecord.flowData.getFields()
|
||
|
|
for k, v := range tags {
|
||
|
|
tags2[k] = v
|
||
|
|
}
|
||
|
|
for k, v := range fields {
|
||
|
|
fields2[k] = v
|
||
|
|
}
|
||
|
|
m := metric.New("sflow", tags2, fields2, now)
|
||
|
|
metrics = append(metrics, m)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
return metrics
|
||
|
|
}
|