chore: Go 1.19

Signed-off-by: Valery Piashchynski <[email protected]>

.github/workflows/linters.yml

@@ -25,10 +25,10 @@ jobs:
       - name: Set up Go
         uses: actions/setup-go@v3
         with:
-          go-version: 1.18
+          go-version: 1.19
 
       - name: Run linter
         uses: golangci/golangci-lint-action@v3 # Action page: <https://github.com/golangci/golangci-lint-action>
         with:
-          version: v1.47 # without patch version
+          version: v1.48 # without patch version
           only-new-issues: false # show only new issues if it's a pull request

.github/workflows/linux.yml

@@ -23,7 +23,7 @@ jobs:
     strategy:
       fail-fast: true
       matrix:
-        go: [ 1.18 ]
+        go: [ 1.19 ]
         os: [ ubuntu-latest ]
     steps:
       - name: Set up Go ${{ matrix.go }}

.github/workflows/macos.yml

@@ -23,7 +23,7 @@ jobs:
     strategy:
       fail-fast: true
       matrix:
-        go: [ 1.18 ]
+        go: [ 1.19 ]
         os: [ macos-latest ]
     steps:
       - name: Set up Go ${{ matrix.go }}

.github/workflows/windows.yml

@@ -23,7 +23,7 @@ jobs:
     strategy:
       fail-fast: true
       matrix:
-        go: [ 1.18 ]
+        go: [ 1.19 ]
         os: [ windows-latest ]
     steps:
       - name: Set up Go ${{ matrix.go }}

internal/bpool.go

@@ -19,19 +19,19 @@ func Preallocate() {
 
 func internalAllocate() {
 	pool1 := &sync.Pool{
-		New: func() interface{} {
+		New: func() any {
 			data := make([]byte, OneMB)
 			return &data
 		},
 	}
 	pool5 := &sync.Pool{
-		New: func() interface{} {
+		New: func() any {
 			data := make([]byte, FiveMB)
 			return &data
 		},
 	}
 	pool10 := &sync.Pool{
-		New: func() interface{} {
+		New: func() any {
 			data := make([]byte, TenMB)
 			return &data
 		},

pkg/rpc/client.go

@@ -30,11 +30,11 @@ type ClientCodec struct {
 // NewClientCodec initiates new server rpc codec over socket connection.
 func NewClientCodec(rwc io.ReadWriteCloser) *ClientCodec {
 	return &ClientCodec{
-		bPool: sync.Pool{New: func() interface{} {
+		bPool: sync.Pool{New: func() any {
 			return new(bytes.Buffer)
 		}},
 
-		fPool: sync.Pool{New: func() interface{} {
+		fPool: sync.Pool{New: func() any {
 			return frame.NewFrame()
 		}},
 
@@ -61,7 +61,7 @@ func (c *ClientCodec) putFrame(f *frame.Frame) {
 }
 
 // WriteRequest writes request to the connection. Sequential.
-func (c *ClientCodec) WriteRequest(r *rpc.Request, body interface{}) error {
+func (c *ClientCodec) WriteRequest(r *rpc.Request, body any) error {
 	const op = errors.Op("goridge_write_request")
 
 	// get a frame from the pool
@@ -148,7 +148,7 @@ func (c *ClientCodec) ReadResponseHeader(r *rpc.Response) error {
 }
 
 // ReadResponseBody response from the connection.
-func (c *ClientCodec) ReadResponseBody(out interface{}) error {
+func (c *ClientCodec) ReadResponseBody(out any) error {
 	const op = errors.Op("client_read_response_body")
 
 	// put frame after response was sent

pkg/rpc/codec.go

@@ -34,11 +34,11 @@ func NewCodec(rwc io.ReadWriteCloser) *Codec {
 		relay: socket.NewSocketRelay(rwc),
 		codec: sync.Map{},
 
-		bPool: sync.Pool{New: func() interface{} {
+		bPool: sync.Pool{New: func() any {
 			return new(bytes.Buffer)
 		}},
 
-		fPool: sync.Pool{New: func() interface{} {
+		fPool: sync.Pool{New: func() any {
 			return frame.NewFrame()
 		}},
 	}
@@ -68,7 +68,7 @@ func (c *Codec) putFrame(f *frame.Frame) {
 }
 
 // WriteResponse marshals response, byte slice or error to remote party.
-func (c *Codec) WriteResponse(r *rpc.Response, body interface{}) error { //nolint:funlen
+func (c *Codec) WriteResponse(r *rpc.Response, body any) error { //nolint:funlen
 	const op = errors.Op("goridge_write_response")
 	fr := c.getFrame()
 	defer c.putFrame(fr)
@@ -292,7 +292,7 @@ func (c *Codec) storeCodec(r *rpc.Request, flag byte) error {
 
 // ReadRequestBody fetches prefixed body data and automatically unmarshal it as json. RawBody flag will populate
 // []byte lice argument for rpc method.
-func (c *Codec) ReadRequestBody(out interface{}) error {
+func (c *Codec) ReadRequestBody(out any) error {
 	const op = errors.Op("goridge_read_request_body")
 	if out == nil {
 		return nil

pkg/shared_memory/posix/posix_shm.go

@@ -51,7 +51,9 @@ type SharedMemorySegment struct {
 	data    []byte
 }
 
-/* The args are:
+/*
+	The args are:
+
 key - int, used as uniques identifier for the shared memory segment
 size - uint, size in bytes to allocate
 permission - int, if passed zero, 0600 will be used by default