Abhishek jha/traceroute input plugin

plugins/inputs/all/traceroute.go

@@ -0,0 +1,5 @@
+//go:build !custom || inputs || inputs.activemq
+
+package all
+
+import _ "github.com/influxdata/telegraf/plugins/inputs/traceroute" // register plugin

plugins/inputs/traceroute/sample.conf

@@ -0,0 +1,14 @@
+# Gather metrics from traceroute to URLs.
+[[inputs.traceroute]]
+  urls = ["example.org"]
+
+  ## Use only IPv6 addresses when resolving a hostname.
+  # ipv6 = false
+
+  ## number of queries to send per hop
+
+  ## time to wait for a response
+
+  ## the hop limit and port to use
+
+  ## traceroute -w 3 -q 1 -m 16 google.com

plugins/inputs/traceroute/traceroute.go

@@ -0,0 +1,44 @@
+//go:generate ../../../tools/readme_config_includer/generator
+package traceroute
+
+import (
+	_ "embed"
+	"fmt"
+	"github.com/influxdata/telegraf"
+	"github.com/influxdata/telegraf/plugins/inputs"
+	"sync"
+)
+
+//go:embed sample.conf
+var sampleConfig string
+
+type Traceroute struct {
+	wg sync.WaitGroup
+
+	Log telegraf.Logger `toml:"-"`
+
+	// URLs to traceroute
+	Urls []string
+}
+
+func (*Traceroute) SampleConfig() string {
+	return sampleConfig
+}
+
+func (t *Traceroute) Init() error {
+	for index, element := range t.Urls {
+		fmt.Println("At index", index, "value is", element)
+	}
+	return nil
+}
+
+func (t *Traceroute) Gather(acc telegraf.Accumulator) error {
+	println("Hola!")
+	return nil
+}
+
+func init() {
+	inputs.Add("traceroute", func() telegraf.Input {
+		return &Traceroute{}
+	})
+}

plugins/inputs/traceroute/traceroute_test.go

@@ -0,0 +1 @@
+package traceroute