feature: add MetricsUpdateIntervalSeconds args option in trimaran plugins

Author: googs1025

apis/config/types.go

@@ -88,6 +88,8 @@ type TrimaranSpec struct {
 	MetricProvider MetricProviderSpec
 	// Address of load watcher service
 	WatcherAddress string
+	// Interval in seconds for periodic metrics updates. Default is 30 seconds if not set.
+	MetricsUpdateIntervalSeconds int32
 }
 
 // +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

apis/config/v1/types.go

@@ -88,6 +88,8 @@ type TrimaranSpec struct {
 	MetricProvider MetricProviderSpec `json:"metricProvider,omitempty"`
 	// Address of load watcher service
 	WatcherAddress *string `json:"watcherAddress,omitempty"`
+	// Interval in seconds for periodic metrics updates. Default is 30 seconds if not set.
+	MetricsUpdateIntervalSeconds *int32 `json:"metricsUpdateIntervalSeconds,omitempty"`
 }
 
 // +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

apis/config/v1/zz_generated.conversion.go

@@ -30,7 +30,7 @@ import (
 )
 
 const (
-	metricsUpdateIntervalSeconds = 30
+	defaultMetricsUpdateIntervalSeconds = 30
 )
 
 // Collector : get data from load watcher, encapsulating the load watcher and its operations
@@ -69,6 +69,11 @@ func NewCollector(logger klog.Logger, trimaranSpec *pluginConfig.TrimaranSpec) (
 		client, _ = loadwatcherapi.NewLibraryClient(opts)
 	}
 
+	metricsUpdateIntervalSeconds := trimaranSpec.MetricsUpdateIntervalSeconds
+	if metricsUpdateIntervalSeconds == 0 {
+		metricsUpdateIntervalSeconds = defaultMetricsUpdateIntervalSeconds
+	}
+
 	collector := &Collector{
 		client: client,
 	}
@@ -80,7 +85,7 @@ func NewCollector(logger klog.Logger, trimaranSpec *pluginConfig.TrimaranSpec) (
 	}
 	// start periodic updates
 	go func() {
-		metricsUpdaterTicker := time.NewTicker(time.Second * metricsUpdateIntervalSeconds)
+		metricsUpdaterTicker := time.NewTicker(time.Second * time.Duration(metricsUpdateIntervalSeconds))
 		for range metricsUpdaterTicker.C {
 			err = collector.updateMetrics(logger)
 			if err != nil {