Goworker V2

.github/workflows/go.yml

@@ -12,96 +12,132 @@ jobs:
     strategy:
       matrix:
         go:
-          - "1.12"
-          - "1.13"
-          - "1.14"
-          - "1.15"
-        redis-version:
-          - 4
-          - 5
-          - 6
+          - "1.21"
+          - "1.22"
+          - "1.23"
+          - "1.24"
+        broker:
+          - type: redis
+            redis-version: 6
+          - type: redis
+            redis-version: 7
+          - type: rabbitmq
+            rabbitmq-version: "3.12"
+          - type: rabbitmq
+            rabbitmq-version: "3.13"
 
     steps:
       - name: Check out code into the Go module directory
-        uses: actions/checkout@v2
+        uses: actions/checkout@v4
 
       - name: Setup Go
-        uses: actions/setup-go@v2
+        uses: actions/setup-go@v5
         with:
           go-version: ${{ matrix.go }}
 
       - name: Setup Redis
+        if: matrix.broker.type == 'redis'
         uses: supercharge/[email protected]
         with:
-          redis-version: ${{ matrix.redis-version }}
+          redis-version: ${{ matrix.broker.redis-version }}
+
+      - name: Setup RabbitMQ
+        if: matrix.broker.type == 'rabbitmq'
+        uses: mer-team/[email protected]
+        with:
+          RABBITMQ_TAG: ${{ matrix.broker.rabbitmq-version }}
 
       - name: Build
-        run: go build -v .
+        run: go build -v ./...
 
       - name: Test
-        run: go test -v .
+        run: go test -v ./...
 
   imports:
     name: Imports
     runs-on: ubuntu-latest
     steps:
-      - uses: actions/checkout@master
-      - name: check
-        uses: grandcolline/[email protected]
+      - name: Check out code
+        uses: actions/checkout@v4
+
+      - name: Setup Go
+        uses: actions/setup-go@v5
+        with:
+          go-version: '1.24'
+
+      - name: Install goimports
+        run: go install golang.org/x/tools/cmd/goimports@latest
+
+      - name: Check imports
+        run: |
+          if [ "$(goimports -l . | wc -l)" -gt 0 ]; then
+            echo "The following files need goimports formatting:"
+            goimports -l .
+            echo "Run 'goimports -w .' to fix"
+            exit 1
+          fi
+
+  lint:
+    name: Lint
+    runs-on: ubuntu-latest
+    steps:
+      - name: Check out code
+        uses: actions/checkout@v4
+
+      - name: Setup Go
+        uses: actions/setup-go@v5
+        with:
+          go-version: '1.24'
+
+      - name: golangci-lint
+        uses: golangci/golangci-lint-action@v6
+        with:
+          version: latest
+
+  staticcheck:
+    name: StaticCheck
+    runs-on: ubuntu-latest
+    steps:
+      - name: Check out code
+        uses: actions/checkout@v4
+
+      - name: Setup Go
+        uses: actions/setup-go@v5
         with:
-          run: imports
-          token: ${{ secrets.GITHUB_TOKEN }}
+          go-version: '1.24'
 
-  ## Checks to be enabled in the future:
+      - name: Install staticcheck
+        run: go install honnef.co/go/tools/cmd/staticcheck@latest
+
+      - name: Run staticcheck
+        run: staticcheck ./...
+
+  ## Additional checks that can be enabled if needed:
 
   # errcheck:
   #   name: Errcheck
   #   runs-on: ubuntu-latest
   #   steps:
-  #     - uses: actions/checkout@master
-  #     - name: check
-  #       uses: grandcolline/[email protected]
-  #       with:
-  #         run: errcheck
-  #         token: ${{ secrets.GITHUB_TOKEN }}
-  # lint:
-  #   name: Lint
-  #   runs-on: ubuntu-latest
-  #   steps:
-  #     - uses: actions/checkout@master
-  #     - name: check
-  #       uses: grandcolline/[email protected]
-  #       with:
-  #         run: lint
-  #         token: ${{ secrets.GITHUB_TOKEN }}
-  # shadow:
-  #   name: Shadow
-  #   runs-on: ubuntu-latest
-  #   steps:
-  #     - uses: actions/checkout@master
-  #     - name: check
-  #       uses: grandcolline/[email protected]
+  #     - uses: actions/checkout@v4
+  #     - name: Setup Go
+  #       uses: actions/setup-go@v5
   #       with:
-  #         run: shadow
-  #         token: ${{ secrets.GITHUB_TOKEN }}
-  # staticcheck:
-  #   name: StaticCheck
-  #   runs-on: ubuntu-latest
-  #   steps:
-  #     - uses: actions/checkout@master
-  #     - name: check
-  #       uses: grandcolline/[email protected]
-  #       with:
-  #         run: staticcheck
-  #         token: ${{ secrets.GITHUB_TOKEN }}
+  #         go-version: '1.24'
+  #     - name: Install errcheck
+  #       run: go install github.com/kisielk/errcheck@latest
+  #     - name: Run errcheck
+  #       run: errcheck ./...
+
   # sec:
   #   name: Sec
   #   runs-on: ubuntu-latest
   #   steps:
-  #     - uses: actions/checkout@master
-  #     - name: check
-  #       uses: grandcolline/[email protected]
+  #     - uses: actions/checkout@v4
+  #     - name: Setup Go
+  #       uses: actions/setup-go@v5
   #       with:
-  #         run: sec
-  #         token: ${{ secrets.GITHUB_TOKEN }}
-  #         # flags: "-exclude=G104"
+  #         go-version: '1.24'
+  #     - name: Install gosec
+  #       run: go install github.com/securego/gosec/v2/cmd/gosec@latest
+  #     - name: Run gosec
+  #       run: gosec ./...

.gitignore

@@ -0,0 +1,35 @@
+# If you prefer the allow list template instead of the deny list, see community template:
+# https://github.com/github/gitignore/blob/main/community/Golang/Go.AllowList.gitignore
+#
+# Binaries for programs and plugins
+*.exe
+*.exe~
+*.dll
+*.so
+*.dylib
+
+# Test binary, built with `go test -c`
+*.test
+
+# Code coverage profiles and other test artifacts
+*.out
+coverage.*
+*.coverprofile
+profile.cov
+
+# Dependency directories (remove the comment below to include it)
+# vendor/
+
+# Go workspace file
+go.work
+go.work.sum
+
+# env file
+.env
+
+# Editor/IDE
+# .idea/
+# .vscode/
+
+# OS-generated files
+.DS_Store

.golangci.yml

@@ -0,0 +1,11 @@
+linters-settings:
+  errcheck:
+    exclude-functions:
+      - (github.com/cihub/seelog.LoggerInterface).Errorf
+      - (github.com/cihub/seelog.LoggerInterface).Error
+      - (github.com/cihub/seelog.LoggerInterface).Infof
+      - (github.com/cihub/seelog.LoggerInterface).Info
+      - (github.com/cihub/seelog.LoggerInterface).Debugf
+      - (github.com/cihub/seelog.LoggerInterface).Debug
+      - (github.com/cihub/seelog.LoggerInterface).Warnf
+      - (github.com/cihub/seelog.LoggerInterface).Warn 

LICENSE

@@ -1,6 +1,10 @@
 The MIT License (MIT)
 
-Copyright (c) 2013 Benjamin Manns
+Original goworker Copyright (c) 2013 Benjamin Manns
+goworker2 Copyright (c) 2024 BranchIntl
+
+This project is a complete rewrite and modernization of the original goworker
+library by Benjamin Manns (https://github.com/benmanns/goworker).
 
 Permission is hereby granted, free of charge, to any person obtaining a copy of
 this software and associated documentation files (the "Software"), to deal in