fix state update

gwos · Oct 22, 2023 · 0f5251a · 0f5251a
1 parent cb34742
commit 0f5251a
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/connectors/kubernetes-connector/kubernetesConnector.go b/connectors/kubernetes-connector/kubernetesConnector.go
@@ -583,9 +583,9 @@ func (connector *KubernetesConnector) collectNodeMetrics(state *MonitoredState)
 				}
 				if monitoredService != nil {
 					resource.Services[metricBuilder.Name] = *monitoredService
-					state.State[stateKey] = resource
 				}
 			}
+			state.State[stateKey] = resource
 		} else if _, ok = state.Mismatched[stateKey]; !ok {
 			log.Warn().Msgf("node not found in monitored state: %v", stateKey)
 		}
@@ -647,10 +647,10 @@ func (connector *KubernetesConnector) collectPodMetricsPerReplica(state *Monitor
 					}
 					if monitoredService != nil {
 						resource.Services[metricBuilder.Name] = *monitoredService
-						state.State[stateKey] = resource
 					}
 				}
 			}
+			state.State[stateKey] = resource
 		} else if _, ok = state.Mismatched[stateKey]; !ok {
 			log.Warn().Msgf("pod not found in monitored state: %v", stateKey)
 		}
@@ -733,8 +733,8 @@ func (connector *KubernetesConnector) collectPodMetricsPerContainer(state *Monit
 					}
 					if monitoredService != nil {
 						resource.Services[metricDefinition.Name] = *monitoredService
-						state.State[stateKey] = resource
 					}
+					state.State[stateKey] = resource
 				} else if _, ok = state.Mismatched[stateKey]; !ok {
 					log.Debug().Msgf("pod container not found in monitored state: %v", stateKey)
 					debugDetails = true