Merge pull request #23 from junotx/release-0.3

[release-0.3] fix closure variables

Author: benjaminhuo

Makefile

@@ -4,7 +4,7 @@ REGISTRY?=kubesphere
 REPO_OPERATOR?=$(REGISTRY)/kube-events-operator
 REPO_EXPORTER?=$(REGISTRY)/kube-events-exporter
 REPO_RULER?=$(REGISTRY)/kube-events-ruler
-TAG?=v0.3.0
+TAG?=v0.3.1
 
 GO_PKG?=github.com/kubesphere/kube-events
 

config/bundle.yaml

@@ -1375,7 +1375,7 @@ spec:
           valueFrom:
             fieldRef:
               fieldPath: metadata.namespace
-        image: kubesphere/kube-events-operator:latest
+        image: kubesphere/kube-events-operator:v0.3.1
         name: events-operator
         ports:
         - containerPort: 9443

config/crs/bundle.yaml

@@ -4,7 +4,7 @@ metadata:
   name: kube-events-exporter
   namespace: kubesphere-logging-system
 spec:
-  image: kubesphere/kube-events-exporter:latest
+  image: kubesphere/kube-events-exporter:v0.3.1
   resources: {}
   sinks:
     stdout: {}
@@ -893,8 +893,9 @@ metadata:
   name: kube-events-ruler
   namespace: kubesphere-logging-system
 spec:
-  image: kubesphere/kube-events-ruler:latest
+  image: kubesphere/kube-events-ruler:v0.3.1
   replicas: 2
+  resources: {}
   sinks:
     alertmanager:
       name: alertmanager-main

config/crs/kustomization.yaml

@@ -11,9 +11,9 @@ patchesStrategicMerge:
 images:
 - name: exporter
   newName: kubesphere/kube-events-exporter
-  newTag: latest
+  newTag: v0.3.1
 - name: ruler
   newName: kubesphere/kube-events-ruler
-  newTag: latest
+  newTag: v0.3.1
 apiVersion: kustomize.config.k8s.io/v1beta1
 kind: Kustomization

config/kustomization.yaml

@@ -9,6 +9,6 @@ configurations:
 images:
 - name: operator
   newName: kubesphere/kube-events-operator
-  newTag: latest
+  newTag: v0.3.1
 apiVersion: kustomize.config.k8s.io/v1beta1
 kind: Kustomization

pkg/ruler/kube_events_ruler.go

@@ -215,7 +215,8 @@ func (r *KubeEventsRuler) evalEvents(ctx context.Context) {
 			}
 			r.evtQueue.Done(evt)
 		}
-		for _, evt := range evts {
+		for _, event := range evts {
+			evt := event
 			if err := r.taskPool.Submit(func() {
 				var err error
 				defer func() {