mutex on stats

Author: roffe

app/controllers/health_controller.go

@@ -27,6 +27,7 @@ type HealthController struct {
 
 //HealthStats is holds the latest heartbeats
 type HealthStats struct {
+	sync.Mutex
 	Healthy                        bool
 	MetricsControllerAlive         time.Time
 	NetworkPolicyControllerAlive   time.Time
@@ -69,6 +70,9 @@ func (hc *HealthController) Handler(w http.ResponseWriter, req *http.Request) {
 func (hc *HealthController) HandleHeartbeat(beat *ControllerHeartbeat) {
 	glog.V(3).Infof("Received heartbeat from %s", beat.Component)
 
+	hc.Status.Lock()
+	defer hc.Status.Unlock()
+
 	switch component := beat.Component; component {
 	case "NSC":
 		hc.Status.NetworkServicesControllerAlive = time.Now()

daemonset/generic-kuberouter-all-features-advertise-routes.yaml

@@ -47,6 +47,10 @@ metadata:
   name: kube-router
   namespace: kube-system
 spec:
+  updateStrategy:
+    type: RollingUpdate
+    rollingUpdate:
+      maxUnavailable: 2
   template:
     metadata:
       labels:

daemonset/generic-kuberouter-all-features.yaml

@@ -47,6 +47,10 @@ metadata:
   name: kube-router
   namespace: kube-system
 spec:
+  updateStrategy:
+    type: RollingUpdate
+    rollingUpdate:
+      maxUnavailable: 2
   template:
     metadata:
       labels:

daemonset/generic-kuberouter.yaml

@@ -28,6 +28,10 @@ metadata:
   name: kube-router
   namespace: kube-system
 spec:
+  updateStrategy:
+    type: RollingUpdate
+    rollingUpdate:
+      maxUnavailable: 2
   template:
     metadata:
       labels:

daemonset/kube-router-all-service-daemonset-advertise-routes.yaml

@@ -26,6 +26,10 @@ metadata:
   labels:
     k8s-app: kube-router
 spec:
+  updateStrategy:
+    type: RollingUpdate
+    rollingUpdate:
+      maxUnavailable: 2
   template:
     metadata:
       labels:

daemonset/kube-router-all-service-daemonset.yaml

@@ -26,6 +26,10 @@ metadata:
   labels:
     k8s-app: kube-router
 spec:
+  updateStrategy:
+    type: RollingUpdate
+    rollingUpdate:
+      maxUnavailable: 2
   template:
     metadata:
       labels:

daemonset/kube-router-firewall-daemonset.yaml

@@ -26,6 +26,10 @@ metadata:
   labels:
     k8s-app: kube-router
 spec:
+  updateStrategy:
+    type: RollingUpdate
+    rollingUpdate:
+      maxUnavailable: 2
   template:
     metadata:
       labels:

daemonset/kube-router-proxy-daemonset.yaml

@@ -26,6 +26,10 @@ metadata:
   labels:
     k8s-app: kube-router
 spec:
+  updateStrategy:
+    type: RollingUpdate
+    rollingUpdate:
+      maxUnavailable: 2
   template:
     metadata:
       labels:

daemonset/kubeadm-kuberouter-all-features-dsr.yaml

@@ -27,6 +27,10 @@ metadata:
   name: kube-router
   namespace: kube-system
 spec:
+  updateStrategy:
+    type: RollingUpdate
+    rollingUpdate:
+      maxUnavailable: 2
   template:
     metadata:
       labels:

daemonset/kubeadm-kuberouter-all-features.yaml

@@ -27,6 +27,10 @@ metadata:
   name: kube-router
   namespace: kube-system
 spec:
+  updateStrategy:
+    type: RollingUpdate
+    rollingUpdate:
+      maxUnavailable: 2
   template:
     metadata:
       labels: