feat: adding job module

.github/workflows/lint.yml

@@ -7,13 +7,13 @@ jobs:
     steps:
       - uses: actions/setup-go@v2
         with:
-          go-version: "1.18"
+          go-version: "1.21"
       - uses: actions/checkout@v2
         with:
           fetch-depth: 0
       - name: golangci-lint
         uses: golangci/golangci-lint-action@v2
         with:
           skip-go-installation: true
-          version: v1.46.2
+          version: v1.51.2
           args: --timeout=10m

.github/workflows/release.yml

@@ -14,7 +14,7 @@ jobs:
           fetch-depth: 0
       - uses: actions/setup-go@v2
         with:
-          go-version: "1.18"
+          go-version: "1.21"
       - name: Login to DockerHub
         uses: docker/login-action@v1
         with:

.github/workflows/test.yml

@@ -8,6 +8,6 @@ jobs:
       - uses: actions/checkout@v2
       - uses: actions/setup-go@v2
         with:
-          go-version: "1.18"
+          go-version: "1.21"
       - name: run tests
         run: make test

.golangci.yml

@@ -1,5 +1,5 @@
 run:
-  go: '1.17'
+  go: '1.21'
   timeout: 10m
   skip-files:
     - expt/main.go
@@ -8,38 +8,40 @@ output:
   format: colored-line-number
 
 linters:
-  enable-all: true
-  disable:
-    - exhaustruct
-    - cyclop
-    - exhaustive
-    - exhaustivestruct
-    - exhaustruct
-    - funlen
-    - gochecknoglobals
+  disable-all: true
+  enable:
+    - bodyclose
+    - depguard
+    - dogsled
+    - dupl
+    - errcheck
+    - exportloopref
+    - gci
+    - gochecknoinits
+    - goconst
+    - gocritic
     - gocyclo
-    - godox
-    - gofumpt
-    - golint
-    - interfacer
-    - lll
-    - maintidx
-    - ireturn
-    - maligned
-    - nlreturn
+    - gofmt
+    - goimports
+    - gomnd
+    - goprintffuncname
+    - gosec
+    - gosimple
+    - govet
+    - decorder
+    - ineffassign
+    - misspell
+    - nakedret
+    - noctx
     - nolintlint
-    - prealloc
-    - promlinter
-    - scopelint
-    - tagliatelle
-    - testpackage
-    - paralleltest
-    - tparallel
-    - containedctx
-    - varnamelen
-    - wrapcheck
-    - wsl
-
+    - revive
+    - staticcheck
+    - stylecheck
+    - typecheck
+    - unconvert
+    - unparam
+    - unused
+    - whitespace
 linters-settings:
   decorder:
     dec-order:

cli/client/utils.go

@@ -39,7 +39,7 @@ func parseFile(filePath string, v protoreflect.ProtoMessage) error {
 		}
 
 	default:
-		return errors.New("unsupported file type") // nolint
+		return errors.New("unsupported file type")
 	}
 
 	return nil

cli/serve.go

@@ -13,6 +13,7 @@ import (
 	"github.com/goto/entropy/internal/store/postgres"
 	"github.com/goto/entropy/modules"
 	"github.com/goto/entropy/modules/firehose"
+	"github.com/goto/entropy/modules/job"
 	"github.com/goto/entropy/modules/kubernetes"
 	"github.com/goto/entropy/pkg/logger"
 	"github.com/goto/entropy/pkg/telemetry"
@@ -80,6 +81,7 @@ func setupRegistry() module.Registry {
 	supported := []module.Descriptor{
 		kubernetes.Module,
 		firehose.Module,
+		job.Module,
 	}
 
 	registry := &modules.Registry{}