go fmt (#291)

operator/builtin/input/tcp/tcp.go

@@ -3,12 +3,12 @@ package tcp
 import (
 	"bufio"
 	"context"
+	"crypto/rand"
+	"crypto/tls"
 	"fmt"
 	"net"
 	"sync"
 	"time"
-	"crypto/rand"
-	"crypto/tls"
 
 	"github.com/observiq/stanza/operator"
 	"github.com/observiq/stanza/operator/helper"
@@ -18,11 +18,11 @@ import (
 const (
 	// minBufferSize is the initial size used for buffering
 	// TCP input
-	minBufferSize = 64*1024
+	minBufferSize = 64 * 1024
 
 	// DefaultMaxBufferSize is the max buffer sized used
 	// if MaxBufferSize is not set
-	DefaultMaxBufferSize = 1024*1024
+	DefaultMaxBufferSize = 1024 * 1024
 )
 
 func init() {
@@ -41,20 +41,20 @@ type TCPInputConfig struct {
 	helper.InputConfig `yaml:",inline"`
 
 	MaxBufferSize helper.ByteSize `json:"max_buffer_size,omitempty" yaml:"max_buffer_size,omitempty"`
-	ListenAddress string    `json:"listen_address,omitempty" yaml:"listen_address,omitempty"`
-	TLS           TLSConfig `json:"tls,omitempty" yaml:"tls,omitempty"`
+	ListenAddress string          `json:"listen_address,omitempty" yaml:"listen_address,omitempty"`
+	TLS           TLSConfig       `json:"tls,omitempty" yaml:"tls,omitempty"`
 }
 
 // TLSConfig is the configuration for a TLS listener
 type TLSConfig struct {
 	// Enable forces the user of TLS
-	Enable     bool    `json:"enable,omitempty" yaml:"enable,omitempty"`
+	Enable bool `json:"enable,omitempty" yaml:"enable,omitempty"`
 
 	// Certificate is the file path for the certificate
 	Certificate string `json:"certificate,omitempty" yaml:"certificate,omitempty"`
 
 	// PrivateKey is the file path for the private key
-	PrivateKey  string `json:"private_key,omitempty" yaml:"private_key,omitempty"`
+	PrivateKey string `json:"private_key,omitempty" yaml:"private_key,omitempty"`
 }
 
 // Build will build a tcp input operator.
@@ -136,7 +136,7 @@ func (t *TCPInput) Start() error {
 }
 
 func (t *TCPInput) configureListener() error {
-	if ! t.tlsEnable {
+	if !t.tlsEnable {
 		listener, err := net.Listen("tcp", t.address)
 		if err != nil {
 			return fmt.Errorf("failed to configure tcp listener: %w", err)
@@ -206,10 +206,10 @@ func (t *TCPInput) goHandleMessages(ctx context.Context, conn net.Conn, cancel c
 		defer t.wg.Done()
 		defer cancel()
 
-        // Initial buffer size is 64k
-        buf := make([]byte, 0, 64 * 1024)
+		// Initial buffer size is 64k
+		buf := make([]byte, 0, 64*1024)
 		scanner := bufio.NewScanner(conn)
-        scanner.Buffer(buf, t.maxBufferSize * 1024)
+		scanner.Buffer(buf, t.maxBufferSize*1024)
 		for scanner.Scan() {
 			entry, err := t.NewEntry(scanner.Text())
 			if err != nil {

operator/builtin/input/tcp/tcp_test.go

@@ -1,11 +1,11 @@
 package tcp
 
 import (
-	"os"
+	"crypto/tls"
 	"net"
+	"os"
 	"testing"
 	"time"
-	"crypto/tls"
 
 	"github.com/observiq/stanza/entry"
 	"github.com/observiq/stanza/operator"
@@ -117,26 +117,26 @@ func tlsTCPInputTest(input []byte, expected []string) func(t *testing.T) {
 	return func(t *testing.T) {
 
 		f, err := os.Create("test.crt")
-	    require.NoError(t, err)
-	    defer f.Close()
+		require.NoError(t, err)
+		defer f.Close()
 		defer os.Remove("test.crt")
-	    _, err = f.WriteString(testTLSCertificate + "\n")
-	    require.NoError(t, err)
+		_, err = f.WriteString(testTLSCertificate + "\n")
+		require.NoError(t, err)
 		f.Close()
 
 		f, err = os.Create("test.key")
-	    require.NoError(t, err)
-	    defer f.Close()
+		require.NoError(t, err)
+		defer f.Close()
 		defer os.Remove("test.key")
-	    _, err = f.WriteString(testTLSPrivateKey + "\n")
-	    require.NoError(t, err)
+		_, err = f.WriteString(testTLSPrivateKey + "\n")
+		require.NoError(t, err)
 		f.Close()
 
 		cfg := NewTCPInputConfig("test_id")
 		cfg.ListenAddress = ":0"
 		cfg.TLS.Enable = true
 		cfg.TLS.Certificate = "test.crt"
-		cfg.TLS.PrivateKey  = "test.key"
+		cfg.TLS.PrivateKey = "test.key"
 
 		ops, err := cfg.Build(testutil.NewBuildContext(t))
 		require.NoError(t, err)
@@ -182,9 +182,9 @@ func tlsTCPInputTest(input []byte, expected []string) func(t *testing.T) {
 
 func TestBuild(t *testing.T) {
 	cases := []struct {
-		name           string
-		inputRecord    TCPInputConfig
-		expectErr      bool
+		name        string
+		inputRecord TCPInputConfig
+		expectErr   bool
 	}{
 		{
 			"default-auto-address",
@@ -237,9 +237,9 @@ func TestBuild(t *testing.T) {
 				MaxBufferSize: 65536,
 				ListenAddress: "10.0.0.1:9000",
 				TLS: TLSConfig{
-					Enable: false,
+					Enable:      false,
 					Certificate: "/tmp/cert",
-					PrivateKey: "/tmp/key",
+					PrivateKey:  "/tmp/key",
 				},
 			},
 			false,
@@ -250,9 +250,9 @@ func TestBuild(t *testing.T) {
 				MaxBufferSize: 65536,
 				ListenAddress: "10.0.0.1:9000",
 				TLS: TLSConfig{
-					Enable: true,
+					Enable:      true,
 					Certificate: "/tmp/cert/missing",
-					PrivateKey: "/tmp/key/missing",
+					PrivateKey:  "/tmp/key/missing",
 				},
 			},
 			true,