From 4259fd3a186223e5efa8164d6ae4a58e63ab8672 Mon Sep 17 00:00:00 2001 From: JimmyYang20 Date: Wed, 28 Jul 2021 10:09:17 +0800 Subject: [PATCH] LC: send dataset update to GM only when changed number of samples has been sent to GM only when adding new data. Signed-off-by: JimmyYang20 --- pkg/localcontroller/manager/dataset.go | 29 +++++++++++++------------- 1 file changed, 15 insertions(+), 14 deletions(-) diff --git a/pkg/localcontroller/manager/dataset.go b/pkg/localcontroller/manager/dataset.go index 77eafd8d..b578b697 100644 --- a/pkg/localcontroller/manager/dataset.go +++ b/pkg/localcontroller/manager/dataset.go @@ -38,7 +38,7 @@ import ( const ( // MonitorDataSourceIntervalSeconds is interval time of monitoring data source - MonitorDataSourceIntervalSeconds = 10 + MonitorDataSourceIntervalSeconds = 60 // DatasetResourceKind is kind of dataset resource DatasetResourceKind = "dataset" ) @@ -185,20 +185,21 @@ func (dm *DatasetManager) monitorDataSources(name string) { samplesNumber = dataSource.NumberOfSamples klog.Infof("dataset(name=%s) get samples from data source(url=%s) successfully. number of samples: %d", name, dataURL, dataSource.NumberOfSamples) - } - header := gmclient.MessageHeader{ - Namespace: ds.Namespace, - ResourceKind: ds.Kind, - ResourceName: ds.Name, - Operation: gmclient.StatusOperation, - } - if err := dm.Client.WriteMessage(struct { - NumberOfSamples int `json:"numberOfSamples"` - }{ - dataSource.NumberOfSamples, - }, header); err != nil { - klog.Errorf("dataset(name=%s) publish samples info failed, error: %+v", name, err) + header := gmclient.MessageHeader{ + Namespace: ds.Namespace, + ResourceKind: ds.Kind, + ResourceName: ds.Name, + Operation: gmclient.StatusOperation, + } + + if err := dm.Client.WriteMessage(struct { + NumberOfSamples int `json:"numberOfSamples"` + }{ + dataSource.NumberOfSamples, + }, header); err != nil { + klog.Errorf("dataset(name=%s) publish samples info failed, error: %+v", name, err) + } } } <-time.After(MonitorDataSourceIntervalSeconds * time.Second)