Kiu/VictoriaMetrics
Kiu/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2024-12-15 08:23:34 +01:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

lib/promscrape/discovery/consul: log the time needed for stoppig Consul service watcher

Browse Source
This commit is contained in:
Aliaksandr Valialkin 2020-12-03 20:14:17 +02:00
parent 4e4a93c586
commit 96190f9d45
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
lib/promscrape/discovery/consul/watch.go
View File

@ -136,13 +136,14 @@ func (cw *consulWatcher) watchForServicesUpdates() {
if time.Since(lastAccessTime) > 3*checkInterval { if time.Since(lastAccessTime) > 3*checkInterval {
// The given cw is no longer used. Stop all service watchers and exit. // The given cw is no longer used. Stop all service watchers and exit.
logger.Infof("starting to stop Consul service watchers for %q", clientAddr) logger.Infof("starting to stop Consul service watchers for %q", clientAddr)
startTime := time.Now()
cw.servicesLock.Lock() cw.servicesLock.Lock()
for _, sw := range cw.services { for _, sw := range cw.services {
close(sw.stopCh) close(sw.stopCh)
} }
cw.servicesLock.Unlock() cw.servicesLock.Unlock()
cw.wg.Wait() cw.wg.Wait()
logger.Infof("stopped Consul service watcher for %q", clientAddr) logger.Infof("stopped Consul service watcher for %q in %.3f seconds", clientAddr, time.Since(startTime).Seconds())
return return
} }