implement Forward Protocol v1.5 custom marshal/unmarshal for EntryExt (#70)

- Add custom msgpack decode and unmarshal functions for EntryExt
struct to support Fluent Forward Protocol v1.5 specification
- Update all dependencies
- Update .travis.yml
- Update .golangci.yml

---------

Signed-off-by: Mirko Lazarevic <[email protected]>

Author: mirko-lazarevic

.golangci.yml

@@ -1,43 +1,70 @@
+version: "2"
+
 run:
-  # timeout for analysis, e.g. 30s, 5m, default is 1m
+  # Timeout for total work, e.g. 30s, 5m, 5m30s.
+  # If the value is lower or equal to 0, the timeout is disabled.
+  # Default: 0 (disabled)
   timeout: 3m
+
+  # Include test files or not.
+  # Default: true
+  tests: false
 linters:
-  # enable some additional (non-default) linters
   enable:
-    - revive
     - bodyclose
-    - exportloopref
-    - gocognit
     - goconst
-    - gofmt
     - gosec
     - misspell
     - nakedret
+    - revive
     - unconvert
     - unparam
-    - wsl
+  settings:
+    goconst:
+      min-len: 2
+      min-occurrences: 5
+    misspell:
+      locale: US
+    revive:
+      rules:
+        - name: unused-parameter
+          disabled: true
+  exclusions:
+    generated: lax
+    presets:
+      - comments
+      - common-false-positives
+      - legacy
+      - std-error-handling
+    rules:
+      - linters:
+          - errcheck
+          - gocognit
+          - goconst
+          - gosec
+          - unparam
+          - wsl
+        path: _test\.go
+      - linters:
+          - errcheck
+          - gocognit
+          - goconst
+          - gosec
+          - unparam
+          - wsl
+        path: _gen\.go
+    paths:
+      - third_party$
+      - builtin$
+      - examples$
 issues:
-  exclude-rules:
-    # exclude some linters from running on tests files.
-    - path: _test\.go
-      linters:
-        - errcheck
-        - exportloopref
-        - gocognit
-        - goconst
-        - gosec
-        - unparam
-        - wsl
-        - revive
-    - path: '(.+)_test.go'
-      linters:
-        - revive
-      text: "dot-imports: should not use dot imports"
-  # maximum count of issues with the same text. set to 0 to disable. default is 3.
   max-same-issues: 0
-linters-settings:
-  goconst:
-    min-len: 2
-    min-occurrences: 5
-  misspell:
-    locale: US
+formatters:
+  enable:
+    - gofmt
+  exclusions:
+    generated: lax
+    paths:
+      - third_party$
+      - builtin$
+      - examples$

.travis.yml

@@ -3,7 +3,7 @@ language: go
 os: linux
 dist: focal
 go:
-  - "1.20.14"
+  - "1.24.x"
 
 before_install:
   - pip --quiet install yamllint

fluent/client/client.go

@@ -258,7 +258,7 @@ func (c *Client) checkAck(chunk string) error {
 	}
 
 	if ack.Ack != chunk {
-		return fmt.Errorf("Expected chunk %s, but got %s", chunk, ack.Ack)
+		return fmt.Errorf("expected chunk %s, but got %s", chunk, ack.Ack)
 	}
 
 	return nil

fluent/client/client_test.go

@@ -238,7 +238,7 @@ var _ = Describe("Client", func() {
 					defer GinkgoRecover()
 					defer func() { done <- true }()
 					err := client.Send(&msg)
-					Expect(err.Error()).To(ContainSubstring("Expected chunk"))
+					Expect(err.Error()).To(ContainSubstring("expected chunk"))
 				}()
 
 				rcvd := &protocol.MessageExt{}

fluent/client/clientfakes/fake_connection_factory.go

@@ -71,12 +71,12 @@ func NewForwardMessage(
 }
 
 func (fm *ForwardMessage) EncodeMsg(dc *msgp.Writer) error {
-	size := 2
+	size := uint32(2)
 	if fm.Options != nil {
 		size = 3
 	}
 
-	err := dc.WriteArrayHeader(uint32(size))
+	err := dc.WriteArrayHeader(size)
 	if err != nil {
 		return msgp.WrapError(err, "Array Header")
 	}