all: gofmt code for current go versions

Signed-off-by: Sebastiaan van Stijn <[email protected]>

Author: thaJeztah

README.md

@@ -8,15 +8,15 @@ fluent-logger-golang
 
 ## How to install
 
-```
-go get github.com/fluent/fluent-logger-golang/fluent
+```bash
+go get github.com/fluent/fluent-logger-golang/fluent@latest
 ```
 
 ## Usage
 
 Install the package with `go get` and use `import` to include it in your project.
 
-```
+```go
 import "github.com/fluent/fluent-logger-golang/fluent"
 ```
 
@@ -26,27 +26,28 @@ import "github.com/fluent/fluent-logger-golang/fluent"
 package main
 
 import (
-  "github.com/fluent/fluent-logger-golang/fluent"
-  "fmt"
-  //"time"
+	"fmt"
+	// "time"
+
+	"github.com/fluent/fluent-logger-golang/fluent"
 )
 
 func main() {
-  logger, err := fluent.New(fluent.Config{})
-  if err != nil {
-    fmt.Println(err)
-  }
-  defer logger.Close()
-  tag := "myapp.access"
-  var data = map[string]string{
-    "foo":  "bar",
-    "hoge": "hoge",
-  }
-  error := logger.Post(tag, data)
-  // error := logger.PostWithTime(tag, time.Now(), data)
-  if error != nil {
-    panic(error)
-  }
+	logger, err := fluent.New(fluent.Config{})
+	if err != nil {
+		fmt.Println(err)
+	}
+	defer logger.Close()
+	tag := "myapp.access"
+	data := map[string]string{
+		"foo":  "bar",
+		"hoge": "hoge",
+	}
+	error := logger.Post(tag, data)
+	// error = logger.PostWithTime(tag, time.Now(), data)
+	if error != nil {
+		panic(error)
+	}
 }
 ```
 
@@ -181,7 +182,7 @@ were involved. Starting v1.8.0, the logger no longer accepts `Fluent.Post()`
 after `Fluent.Close()`, and instead returns a "Logger already closed" error.
 
 ## Tests
-```
 
+```bash
 go test
 ```

_examples/main.go

@@ -5,7 +5,7 @@ import (
 	"log"
 	"time"
 
-	"../fluent"
+	"github.com/fluent/fluent-logger-golang/fluent"
 )
 
 func main() {
@@ -15,9 +15,10 @@ func main() {
 	}
 	defer logger.Close()
 	tag := "myapp.access"
-	var data = map[string]string{
+	data := map[string]string{
 		"foo":  "bar",
-		"hoge": "hoge"}
+		"hoge": "hoge",
+	}
 	for i := 0; i < 100; i++ {
 		e := logger.Post(tag, data)
 		if e != nil {

fluent/fluent.go

@@ -1,8 +1,11 @@
 package fluent
 
 import (
+	"bytes"
 	"context"
 	"crypto/tls"
+	"encoding/base64"
+	"encoding/binary"
 	"encoding/json"
 	"errors"
 	"fmt"
@@ -16,10 +19,6 @@ import (
 	"sync/atomic"
 	"time"
 
-	"bytes"
-	"encoding/base64"
-	"encoding/binary"
-
 	"github.com/tinylib/msgp/msgp"
 )
 

fluent/fluent_test.go

@@ -311,7 +311,8 @@ func Test_New_itShouldUseUnixDomainSocketIfUnixSocketSpecified(t *testing.T) {
 
 	f, err := New(Config{
 		FluentNetwork:    network,
-		FluentSocketPath: socketFile})
+		FluentSocketPath: socketFile,
+	})
 	if err != nil {
 		t.Error(err)
 		return
@@ -324,7 +325,8 @@ func Test_New_itShouldUseUnixDomainSocketIfUnixSocketSpecified(t *testing.T) {
 	network = "unixxxx"
 	fUnknown, err := New(Config{
 		FluentNetwork:    network,
-		FluentSocketPath: socketFile})
+		FluentSocketPath: socketFile,
+	})
 	if _, ok := err.(*ErrUnknownNetwork); !ok {
 		t.Errorf("err type: %T", err)
 	}
@@ -350,12 +352,12 @@ func Test_MarshalAsMsgpack(t *testing.T) {
 	f := &Fluent{Config: Config{}}
 
 	tag := "tag"
-	var data = map[string]string{
+	data := map[string]string{
 		"foo":  "bar",
-		"hoge": "hoge"}
+		"hoge": "hoge",
+	}
 	tm := time.Unix(1267867237, 0)
 	result, err := f.EncodeData(tag, tm, data)
-
 	if err != nil {
 		t.Error(err)
 	}
@@ -383,7 +385,6 @@ func Test_SubSecondPrecision(t *testing.T) {
 	encodedData, err := fluent.EncodeData("tag", timestamp, map[string]string{
 		"foo": "bar",
 	})
-
 	// Assert no encoding errors and that the timestamp has been encoded into
 	// the message as expected.
 	if err != nil {
@@ -402,12 +403,12 @@ func Test_SubSecondPrecision(t *testing.T) {
 func Test_MarshalAsJSON(t *testing.T) {
 	f := &Fluent{Config: Config{MarshalAsJSON: true}}
 
-	var data = map[string]string{
+	data := map[string]string{
 		"foo":  "bar",
-		"hoge": "hoge"}
+		"hoge": "hoge",
+	}
 	tm := time.Unix(1267867237, 0)
 	result, err := f.EncodeData("tag", tm, data)
-
 	if err != nil {
 		t.Error(err)
 	}