From b2294d1cf13fb4422f596a2f44c97ee6472a9101 Mon Sep 17 00:00:00 2001
From: Dmytro Kozlov <kozlovdmitriyy@gmail.com>
Date: Mon, 2 May 2022 10:06:34 +0300
Subject: [PATCH] vmctl/vm: added datapoints collection bar (#2486)

add progress bars to the VM importer

The new progress bars supposed to display the processing speed per each
VM importer worker. This info should help to identify if there is a bottleneck
on the VM side during the import process, without waiting for its finish.
The new progress bars can be disabled by passing `vm-disable-progress-bar` flag.

Plotting multiple progress bars requires using experimental progress bar pool
from github.com/cheggaaa/pb/v3. Switch to progress bar pool required changes
in all import modes.

The openTSDB mode wasn't changed due to its implementation, which implies individual progress
bars per each series. Because of this, using the pool wasn't possible.

Signed-off-by: dmitryk-dk <kozlovdmitriyy@gmail.com>

Co-authored-by: hagen1778 <roman@victoriametrics.com>
---
 .../notifier/alertmanager_request.qtpl.go     | 112 +--
 app/vmalert/tpl/footer.qtpl.go                |  36 +-
 app/vmalert/tpl/header.qtpl                   |   5 -
 app/vmalert/tpl/header.qtpl.go                |  55 +-
 app/vmalert/tpl/nav.qtpl.go                   |  62 +-
 app/vmalert/web.qtpl                          |   4 +-
 app/vmalert/web.qtpl.go                       | 780 +++++++++---------
 app/vmctl/barpool/pool.go                     |  26 +
 app/vmctl/flags.go                            |   5 +
 app/vmctl/influx.go                           |  10 +-
 app/vmctl/main.go                             |   4 +
 app/vmctl/prometheus.go                       |  11 +-
 app/vmctl/utils.go                            |   2 +
 app/vmctl/vm/vm.go                            |  27 +-
 app/vmctl/vm_native.go                        |  13 +-
 go.mod                                        |   2 +-
 go.sum                                        |   4 +-
 vendor/github.com/cheggaaa/pb/v3/pb.go        |   7 +
 vendor/github.com/cheggaaa/pb/v3/pool.go      | 105 +++
 vendor/github.com/cheggaaa/pb/v3/pool_win.go  |  46 ++
 vendor/github.com/cheggaaa/pb/v3/pool_x.go    |  43 +
 .../cheggaaa/pb/v3/termutil/term.go           |  16 +-
 .../cheggaaa/pb/v3/termutil/term_win.go       |   4 +-
 .../cheggaaa/pb/v3/termutil/term_x.go         |  10 +-
 vendor/modules.txt                            |   2 +-
 25 files changed, 833 insertions(+), 558 deletions(-)
 create mode 100644 app/vmctl/barpool/pool.go
 create mode 100644 vendor/github.com/cheggaaa/pb/v3/pool.go
 create mode 100644 vendor/github.com/cheggaaa/pb/v3/pool_win.go
 create mode 100644 vendor/github.com/cheggaaa/pb/v3/pool_x.go

diff --git a/app/vmalert/notifier/alertmanager_request.qtpl.go b/app/vmalert/notifier/alertmanager_request.qtpl.go
index 8a6ce45e2..f3f7b193a 100644
--- a/app/vmalert/notifier/alertmanager_request.qtpl.go
+++ b/app/vmalert/notifier/alertmanager_request.qtpl.go
@@ -1,135 +1,135 @@
 // Code generated by qtc from "alertmanager_request.qtpl". DO NOT EDIT.
 // See https://github.com/valyala/quicktemplate for details.
 
-//line app/vmalert/notifier/alertmanager_request.qtpl:1
+//line notifier/alertmanager_request.qtpl:1
 package notifier
 
-//line app/vmalert/notifier/alertmanager_request.qtpl:1
+//line notifier/alertmanager_request.qtpl:1
 import (
 	"time"
 
 	"github.com/VictoriaMetrics/VictoriaMetrics/lib/promrelabel"
 )
 
-//line app/vmalert/notifier/alertmanager_request.qtpl:8
+//line notifier/alertmanager_request.qtpl:8
 import (
 	qtio422016 "io"
 
 	qt422016 "github.com/valyala/quicktemplate"
 )
 
-//line app/vmalert/notifier/alertmanager_request.qtpl:8
+//line notifier/alertmanager_request.qtpl:8
 var (
 	_ = qtio422016.Copy
 	_ = qt422016.AcquireByteBuffer
 )
 
-//line app/vmalert/notifier/alertmanager_request.qtpl:8
+//line notifier/alertmanager_request.qtpl:8
 func streamamRequest(qw422016 *qt422016.Writer, alerts []Alert, generatorURL func(Alert) string, relabelCfg *promrelabel.ParsedConfigs) {
-//line app/vmalert/notifier/alertmanager_request.qtpl:8
+//line notifier/alertmanager_request.qtpl:8
 	qw422016.N().S(`[`)
-//line app/vmalert/notifier/alertmanager_request.qtpl:10
+//line notifier/alertmanager_request.qtpl:10
 	for i, alert := range alerts {
-//line app/vmalert/notifier/alertmanager_request.qtpl:10
+//line notifier/alertmanager_request.qtpl:10
 		qw422016.N().S(`{"startsAt":`)
-//line app/vmalert/notifier/alertmanager_request.qtpl:12
+//line notifier/alertmanager_request.qtpl:12
 		qw422016.N().Q(alert.Start.Format(time.RFC3339Nano))
-//line app/vmalert/notifier/alertmanager_request.qtpl:12
+//line notifier/alertmanager_request.qtpl:12
 		qw422016.N().S(`,"generatorURL":`)
-//line app/vmalert/notifier/alertmanager_request.qtpl:13
+//line notifier/alertmanager_request.qtpl:13
 		qw422016.N().Q(generatorURL(alert))
-//line app/vmalert/notifier/alertmanager_request.qtpl:13
+//line notifier/alertmanager_request.qtpl:13
 		qw422016.N().S(`,`)
-//line app/vmalert/notifier/alertmanager_request.qtpl:14
+//line notifier/alertmanager_request.qtpl:14
 		if !alert.End.IsZero() {
-//line app/vmalert/notifier/alertmanager_request.qtpl:14
+//line notifier/alertmanager_request.qtpl:14
 			qw422016.N().S(`"endsAt":`)
-//line app/vmalert/notifier/alertmanager_request.qtpl:15
+//line notifier/alertmanager_request.qtpl:15
 			qw422016.N().Q(alert.End.Format(time.RFC3339Nano))
-//line app/vmalert/notifier/alertmanager_request.qtpl:15
+//line notifier/alertmanager_request.qtpl:15
 			qw422016.N().S(`,`)
-//line app/vmalert/notifier/alertmanager_request.qtpl:16
+//line notifier/alertmanager_request.qtpl:16
 		}
-//line app/vmalert/notifier/alertmanager_request.qtpl:16
+//line notifier/alertmanager_request.qtpl:16
 		qw422016.N().S(`"labels": {"alertname":`)
-//line app/vmalert/notifier/alertmanager_request.qtpl:18
+//line notifier/alertmanager_request.qtpl:18
 		qw422016.N().Q(alert.Name)
-//line app/vmalert/notifier/alertmanager_request.qtpl:19
+//line notifier/alertmanager_request.qtpl:19
 		lbls := alert.toPromLabels(relabelCfg)
 
-//line app/vmalert/notifier/alertmanager_request.qtpl:20
+//line notifier/alertmanager_request.qtpl:20
 		for _, l := range lbls {
-//line app/vmalert/notifier/alertmanager_request.qtpl:20
+//line notifier/alertmanager_request.qtpl:20
 			qw422016.N().S(`,`)
-//line app/vmalert/notifier/alertmanager_request.qtpl:21
+//line notifier/alertmanager_request.qtpl:21
 			qw422016.N().Q(l.Name)
-//line app/vmalert/notifier/alertmanager_request.qtpl:21
+//line notifier/alertmanager_request.qtpl:21
 			qw422016.N().S(`:`)
-//line app/vmalert/notifier/alertmanager_request.qtpl:21
+//line notifier/alertmanager_request.qtpl:21
 			qw422016.N().Q(l.Value)
-//line app/vmalert/notifier/alertmanager_request.qtpl:22
+//line notifier/alertmanager_request.qtpl:22
 		}
-//line app/vmalert/notifier/alertmanager_request.qtpl:22
+//line notifier/alertmanager_request.qtpl:22
 		qw422016.N().S(`},"annotations": {`)
-//line app/vmalert/notifier/alertmanager_request.qtpl:25
+//line notifier/alertmanager_request.qtpl:25
 		c := len(alert.Annotations)
 
-//line app/vmalert/notifier/alertmanager_request.qtpl:26
+//line notifier/alertmanager_request.qtpl:26
 		for k, v := range alert.Annotations {
-//line app/vmalert/notifier/alertmanager_request.qtpl:27
+//line notifier/alertmanager_request.qtpl:27
 			c = c - 1
 
-//line app/vmalert/notifier/alertmanager_request.qtpl:28
+//line notifier/alertmanager_request.qtpl:28
 			qw422016.N().Q(k)
-//line app/vmalert/notifier/alertmanager_request.qtpl:28
+//line notifier/alertmanager_request.qtpl:28
 			qw422016.N().S(`:`)
-//line app/vmalert/notifier/alertmanager_request.qtpl:28
+//line notifier/alertmanager_request.qtpl:28
 			qw422016.N().Q(v)
-//line app/vmalert/notifier/alertmanager_request.qtpl:28
+//line notifier/alertmanager_request.qtpl:28
 			if c > 0 {
-//line app/vmalert/notifier/alertmanager_request.qtpl:28
+//line notifier/alertmanager_request.qtpl:28
 				qw422016.N().S(`,`)
-//line app/vmalert/notifier/alertmanager_request.qtpl:28
+//line notifier/alertmanager_request.qtpl:28
 			}
-//line app/vmalert/notifier/alertmanager_request.qtpl:29
+//line notifier/alertmanager_request.qtpl:29
 		}
-//line app/vmalert/notifier/alertmanager_request.qtpl:29
+//line notifier/alertmanager_request.qtpl:29
 		qw422016.N().S(`}}`)
-//line app/vmalert/notifier/alertmanager_request.qtpl:32
+//line notifier/alertmanager_request.qtpl:32
 		if i != len(alerts)-1 {
-//line app/vmalert/notifier/alertmanager_request.qtpl:32
+//line notifier/alertmanager_request.qtpl:32
 			qw422016.N().S(`,`)
-//line app/vmalert/notifier/alertmanager_request.qtpl:32
+//line notifier/alertmanager_request.qtpl:32
 		}
-//line app/vmalert/notifier/alertmanager_request.qtpl:33
+//line notifier/alertmanager_request.qtpl:33
 	}
-//line app/vmalert/notifier/alertmanager_request.qtpl:33
+//line notifier/alertmanager_request.qtpl:33
 	qw422016.N().S(`]`)
-//line app/vmalert/notifier/alertmanager_request.qtpl:35
+//line notifier/alertmanager_request.qtpl:35
 }
 
-//line app/vmalert/notifier/alertmanager_request.qtpl:35
+//line notifier/alertmanager_request.qtpl:35
 func writeamRequest(qq422016 qtio422016.Writer, alerts []Alert, generatorURL func(Alert) string, relabelCfg *promrelabel.ParsedConfigs) {
-//line app/vmalert/notifier/alertmanager_request.qtpl:35
+//line notifier/alertmanager_request.qtpl:35
 	qw422016 := qt422016.AcquireWriter(qq422016)
-//line app/vmalert/notifier/alertmanager_request.qtpl:35
+//line notifier/alertmanager_request.qtpl:35
 	streamamRequest(qw422016, alerts, generatorURL, relabelCfg)
-//line app/vmalert/notifier/alertmanager_request.qtpl:35
+//line notifier/alertmanager_request.qtpl:35
 	qt422016.ReleaseWriter(qw422016)
-//line app/vmalert/notifier/alertmanager_request.qtpl:35
+//line notifier/alertmanager_request.qtpl:35
 }
 
-//line app/vmalert/notifier/alertmanager_request.qtpl:35
+//line notifier/alertmanager_request.qtpl:35
 func amRequest(alerts []Alert, generatorURL func(Alert) string, relabelCfg *promrelabel.ParsedConfigs) string {
-//line app/vmalert/notifier/alertmanager_request.qtpl:35
+//line notifier/alertmanager_request.qtpl:35
 	qb422016 := qt422016.AcquireByteBuffer()
-//line app/vmalert/notifier/alertmanager_request.qtpl:35
+//line notifier/alertmanager_request.qtpl:35
 	writeamRequest(qb422016, alerts, generatorURL, relabelCfg)
-//line app/vmalert/notifier/alertmanager_request.qtpl:35
+//line notifier/alertmanager_request.qtpl:35
 	qs422016 := string(qb422016.B)
-//line app/vmalert/notifier/alertmanager_request.qtpl:35
+//line notifier/alertmanager_request.qtpl:35
 	qt422016.ReleaseByteBuffer(qb422016)
-//line app/vmalert/notifier/alertmanager_request.qtpl:35
+//line notifier/alertmanager_request.qtpl:35
 	return qs422016
-//line app/vmalert/notifier/alertmanager_request.qtpl:35
+//line notifier/alertmanager_request.qtpl:35
 }
diff --git a/app/vmalert/tpl/footer.qtpl.go b/app/vmalert/tpl/footer.qtpl.go
index fd5a0a1ce..7100c36bc 100644
--- a/app/vmalert/tpl/footer.qtpl.go
+++ b/app/vmalert/tpl/footer.qtpl.go
@@ -1,25 +1,25 @@
 // Code generated by qtc from "footer.qtpl". DO NOT EDIT.
 // See https://github.com/valyala/quicktemplate for details.
 
-//line app/vmalert/tpl/footer.qtpl:1
+//line tpl/footer.qtpl:1
 package tpl
 
-//line app/vmalert/tpl/footer.qtpl:1
+//line tpl/footer.qtpl:1
 import (
 	qtio422016 "io"
 
 	qt422016 "github.com/valyala/quicktemplate"
 )
 
-//line app/vmalert/tpl/footer.qtpl:1
+//line tpl/footer.qtpl:1
 var (
 	_ = qtio422016.Copy
 	_ = qt422016.AcquireByteBuffer
 )
 
-//line app/vmalert/tpl/footer.qtpl:1
+//line tpl/footer.qtpl:1
 func StreamFooter(qw422016 *qt422016.Writer) {
-//line app/vmalert/tpl/footer.qtpl:1
+//line tpl/footer.qtpl:1
 	qw422016.N().S(`
         </main>
         <script src="https://cdn.jsdelivr.net/npm/bootstrap@5.0.2/dist/js/bootstrap.bundle.min.js" integrity="sha384-MrcW6ZMFYlzcLA8Nl+NtUVF0sA7MsXsP1UyJoMp4YLEuNSfAP+JcXn/tWtIaxVXM" crossorigin="anonymous"></script>
@@ -56,31 +56,31 @@ func StreamFooter(qw422016 *qt422016.Writer) {
     </body>
 </html>
 `)
-//line app/vmalert/tpl/footer.qtpl:36
+//line tpl/footer.qtpl:36
 }
 
-//line app/vmalert/tpl/footer.qtpl:36
+//line tpl/footer.qtpl:36
 func WriteFooter(qq422016 qtio422016.Writer) {
-//line app/vmalert/tpl/footer.qtpl:36
+//line tpl/footer.qtpl:36
 	qw422016 := qt422016.AcquireWriter(qq422016)
-//line app/vmalert/tpl/footer.qtpl:36
+//line tpl/footer.qtpl:36
 	StreamFooter(qw422016)
-//line app/vmalert/tpl/footer.qtpl:36
+//line tpl/footer.qtpl:36
 	qt422016.ReleaseWriter(qw422016)
-//line app/vmalert/tpl/footer.qtpl:36
+//line tpl/footer.qtpl:36
 }
 
-//line app/vmalert/tpl/footer.qtpl:36
+//line tpl/footer.qtpl:36
 func Footer() string {
-//line app/vmalert/tpl/footer.qtpl:36
+//line tpl/footer.qtpl:36
 	qb422016 := qt422016.AcquireByteBuffer()
-//line app/vmalert/tpl/footer.qtpl:36
+//line tpl/footer.qtpl:36
 	WriteFooter(qb422016)
-//line app/vmalert/tpl/footer.qtpl:36
+//line tpl/footer.qtpl:36
 	qs422016 := string(qb422016.B)
-//line app/vmalert/tpl/footer.qtpl:36
+//line tpl/footer.qtpl:36
 	qt422016.ReleaseByteBuffer(qb422016)
-//line app/vmalert/tpl/footer.qtpl:36
+//line tpl/footer.qtpl:36
 	return qs422016
-//line app/vmalert/tpl/footer.qtpl:36
+//line tpl/footer.qtpl:36
 }
diff --git a/app/vmalert/tpl/header.qtpl b/app/vmalert/tpl/header.qtpl
index d5edf68e0..00410519c 100644
--- a/app/vmalert/tpl/header.qtpl
+++ b/app/vmalert/tpl/header.qtpl
@@ -9,11 +9,6 @@
           min-height: 75rem;
           padding-top: 4.5rem;
         }
-        pre {
-            overflow: scroll;
-            max-width: 600px;
-            min-height: 30px;
-        }
         .group-heading {
             cursor: pointer;
             padding: 5px;
diff --git a/app/vmalert/tpl/header.qtpl.go b/app/vmalert/tpl/header.qtpl.go
index 366a75727..a4f75c3e7 100644
--- a/app/vmalert/tpl/header.qtpl.go
+++ b/app/vmalert/tpl/header.qtpl.go
@@ -1,39 +1,39 @@
 // Code generated by qtc from "header.qtpl". DO NOT EDIT.
 // See https://github.com/valyala/quicktemplate for details.
 
-//line app/vmalert/tpl/header.qtpl:1
+//line tpl/header.qtpl:1
 package tpl
 
-//line app/vmalert/tpl/header.qtpl:1
+//line tpl/header.qtpl:1
 import (
 	qtio422016 "io"
 
 	qt422016 "github.com/valyala/quicktemplate"
 )
 
-//line app/vmalert/tpl/header.qtpl:1
+//line tpl/header.qtpl:1
 var (
 	_ = qtio422016.Copy
 	_ = qt422016.AcquireByteBuffer
 )
 
-//line app/vmalert/tpl/header.qtpl:1
+//line tpl/header.qtpl:1
 func StreamHeader(qw422016 *qt422016.Writer, title string, pages []NavItem) {
-//line app/vmalert/tpl/header.qtpl:1
+//line tpl/header.qtpl:1
 	qw422016.N().S(`
 <!DOCTYPE html>
 <html lang="en">
 <head>
     <title>vmalert`)
-//line app/vmalert/tpl/header.qtpl:5
+//line tpl/header.qtpl:5
 	if title != "" {
-//line app/vmalert/tpl/header.qtpl:5
+//line tpl/header.qtpl:5
 		qw422016.N().S(` - `)
-//line app/vmalert/tpl/header.qtpl:5
+//line tpl/header.qtpl:5
 		qw422016.E().S(title)
-//line app/vmalert/tpl/header.qtpl:5
+//line tpl/header.qtpl:5
 	}
-//line app/vmalert/tpl/header.qtpl:5
+//line tpl/header.qtpl:5
 	qw422016.N().S(`</title>
     <link href="https://cdn.jsdelivr.net/npm/bootstrap@5.0.2/dist/css/bootstrap.min.css" rel="stylesheet" integrity="sha384-EVSTQN3/azprG1Anm3QDgpJLIm9Nao0Yz1ztcQTwFspd3yD65VohhpuuCOmLASjC" crossorigin="anonymous">
     <style>
@@ -41,11 +41,6 @@ func StreamHeader(qw422016 *qt422016.Writer, title string, pages []NavItem) {
           min-height: 75rem;
           padding-top: 4.5rem;
         }
-        pre {
-            overflow: scroll;
-            max-width: 600px;
-            min-height: 30px;
-        }
         .group-heading {
             cursor: pointer;
             padding: 5px;
@@ -71,37 +66,37 @@ func StreamHeader(qw422016 *qt422016.Writer, title string, pages []NavItem) {
 </head>
 <body>
     `)
-//line app/vmalert/tpl/header.qtpl:41
+//line tpl/header.qtpl:36
 	StreamPrintNavItems(qw422016, title, pages)
-//line app/vmalert/tpl/header.qtpl:41
+//line tpl/header.qtpl:36
 	qw422016.N().S(`
     <main class="px-2">
 `)
-//line app/vmalert/tpl/header.qtpl:43
+//line tpl/header.qtpl:38
 }
 
-//line app/vmalert/tpl/header.qtpl:43
+//line tpl/header.qtpl:38
 func WriteHeader(qq422016 qtio422016.Writer, title string, pages []NavItem) {
-//line app/vmalert/tpl/header.qtpl:43
+//line tpl/header.qtpl:38
 	qw422016 := qt422016.AcquireWriter(qq422016)
-//line app/vmalert/tpl/header.qtpl:43
+//line tpl/header.qtpl:38
 	StreamHeader(qw422016, title, pages)
-//line app/vmalert/tpl/header.qtpl:43
+//line tpl/header.qtpl:38
 	qt422016.ReleaseWriter(qw422016)
-//line app/vmalert/tpl/header.qtpl:43
+//line tpl/header.qtpl:38
 }
 
-//line app/vmalert/tpl/header.qtpl:43
+//line tpl/header.qtpl:38
 func Header(title string, pages []NavItem) string {
-//line app/vmalert/tpl/header.qtpl:43
+//line tpl/header.qtpl:38
 	qb422016 := qt422016.AcquireByteBuffer()
-//line app/vmalert/tpl/header.qtpl:43
+//line tpl/header.qtpl:38
 	WriteHeader(qb422016, title, pages)
-//line app/vmalert/tpl/header.qtpl:43
+//line tpl/header.qtpl:38
 	qs422016 := string(qb422016.B)
-//line app/vmalert/tpl/header.qtpl:43
+//line tpl/header.qtpl:38
 	qt422016.ReleaseByteBuffer(qb422016)
-//line app/vmalert/tpl/header.qtpl:43
+//line tpl/header.qtpl:38
 	return qs422016
-//line app/vmalert/tpl/header.qtpl:43
+//line tpl/header.qtpl:38
 }
diff --git a/app/vmalert/tpl/nav.qtpl.go b/app/vmalert/tpl/nav.qtpl.go
index 85b56266f..d4e7f56a0 100644
--- a/app/vmalert/tpl/nav.qtpl.go
+++ b/app/vmalert/tpl/nav.qtpl.go
@@ -1,96 +1,96 @@
 // Code generated by qtc from "nav.qtpl". DO NOT EDIT.
 // See https://github.com/valyala/quicktemplate for details.
 
-//line app/vmalert/tpl/nav.qtpl:1
+//line tpl/nav.qtpl:1
 package tpl
 
-//line app/vmalert/tpl/nav.qtpl:1
+//line tpl/nav.qtpl:1
 import (
 	qtio422016 "io"
 
 	qt422016 "github.com/valyala/quicktemplate"
 )
 
-//line app/vmalert/tpl/nav.qtpl:1
+//line tpl/nav.qtpl:1
 var (
 	_ = qtio422016.Copy
 	_ = qt422016.AcquireByteBuffer
 )
 
-//line app/vmalert/tpl/nav.qtpl:2
+//line tpl/nav.qtpl:2
 type NavItem struct {
 	Name string
 	Url  string
 }
 
-//line app/vmalert/tpl/nav.qtpl:8
+//line tpl/nav.qtpl:8
 func StreamPrintNavItems(qw422016 *qt422016.Writer, current string, items []NavItem) {
-//line app/vmalert/tpl/nav.qtpl:8
+//line tpl/nav.qtpl:8
 	qw422016.N().S(`
 <nav class="navbar navbar-expand-md navbar-dark fixed-top bg-dark">
   <div class="container-fluid">
     <div class="collapse navbar-collapse" id="navbarCollapse">
         <ul class="navbar-nav me-auto mb-2 mb-md-0">
             `)
-//line app/vmalert/tpl/nav.qtpl:13
+//line tpl/nav.qtpl:13
 	for _, item := range items {
-//line app/vmalert/tpl/nav.qtpl:13
+//line tpl/nav.qtpl:13
 		qw422016.N().S(`
                 <li class="nav-item">
                     <a class="nav-link`)
-//line app/vmalert/tpl/nav.qtpl:15
+//line tpl/nav.qtpl:15
 		if current == item.Name {
-//line app/vmalert/tpl/nav.qtpl:15
+//line tpl/nav.qtpl:15
 			qw422016.N().S(` active`)
-//line app/vmalert/tpl/nav.qtpl:15
+//line tpl/nav.qtpl:15
 		}
-//line app/vmalert/tpl/nav.qtpl:15
+//line tpl/nav.qtpl:15
 		qw422016.N().S(`" href="`)
-//line app/vmalert/tpl/nav.qtpl:15
+//line tpl/nav.qtpl:15
 		qw422016.E().S(item.Url)
-//line app/vmalert/tpl/nav.qtpl:15
+//line tpl/nav.qtpl:15
 		qw422016.N().S(`">
                         `)
-//line app/vmalert/tpl/nav.qtpl:16
+//line tpl/nav.qtpl:16
 		qw422016.E().S(item.Name)
-//line app/vmalert/tpl/nav.qtpl:16
+//line tpl/nav.qtpl:16
 		qw422016.N().S(`
                     </a>
                 </li>
             `)
-//line app/vmalert/tpl/nav.qtpl:19
+//line tpl/nav.qtpl:19
 	}
-//line app/vmalert/tpl/nav.qtpl:19
+//line tpl/nav.qtpl:19
 	qw422016.N().S(`
         </ul>
   </div>
 </nav>
 `)
-//line app/vmalert/tpl/nav.qtpl:23
+//line tpl/nav.qtpl:23
 }
 
-//line app/vmalert/tpl/nav.qtpl:23
+//line tpl/nav.qtpl:23
 func WritePrintNavItems(qq422016 qtio422016.Writer, current string, items []NavItem) {
-//line app/vmalert/tpl/nav.qtpl:23
+//line tpl/nav.qtpl:23
 	qw422016 := qt422016.AcquireWriter(qq422016)
-//line app/vmalert/tpl/nav.qtpl:23
+//line tpl/nav.qtpl:23
 	StreamPrintNavItems(qw422016, current, items)
-//line app/vmalert/tpl/nav.qtpl:23
+//line tpl/nav.qtpl:23
 	qt422016.ReleaseWriter(qw422016)
-//line app/vmalert/tpl/nav.qtpl:23
+//line tpl/nav.qtpl:23
 }
 
-//line app/vmalert/tpl/nav.qtpl:23
+//line tpl/nav.qtpl:23
 func PrintNavItems(current string, items []NavItem) string {
-//line app/vmalert/tpl/nav.qtpl:23
+//line tpl/nav.qtpl:23
 	qb422016 := qt422016.AcquireByteBuffer()
-//line app/vmalert/tpl/nav.qtpl:23
+//line tpl/nav.qtpl:23
 	WritePrintNavItems(qb422016, current, items)
-//line app/vmalert/tpl/nav.qtpl:23
+//line tpl/nav.qtpl:23
 	qs422016 := string(qb422016.B)
-//line app/vmalert/tpl/nav.qtpl:23
+//line tpl/nav.qtpl:23
 	qt422016.ReleaseByteBuffer(qb422016)
-//line app/vmalert/tpl/nav.qtpl:23
+//line tpl/nav.qtpl:23
 	return qs422016
-//line app/vmalert/tpl/nav.qtpl:23
+//line tpl/nav.qtpl:23
 }
diff --git a/app/vmalert/web.qtpl b/app/vmalert/web.qtpl
index 89b50b5d8..4e9d56039 100644
--- a/app/vmalert/web.qtpl
+++ b/app/vmalert/web.qtpl
@@ -77,7 +77,7 @@
                                 <b>record:</b> {%s r.Name %}
                                 {% endif %}
                                 <br>
-                                <code><pre>{%s r.Query %}</pre></code><br>
+                                <code><pre class="text-wrap">{%s r.Query %}</pre></code><br>
                                 {% if len(r.Labels) > 0 %} <b>Labels:</b>{% endif %}
                                 {% for k, v := range r.Labels %}
                                         <span class="ms-1 badge bg-primary">{%s k %}={%s v %}</span>
@@ -343,4 +343,4 @@
 
 {% func badgeRestored() %}
 <span class="badge bg-warning text-dark" title="Alert state was restored after the service restart from remote storage">restored</span>
-{% endfunc %}
\ No newline at end of file
+{% endfunc %}
diff --git a/app/vmalert/web.qtpl.go b/app/vmalert/web.qtpl.go
index dd6f4daf2..e7f30c709 100644
--- a/app/vmalert/web.qtpl.go
+++ b/app/vmalert/web.qtpl.go
@@ -1,10 +1,10 @@
 // Code generated by qtc from "web.qtpl". DO NOT EDIT.
 // See https://github.com/valyala/quicktemplate for details.
 
-//line app/vmalert/web.qtpl:1
+//line web.qtpl:1
 package main
 
-//line app/vmalert/web.qtpl:3
+//line web.qtpl:3
 import (
 	"path"
 	"sort"
@@ -14,111 +14,111 @@ import (
 	"github.com/VictoriaMetrics/VictoriaMetrics/app/vmalert/tpl"
 )
 
-//line app/vmalert/web.qtpl:13
+//line web.qtpl:13
 import (
 	qtio422016 "io"
 
 	qt422016 "github.com/valyala/quicktemplate"
 )
 
-//line app/vmalert/web.qtpl:13
+//line web.qtpl:13
 var (
 	_ = qtio422016.Copy
 	_ = qt422016.AcquireByteBuffer
 )
 
-//line app/vmalert/web.qtpl:13
+//line web.qtpl:13
 func StreamWelcome(qw422016 *qt422016.Writer) {
-//line app/vmalert/web.qtpl:13
+//line web.qtpl:13
 	qw422016.N().S(`
     `)
-//line app/vmalert/web.qtpl:14
+//line web.qtpl:14
 	tpl.StreamHeader(qw422016, "vmalert", navItems)
-//line app/vmalert/web.qtpl:14
+//line web.qtpl:14
 	qw422016.N().S(`
     <p>
         API:<br>
         `)
-//line app/vmalert/web.qtpl:17
+//line web.qtpl:17
 	for _, p := range apiLinks {
-//line app/vmalert/web.qtpl:17
+//line web.qtpl:17
 		qw422016.N().S(`
             `)
-//line app/vmalert/web.qtpl:19
+//line web.qtpl:19
 		p, doc := p[0], p[1]
 
-//line app/vmalert/web.qtpl:20
+//line web.qtpl:20
 		qw422016.N().S(`
         	<a href="`)
-//line app/vmalert/web.qtpl:21
+//line web.qtpl:21
 		qw422016.E().S(p)
-//line app/vmalert/web.qtpl:21
+//line web.qtpl:21
 		qw422016.N().S(`">`)
-//line app/vmalert/web.qtpl:21
+//line web.qtpl:21
 		qw422016.E().S(p)
-//line app/vmalert/web.qtpl:21
+//line web.qtpl:21
 		qw422016.N().S(`</a> - `)
-//line app/vmalert/web.qtpl:21
+//line web.qtpl:21
 		qw422016.E().S(doc)
-//line app/vmalert/web.qtpl:21
+//line web.qtpl:21
 		qw422016.N().S(`<br/>
         `)
-//line app/vmalert/web.qtpl:22
+//line web.qtpl:22
 	}
-//line app/vmalert/web.qtpl:22
+//line web.qtpl:22
 	qw422016.N().S(`
     </p>
     `)
-//line app/vmalert/web.qtpl:24
+//line web.qtpl:24
 	tpl.StreamFooter(qw422016)
-//line app/vmalert/web.qtpl:24
+//line web.qtpl:24
 	qw422016.N().S(`
 `)
-//line app/vmalert/web.qtpl:25
+//line web.qtpl:25
 }
 
-//line app/vmalert/web.qtpl:25
+//line web.qtpl:25
 func WriteWelcome(qq422016 qtio422016.Writer) {
-//line app/vmalert/web.qtpl:25
+//line web.qtpl:25
 	qw422016 := qt422016.AcquireWriter(qq422016)
-//line app/vmalert/web.qtpl:25
+//line web.qtpl:25
 	StreamWelcome(qw422016)
-//line app/vmalert/web.qtpl:25
+//line web.qtpl:25
 	qt422016.ReleaseWriter(qw422016)
-//line app/vmalert/web.qtpl:25
+//line web.qtpl:25
 }
 
-//line app/vmalert/web.qtpl:25
+//line web.qtpl:25
 func Welcome() string {
-//line app/vmalert/web.qtpl:25
+//line web.qtpl:25
 	qb422016 := qt422016.AcquireByteBuffer()
-//line app/vmalert/web.qtpl:25
+//line web.qtpl:25
 	WriteWelcome(qb422016)
-//line app/vmalert/web.qtpl:25
+//line web.qtpl:25
 	qs422016 := string(qb422016.B)
-//line app/vmalert/web.qtpl:25
+//line web.qtpl:25
 	qt422016.ReleaseByteBuffer(qb422016)
-//line app/vmalert/web.qtpl:25
+//line web.qtpl:25
 	return qs422016
-//line app/vmalert/web.qtpl:25
+//line web.qtpl:25
 }
 
-//line app/vmalert/web.qtpl:27
+//line web.qtpl:27
 func StreamListGroups(qw422016 *qt422016.Writer, groups []APIGroup) {
-//line app/vmalert/web.qtpl:27
+//line web.qtpl:27
 	qw422016.N().S(`
     `)
-//line app/vmalert/web.qtpl:28
+//line web.qtpl:28
 	tpl.StreamHeader(qw422016, "Groups", navItems)
-//line app/vmalert/web.qtpl:28
+//line web.qtpl:28
 	qw422016.N().S(`
     `)
-//line app/vmalert/web.qtpl:29
+//line web.qtpl:29
 	if len(groups) > 0 {
-//line app/vmalert/web.qtpl:29
+//line web.qtpl:29
 		qw422016.N().S(`
         `)
-//line app/vmalert/web.qtpl:31
+//line web.qtpl:31
 		rOk := make(map[string]int)
 		rNotOk := make(map[string]int)
 		for _, g := range groups {
@@ -131,111 +131,111 @@ func StreamListGroups(qw422016 *qt422016.Writer, groups []APIGroup) {
 			}
 		}
 
-//line app/vmalert/web.qtpl:42
+//line web.qtpl:42
 		qw422016.N().S(`
          <a class="btn btn-primary" role="button" onclick="collapseAll()">Collapse All</a>
          <a class="btn btn-primary" role="button" onclick="expandAll()">Expand All</a>
         `)
-//line app/vmalert/web.qtpl:45
+//line web.qtpl:45
 		for _, g := range groups {
-//line app/vmalert/web.qtpl:45
+//line web.qtpl:45
 			qw422016.N().S(`
               <div class="group-heading`)
-//line app/vmalert/web.qtpl:46
+//line web.qtpl:46
 			if rNotOk[g.Name] > 0 {
-//line app/vmalert/web.qtpl:46
+//line web.qtpl:46
 				qw422016.N().S(` alert-danger`)
-//line app/vmalert/web.qtpl:46
+//line web.qtpl:46
 			}
-//line app/vmalert/web.qtpl:46
+//line web.qtpl:46
 			qw422016.N().S(`"  data-bs-target="rules-`)
-//line app/vmalert/web.qtpl:46
+//line web.qtpl:46
 			qw422016.E().S(g.ID)
-//line app/vmalert/web.qtpl:46
+//line web.qtpl:46
 			qw422016.N().S(`">
                 <span class="anchor" id="group-`)
-//line app/vmalert/web.qtpl:47
+//line web.qtpl:47
 			qw422016.E().S(g.ID)
-//line app/vmalert/web.qtpl:47
+//line web.qtpl:47
 			qw422016.N().S(`"></span>
                 <a href="#group-`)
-//line app/vmalert/web.qtpl:48
+//line web.qtpl:48
 			qw422016.E().S(g.ID)
-//line app/vmalert/web.qtpl:48
+//line web.qtpl:48
 			qw422016.N().S(`">`)
-//line app/vmalert/web.qtpl:48
+//line web.qtpl:48
 			qw422016.E().S(g.Name)
-//line app/vmalert/web.qtpl:48
+//line web.qtpl:48
 			if g.Type != "prometheus" {
-//line app/vmalert/web.qtpl:48
+//line web.qtpl:48
 				qw422016.N().S(` (`)
-//line app/vmalert/web.qtpl:48
+//line web.qtpl:48
 				qw422016.E().S(g.Type)
-//line app/vmalert/web.qtpl:48
+//line web.qtpl:48
 				qw422016.N().S(`)`)
-//line app/vmalert/web.qtpl:48
+//line web.qtpl:48
 			}
-//line app/vmalert/web.qtpl:48
+//line web.qtpl:48
 			qw422016.N().S(` (every `)
-//line app/vmalert/web.qtpl:48
+//line web.qtpl:48
 			qw422016.N().FPrec(g.Interval, 0)
-//line app/vmalert/web.qtpl:48
+//line web.qtpl:48
 			qw422016.N().S(`s)</a>
                  `)
-//line app/vmalert/web.qtpl:49
+//line web.qtpl:49
 			if rNotOk[g.Name] > 0 {
-//line app/vmalert/web.qtpl:49
+//line web.qtpl:49
 				qw422016.N().S(`<span class="badge bg-danger" title="Number of rules with status Error">`)
-//line app/vmalert/web.qtpl:49
+//line web.qtpl:49
 				qw422016.N().D(rNotOk[g.Name])
-//line app/vmalert/web.qtpl:49
+//line web.qtpl:49
 				qw422016.N().S(`</span> `)
-//line app/vmalert/web.qtpl:49
+//line web.qtpl:49
 			}
-//line app/vmalert/web.qtpl:49
+//line web.qtpl:49
 			qw422016.N().S(`
                 <span class="badge bg-success" title="Number of rules withs status Ok">`)
-//line app/vmalert/web.qtpl:50
+//line web.qtpl:50
 			qw422016.N().D(rOk[g.Name])
-//line app/vmalert/web.qtpl:50
+//line web.qtpl:50
 			qw422016.N().S(`</span>
                 <p class="fs-6 fw-lighter">`)
-//line app/vmalert/web.qtpl:51
+//line web.qtpl:51
 			qw422016.E().S(g.File)
-//line app/vmalert/web.qtpl:51
+//line web.qtpl:51
 			qw422016.N().S(`</p>
                 `)
-//line app/vmalert/web.qtpl:52
+//line web.qtpl:52
 			if len(g.Params) > 0 {
-//line app/vmalert/web.qtpl:52
+//line web.qtpl:52
 				qw422016.N().S(`
                     <div class="fs-6 fw-lighter">Extra params
                     `)
-//line app/vmalert/web.qtpl:54
+//line web.qtpl:54
 				for _, param := range g.Params {
-//line app/vmalert/web.qtpl:54
+//line web.qtpl:54
 					qw422016.N().S(`
                             <span class="float-left badge bg-primary">`)
-//line app/vmalert/web.qtpl:55
+//line web.qtpl:55
 					qw422016.E().S(param)
-//line app/vmalert/web.qtpl:55
+//line web.qtpl:55
 					qw422016.N().S(`</span>
                     `)
-//line app/vmalert/web.qtpl:56
+//line web.qtpl:56
 				}
-//line app/vmalert/web.qtpl:56
+//line web.qtpl:56
 				qw422016.N().S(`
                     </div>
                 `)
-//line app/vmalert/web.qtpl:58
+//line web.qtpl:58
 			}
-//line app/vmalert/web.qtpl:58
+//line web.qtpl:58
 			qw422016.N().S(`
             </div>
             <div class="collapse" id="rules-`)
-//line app/vmalert/web.qtpl:60
+//line web.qtpl:60
 			qw422016.E().S(g.ID)
-//line app/vmalert/web.qtpl:60
+//line web.qtpl:60
 			qw422016.N().S(`">
                 <table class="table table-striped table-hover table-sm">
                     <thead>
@@ -248,230 +248,230 @@ func StreamListGroups(qw422016 *qt422016.Writer, groups []APIGroup) {
                     </thead>
                     <tbody>
                     `)
-//line app/vmalert/web.qtpl:71
+//line web.qtpl:71
 			for _, r := range g.Rules {
-//line app/vmalert/web.qtpl:71
+//line web.qtpl:71
 				qw422016.N().S(`
                         <tr`)
-//line app/vmalert/web.qtpl:72
+//line web.qtpl:72
 				if r.LastError != "" {
-//line app/vmalert/web.qtpl:72
+//line web.qtpl:72
 					qw422016.N().S(` class="alert-danger"`)
-//line app/vmalert/web.qtpl:72
+//line web.qtpl:72
 				}
-//line app/vmalert/web.qtpl:72
+//line web.qtpl:72
 				qw422016.N().S(`>
                             <td>
                                 `)
-//line app/vmalert/web.qtpl:74
+//line web.qtpl:74
 				if r.Type == "alerting" {
-//line app/vmalert/web.qtpl:74
+//line web.qtpl:74
 					qw422016.N().S(`
                                 <b>alert:</b> (for: `)
-//line app/vmalert/web.qtpl:75
+//line web.qtpl:75
 					qw422016.E().V(r.Duration)
-//line app/vmalert/web.qtpl:75
+//line web.qtpl:75
 					qw422016.N().S(`)
                                 `)
-//line app/vmalert/web.qtpl:76
+//line web.qtpl:76
 				} else {
-//line app/vmalert/web.qtpl:76
+//line web.qtpl:76
 					qw422016.N().S(`
                                 <b>record:</b> `)
-//line app/vmalert/web.qtpl:77
+//line web.qtpl:77
 					qw422016.E().S(r.Name)
-//line app/vmalert/web.qtpl:77
+//line web.qtpl:77
 					qw422016.N().S(`
                                 `)
-//line app/vmalert/web.qtpl:78
+//line web.qtpl:78
 				}
-//line app/vmalert/web.qtpl:78
+//line web.qtpl:78
 				qw422016.N().S(`
                                 <br>
-                                <code><pre>`)
-//line app/vmalert/web.qtpl:80
+                                <code><pre class="text-wrap">`)
+//line web.qtpl:80
 				qw422016.E().S(r.Query)
-//line app/vmalert/web.qtpl:80
+//line web.qtpl:80
 				qw422016.N().S(`</pre></code><br>
                                 `)
-//line app/vmalert/web.qtpl:81
+//line web.qtpl:81
 				if len(r.Labels) > 0 {
-//line app/vmalert/web.qtpl:81
+//line web.qtpl:81
 					qw422016.N().S(` <b>Labels:</b>`)
-//line app/vmalert/web.qtpl:81
+//line web.qtpl:81
 				}
-//line app/vmalert/web.qtpl:81
+//line web.qtpl:81
 				qw422016.N().S(`
                                 `)
-//line app/vmalert/web.qtpl:82
+//line web.qtpl:82
 				for k, v := range r.Labels {
-//line app/vmalert/web.qtpl:82
+//line web.qtpl:82
 					qw422016.N().S(`
                                         <span class="ms-1 badge bg-primary">`)
-//line app/vmalert/web.qtpl:83
+//line web.qtpl:83
 					qw422016.E().S(k)
-//line app/vmalert/web.qtpl:83
+//line web.qtpl:83
 					qw422016.N().S(`=`)
-//line app/vmalert/web.qtpl:83
+//line web.qtpl:83
 					qw422016.E().S(v)
-//line app/vmalert/web.qtpl:83
+//line web.qtpl:83
 					qw422016.N().S(`</span>
                                 `)
-//line app/vmalert/web.qtpl:84
+//line web.qtpl:84
 				}
-//line app/vmalert/web.qtpl:84
+//line web.qtpl:84
 				qw422016.N().S(`
                             </td>
                             <td><div class="error-cell">`)
-//line app/vmalert/web.qtpl:86
+//line web.qtpl:86
 				qw422016.E().S(r.LastError)
-//line app/vmalert/web.qtpl:86
+//line web.qtpl:86
 				qw422016.N().S(`</div></td>
                             <td>`)
-//line app/vmalert/web.qtpl:87
+//line web.qtpl:87
 				qw422016.N().D(r.LastSamples)
-//line app/vmalert/web.qtpl:87
+//line web.qtpl:87
 				qw422016.N().S(`</td>
                             <td>`)
-//line app/vmalert/web.qtpl:88
+//line web.qtpl:88
 				qw422016.N().FPrec(time.Since(r.LastEvaluation).Seconds(), 3)
-//line app/vmalert/web.qtpl:88
+//line web.qtpl:88
 				qw422016.N().S(`s ago</td>
                         </tr>
                     `)
-//line app/vmalert/web.qtpl:90
+//line web.qtpl:90
 			}
-//line app/vmalert/web.qtpl:90
+//line web.qtpl:90
 			qw422016.N().S(`
                  </tbody>
                 </table>
             </div>
         `)
-//line app/vmalert/web.qtpl:94
+//line web.qtpl:94
 		}
-//line app/vmalert/web.qtpl:94
+//line web.qtpl:94
 		qw422016.N().S(`
 
     `)
-//line app/vmalert/web.qtpl:96
+//line web.qtpl:96
 	} else {
-//line app/vmalert/web.qtpl:96
+//line web.qtpl:96
 		qw422016.N().S(`
         <div>
             <p>No items...</p>
         </div>
     `)
-//line app/vmalert/web.qtpl:100
+//line web.qtpl:100
 	}
-//line app/vmalert/web.qtpl:100
+//line web.qtpl:100
 	qw422016.N().S(`
 
     `)
-//line app/vmalert/web.qtpl:102
+//line web.qtpl:102
 	tpl.StreamFooter(qw422016)
-//line app/vmalert/web.qtpl:102
+//line web.qtpl:102
 	qw422016.N().S(`
 
 `)
-//line app/vmalert/web.qtpl:104
+//line web.qtpl:104
 }
 
-//line app/vmalert/web.qtpl:104
+//line web.qtpl:104
 func WriteListGroups(qq422016 qtio422016.Writer, groups []APIGroup) {
-//line app/vmalert/web.qtpl:104
+//line web.qtpl:104
 	qw422016 := qt422016.AcquireWriter(qq422016)
-//line app/vmalert/web.qtpl:104
+//line web.qtpl:104
 	StreamListGroups(qw422016, groups)
-//line app/vmalert/web.qtpl:104
+//line web.qtpl:104
 	qt422016.ReleaseWriter(qw422016)
-//line app/vmalert/web.qtpl:104
+//line web.qtpl:104
 }
 
-//line app/vmalert/web.qtpl:104
+//line web.qtpl:104
 func ListGroups(groups []APIGroup) string {
-//line app/vmalert/web.qtpl:104
+//line web.qtpl:104
 	qb422016 := qt422016.AcquireByteBuffer()
-//line app/vmalert/web.qtpl:104
+//line web.qtpl:104
 	WriteListGroups(qb422016, groups)
-//line app/vmalert/web.qtpl:104
+//line web.qtpl:104
 	qs422016 := string(qb422016.B)
-//line app/vmalert/web.qtpl:104
+//line web.qtpl:104
 	qt422016.ReleaseByteBuffer(qb422016)
-//line app/vmalert/web.qtpl:104
+//line web.qtpl:104
 	return qs422016
-//line app/vmalert/web.qtpl:104
+//line web.qtpl:104
 }
 
-//line app/vmalert/web.qtpl:107
+//line web.qtpl:107
 func StreamListAlerts(qw422016 *qt422016.Writer, pathPrefix string, groupAlerts []GroupAlerts) {
-//line app/vmalert/web.qtpl:107
+//line web.qtpl:107
 	qw422016.N().S(`
     `)
-//line app/vmalert/web.qtpl:108
+//line web.qtpl:108
 	tpl.StreamHeader(qw422016, "Alerts", navItems)
-//line app/vmalert/web.qtpl:108
+//line web.qtpl:108
 	qw422016.N().S(`
     `)
-//line app/vmalert/web.qtpl:109
+//line web.qtpl:109
 	if len(groupAlerts) > 0 {
-//line app/vmalert/web.qtpl:109
+//line web.qtpl:109
 		qw422016.N().S(`
          <a class="btn btn-primary" role="button" onclick="collapseAll()">Collapse All</a>
          <a class="btn btn-primary" role="button" onclick="expandAll()">Expand All</a>
          `)
-//line app/vmalert/web.qtpl:112
+//line web.qtpl:112
 		for _, ga := range groupAlerts {
-//line app/vmalert/web.qtpl:112
+//line web.qtpl:112
 			qw422016.N().S(`
             `)
-//line app/vmalert/web.qtpl:113
+//line web.qtpl:113
 			g := ga.Group
 
-//line app/vmalert/web.qtpl:113
+//line web.qtpl:113
 			qw422016.N().S(`
             <div class="group-heading alert-danger" data-bs-target="rules-`)
-//line app/vmalert/web.qtpl:114
+//line web.qtpl:114
 			qw422016.E().S(g.ID)
-//line app/vmalert/web.qtpl:114
+//line web.qtpl:114
 			qw422016.N().S(`">
                 <span class="anchor" id="group-`)
-//line app/vmalert/web.qtpl:115
+//line web.qtpl:115
 			qw422016.E().S(g.ID)
-//line app/vmalert/web.qtpl:115
+//line web.qtpl:115
 			qw422016.N().S(`"></span>
                 <a href="#group-`)
-//line app/vmalert/web.qtpl:116
+//line web.qtpl:116
 			qw422016.E().S(g.ID)
-//line app/vmalert/web.qtpl:116
+//line web.qtpl:116
 			qw422016.N().S(`">`)
-//line app/vmalert/web.qtpl:116
+//line web.qtpl:116
 			qw422016.E().S(g.Name)
-//line app/vmalert/web.qtpl:116
+//line web.qtpl:116
 			if g.Type != "prometheus" {
-//line app/vmalert/web.qtpl:116
+//line web.qtpl:116
 				qw422016.N().S(` (`)
-//line app/vmalert/web.qtpl:116
+//line web.qtpl:116
 				qw422016.E().S(g.Type)
-//line app/vmalert/web.qtpl:116
+//line web.qtpl:116
 				qw422016.N().S(`)`)
-//line app/vmalert/web.qtpl:116
+//line web.qtpl:116
 			}
-//line app/vmalert/web.qtpl:116
+//line web.qtpl:116
 			qw422016.N().S(`</a>
                 <span class="badge bg-danger" title="Number of active alerts">`)
-//line app/vmalert/web.qtpl:117
+//line web.qtpl:117
 			qw422016.N().D(len(ga.Alerts))
-//line app/vmalert/web.qtpl:117
+//line web.qtpl:117
 			qw422016.N().S(`</span>
                 <br>
                 <p class="fs-6 fw-lighter">`)
-//line app/vmalert/web.qtpl:119
+//line web.qtpl:119
 			qw422016.E().S(g.File)
-//line app/vmalert/web.qtpl:119
+//line web.qtpl:119
 			qw422016.N().S(`</p>
             </div>
             `)
-//line app/vmalert/web.qtpl:122
+//line web.qtpl:122
 			var keys []string
 			alertsByRule := make(map[string][]*APIAlert)
 			for _, alert := range ga.Alerts {
@@ -482,20 +482,20 @@ func StreamListAlerts(qw422016 *qt422016.Writer, pathPrefix string, groupAlerts
 			}
 			sort.Strings(keys)
 
-//line app/vmalert/web.qtpl:131
+//line web.qtpl:131
 			qw422016.N().S(`
             <div class="collapse" id="rules-`)
-//line app/vmalert/web.qtpl:132
+//line web.qtpl:132
 			qw422016.E().S(g.ID)
-//line app/vmalert/web.qtpl:132
+//line web.qtpl:132
 			qw422016.N().S(`">
                 `)
-//line app/vmalert/web.qtpl:133
+//line web.qtpl:133
 			for _, ruleID := range keys {
-//line app/vmalert/web.qtpl:133
+//line web.qtpl:133
 				qw422016.N().S(`
                     `)
-//line app/vmalert/web.qtpl:135
+//line web.qtpl:135
 				defaultAR := alertsByRule[ruleID][0]
 				var labelKeys []string
 				for k := range defaultAR.Labels {
@@ -503,28 +503,28 @@ func StreamListAlerts(qw422016 *qt422016.Writer, pathPrefix string, groupAlerts
 				}
 				sort.Strings(labelKeys)
 
-//line app/vmalert/web.qtpl:141
+//line web.qtpl:141
 				qw422016.N().S(`
                     <br>
                     <b>alert:</b> `)
-//line app/vmalert/web.qtpl:143
+//line web.qtpl:143
 				qw422016.E().S(defaultAR.Name)
-//line app/vmalert/web.qtpl:143
+//line web.qtpl:143
 				qw422016.N().S(` (`)
-//line app/vmalert/web.qtpl:143
+//line web.qtpl:143
 				qw422016.N().D(len(alertsByRule[ruleID]))
-//line app/vmalert/web.qtpl:143
+//line web.qtpl:143
 				qw422016.N().S(`)
                      | <span><a target="_blank" href="`)
-//line app/vmalert/web.qtpl:144
+//line web.qtpl:144
 				qw422016.E().S(defaultAR.SourceLink)
-//line app/vmalert/web.qtpl:144
+//line web.qtpl:144
 				qw422016.N().S(`">Source</a></span>
                     <br>
                     <b>expr:</b><code><pre>`)
-//line app/vmalert/web.qtpl:146
+//line web.qtpl:146
 				qw422016.E().S(defaultAR.Expression)
-//line app/vmalert/web.qtpl:146
+//line web.qtpl:146
 				qw422016.N().S(`</pre></code>
                     <table class="table table-striped table-hover table-sm">
                         <thead>
@@ -538,204 +538,204 @@ func StreamListAlerts(qw422016 *qt422016.Writer, pathPrefix string, groupAlerts
                         </thead>
                         <tbody>
                         `)
-//line app/vmalert/web.qtpl:158
+//line web.qtpl:158
 				for _, ar := range alertsByRule[ruleID] {
-//line app/vmalert/web.qtpl:158
+//line web.qtpl:158
 					qw422016.N().S(`
                             <tr>
                                 <td>
                                     `)
-//line app/vmalert/web.qtpl:161
+//line web.qtpl:161
 					for _, k := range labelKeys {
-//line app/vmalert/web.qtpl:161
+//line web.qtpl:161
 						qw422016.N().S(`
                                         <span class="ms-1 badge bg-primary">`)
-//line app/vmalert/web.qtpl:162
+//line web.qtpl:162
 						qw422016.E().S(k)
-//line app/vmalert/web.qtpl:162
+//line web.qtpl:162
 						qw422016.N().S(`=`)
-//line app/vmalert/web.qtpl:162
+//line web.qtpl:162
 						qw422016.E().S(ar.Labels[k])
-//line app/vmalert/web.qtpl:162
+//line web.qtpl:162
 						qw422016.N().S(`</span>
                                     `)
-//line app/vmalert/web.qtpl:163
+//line web.qtpl:163
 					}
-//line app/vmalert/web.qtpl:163
+//line web.qtpl:163
 					qw422016.N().S(`
                                 </td>
                                 <td>`)
-//line app/vmalert/web.qtpl:165
+//line web.qtpl:165
 					streambadgeState(qw422016, ar.State)
-//line app/vmalert/web.qtpl:165
+//line web.qtpl:165
 					qw422016.N().S(`</td>
                                 <td>
                                     `)
-//line app/vmalert/web.qtpl:167
+//line web.qtpl:167
 					qw422016.E().S(ar.ActiveAt.Format("2006-01-02T15:04:05Z07:00"))
-//line app/vmalert/web.qtpl:167
+//line web.qtpl:167
 					qw422016.N().S(`
                                     `)
-//line app/vmalert/web.qtpl:168
+//line web.qtpl:168
 					if ar.Restored {
-//line app/vmalert/web.qtpl:168
+//line web.qtpl:168
 						streambadgeRestored(qw422016)
-//line app/vmalert/web.qtpl:168
+//line web.qtpl:168
 					}
-//line app/vmalert/web.qtpl:168
+//line web.qtpl:168
 					qw422016.N().S(`
                                 </td>
                                 <td>`)
-//line app/vmalert/web.qtpl:170
+//line web.qtpl:170
 					qw422016.E().S(ar.Value)
-//line app/vmalert/web.qtpl:170
+//line web.qtpl:170
 					qw422016.N().S(`</td>
                                 <td>
                                     <a href="`)
-//line app/vmalert/web.qtpl:172
+//line web.qtpl:172
 					qw422016.E().S(path.Join(pathPrefix, g.ID, ar.ID, "status"))
-//line app/vmalert/web.qtpl:172
+//line web.qtpl:172
 					qw422016.N().S(`">Details</a>
                                 </td>
                             </tr>
                         `)
-//line app/vmalert/web.qtpl:175
+//line web.qtpl:175
 				}
-//line app/vmalert/web.qtpl:175
+//line web.qtpl:175
 				qw422016.N().S(`
                      </tbody>
                     </table>
                 `)
-//line app/vmalert/web.qtpl:178
+//line web.qtpl:178
 			}
-//line app/vmalert/web.qtpl:178
+//line web.qtpl:178
 			qw422016.N().S(`
             </div>
             <br>
         `)
-//line app/vmalert/web.qtpl:181
+//line web.qtpl:181
 		}
-//line app/vmalert/web.qtpl:181
+//line web.qtpl:181
 		qw422016.N().S(`
 
     `)
-//line app/vmalert/web.qtpl:183
+//line web.qtpl:183
 	} else {
-//line app/vmalert/web.qtpl:183
+//line web.qtpl:183
 		qw422016.N().S(`
         <div>
             <p>No items...</p>
         </div>
     `)
-//line app/vmalert/web.qtpl:187
+//line web.qtpl:187
 	}
-//line app/vmalert/web.qtpl:187
+//line web.qtpl:187
 	qw422016.N().S(`
 
     `)
-//line app/vmalert/web.qtpl:189
+//line web.qtpl:189
 	tpl.StreamFooter(qw422016)
-//line app/vmalert/web.qtpl:189
+//line web.qtpl:189
 	qw422016.N().S(`
 
 `)
-//line app/vmalert/web.qtpl:191
+//line web.qtpl:191
 }
 
-//line app/vmalert/web.qtpl:191
+//line web.qtpl:191
 func WriteListAlerts(qq422016 qtio422016.Writer, pathPrefix string, groupAlerts []GroupAlerts) {
-//line app/vmalert/web.qtpl:191
+//line web.qtpl:191
 	qw422016 := qt422016.AcquireWriter(qq422016)
-//line app/vmalert/web.qtpl:191
+//line web.qtpl:191
 	StreamListAlerts(qw422016, pathPrefix, groupAlerts)
-//line app/vmalert/web.qtpl:191
+//line web.qtpl:191
 	qt422016.ReleaseWriter(qw422016)
-//line app/vmalert/web.qtpl:191
+//line web.qtpl:191
 }
 
-//line app/vmalert/web.qtpl:191
+//line web.qtpl:191
 func ListAlerts(pathPrefix string, groupAlerts []GroupAlerts) string {
-//line app/vmalert/web.qtpl:191
+//line web.qtpl:191
 	qb422016 := qt422016.AcquireByteBuffer()
-//line app/vmalert/web.qtpl:191
+//line web.qtpl:191
 	WriteListAlerts(qb422016, pathPrefix, groupAlerts)
-//line app/vmalert/web.qtpl:191
+//line web.qtpl:191
 	qs422016 := string(qb422016.B)
-//line app/vmalert/web.qtpl:191
+//line web.qtpl:191
 	qt422016.ReleaseByteBuffer(qb422016)
-//line app/vmalert/web.qtpl:191
+//line web.qtpl:191
 	return qs422016
-//line app/vmalert/web.qtpl:191
+//line web.qtpl:191
 }
 
-//line app/vmalert/web.qtpl:193
+//line web.qtpl:193
 func StreamListTargets(qw422016 *qt422016.Writer, targets map[notifier.TargetType][]notifier.Target) {
-//line app/vmalert/web.qtpl:193
+//line web.qtpl:193
 	qw422016.N().S(`
     `)
-//line app/vmalert/web.qtpl:194
+//line web.qtpl:194
 	tpl.StreamHeader(qw422016, "Notifiers", navItems)
-//line app/vmalert/web.qtpl:194
+//line web.qtpl:194
 	qw422016.N().S(`
     `)
-//line app/vmalert/web.qtpl:195
+//line web.qtpl:195
 	if len(targets) > 0 {
-//line app/vmalert/web.qtpl:195
+//line web.qtpl:195
 		qw422016.N().S(`
          <a class="btn btn-primary" role="button" onclick="collapseAll()">Collapse All</a>
          <a class="btn btn-primary" role="button" onclick="expandAll()">Expand All</a>
 
          `)
-//line app/vmalert/web.qtpl:200
+//line web.qtpl:200
 		var keys []string
 		for key := range targets {
 			keys = append(keys, string(key))
 		}
 		sort.Strings(keys)
 
-//line app/vmalert/web.qtpl:205
+//line web.qtpl:205
 		qw422016.N().S(`
 
          `)
-//line app/vmalert/web.qtpl:207
+//line web.qtpl:207
 		for i := range keys {
-//line app/vmalert/web.qtpl:207
+//line web.qtpl:207
 			qw422016.N().S(`
            `)
-//line app/vmalert/web.qtpl:208
+//line web.qtpl:208
 			typeK, ns := keys[i], targets[notifier.TargetType(keys[i])]
 			count := len(ns)
 
-//line app/vmalert/web.qtpl:210
+//line web.qtpl:210
 			qw422016.N().S(`
            <div class="group-heading data-bs-target="rules-`)
-//line app/vmalert/web.qtpl:211
+//line web.qtpl:211
 			qw422016.E().S(typeK)
-//line app/vmalert/web.qtpl:211
+//line web.qtpl:211
 			qw422016.N().S(`">
              <span class="anchor" id="notifiers-`)
-//line app/vmalert/web.qtpl:212
+//line web.qtpl:212
 			qw422016.E().S(typeK)
-//line app/vmalert/web.qtpl:212
+//line web.qtpl:212
 			qw422016.N().S(`"></span>
              <a href="#notifiers-`)
-//line app/vmalert/web.qtpl:213
+//line web.qtpl:213
 			qw422016.E().S(typeK)
-//line app/vmalert/web.qtpl:213
+//line web.qtpl:213
 			qw422016.N().S(`">`)
-//line app/vmalert/web.qtpl:213
+//line web.qtpl:213
 			qw422016.E().S(typeK)
-//line app/vmalert/web.qtpl:213
+//line web.qtpl:213
 			qw422016.N().S(` (`)
-//line app/vmalert/web.qtpl:213
+//line web.qtpl:213
 			qw422016.N().D(count)
-//line app/vmalert/web.qtpl:213
+//line web.qtpl:213
 			qw422016.N().S(`)</a>
          </div>
          <div class="collapse show" id="notifiers-`)
-//line app/vmalert/web.qtpl:215
+//line web.qtpl:215
 			qw422016.E().S(typeK)
-//line app/vmalert/web.qtpl:215
+//line web.qtpl:215
 			qw422016.N().S(`">
              <table class="table table-striped table-hover table-sm">
                  <thead>
@@ -746,113 +746,113 @@ func StreamListTargets(qw422016 *qt422016.Writer, targets map[notifier.TargetTyp
                  </thead>
                  <tbody>
                  `)
-//line app/vmalert/web.qtpl:224
+//line web.qtpl:224
 			for _, n := range ns {
-//line app/vmalert/web.qtpl:224
+//line web.qtpl:224
 				qw422016.N().S(`
                      <tr>
                          <td>
                               `)
-//line app/vmalert/web.qtpl:227
+//line web.qtpl:227
 				for _, l := range n.Labels {
-//line app/vmalert/web.qtpl:227
+//line web.qtpl:227
 					qw422016.N().S(`
                                       <span class="ms-1 badge bg-primary">`)
-//line app/vmalert/web.qtpl:228
+//line web.qtpl:228
 					qw422016.E().S(l.Name)
-//line app/vmalert/web.qtpl:228
+//line web.qtpl:228
 					qw422016.N().S(`=`)
-//line app/vmalert/web.qtpl:228
+//line web.qtpl:228
 					qw422016.E().S(l.Value)
-//line app/vmalert/web.qtpl:228
+//line web.qtpl:228
 					qw422016.N().S(`</span>
                               `)
-//line app/vmalert/web.qtpl:229
+//line web.qtpl:229
 				}
-//line app/vmalert/web.qtpl:229
+//line web.qtpl:229
 				qw422016.N().S(`
                           </td>
                          <td>`)
-//line app/vmalert/web.qtpl:231
+//line web.qtpl:231
 				qw422016.E().S(n.Notifier.Addr())
-//line app/vmalert/web.qtpl:231
+//line web.qtpl:231
 				qw422016.N().S(`</td>
                      </tr>
                  `)
-//line app/vmalert/web.qtpl:233
+//line web.qtpl:233
 			}
-//line app/vmalert/web.qtpl:233
+//line web.qtpl:233
 			qw422016.N().S(`
               </tbody>
              </table>
          </div>
      `)
-//line app/vmalert/web.qtpl:237
+//line web.qtpl:237
 		}
-//line app/vmalert/web.qtpl:237
+//line web.qtpl:237
 		qw422016.N().S(`
 
     `)
-//line app/vmalert/web.qtpl:239
+//line web.qtpl:239
 	} else {
-//line app/vmalert/web.qtpl:239
+//line web.qtpl:239
 		qw422016.N().S(`
         <div>
             <p>No items...</p>
         </div>
     `)
-//line app/vmalert/web.qtpl:243
+//line web.qtpl:243
 	}
-//line app/vmalert/web.qtpl:243
+//line web.qtpl:243
 	qw422016.N().S(`
 
     `)
-//line app/vmalert/web.qtpl:245
+//line web.qtpl:245
 	tpl.StreamFooter(qw422016)
-//line app/vmalert/web.qtpl:245
+//line web.qtpl:245
 	qw422016.N().S(`
 
 `)
-//line app/vmalert/web.qtpl:247
+//line web.qtpl:247
 }
 
-//line app/vmalert/web.qtpl:247
+//line web.qtpl:247
 func WriteListTargets(qq422016 qtio422016.Writer, targets map[notifier.TargetType][]notifier.Target) {
-//line app/vmalert/web.qtpl:247
+//line web.qtpl:247
 	qw422016 := qt422016.AcquireWriter(qq422016)
-//line app/vmalert/web.qtpl:247
+//line web.qtpl:247
 	StreamListTargets(qw422016, targets)
-//line app/vmalert/web.qtpl:247
+//line web.qtpl:247
 	qt422016.ReleaseWriter(qw422016)
-//line app/vmalert/web.qtpl:247
+//line web.qtpl:247
 }
 
-//line app/vmalert/web.qtpl:247
+//line web.qtpl:247
 func ListTargets(targets map[notifier.TargetType][]notifier.Target) string {
-//line app/vmalert/web.qtpl:247
+//line web.qtpl:247
 	qb422016 := qt422016.AcquireByteBuffer()
-//line app/vmalert/web.qtpl:247
+//line web.qtpl:247
 	WriteListTargets(qb422016, targets)
-//line app/vmalert/web.qtpl:247
+//line web.qtpl:247
 	qs422016 := string(qb422016.B)
-//line app/vmalert/web.qtpl:247
+//line web.qtpl:247
 	qt422016.ReleaseByteBuffer(qb422016)
-//line app/vmalert/web.qtpl:247
+//line web.qtpl:247
 	return qs422016
-//line app/vmalert/web.qtpl:247
+//line web.qtpl:247
 }
 
-//line app/vmalert/web.qtpl:249
+//line web.qtpl:249
 func StreamAlert(qw422016 *qt422016.Writer, pathPrefix string, alert *APIAlert) {
-//line app/vmalert/web.qtpl:249
+//line web.qtpl:249
 	qw422016.N().S(`
     `)
-//line app/vmalert/web.qtpl:250
+//line web.qtpl:250
 	tpl.StreamHeader(qw422016, "", navItems)
-//line app/vmalert/web.qtpl:250
+//line web.qtpl:250
 	qw422016.N().S(`
     `)
-//line app/vmalert/web.qtpl:252
+//line web.qtpl:252
 	var labelKeys []string
 	for k := range alert.Labels {
 		labelKeys = append(labelKeys, k)
@@ -865,28 +865,28 @@ func StreamAlert(qw422016 *qt422016.Writer, pathPrefix string, alert *APIAlert)
 	}
 	sort.Strings(annotationKeys)
 
-//line app/vmalert/web.qtpl:263
+//line web.qtpl:263
 	qw422016.N().S(`
     <div class="display-6 pb-3 mb-3">`)
-//line app/vmalert/web.qtpl:264
+//line web.qtpl:264
 	qw422016.E().S(alert.Name)
-//line app/vmalert/web.qtpl:264
+//line web.qtpl:264
 	qw422016.N().S(`<span class="ms-2 badge `)
-//line app/vmalert/web.qtpl:264
+//line web.qtpl:264
 	if alert.State == "firing" {
-//line app/vmalert/web.qtpl:264
+//line web.qtpl:264
 		qw422016.N().S(`bg-danger`)
-//line app/vmalert/web.qtpl:264
+//line web.qtpl:264
 	} else {
-//line app/vmalert/web.qtpl:264
+//line web.qtpl:264
 		qw422016.N().S(` bg-warning text-dark`)
-//line app/vmalert/web.qtpl:264
+//line web.qtpl:264
 	}
-//line app/vmalert/web.qtpl:264
+//line web.qtpl:264
 	qw422016.N().S(`">`)
-//line app/vmalert/web.qtpl:264
+//line web.qtpl:264
 	qw422016.E().S(alert.State)
-//line app/vmalert/web.qtpl:264
+//line web.qtpl:264
 	qw422016.N().S(`</span></div>
     <div class="container border-bottom p-2">
       <div class="row">
@@ -895,9 +895,9 @@ func StreamAlert(qw422016 *qt422016.Writer, pathPrefix string, alert *APIAlert)
         </div>
         <div class="col">
           `)
-//line app/vmalert/web.qtpl:271
+//line web.qtpl:271
 	qw422016.E().S(alert.ActiveAt.Format("2006-01-02T15:04:05Z07:00"))
-//line app/vmalert/web.qtpl:271
+//line web.qtpl:271
 	qw422016.N().S(`
         </div>
       </div>
@@ -909,9 +909,9 @@ func StreamAlert(qw422016 *qt422016.Writer, pathPrefix string, alert *APIAlert)
         </div>
         <div class="col">
           <code><pre>`)
-//line app/vmalert/web.qtpl:281
+//line web.qtpl:281
 	qw422016.E().S(alert.Expression)
-//line app/vmalert/web.qtpl:281
+//line web.qtpl:281
 	qw422016.N().S(`</pre></code>
         </div>
       </div>
@@ -923,23 +923,23 @@ func StreamAlert(qw422016 *qt422016.Writer, pathPrefix string, alert *APIAlert)
         </div>
         <div class="col">
            `)
-//line app/vmalert/web.qtpl:291
+//line web.qtpl:291
 	for _, k := range labelKeys {
-//line app/vmalert/web.qtpl:291
+//line web.qtpl:291
 		qw422016.N().S(`
                 <span class="m-1 badge bg-primary">`)
-//line app/vmalert/web.qtpl:292
+//line web.qtpl:292
 		qw422016.E().S(k)
-//line app/vmalert/web.qtpl:292
+//line web.qtpl:292
 		qw422016.N().S(`=`)
-//line app/vmalert/web.qtpl:292
+//line web.qtpl:292
 		qw422016.E().S(alert.Labels[k])
-//line app/vmalert/web.qtpl:292
+//line web.qtpl:292
 		qw422016.N().S(`</span>
           `)
-//line app/vmalert/web.qtpl:293
+//line web.qtpl:293
 	}
-//line app/vmalert/web.qtpl:293
+//line web.qtpl:293
 	qw422016.N().S(`
         </div>
       </div>
@@ -951,24 +951,24 @@ func StreamAlert(qw422016 *qt422016.Writer, pathPrefix string, alert *APIAlert)
         </div>
         <div class="col">
            `)
-//line app/vmalert/web.qtpl:303
+//line web.qtpl:303
 	for _, k := range annotationKeys {
-//line app/vmalert/web.qtpl:303
+//line web.qtpl:303
 		qw422016.N().S(`
                 <b>`)
-//line app/vmalert/web.qtpl:304
+//line web.qtpl:304
 		qw422016.E().S(k)
-//line app/vmalert/web.qtpl:304
+//line web.qtpl:304
 		qw422016.N().S(`:</b><br>
                 <p>`)
-//line app/vmalert/web.qtpl:305
+//line web.qtpl:305
 		qw422016.E().S(alert.Annotations[k])
-//line app/vmalert/web.qtpl:305
+//line web.qtpl:305
 		qw422016.N().S(`</p>
           `)
-//line app/vmalert/web.qtpl:306
+//line web.qtpl:306
 	}
-//line app/vmalert/web.qtpl:306
+//line web.qtpl:306
 	qw422016.N().S(`
         </div>
       </div>
@@ -980,17 +980,17 @@ func StreamAlert(qw422016 *qt422016.Writer, pathPrefix string, alert *APIAlert)
         </div>
         <div class="col">
            <a target="_blank" href="`)
-//line app/vmalert/web.qtpl:316
+//line web.qtpl:316
 	qw422016.E().S(path.Join(pathPrefix, "groups"))
-//line app/vmalert/web.qtpl:316
+//line web.qtpl:316
 	qw422016.N().S(`#group-`)
-//line app/vmalert/web.qtpl:316
+//line web.qtpl:316
 	qw422016.E().S(alert.GroupID)
-//line app/vmalert/web.qtpl:316
+//line web.qtpl:316
 	qw422016.N().S(`">`)
-//line app/vmalert/web.qtpl:316
+//line web.qtpl:316
 	qw422016.E().S(alert.GroupID)
-//line app/vmalert/web.qtpl:316
+//line web.qtpl:316
 	qw422016.N().S(`</a>
         </div>
       </div>
@@ -1002,132 +1002,132 @@ func StreamAlert(qw422016 *qt422016.Writer, pathPrefix string, alert *APIAlert)
         </div>
         <div class="col">
            <a target="_blank" href="`)
-//line app/vmalert/web.qtpl:326
+//line web.qtpl:326
 	qw422016.E().S(alert.SourceLink)
-//line app/vmalert/web.qtpl:326
+//line web.qtpl:326
 	qw422016.N().S(`">Link</a>
         </div>
       </div>
     </div>
     `)
-//line app/vmalert/web.qtpl:330
+//line web.qtpl:330
 	tpl.StreamFooter(qw422016)
-//line app/vmalert/web.qtpl:330
+//line web.qtpl:330
 	qw422016.N().S(`
 
 `)
-//line app/vmalert/web.qtpl:332
+//line web.qtpl:332
 }
 
-//line app/vmalert/web.qtpl:332
+//line web.qtpl:332
 func WriteAlert(qq422016 qtio422016.Writer, pathPrefix string, alert *APIAlert) {
-//line app/vmalert/web.qtpl:332
+//line web.qtpl:332
 	qw422016 := qt422016.AcquireWriter(qq422016)
-//line app/vmalert/web.qtpl:332
+//line web.qtpl:332
 	StreamAlert(qw422016, pathPrefix, alert)
-//line app/vmalert/web.qtpl:332
+//line web.qtpl:332
 	qt422016.ReleaseWriter(qw422016)
-//line app/vmalert/web.qtpl:332
+//line web.qtpl:332
 }
 
-//line app/vmalert/web.qtpl:332
+//line web.qtpl:332
 func Alert(pathPrefix string, alert *APIAlert) string {
-//line app/vmalert/web.qtpl:332
+//line web.qtpl:332
 	qb422016 := qt422016.AcquireByteBuffer()
-//line app/vmalert/web.qtpl:332
+//line web.qtpl:332
 	WriteAlert(qb422016, pathPrefix, alert)
-//line app/vmalert/web.qtpl:332
+//line web.qtpl:332
 	qs422016 := string(qb422016.B)
-//line app/vmalert/web.qtpl:332
+//line web.qtpl:332
 	qt422016.ReleaseByteBuffer(qb422016)
-//line app/vmalert/web.qtpl:332
+//line web.qtpl:332
 	return qs422016
-//line app/vmalert/web.qtpl:332
+//line web.qtpl:332
 }
 
-//line app/vmalert/web.qtpl:334
+//line web.qtpl:334
 func streambadgeState(qw422016 *qt422016.Writer, state string) {
-//line app/vmalert/web.qtpl:334
+//line web.qtpl:334
 	qw422016.N().S(`
 `)
-//line app/vmalert/web.qtpl:336
+//line web.qtpl:336
 	badgeClass := "bg-warning text-dark"
 	if state == "firing" {
 		badgeClass = "bg-danger"
 	}
 
-//line app/vmalert/web.qtpl:340
+//line web.qtpl:340
 	qw422016.N().S(`
 <span class="badge `)
-//line app/vmalert/web.qtpl:341
+//line web.qtpl:341
 	qw422016.E().S(badgeClass)
-//line app/vmalert/web.qtpl:341
+//line web.qtpl:341
 	qw422016.N().S(`">`)
-//line app/vmalert/web.qtpl:341
+//line web.qtpl:341
 	qw422016.E().S(state)
-//line app/vmalert/web.qtpl:341
+//line web.qtpl:341
 	qw422016.N().S(`</span>
 `)
-//line app/vmalert/web.qtpl:342
+//line web.qtpl:342
 }
 
-//line app/vmalert/web.qtpl:342
+//line web.qtpl:342
 func writebadgeState(qq422016 qtio422016.Writer, state string) {
-//line app/vmalert/web.qtpl:342
+//line web.qtpl:342
 	qw422016 := qt422016.AcquireWriter(qq422016)
-//line app/vmalert/web.qtpl:342
+//line web.qtpl:342
 	streambadgeState(qw422016, state)
-//line app/vmalert/web.qtpl:342
+//line web.qtpl:342
 	qt422016.ReleaseWriter(qw422016)
-//line app/vmalert/web.qtpl:342
+//line web.qtpl:342
 }
 
-//line app/vmalert/web.qtpl:342
+//line web.qtpl:342
 func badgeState(state string) string {
-//line app/vmalert/web.qtpl:342
+//line web.qtpl:342
 	qb422016 := qt422016.AcquireByteBuffer()
-//line app/vmalert/web.qtpl:342
+//line web.qtpl:342
 	writebadgeState(qb422016, state)
-//line app/vmalert/web.qtpl:342
+//line web.qtpl:342
 	qs422016 := string(qb422016.B)
-//line app/vmalert/web.qtpl:342
+//line web.qtpl:342
 	qt422016.ReleaseByteBuffer(qb422016)
-//line app/vmalert/web.qtpl:342
+//line web.qtpl:342
 	return qs422016
-//line app/vmalert/web.qtpl:342
+//line web.qtpl:342
 }
 
-//line app/vmalert/web.qtpl:344
+//line web.qtpl:344
 func streambadgeRestored(qw422016 *qt422016.Writer) {
-//line app/vmalert/web.qtpl:344
+//line web.qtpl:344
 	qw422016.N().S(`
 <span class="badge bg-warning text-dark" title="Alert state was restored after the service restart from remote storage">restored</span>
 `)
-//line app/vmalert/web.qtpl:346
+//line web.qtpl:346
 }
 
-//line app/vmalert/web.qtpl:346
+//line web.qtpl:346
 func writebadgeRestored(qq422016 qtio422016.Writer) {
-//line app/vmalert/web.qtpl:346
+//line web.qtpl:346
 	qw422016 := qt422016.AcquireWriter(qq422016)
-//line app/vmalert/web.qtpl:346
+//line web.qtpl:346
 	streambadgeRestored(qw422016)
-//line app/vmalert/web.qtpl:346
+//line web.qtpl:346
 	qt422016.ReleaseWriter(qw422016)
-//line app/vmalert/web.qtpl:346
+//line web.qtpl:346
 }
 
-//line app/vmalert/web.qtpl:346
+//line web.qtpl:346
 func badgeRestored() string {
-//line app/vmalert/web.qtpl:346
+//line web.qtpl:346
 	qb422016 := qt422016.AcquireByteBuffer()
-//line app/vmalert/web.qtpl:346
+//line web.qtpl:346
 	writebadgeRestored(qb422016)
-//line app/vmalert/web.qtpl:346
+//line web.qtpl:346
 	qs422016 := string(qb422016.B)
-//line app/vmalert/web.qtpl:346
+//line web.qtpl:346
 	qt422016.ReleaseByteBuffer(qb422016)
-//line app/vmalert/web.qtpl:346
+//line web.qtpl:346
 	return qs422016
-//line app/vmalert/web.qtpl:346
+//line web.qtpl:346
 }
diff --git a/app/vmctl/barpool/pool.go b/app/vmctl/barpool/pool.go
new file mode 100644
index 000000000..4f095d8ac
--- /dev/null
+++ b/app/vmctl/barpool/pool.go
@@ -0,0 +1,26 @@
+// Package barpool provides access to the global
+// pool of progress bars, so they could be rendered
+// altogether.
+package barpool
+
+import "github.com/cheggaaa/pb/v3"
+
+var pool = pb.NewPool()
+
+// Add adds bar to the global pool
+func Add(bar *pb.ProgressBar) { pool.Add(bar) }
+
+// Start starts the global pool
+// Must be called after all progress bars were added
+func Start() error { return pool.Start() }
+
+// Stop stops the global pool
+func Stop() { _ = pool.Stop() }
+
+// AddWithTemplate adds bar with the given template
+// to the global pool
+func AddWithTemplate(format string, total int) *pb.ProgressBar {
+	bar := pb.ProgressBarTemplate(format).New(total)
+	Add(bar)
+	return bar
+}
diff --git a/app/vmctl/flags.go b/app/vmctl/flags.go
index 97765314a..cf14d0d9d 100644
--- a/app/vmctl/flags.go
+++ b/app/vmctl/flags.go
@@ -36,6 +36,7 @@ const (
 	vmBatchSize          = "vm-batch-size"
 	vmSignificantFigures = "vm-significant-figures"
 	vmRoundDigits        = "vm-round-digits"
+	vmDisableProgressBar = "vm-disable-progress-bar"
 
 	// also used in vm-native
 	vmExtraLabel = "vm-extra-label"
@@ -109,6 +110,10 @@ var (
 			Usage: "Optional data transfer rate limit in bytes per second.\n" +
 				"By default the rate limit is disabled. It can be useful for limiting load on configured via '--vmAddr' destination.",
 		},
+		&cli.BoolFlag{
+			Name:  vmDisableProgressBar,
+			Usage: "Whether to disable progress bar per each worker during the import.",
+		},
 	}
 )
 
diff --git a/app/vmctl/influx.go b/app/vmctl/influx.go
index 1118ba606..b795d12e9 100644
--- a/app/vmctl/influx.go
+++ b/app/vmctl/influx.go
@@ -6,9 +6,9 @@ import (
 	"log"
 	"sync"
 
+	"github.com/VictoriaMetrics/VictoriaMetrics/app/vmctl/barpool"
 	"github.com/VictoriaMetrics/VictoriaMetrics/app/vmctl/influx"
 	"github.com/VictoriaMetrics/VictoriaMetrics/app/vmctl/vm"
-	"github.com/cheggaaa/pb/v3"
 )
 
 type influxProcessor struct {
@@ -44,7 +44,11 @@ func (ip *influxProcessor) run(silent, verbose bool) error {
 		return nil
 	}
 
-	bar := pb.StartNew(len(series))
+	bar := barpool.AddWithTemplate(fmt.Sprintf(barTpl, "Processing series"), len(series))
+	if err := barpool.Start(); err != nil {
+		return err
+	}
+
 	seriesCh := make(chan *influx.Series)
 	errCh := make(chan error)
 	ip.im.ResetStats()
@@ -84,7 +88,7 @@ func (ip *influxProcessor) run(silent, verbose bool) error {
 			return fmt.Errorf("import process failed: %s", wrapErr(vmErr, verbose))
 		}
 	}
-	bar.Finish()
+	barpool.Stop()
 	log.Println("Import finished!")
 	log.Print(ip.im.Stats())
 	return nil
diff --git a/app/vmctl/main.go b/app/vmctl/main.go
index abf5df6af..9b021371d 100644
--- a/app/vmctl/main.go
+++ b/app/vmctl/main.go
@@ -55,6 +55,9 @@ func main() {
 					}
 
 					vmCfg := initConfigVM(c)
+					// disable progress bars since openTSDB implementation
+					// does not use progress bar pool
+					vmCfg.DisableProgressBar = true
 					importer, err := vm.NewImporter(vmCfg)
 					if err != nil {
 						return fmt.Errorf("failed to create VM importer: %s", err)
@@ -233,5 +236,6 @@ func initConfigVM(c *cli.Context) vm.Config {
 		RoundDigits:        c.Int(vmRoundDigits),
 		ExtraLabels:        c.StringSlice(vmExtraLabel),
 		RateLimit:          c.Int64(vmRateLimit),
+		DisableProgressBar: c.Bool(vmDisableProgressBar),
 	}
 }
diff --git a/app/vmctl/prometheus.go b/app/vmctl/prometheus.go
index c417204e5..325e53eda 100644
--- a/app/vmctl/prometheus.go
+++ b/app/vmctl/prometheus.go
@@ -5,9 +5,9 @@ import (
 	"log"
 	"sync"
 
+	"github.com/VictoriaMetrics/VictoriaMetrics/app/vmctl/barpool"
 	"github.com/VictoriaMetrics/VictoriaMetrics/app/vmctl/prometheus"
 	"github.com/VictoriaMetrics/VictoriaMetrics/app/vmctl/vm"
-	"github.com/cheggaaa/pb/v3"
 	"github.com/prometheus/prometheus/tsdb"
 )
 
@@ -38,7 +38,12 @@ func (pp *prometheusProcessor) run(silent, verbose bool) error {
 		return nil
 	}
 
-	bar := pb.StartNew(len(blocks))
+	bar := barpool.AddWithTemplate(fmt.Sprintf(barTpl, "Processing blocks"), len(blocks))
+
+	if err := barpool.Start(); err != nil {
+		return err
+	}
+
 	blockReadersCh := make(chan tsdb.BlockReader)
 	errCh := make(chan error, pp.cc)
 	pp.im.ResetStats()
@@ -81,7 +86,7 @@ func (pp *prometheusProcessor) run(silent, verbose bool) error {
 			return fmt.Errorf("import process failed: %s", wrapErr(vmErr, verbose))
 		}
 	}
-	bar.Finish()
+	barpool.Stop()
 	log.Println("Import finished!")
 	log.Print(pp.im.Stats())
 	return nil
diff --git a/app/vmctl/utils.go b/app/vmctl/utils.go
index 522169227..de1fde0c2 100644
--- a/app/vmctl/utils.go
+++ b/app/vmctl/utils.go
@@ -9,6 +9,8 @@ import (
 	"github.com/VictoriaMetrics/VictoriaMetrics/app/vmctl/vm"
 )
 
+const barTpl = `{{ blue "%s:" }} {{ counters . }} {{ bar . "[" "█" (cycle . "█") "▒" "]" }} {{ percent . }}`
+
 func prompt(question string) bool {
 	reader := bufio.NewReader(os.Stdin)
 	fmt.Print(question, " [Y/n] ")
diff --git a/app/vmctl/vm/vm.go b/app/vmctl/vm/vm.go
index d37b040ff..3df1bed97 100644
--- a/app/vmctl/vm/vm.go
+++ b/app/vmctl/vm/vm.go
@@ -13,6 +13,9 @@ import (
 	"sync"
 	"time"
 
+	"github.com/cheggaaa/pb/v3"
+
+	"github.com/VictoriaMetrics/VictoriaMetrics/app/vmctl/barpool"
 	"github.com/VictoriaMetrics/VictoriaMetrics/app/vmctl/limiter"
 	"github.com/VictoriaMetrics/VictoriaMetrics/lib/decimal"
 )
@@ -51,6 +54,8 @@ type Config struct {
 	// RateLimit defines a data transfer speed in bytes per second.
 	// Is applied to each worker (see Concurrency) independently.
 	RateLimit int64
+	// Whether to disable progress bar per VM worker
+	DisableProgressBar bool
 }
 
 // Importer performs insertion of timeseries
@@ -144,15 +149,22 @@ func NewImporter(cfg Config) (*Importer, error) {
 
 	im.wg.Add(int(cfg.Concurrency))
 	for i := 0; i < int(cfg.Concurrency); i++ {
-		go func() {
+		var bar *pb.ProgressBar
+		if !cfg.DisableProgressBar {
+			pbPrefix := fmt.Sprintf(`{{ green "VM worker %d:" }}`, i)
+			bar = barpool.AddWithTemplate(pbPrefix+pbTpl, 0)
+		}
+		go func(bar *pb.ProgressBar) {
 			defer im.wg.Done()
-			im.startWorker(cfg.BatchSize, cfg.SignificantFigures, cfg.RoundDigits)
-		}()
+			im.startWorker(bar, cfg.BatchSize, cfg.SignificantFigures, cfg.RoundDigits)
+		}(bar)
 	}
 	im.ResetStats()
 	return im, nil
 }
 
+const pbTpl = `{{ (cycle . "←" "↖" "↑" "↗" "→" "↘" "↓" "↙" ) }} {{speed . "%s samples/s"}}`
+
 // ImportError is type of error generated
 // in case of unsuccessful import request
 type ImportError struct {
@@ -182,7 +194,7 @@ func (im *Importer) Close() {
 	})
 }
 
-func (im *Importer) startWorker(batchSize, significantFigures, roundDigits int) {
+func (im *Importer) startWorker(bar *pb.ProgressBar, batchSize, significantFigures, roundDigits int) {
 	var batch []*TimeSeries
 	var dataPoints int
 	var waitForBatch time.Time
@@ -217,6 +229,11 @@ func (im *Importer) startWorker(batchSize, significantFigures, roundDigits int)
 
 			batch = append(batch, ts)
 			dataPoints += len(ts.Values)
+
+			if bar != nil {
+				bar.Add(len(ts.Values))
+			}
+
 			if dataPoints < batchSize {
 				continue
 			}
@@ -232,8 +249,8 @@ func (im *Importer) startWorker(batchSize, significantFigures, roundDigits int)
 				// make a new batch, since old one was referenced as err
 				batch = make([]*TimeSeries, len(batch))
 			}
-			batch = batch[:0]
 			dataPoints = 0
+			batch = batch[:0]
 			waitForBatch = time.Now()
 		}
 	}
diff --git a/app/vmctl/vm_native.go b/app/vmctl/vm_native.go
index 60cec652f..b04e8bd7a 100644
--- a/app/vmctl/vm_native.go
+++ b/app/vmctl/vm_native.go
@@ -7,8 +7,7 @@ import (
 	"log"
 	"net/http"
 
-	"github.com/cheggaaa/pb/v3"
-
+	"github.com/VictoriaMetrics/VictoriaMetrics/app/vmctl/barpool"
 	"github.com/VictoriaMetrics/VictoriaMetrics/app/vmctl/limiter"
 	"github.com/VictoriaMetrics/VictoriaMetrics/app/vmctl/vm"
 )
@@ -49,7 +48,7 @@ const (
 	nativeExportAddr = "api/v1/export/native"
 	nativeImportAddr = "api/v1/import/native"
 
-	barTpl = `Total: {{counters . }} {{ cycle . "↖" "↗" "↘" "↙" }} Speed: {{speed . }} {{string . "suffix"}}`
+	nativeBarTpl = `Total: {{counters . }} {{ cycle . "↖" "↗" "↘" "↙" }} Speed: {{speed . }} {{string . "suffix"}}`
 )
 
 func (p *vmNativeProcessor) run() error {
@@ -84,8 +83,12 @@ func (p *vmNativeProcessor) run() error {
 	}()
 
 	fmt.Printf("Initing import process to %q:\n", p.dst.addr)
-	bar := pb.ProgressBarTemplate(barTpl).Start64(0)
+	bar := barpool.AddWithTemplate(nativeBarTpl, 0)
 	barReader := bar.NewProxyReader(exportReader)
+	if err := barpool.Start(); err != nil {
+		log.Printf("error start process bars pool: %s", err)
+		return err
+	}
 
 	w := io.Writer(pw)
 	if p.rateLimit > 0 {
@@ -101,7 +104,7 @@ func (p *vmNativeProcessor) run() error {
 	}
 	<-sync
 
-	bar.Finish()
+	barpool.Stop()
 	return nil
 }
 
diff --git a/go.mod b/go.mod
index 83c4e62de..69aad20d3 100644
--- a/go.mod
+++ b/go.mod
@@ -13,7 +13,7 @@ require (
 	github.com/VictoriaMetrics/metricsql v0.43.0
 	github.com/aws/aws-sdk-go v1.44.0
 	github.com/cespare/xxhash/v2 v2.1.2
-	github.com/cheggaaa/pb/v3 v3.0.8
+	github.com/cheggaaa/pb/v3 v3.0.9-0.20211222075416-90c02fa07ea4
 	github.com/golang/snappy v0.0.4
 	github.com/influxdata/influxdb v1.9.6
 	github.com/klauspost/compress v1.15.1
diff --git a/go.sum b/go.sum
index aba09c9d7..5077e69e2 100644
--- a/go.sum
+++ b/go.sum
@@ -198,8 +198,8 @@ github.com/cespare/xxhash/v2 v2.1.0/go.mod h1:dgIUBU3pDso/gPgZ1osOZ0iQf77oPR28Tj
 github.com/cespare/xxhash/v2 v2.1.1/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
 github.com/cespare/xxhash/v2 v2.1.2 h1:YRXhKfTDauu4ajMg1TPgFO5jnlC2HCbmLXMcTG5cbYE=
 github.com/cespare/xxhash/v2 v2.1.2/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
-github.com/cheggaaa/pb/v3 v3.0.8 h1:bC8oemdChbke2FHIIGy9mn4DPJ2caZYQnfbRqwmdCoA=
-github.com/cheggaaa/pb/v3 v3.0.8/go.mod h1:UICbiLec/XO6Hw6k+BHEtHeQFzzBH4i2/qk/ow1EJTA=
+github.com/cheggaaa/pb/v3 v3.0.9-0.20211222075416-90c02fa07ea4 h1:sbHAiGddrdLsd3i9/RYsm0OKOEh+UDFOONxai8YMMcw=
+github.com/cheggaaa/pb/v3 v3.0.9-0.20211222075416-90c02fa07ea4/go.mod h1:UICbiLec/XO6Hw6k+BHEtHeQFzzBH4i2/qk/ow1EJTA=
 github.com/chzyer/logex v1.1.10/go.mod h1:+Ywpsq7O8HXn0nuIou7OrIPyXbp3wmkHB+jjWRnGsAI=
 github.com/chzyer/readline v0.0.0-20180603132655-2972be24d48e/go.mod h1:nSuG5e5PlCu98SY8svDHJxuZscDgtXS6KTTbou5AhLI=
 github.com/chzyer/test v0.0.0-20180213035817-a1ea475d72b1/go.mod h1:Q3SI9o4m/ZMnBNeIyt5eFwwo7qiLfzFZmjNmxjkiQlU=
diff --git a/vendor/github.com/cheggaaa/pb/v3/pb.go b/vendor/github.com/cheggaaa/pb/v3/pb.go
index 963f7000b..76440e172 100644
--- a/vendor/github.com/cheggaaa/pb/v3/pb.go
+++ b/vendor/github.com/cheggaaa/pb/v3/pb.go
@@ -408,6 +408,13 @@ func (pb *ProgressBar) IsStarted() bool {
 	return pb.finish != nil
 }
 
+// IsFinished indicates progress bar is finished
+func (pb *ProgressBar) IsFinished() bool {
+	pb.mu.RLock()
+	defer pb.mu.RUnlock()
+	return pb.finished
+}
+
 // SetTemplateString sets ProgressBar tempate string and parse it
 func (pb *ProgressBar) SetTemplateString(tmpl string) *ProgressBar {
 	pb.mu.Lock()
diff --git a/vendor/github.com/cheggaaa/pb/v3/pool.go b/vendor/github.com/cheggaaa/pb/v3/pool.go
new file mode 100644
index 000000000..69cc825b6
--- /dev/null
+++ b/vendor/github.com/cheggaaa/pb/v3/pool.go
@@ -0,0 +1,105 @@
+// +build linux darwin freebsd netbsd openbsd solaris dragonfly windows plan9 aix
+
+package pb
+
+import (
+	"io"
+	"sync"
+	"time"
+
+	"github.com/cheggaaa/pb/v3/termutil"
+)
+
+// Create and start new pool with given bars
+// You need call pool.Stop() after work
+func StartPool(pbs ...*ProgressBar) (pool *Pool, err error) {
+	pool = new(Pool)
+	if err = pool.Start(); err != nil {
+		return
+	}
+	pool.Add(pbs...)
+	return
+}
+
+// NewPool initialises a pool with progress bars, but
+// doesn't start it. You need to call Start manually
+func NewPool(pbs ...*ProgressBar) (pool *Pool) {
+	pool = new(Pool)
+	pool.Add(pbs...)
+	return
+}
+
+type Pool struct {
+	Output        io.Writer
+	RefreshRate   time.Duration
+	bars          []*ProgressBar
+	lastBarsCount int
+	shutdownCh    chan struct{}
+	workerCh      chan struct{}
+	m             sync.Mutex
+	finishOnce    sync.Once
+}
+
+// Add progress bars.
+func (p *Pool) Add(pbs ...*ProgressBar) {
+	p.m.Lock()
+	defer p.m.Unlock()
+	for _, bar := range pbs {
+		bar.Set(Static, true)
+		bar.Start()
+		p.bars = append(p.bars, bar)
+	}
+}
+
+func (p *Pool) Start() (err error) {
+	p.RefreshRate = defaultRefreshRate
+	p.shutdownCh, err = termutil.RawModeOn()
+	if err != nil {
+		return
+	}
+	p.workerCh = make(chan struct{})
+	go p.writer()
+	return
+}
+
+func (p *Pool) writer() {
+	var first = true
+	defer func() {
+		if first == false {
+			p.print(false)
+		} else {
+			p.print(true)
+			p.print(false)
+		}
+		close(p.workerCh)
+	}()
+
+	for {
+		select {
+		case <-time.After(p.RefreshRate):
+			if p.print(first) {
+				p.print(false)
+				return
+			}
+			first = false
+		case <-p.shutdownCh:
+			return
+		}
+	}
+}
+
+// Restore terminal state and close pool
+func (p *Pool) Stop() error {
+	p.finishOnce.Do(func() {
+		if p.shutdownCh != nil {
+			close(p.shutdownCh)
+		}
+	})
+
+	// Wait for the worker to complete
+	select {
+	case <-p.workerCh:
+	}
+
+	return termutil.RawModeOff()
+}
diff --git a/vendor/github.com/cheggaaa/pb/v3/pool_win.go b/vendor/github.com/cheggaaa/pb/v3/pool_win.go
new file mode 100644
index 000000000..35a61474a
--- /dev/null
+++ b/vendor/github.com/cheggaaa/pb/v3/pool_win.go
@@ -0,0 +1,46 @@
+// +build windows
+
+package pb
+
+import (
+	"fmt"
+	"log"
+
+	"github.com/cheggaaa/pb/v3/termutil"
+)
+
+func (p *Pool) print(first bool) bool {
+	p.m.Lock()
+	defer p.m.Unlock()
+	var out string
+	if !first {
+		coords, err := termutil.GetCursorPos()
+		if err != nil {
+			log.Panic(err)
+		}
+		coords.Y -= int16(p.lastBarsCount)
+		if coords.Y < 0 {
+			coords.Y = 0
+		}
+		coords.X = 0
+
+		err =  termutil.SetCursorPos(coords)
+		if err != nil {
+			log.Panic(err)
+		}
+	}
+	isFinished := true
+	for _, bar := range p.bars {
+		if !bar.IsFinished() {
+			isFinished = false
+		}
+		out += fmt.Sprintf("\r%s\n", bar.String())
+	}
+	if p.Output != nil {
+		fmt.Fprint(p.Output, out)
+	} else {
+		fmt.Print(out)
+	}
+	p.lastBarsCount = len(p.bars)
+	return isFinished
+}
diff --git a/vendor/github.com/cheggaaa/pb/v3/pool_x.go b/vendor/github.com/cheggaaa/pb/v3/pool_x.go
new file mode 100644
index 000000000..435030155
--- /dev/null
+++ b/vendor/github.com/cheggaaa/pb/v3/pool_x.go
@@ -0,0 +1,43 @@
+// +build linux darwin freebsd netbsd openbsd solaris dragonfly plan9 aix
+
+package pb
+
+import (
+	"fmt"
+	"os"
+
+	"github.com/cheggaaa/pb/v3/termutil"
+)
+
+func (p *Pool) print(first bool) bool {
+	p.m.Lock()
+	defer p.m.Unlock()
+	var out string
+	if !first {
+		out = fmt.Sprintf("\033[%dA", p.lastBarsCount)
+	}
+	isFinished := true
+	bars := p.bars
+	rows, cols, err := termutil.TerminalSize()
+	if err != nil {
+		cols = defaultBarWidth
+	}
+	if rows > 0 && len(bars) > rows {
+		// we need to hide bars that overflow terminal height
+		bars = bars[len(bars)-rows:]
+	}
+	for _, bar := range bars {
+		if !bar.IsFinished() {
+			isFinished = false
+		}
+		bar.SetWidth(cols)
+		out += fmt.Sprintf("\r%s\n", bar.String())
+	}
+	if p.Output != nil {
+		fmt.Fprint(p.Output, out)
+	} else {
+		fmt.Fprint(os.Stderr, out)
+	}
+	p.lastBarsCount = len(bars)
+	return isFinished
+}
diff --git a/vendor/github.com/cheggaaa/pb/v3/termutil/term.go b/vendor/github.com/cheggaaa/pb/v3/termutil/term.go
index 02b52797e..c838d4f98 100644
--- a/vendor/github.com/cheggaaa/pb/v3/termutil/term.go
+++ b/vendor/github.com/cheggaaa/pb/v3/termutil/term.go
@@ -10,6 +10,16 @@ import (
 var echoLocked bool
 var echoLockMutex sync.Mutex
 var errLocked = errors.New("terminal locked")
+var autoTerminate = true
+
+// AutoTerminate enables or disables automatic terminate signal catching.
+// It's needed to restore the terminal state after the pool was used.
+// By default, it's enabled.
+func AutoTerminate(enable bool) {
+	echoLockMutex.Lock()
+	defer echoLockMutex.Unlock()
+	autoTerminate = enable
+}
 
 // RawModeOn switches terminal to raw mode
 func RawModeOn() (quit chan struct{}, err error) {
@@ -45,8 +55,10 @@ func RawModeOff() (err error) {
 // listen exit signals and restore terminal state
 func catchTerminate(quit chan struct{}) {
 	sig := make(chan os.Signal, 1)
-	signal.Notify(sig, unlockSignals...)
-	defer signal.Stop(sig)
+	if autoTerminate {
+		signal.Notify(sig, unlockSignals...)
+		defer signal.Stop(sig)
+	}
 	select {
 	case <-quit:
 		RawModeOff()
diff --git a/vendor/github.com/cheggaaa/pb/v3/termutil/term_win.go b/vendor/github.com/cheggaaa/pb/v3/termutil/term_win.go
index c867d2722..3150dfd31 100644
--- a/vendor/github.com/cheggaaa/pb/v3/termutil/term_win.go
+++ b/vendor/github.com/cheggaaa/pb/v3/termutil/term_win.go
@@ -111,7 +111,7 @@ func termWidthTPut() (width int, err error) {
 	return strconv.Atoi(string(res))
 }
 
-func getCursorPos() (pos coordinates, err error) {
+func GetCursorPos() (pos coordinates, err error) {
 	var info consoleScreenBufferInfo
 	_, _, e := syscall.Syscall(procGetConsoleScreenBufferInfo.Addr(), 2, uintptr(syscall.Stdout), uintptr(unsafe.Pointer(&info)), 0)
 	if e != 0 {
@@ -120,7 +120,7 @@ func getCursorPos() (pos coordinates, err error) {
 	return info.dwCursorPosition, nil
 }
 
-func setCursorPos(pos coordinates) error {
+func SetCursorPos(pos coordinates) error {
 	_, _, e := syscall.Syscall(setConsoleCursorPosition.Addr(), 2, uintptr(syscall.Stdout), uintptr(uint32(uint16(pos.Y))<<16|uint32(uint16(pos.X))), 0)
 	if e != 0 {
 		return error(e)
diff --git a/vendor/github.com/cheggaaa/pb/v3/termutil/term_x.go b/vendor/github.com/cheggaaa/pb/v3/termutil/term_x.go
index 693775549..1674d3e5e 100644
--- a/vendor/github.com/cheggaaa/pb/v3/termutil/term_x.go
+++ b/vendor/github.com/cheggaaa/pb/v3/termutil/term_x.go
@@ -35,6 +35,12 @@ func init() {
 
 // TerminalWidth returns width of the terminal.
 func TerminalWidth() (int, error) {
+	_, c, err := TerminalSize()
+	return c, err
+}
+
+// TerminalSize returns size of the terminal.
+func TerminalSize() (rows, cols int, err error) {
 	w := new(window)
 	res, _, err := syscall.Syscall(sysIoctl,
 		tty.Fd(),
@@ -42,9 +48,9 @@ func TerminalWidth() (int, error) {
 		uintptr(unsafe.Pointer(w)),
 	)
 	if int(res) == -1 {
-		return 0, err
+		return 0, 0, err
 	}
-	return int(w.Col), nil
+	return int(w.Row), int(w.Col), nil
 }
 
 var oldState syscall.Termios
diff --git a/vendor/modules.txt b/vendor/modules.txt
index 9d1785b83..48ad757c5 100644
--- a/vendor/modules.txt
+++ b/vendor/modules.txt
@@ -93,7 +93,7 @@ github.com/beorn7/perks/quantile
 # github.com/cespare/xxhash/v2 v2.1.2
 ## explicit; go 1.11
 github.com/cespare/xxhash/v2
-# github.com/cheggaaa/pb/v3 v3.0.8
+# github.com/cheggaaa/pb/v3 v3.0.9-0.20211222075416-90c02fa07ea4
 ## explicit; go 1.12
 github.com/cheggaaa/pb/v3
 github.com/cheggaaa/pb/v3/termutil