chore: upgrade golang to 1.19

.github/workflows/e2e.yaml

@@ -37,7 +37,7 @@ jobs:
       - name: Set up Go
         uses: actions/setup-go@v2
         with:
-          go-version: 1.18
+          go-version: 1.19
       - uses: actions/checkout@v2
       - name: Setup k3s
         run: |

.github/workflows/gh-pages.yaml

@@ -21,7 +21,7 @@ jobs:
       - name: Set up Go
         uses: actions/setup-go@v2
         with:
-          go-version: 1.18
+          go-version: 1.19
       - name: build
         run: |
           pip install mkdocs mkdocs_material

.github/workflows/go.yml

@@ -9,7 +9,7 @@ on:
       - "master"
 env:
   # Golang version to use across CI steps
-  GOLANG_VERSION: '1.18'
+  GOLANG_VERSION: '1.19'
 
 concurrency:
   group: ${{ github.workflow }}-${{ github.ref }}
@@ -38,7 +38,7 @@ jobs:
       - name: Run golangci-lint
         uses: golangci/golangci-lint-action@v3
         with:
-          version: v1.47.2
+          version: v1.49.0
           args: --timeout 5m
   build:
     name: Build

.github/workflows/release.yaml

@@ -106,7 +106,7 @@ jobs:
       - name: Setup Golang
         uses: actions/setup-go@v2
         with:
-          go-version: 1.18
+          go-version: 1.19
 
       - name: Generate release artifacts
         run: |

.golangci.yml

@@ -13,9 +13,7 @@ linters:
     - vet
     - gofmt
     - goimports
-    - deadcode
-    - varcheck
-    - structcheck
+    - unused
     - ineffassign
     - unconvert
     - misspell

Dockerfile

@@ -3,7 +3,7 @@
 # Initial stage which pulls prepares build dependencies and CLI tooling we need for our final image
 # Also used as the image in CI jobs so needs all dependencies
 ####################################################################################################
-FROM --platform=$BUILDPLATFORM golang:1.18 as builder
+FROM --platform=$BUILDPLATFORM golang:1.19 as builder
 
 RUN apt-get update && apt-get install -y \
     wget \
