diff options
5 files changed, 7 insertions, 8 deletions
diff --git a/docs/proposals/device-crd-v1beta1.md b/docs/proposals/device-crd-v1beta1.md index 84eacf261..1a722a308 100644 --- a/docs/proposals/device-crd-v1beta1.md +++ b/docs/proposals/device-crd-v1beta1.md @@ -342,8 +342,8 @@ spec: nodeName: worker-node1 properties: - name: temp - collectCycle: 2000 - reportCycle: 2000 + collectCycle: 2000 # 2000 stands for 2000 milliseconds (2 seconds) + reportCycle: 2000 # 2000 stands for 2000 milliseconds (2 seconds) desired: value: "30" reportToCloud: true diff --git a/staging/src/github.com/kubeedge/mapper-framework/_template/mapper/data/dbmethod/influxdb2/handler.go b/staging/src/github.com/kubeedge/mapper-framework/_template/mapper/data/dbmethod/influxdb2/handler.go index 287bb5616..53d950967 100644 --- a/staging/src/github.com/kubeedge/mapper-framework/_template/mapper/data/dbmethod/influxdb2/handler.go +++ b/staging/src/github.com/kubeedge/mapper-framework/_template/mapper/data/dbmethod/influxdb2/handler.go @@ -21,7 +21,6 @@ import ( "time" "k8s.io/klog/v2" - "github.com/kubeedge/Template/driver" "github.com/kubeedge/mapper-framework/pkg/common" ) @@ -37,7 +36,7 @@ func DataHandler(ctx context.Context, twin *common.Twin, client *driver.Customiz klog.Errorf("init database client err: %v", err) return } - reportCycle := time.Duration(twin.Property.ReportCycle) + reportCycle := time.Millisecond * time.Duration(twin.Property.ReportCycle) if reportCycle == 0 { reportCycle = common.DefaultReportCycle } diff --git a/staging/src/github.com/kubeedge/mapper-framework/_template/mapper/data/dbmethod/redis/handler.go b/staging/src/github.com/kubeedge/mapper-framework/_template/mapper/data/dbmethod/redis/handler.go index 9363f6f0e..dfec8af78 100644 --- a/staging/src/github.com/kubeedge/mapper-framework/_template/mapper/data/dbmethod/redis/handler.go +++ b/staging/src/github.com/kubeedge/mapper-framework/_template/mapper/data/dbmethod/redis/handler.go @@ -37,7 +37,7 @@ func DataHandler(ctx context.Context, twin *common.Twin, client *driver.Customiz klog.Errorf("init redis database client err: %v", err) return } - reportCycle := time.Duration(twin.Property.ReportCycle) + reportCycle := time.Millisecond * time.Duration(twin.Property.ReportCycle) if reportCycle == 0 { reportCycle = common.DefaultReportCycle } diff --git a/staging/src/github.com/kubeedge/mapper-framework/_template/mapper/data/dbmethod/tdengine/handler.go b/staging/src/github.com/kubeedge/mapper-framework/_template/mapper/data/dbmethod/tdengine/handler.go index 2840a6ed3..ba6732659 100644 --- a/staging/src/github.com/kubeedge/mapper-framework/_template/mapper/data/dbmethod/tdengine/handler.go +++ b/staging/src/github.com/kubeedge/mapper-framework/_template/mapper/data/dbmethod/tdengine/handler.go @@ -37,7 +37,7 @@ func DataHandler(ctx context.Context, twin *common.Twin, client *driver.Customiz klog.Errorf("init database client err: %v", err) return } - reportCycle := time.Duration(twin.Property.ReportCycle) + reportCycle := time.Millisecond * time.Duration(twin.Property.ReportCycle) if reportCycle == 0 { reportCycle = common.DefaultReportCycle } diff --git a/staging/src/github.com/kubeedge/mapper-framework/_template/mapper/device/device.go b/staging/src/github.com/kubeedge/mapper-framework/_template/mapper/device/device.go index f7afe8d37..c8c7fe947 100644 --- a/staging/src/github.com/kubeedge/mapper-framework/_template/mapper/device/device.go +++ b/staging/src/github.com/kubeedge/mapper-framework/_template/mapper/device/device.go @@ -145,7 +145,7 @@ func dataHandler(ctx context.Context, dev *driver.CustomizedDev) { ObservedDesired: twin.ObservedDesired, VisitorConfig: &visitorConfig, Topic: fmt.Sprintf(common.TopicTwinUpdate, dev.Instance.ID), - CollectCycle: time.Duration(twin.Property.CollectCycle), + CollectCycle: time.Millisecond * time.Duration(twin.Property.CollectCycle), ReportToCloud: twin.Property.ReportToCloud, } go twinData.Run(ctx) @@ -196,7 +196,7 @@ func pushHandler(ctx context.Context, twin *common.Twin, client *driver.Customiz klog.Errorf("init publish method err: %v", err) return } - reportCycle := time.Duration(twin.Property.ReportCycle) + reportCycle := time.Millisecond * time.Duration(twin.Property.ReportCycle) if reportCycle == 0 { reportCycle = common.DefaultReportCycle } |