From 0303031fc244a0623a7141262cd6e61b807736e4 Mon Sep 17 00:00:00 2001 From: Tim Vaillancourt Date: Thu, 7 Jul 2022 03:22:53 +0200 Subject: [PATCH] cleanup v2 --- go/logic/migrator.go | 4 ++-- go/logic/throttler.go | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/go/logic/migrator.go b/go/logic/migrator.go index 74772ed..e78aab3 100644 --- a/go/logic/migrator.go +++ b/go/logic/migrator.go @@ -811,7 +811,7 @@ func (this *Migrator) initiateInspector() (err error) { // initiateStatus sets and activates the printStatus() ticker func (this *Migrator) initiateStatus() { this.printStatus(ForcePrintStatusAndHintRule) - ticker := time.NewTicker(1 * time.Second) + ticker := time.NewTicker(time.Second) defer ticker.Stop() for { <-ticker.C @@ -1052,7 +1052,7 @@ func (this *Migrator) initiateStreaming() error { }() go func() { - ticker := time.NewTicker(1 * time.Second) + ticker := time.NewTicker(time.Second) defer ticker.Stop() for { <-ticker.C diff --git a/go/logic/throttler.go b/go/logic/throttler.go index 46bd4bc..071318e 100644 --- a/go/logic/throttler.go +++ b/go/logic/throttler.go @@ -448,7 +448,7 @@ func (this *Throttler) initiateThrottlerCollection(firstThrottlingCollected chan this.collectGeneralThrottleMetrics() firstThrottlingCollected <- true - throttlerMetricsTick := time.NewTicker(1 * time.Second) + throttlerMetricsTick := time.NewTicker(time.Second) defer throttlerMetricsTick.Stop() for { <-throttlerMetricsTick.C