From 1a5c940bf985320684f1dcdf78963e78f5721221 Mon Sep 17 00:00:00 2001
From: Josh Powers <powersj@fastmail.com>
Date: Fri, 7 Jul 2023 14:15:54 -0600
Subject: [PATCH] move port on instrumental

---
 plugins/outputs/instrumental/instrumental.go      | 5 ++++-
 plugins/outputs/instrumental/instrumental_test.go | 3 ++-
 2 files changed, 6 insertions(+), 2 deletions(-)

diff --git a/plugins/outputs/instrumental/instrumental.go b/plugins/outputs/instrumental/instrumental.go
index 30ce9d8cac5e9..6c2d13d91537f 100644
--- a/plugins/outputs/instrumental/instrumental.go
+++ b/plugins/outputs/instrumental/instrumental.go
@@ -28,6 +28,7 @@ var (
 
 type Instrumental struct {
 	Host       string          `toml:"host"`
+	Port       string          `toml:"port"`
 	APIToken   config.Secret   `toml:"api_token"`
 	Prefix     string          `toml:"prefix"`
 	DataFormat string          `toml:"data_format"`
@@ -44,6 +45,7 @@ type Instrumental struct {
 
 const (
 	DefaultHost     = "collector.instrumentalapp.com"
+	DefaultPort     = "8000"
 	HelloMessage    = "hello version go/telegraf/1.1\n"
 	AuthFormat      = "authenticate %s\n"
 	HandshakeFormat = HelloMessage + AuthFormat
@@ -70,7 +72,7 @@ func (i *Instrumental) Init() error {
 }
 
 func (i *Instrumental) Connect() error {
-	connection, err := net.DialTimeout("tcp", i.Host+":8000", time.Duration(i.Timeout))
+	connection, err := net.DialTimeout("tcp", i.Host+":"+i.Port, time.Duration(i.Timeout))
 
 	if err != nil {
 		i.conn = nil
@@ -203,6 +205,7 @@ func init() {
 	outputs.Add("instrumental", func() telegraf.Output {
 		return &Instrumental{
 			Host:     DefaultHost,
+			Port:     DefaultPort,
 			Template: graphite.DefaultTemplate,
 		}
 	})
diff --git a/plugins/outputs/instrumental/instrumental_test.go b/plugins/outputs/instrumental/instrumental_test.go
index 54170e798baef..1e888feaddc26 100644
--- a/plugins/outputs/instrumental/instrumental_test.go
+++ b/plugins/outputs/instrumental/instrumental_test.go
@@ -22,6 +22,7 @@ func TestWrite(t *testing.T) {
 
 	i := Instrumental{
 		Host:     "127.0.0.1",
+		Port:     "8887",
 		APIToken: config.NewSecret([]byte("abc123token")),
 		Prefix:   "my.prefix",
 	}
@@ -81,7 +82,7 @@ func TestWrite(t *testing.T) {
 }
 
 func TCPServer(t *testing.T, wg *sync.WaitGroup) {
-	tcpServer, err := net.Listen("tcp", "127.0.0.1:8000")
+	tcpServer, err := net.Listen("tcp", "127.0.0.1:8887")
 	require.NoError(t, err)
 
 	go func() {