mirror of
https://github.com/VictoriaMetrics/VictoriaMetrics.git
synced 2024-12-20 23:46:23 +01:00
ac47733044
On import process interruption `vmctl` now prints the max and min timestamps of: * last failed batch if import ended with error; * last sent batch if import was cancelled by user. To get more details for each timeseries in batch user needs to specify `--verbose` flag. The change does not relate to `vm-native` mode, since `vmctl` has no control over transferred data in this mode. https://github.com/VictoriaMetrics/VictoriaMetrics/issues/1236 Signed-off-by: hagen1778 <roman@victoriametrics.com>
52 lines
1.3 KiB
Go
52 lines
1.3 KiB
Go
package main
|
|
|
|
import (
|
|
"bufio"
|
|
"fmt"
|
|
"os"
|
|
"strings"
|
|
|
|
"github.com/VictoriaMetrics/VictoriaMetrics/app/vmctl/vm"
|
|
)
|
|
|
|
func prompt(question string) bool {
|
|
reader := bufio.NewReader(os.Stdin)
|
|
fmt.Print(question, " [Y/n] ")
|
|
answer, err := reader.ReadString('\n')
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
answer = strings.TrimSpace(strings.ToLower(answer))
|
|
if answer == "" || answer == "yes" || answer == "y" {
|
|
return true
|
|
}
|
|
return false
|
|
}
|
|
|
|
func wrapErr(vmErr *vm.ImportError, verbose bool) error {
|
|
var errTS string
|
|
var maxTS, minTS int64
|
|
for _, ts := range vmErr.Batch {
|
|
if minTS < ts.Timestamps[0] || minTS == 0 {
|
|
minTS = ts.Timestamps[0]
|
|
}
|
|
if maxTS < ts.Timestamps[len(ts.Timestamps)-1] {
|
|
maxTS = ts.Timestamps[len(ts.Timestamps)-1]
|
|
}
|
|
if verbose {
|
|
errTS += fmt.Sprintf("%s for timestamps range %d - %d\n",
|
|
ts.String(), ts.Timestamps[0], ts.Timestamps[len(ts.Timestamps)-1])
|
|
}
|
|
}
|
|
var verboseMsg string
|
|
if !verbose {
|
|
verboseMsg = "(enable `--verbose` output to get more details)"
|
|
}
|
|
if vmErr.Err == nil {
|
|
return fmt.Errorf("%s\n\tLatest delivered batch for timestamps range %d - %d %s\n%s",
|
|
vmErr.Err, minTS, maxTS, verboseMsg, errTS)
|
|
}
|
|
return fmt.Errorf("%s\n\tImporting batch failed for timestamps range %d - %d %s\n%s",
|
|
vmErr.Err, minTS, maxTS, verboseMsg, errTS)
|
|
}
|