@@ -12,7 +12,7 @@ RUN apt-get update && apt-get install -y \
     rm -rf /var/lib/apt/lists/* /tmp/* /var/tmp/*
 
 # Install golangci-lint
-RUN curl -sSfL https://raw.githubusercontent.com/golangci/golangci-lint/master/install.sh | sh -s -- -b $(go env GOPATH)/bin v1.47.2 && \
+RUN curl -sSfL https://raw.githubusercontent.com/golangci/golangci-lint/master/install.sh | sh -s -- -b $(go env GOPATH)/bin v1.49.0 && \
     golangci-lint linters
 
 COPY .golangci.yml ${GOPATH}/src/dummy/.golangci.yml
@@ -40,7 +40,7 @@ RUN NODE_ENV='production' yarn build
 ####################################################################################################
 # Rollout Controller Build stage which performs the actual build of argo-rollouts binaries
 ####################################################################################################
-FROM --platform=$BUILDPLATFORM golang:1.18 as argo-rollouts-build
+FROM --platform=$BUILDPLATFORM golang:1.19 as argo-rollouts-build
 
 WORKDIR /go/src/github.com/argoproj/argo-rollouts
 

Dockerfile.dev

@@ -1,7 +1,7 @@
 ####################################################################################################
 # argo-rollouts-dev
 ####################################################################################################
-FROM golang:1.17 as builder
+FROM golang:1.19 as builder
 
 RUN apt-get update && apt-get install -y \
     ca-certificates && \

analysis/analysis_test.go

@@ -1279,7 +1279,7 @@ func TestSecretContentReferenceProviderError(t *testing.T) {
 	assert.True(t, strings.Contains(logMessage, "*****"))
 }
 
-//TestSecretContentReferenceAndMultipleArgResolutionSuccess verifies that both secret and non-secret arguments are resolved properly
+// TestSecretContentReferenceAndMultipleArgResolutionSuccess verifies that both secret and non-secret arguments are resolved properly
 func TestSecretContentReferenceAndMultipleArgResolutionSuccess(t *testing.T) {
 	f := newFixture(t)
 	secretName, secretKey, secretValue := "web-metric-secret", "apikey", "12345"

analysis/controller_test.go

@@ -144,7 +144,7 @@ func (f *fixture) run(analysisRunName string) {
 	f.runController(analysisRunName, true, false, c, i, k8sI)
 }
 
-func (f *fixture) runExpectError(analysisRunName string, startInformers bool) {
+func (f *fixture) runExpectError(analysisRunName string, startInformers bool) { //nolint:unused
 	c, i, k8sI := f.newController(noResyncPeriodFunc)
 	f.runController(analysisRunName, startInformers, true, c, i, k8sI)
 }
@@ -238,14 +238,14 @@ func filterInformerActions(actions []core.Action) []core.Action {
 	return ret
 }
 
-func (f *fixture) expectUpdateAnalysisRunAction(analysisRun *v1alpha1.AnalysisRun) int {
+func (f *fixture) expectUpdateAnalysisRunAction(analysisRun *v1alpha1.AnalysisRun) int { //nolint:unused
 	action := core.NewUpdateAction(schema.GroupVersionResource{Resource: "analysisrun"}, analysisRun.Namespace, analysisRun)
 	len := len(f.actions)
 	f.actions = append(f.actions, action)
 	return len
 }
 
-func (f *fixture) getUpdatedAnalysisRun(index int) *v1alpha1.AnalysisRun {
+func (f *fixture) getUpdatedAnalysisRun(index int) *v1alpha1.AnalysisRun { //nolint:unused
 	action := filterInformerActions(f.client.Actions())[index]
 	updateAction, ok := action.(core.UpdateAction)
 	if !ok {
@@ -259,7 +259,7 @@ func (f *fixture) getUpdatedAnalysisRun(index int) *v1alpha1.AnalysisRun {
 	return ar
 }
 
-func (f *fixture) expectPatchAnalysisRunAction(analysisRun *v1alpha1.AnalysisRun) int {
+func (f *fixture) expectPatchAnalysisRunAction(analysisRun *v1alpha1.AnalysisRun) int { //nolint:unused
 	analysisRunSchema := schema.GroupVersionResource{
 		Resource: "analysisruns",
 		Version:  "v1alpha1",
@@ -269,7 +269,7 @@ func (f *fixture) expectPatchAnalysisRunAction(analysisRun *v1alpha1.AnalysisRun
 	return len
 }
 
-func (f *fixture) getPatchedAnalysisRun(index int) v1alpha1.AnalysisRun {
+func (f *fixture) getPatchedAnalysisRun(index int) v1alpha1.AnalysisRun { //nolint:unused
 	action := filterInformerActions(f.client.Actions())[index]
 	patchAction, ok := action.(core.PatchAction)
 	if !ok {

experiments/controller_test.go

@@ -535,7 +535,7 @@ func filterInformerActions(actions []core.Action) []core.Action {
 	return ret
 }
 
-func (f *fixture) expectCreateServiceAction(service *corev1.Service) int {
+func (f *fixture) expectCreateServiceAction(service *corev1.Service) int { //nolint:unused
 	len := len(f.kubeactions)
 	f.kubeactions = append(f.kubeactions, core.NewCreateAction(schema.GroupVersionResource{Resource: "services"}, service.Namespace, service))
 	return len
@@ -559,13 +559,13 @@ func (f *fixture) expectUpdateReplicaSetAction(r *appsv1.ReplicaSet) int {
 	return len
 }
 
-func (f *fixture) expectGetExperimentAction(experiment *v1alpha1.Experiment) int {
+func (f *fixture) expectGetExperimentAction(experiment *v1alpha1.Experiment) int { //nolint:unused
 	len := len(f.actions)
 	f.actions = append(f.actions, core.NewGetAction(schema.GroupVersionResource{Resource: "experiments"}, experiment.Namespace, experiment.Name))
 	return len
 }
 
-func (f *fixture) expectUpdateExperimentAction(experiment *v1alpha1.Experiment) int {
+func (f *fixture) expectUpdateExperimentAction(experiment *v1alpha1.Experiment) int { //nolint:unused
 	action := core.NewUpdateAction(schema.GroupVersionResource{Resource: "experiments"}, experiment.Namespace, experiment)
 	len := len(f.actions)
 	f.actions = append(f.actions, action)
@@ -675,7 +675,7 @@ func (f *fixture) getUpdatedReplicaSet(index int) *appsv1.ReplicaSet {
 	return rs
 }
 
-func (f *fixture) getUpdatedExperiment(index int) *v1alpha1.Experiment {
+func (f *fixture) getUpdatedExperiment(index int) *v1alpha1.Experiment { //nolint:unused
 	action := filterInformerActions(f.client.Actions())[index]
 	updateAction, ok := action.(core.UpdateAction)
 	if !ok {

experiments/replicaset_test.go

@@ -129,7 +129,8 @@ func TestNameCollision(t *testing.T) {
 }
 
 // TestNameCollisionWithEquivalentPodTemplateAndControllerUID verifies we consider the annotations
-//  of the replicaset when encountering name collisions
+//
+//	of the replicaset when encountering name collisions
 func TestNameCollisionWithEquivalentPodTemplateAndControllerUID(t *testing.T) {
 	templates := generateTemplates("bar")
 	e := newExperiment("foo", templates, "")

go.mod

@@ -1,6 +1,6 @@
 module github.com/argoproj/argo-rollouts
 
-go 1.18
+go 1.19
 
 require (
 	github.com/antonmedv/expr v1.9.0

metricproviders/cloudwatch/cloudwatch.go

@@ -115,7 +115,7 @@ func (p *Provider) GarbageCollect(run *v1alpha1.AnalysisRun, metric v1alpha1.Met
 	return nil
 }
 
-//NewCloudWatchProvider creates a new CloudWatch provider
+// NewCloudWatchProvider creates a new CloudWatch provider
 func NewCloudWatchProvider(api CloudWatchClientAPI, logCtx log.Entry) *Provider {
 	return &Provider{
 		api:    api,

metricproviders/kayenta/kayenta_test.go

@@ -19,35 +19,36 @@ func newAnalysisRun() *v1alpha1.AnalysisRun {
 
 /*
 spec:
-  inputs:
-  - name: start-time #2019-03-29T01:08:34Z
-  - name: end-time   #2019-03-29T01:38:34Z
-  - name: stable-hash  #xxxx
-  - name: canary-hash  #yyyy
-  metrics:
-  - name: mann-whitney
-    kayenta:
-      address: https://kayenta.example.com
-      application: guestbook
-      canaryConfigName: my-test
-	  metricsAccountName: wavefront-prod
-      configurationAccountName: intuit-kayenta
-      storageAccountName:  intuit-kayenta
-      thresholds:
-        pass: 90
-        marginal: 75
-      scopes:
-      - name: default
-        controlScope:
-          scope: app=guestbook and rollouts-pod-template-hash={{inputs.stable-hash}}
-          step: 60
-          start: "{{inputs.start-time}}"
-          end: "{{inputs.end-time}}"
-        experimentScope:
-          scope: app=guestbook and rollouts-pod-template-hash={{inputs.canary-hash}}
-          step: 60
-          start: "{{inputs.start-time}}"
-          end: "{{inputs.end-time}}"
+
+	  inputs:
+	  - name: start-time #2019-03-29T01:08:34Z
+	  - name: end-time   #2019-03-29T01:38:34Z
+	  - name: stable-hash  #xxxx
+	  - name: canary-hash  #yyyy
+	  metrics:
+	  - name: mann-whitney
+	    kayenta:
+	      address: https://kayenta.example.com
+	      application: guestbook
+	      canaryConfigName: my-test
+		  metricsAccountName: wavefront-prod
+	      configurationAccountName: intuit-kayenta
+	      storageAccountName:  intuit-kayenta
+	      thresholds:
+	        pass: 90
+	        marginal: 75
+	      scopes:
+	      - name: default
+	        controlScope:
+	          scope: app=guestbook and rollouts-pod-template-hash={{inputs.stable-hash}}
+	          step: 60
+	          start: "{{inputs.start-time}}"
+	          end: "{{inputs.end-time}}"
+	        experimentScope:
+	          scope: app=guestbook and rollouts-pod-template-hash={{inputs.canary-hash}}
+	          step: 60
+	          start: "{{inputs.start-time}}"
+	          end: "{{inputs.end-time}}"
 */
 func buildMetric() v1alpha1.Metric {
 	return v1alpha1.Metric{
@@ -731,7 +732,7 @@ func (f RoundTripFunc) RoundTrip(req *http.Request) (*http.Response, error) {
 	return f(req), nil
 }
 
-//NewTestClient returns *http.Client with Transport replaced to avoid making real calls
+// NewTestClient returns *http.Client with Transport replaced to avoid making real calls
 func NewTestClient(fn RoundTripFunc) http.Client {
 	return http.Client{
 		Transport: fn,

metricproviders/newrelic/newrelic.go

@@ -39,7 +39,7 @@ type NewRelicClient struct {
 	AccountID int
 }
 
-//Query executes a NRQL query against the given New Relic account
+// Query executes a NRQL query against the given New Relic account
 func (n *NewRelicClient) Query(query string) ([]nrdb.NRDBResult, error) {
 	results, err := n.Nrdb.Query(n.AccountID, nrdb.NRQL(query))
 	if err != nil {
@@ -136,15 +136,15 @@ func (p *Provider) GetMetadata(metric v1alpha1.Metric) map[string]string {
 	return nil
 }
 
-//NewNewRelicProvider creates a new NewRelic provider
+// NewNewRelicProvider creates a new NewRelic provider
 func NewNewRelicProvider(api NewRelicClientAPI, logCtx log.Entry) *Provider {
 	return &Provider{
 		logCtx: logCtx,
 		api:    api,
 	}
 }
 
-//NewNewRelicAPIClient creates a new NewRelic API client from metric configuration
+// NewNewRelicAPIClient creates a new NewRelic API client from metric configuration
 func NewNewRelicAPIClient(metric v1alpha1.Metric, kubeclientset kubernetes.Interface) (NewRelicClientAPI, error) {
 	ns := defaults.Namespace()
 	profileSecret := DefaultNewRelicProfileSecretName

rollout/analysis_test.go

@@ -1650,8 +1650,8 @@ func TestCreatePrePromotionAnalysisRun(t *testing.T) {
 	assert.Equal(t, calculatePatch(r2, expectedPatch), patch)
 }
 
-//TestDoNotCreatePrePromotionAnalysisProgressedRollout ensures a pre-promotion analysis is not created after a Rollout
-//points the active service at the new ReplicaSet
+// TestDoNotCreatePrePromotionAnalysisProgressedRollout ensures a pre-promotion analysis is not created after a Rollout
+// points the active service at the new ReplicaSet
 func TestDoNotCreatePrePromotionAnalysisAfterPromotionRollout(t *testing.T) {
 	f := newFixture(t)
 	defer f.Close()
@@ -1700,8 +1700,8 @@ func TestDoNotCreatePrePromotionAnalysisAfterPromotionRollout(t *testing.T) {
 
 }
 
-//TestDoNotCreatePrePromotionAnalysisRunOnNewRollout ensures that a pre-promotion analysis is not created
-//if the Rollout does not have a stable ReplicaSet
+// TestDoNotCreatePrePromotionAnalysisRunOnNewRollout ensures that a pre-promotion analysis is not created
+// if the Rollout does not have a stable ReplicaSet
 func TestDoNotCreatePrePromotionAnalysisRunOnNewRollout(t *testing.T) {
 	f := newFixture(t)
 	defer f.Close()
@@ -1731,8 +1731,8 @@ func TestDoNotCreatePrePromotionAnalysisRunOnNewRollout(t *testing.T) {
 	f.run(getKey(r, t))
 }
 
-//TestDoNotCreatePrePromotionAnalysisRunOnNotReadyReplicaSet ensures that a pre-promotion analysis is not created until
-//the new ReplicaSet is saturated
+// TestDoNotCreatePrePromotionAnalysisRunOnNotReadyReplicaSet ensures that a pre-promotion analysis is not created until
+// the new ReplicaSet is saturated
 func TestDoNotCreatePrePromotionAnalysisRunOnNotReadyReplicaSet(t *testing.T) {
 	f := newFixture(t)
 	defer f.Close()