Sumo Logic output plugin: only support HTTP POST (#8262)

etc/telegraf.conf

@@ -1328,9 +1328,6 @@
 #   ## Timeout used for HTTP request
 #   # timeout = "5s"
 #
-#   ## HTTP method, one of: "POST" or "PUT". "POST" is used by default if unset.
-#   # method = "POST"
-#
 #   ## Max HTTP request body size in bytes before compression (if applied).
 #   ## By default 1MB is recommended.
 #   ## NOTE:

plugins/outputs/sumologic/README.md

@@ -39,9 +39,6 @@ by Sumologic HTTP Source:
   ## Timeout used for HTTP request
   # timeout = "5s"
   
-  ## HTTP method, one of: "POST" or "PUT". "POST" is used by default if unset.
-  # method = "POST"
-
   ## Max HTTP request body size in bytes before compression (if applied).
   ## By default 1MB is recommended.
   ## NOTE:

plugins/outputs/sumologic/sumologic.go

@@ -4,10 +4,8 @@ import (
 	"bytes"
 	"compress/gzip"
 	"context"
-	"fmt"
 	"log"
 	"net/http"
-	"strings"
 	"time"
 
 	"github.com/pkg/errors"
@@ -46,9 +44,6 @@ const (
   ## Timeout used for HTTP request
   # timeout = "5s"
   
-  ## HTTP method, one of: "POST" or "PUT". "POST" is used by default if unset.
-  # method = "POST"
-
   ## Max HTTP request body size in bytes before compression (if applied).
   ## By default 1MB is recommended.
   ## NOTE:
@@ -100,7 +95,6 @@ const (
 type SumoLogic struct {
 	URL               string            `toml:"url"`
 	Timeout           internal.Duration `toml:"timeout"`
-	Method            string            `toml:"method"`
 	MaxRequstBodySize config.Size       `toml:"max_request_body_size"`
 
 	SourceName     string `toml:"source_name"`
@@ -159,14 +153,6 @@ func (s *SumoLogic) Connect() error {
 		return errors.Wrap(s.err, "sumologic: incorrect configuration")
 	}
 
-	if s.Method == "" {
-		s.Method = defaultMethod
-	}
-	s.Method = strings.ToUpper(s.Method)
-	if s.Method != http.MethodPost && s.Method != http.MethodPut {
-		return fmt.Errorf("invalid method [%s] %s", s.URL, s.Method)
-	}
-
 	if s.Timeout.Duration == 0 {
 		s.Timeout.Duration = defaultClientTimeout
 	}
@@ -245,7 +231,7 @@ func (s *SumoLogic) write(reqBody []byte) error {
 		return err
 	}
 
-	req, err := http.NewRequest(s.Method, s.URL, &buff)
+	req, err := http.NewRequest(defaultMethod, s.URL, &buff)
 	if err != nil {
 		return err
 	}
@@ -352,7 +338,6 @@ func Default() *SumoLogic {
 		Timeout: internal.Duration{
 			Duration: defaultClientTimeout,
 		},
-		Method:            defaultMethod,
 		MaxRequstBodySize: defaultMaxRequestBodySize,
 		headers:           make(map[string]string),
 	}

plugins/outputs/sumologic/sumologic_test.go

@@ -64,16 +64,6 @@ func getMetrics(t *testing.T, count int) []telegraf.Metric {
 	return metrics
 }
 
-func TestInvalidMethod(t *testing.T) {
-	plugin := &SumoLogic{
-		URL:    "",
-		Method: http.MethodGet,
-	}
-
-	err := plugin.Connect()
-	require.Error(t, err)
-}
-
 func TestMethod(t *testing.T) {
 	ts := httptest.NewServer(http.NotFoundHandler())
 	defer ts.Close()
@@ -96,36 +86,6 @@ func TestMethod(t *testing.T) {
 			},
 			expectedMethod: http.MethodPost,
 		},
-		{
-			name: "put is okay",
-			plugin: func() *SumoLogic {
-				s := Default()
-				s.URL = u.String()
-				s.Method = http.MethodPut
-				return s
-			},
-			expectedMethod: http.MethodPut,
-		},
-		{
-			name: "get is invalid",
-			plugin: func() *SumoLogic {
-				s := Default()
-				s.URL = u.String()
-				s.Method = http.MethodGet
-				return s
-			},
-			connectError: true,
-		},
-		{
-			name: "method is case insensitive",
-			plugin: func() *SumoLogic {
-				s := Default()
-				s.URL = u.String()
-				s.Method = "poST"
-				return s
-			},
-			expectedMethod: http.MethodPost,
-		},
 	}
 
 	for _, tt := range tests {
@@ -381,7 +341,6 @@ func TestDefaultUserAgent(t *testing.T) {
 
 		plugin := &SumoLogic{
 			URL:               u.String(),
-			Method:            defaultMethod,
 			MaxRequstBodySize: Default().MaxRequstBodySize,
 		}
 
@@ -451,7 +410,6 @@ func TestTOMLConfig(t *testing.T) {
   url = "https://localhost:3000"
   data_format = "carbon2"
   timeout = "5s"
-  method = "POST"
   source_name = "name"
   source_host = "hosta"
   source_category = "category"
@@ -466,7 +424,6 @@ func TestTOMLConfig(t *testing.T) {
   url = "https://localhost:3000"
   data_format = "carbon2"
   timeout = "5s"
-  method = "POST"
   source_name = "name"
   sumo_metadata = "metadata"
             `),