Add metrics for sync result

Created sync metrics collector to collect sync related metrics. Added
metrics to collect the cumulative count of sync results. Specified
metrics emit interval in flags.

pkg/neg/metrics/neg_metrics_collector.go

@@ -69,8 +69,22 @@ func init() {
 // NewNEGMetricsCollector initializes SyncerMetrics and starts a go routine to compute and export metrics periodically.
 func NewNegMetricsCollector(exportInterval time.Duration) *SyncerMetrics {
 	return &SyncerMetrics{
-		countSinceLastExport: make(map[syncError]int),
-		metricsInterval:      exportInterval,
+		countSinceLastExport: map[syncError]int{
+			ErrEPCountsDiffer:         0,
+			ErrEPMissingNodeName:      0,
+			ErrEPMissingZone:          0,
+			ErrInvalidEPAttach:        0,
+			ErrInvalidEPDetach:        0,
+			ErrEPSEndpointCountZero:   0,
+			ErrEPCalculationCountZero: 0,
+			ErrNegNotFound:            0,
+			ErrCurrentEPNotFound:      0,
+			ErrEPSNotFound:            0,
+			ErrNodeNotFound:           0,
+			ErrOtherError:             0,
+			Success:                   0,
+		},
+		metricsInterval: exportInterval,
 	}
 }
 

pkg/neg/syncers/transaction.go

@@ -104,6 +104,9 @@ type transactionSyncer struct {
 	// 4. Endpoint count from EPS or calculated endpoint list is 0
 	// Need to grab syncLock first for any reads or writes based on this value
 	inError bool
+
+	// syncCollector collect sync related metrics
+	syncCollector metrics.SyncerMetricsCollector
 }
 
 func NewTransactionSyncer(
@@ -121,6 +124,7 @@ func NewTransactionSyncer(
 	epc negtypes.NetworkEndpointsCalculator,
 	kubeSystemUID string,
 	svcNegClient svcnegclient.Interface,
+	syncerMetrics *metrics.SyncerMetrics,
 	customName bool,
 	enableEndpointSlices bool,
 	log klog.Logger) negtypes.NegSyncer {
@@ -145,6 +149,7 @@ func NewTransactionSyncer(
 		reflector:            reflector,
 		kubeSystemUID:        kubeSystemUID,
 		svcNegClient:         svcNegClient,
+		syncCollector:        syncerMetrics,
 		customName:           customName,
 		enableEndpointSlices: enableEndpointSlices,
 		inError:              false,
@@ -192,6 +197,9 @@ func (s *transactionSyncer) syncInternal() error {
 
 	s.updateStatus(err)
 	metrics.PublishNegSyncMetrics(string(s.NegSyncerKey.NegType), string(s.endpointsCalculator.Mode()), err, start)
+	if s.enableEndpointSlices {
+		s.syncCollector.UpdateSyncer(s.NegSyncerKey, err)
+	}
 	return err
 }
 
@@ -510,6 +518,7 @@ func (s *transactionSyncer) operationInternal(operation transactionOp, zone stri
 			if operation == detachOp {
 				err = fmt.Errorf("%w, reason: %v", metrics.ErrInvalidEPDetach, err)
 			}
+			s.syncCollector.UpdateSyncer(s.NegSyncerKey, err)
 		}
 	}