mirror of
https://github.com/VictoriaMetrics/VictoriaMetrics.git
synced 2024-11-21 14:44:00 +00:00
122 lines
3 KiB
Go
122 lines
3 KiB
Go
package promutils
|
|
|
|
import (
|
|
"fmt"
|
|
"strconv"
|
|
"strings"
|
|
"time"
|
|
)
|
|
|
|
// ParseTime parses time s in different formats.
|
|
//
|
|
// See https://docs.victoriametrics.com/Single-server-VictoriaMetrics.html#timestamp-formats
|
|
//
|
|
// It returns unix timestamp in seconds.
|
|
func ParseTime(s string) (float64, error) {
|
|
currentTimestamp := float64(time.Now().UnixNano()) / 1e9
|
|
return ParseTimeAt(s, currentTimestamp)
|
|
}
|
|
|
|
// ParseTimeAt parses time s in different formats, assuming the given currentTimestamp.
|
|
//
|
|
// See https://docs.victoriametrics.com/Single-server-VictoriaMetrics.html#timestamp-formats
|
|
//
|
|
// It returns unix timestamp in seconds.
|
|
func ParseTimeAt(s string, currentTimestamp float64) (float64, error) {
|
|
if s == "now" {
|
|
return currentTimestamp, nil
|
|
}
|
|
sOrig := s
|
|
tzOffset := float64(0)
|
|
if len(sOrig) > 6 {
|
|
// Try parsing timezone offset
|
|
tz := sOrig[len(sOrig)-6:]
|
|
if (tz[0] == '-' || tz[0] == '+') && tz[3] == ':' {
|
|
isPlus := tz[0] == '+'
|
|
hour, err := strconv.ParseUint(tz[1:3], 10, 64)
|
|
if err != nil {
|
|
return 0, fmt.Errorf("cannot parse hour from timezone offset %q: %w", tz, err)
|
|
}
|
|
minute, err := strconv.ParseUint(tz[4:], 10, 64)
|
|
if err != nil {
|
|
return 0, fmt.Errorf("cannot parse minute from timezone offset %q: %w", tz, err)
|
|
}
|
|
tzOffset = float64(hour*3600 + minute*60)
|
|
if isPlus {
|
|
tzOffset = -tzOffset
|
|
}
|
|
s = sOrig[:len(sOrig)-6]
|
|
}
|
|
}
|
|
s = strings.TrimSuffix(s, "Z")
|
|
if len(s) > 0 && (s[len(s)-1] > '9' || s[0] == '-') || strings.HasPrefix(s, "now") {
|
|
// Parse duration relative to the current time
|
|
s = strings.TrimPrefix(s, "now")
|
|
d, err := ParseDuration(s)
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
if d > 0 {
|
|
d = -d
|
|
}
|
|
return currentTimestamp + float64(d)/1e9, nil
|
|
}
|
|
if len(s) == 4 {
|
|
// Parse YYYY
|
|
t, err := time.Parse("2006", s)
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
return tzOffset + float64(t.UnixNano())/1e9, nil
|
|
}
|
|
if !strings.Contains(sOrig, "-") {
|
|
// Parse the timestamp in seconds
|
|
return strconv.ParseFloat(sOrig, 64)
|
|
}
|
|
if len(s) == 7 {
|
|
// Parse YYYY-MM
|
|
t, err := time.Parse("2006-01", s)
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
return tzOffset + float64(t.UnixNano())/1e9, nil
|
|
}
|
|
if len(s) == 10 {
|
|
// Parse YYYY-MM-DD
|
|
t, err := time.Parse("2006-01-02", s)
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
return tzOffset + float64(t.UnixNano())/1e9, nil
|
|
}
|
|
if len(s) == 13 {
|
|
// Parse YYYY-MM-DDTHH
|
|
t, err := time.Parse("2006-01-02T15", s)
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
return tzOffset + float64(t.UnixNano())/1e9, nil
|
|
}
|
|
if len(s) == 16 {
|
|
// Parse YYYY-MM-DDTHH:MM
|
|
t, err := time.Parse("2006-01-02T15:04", s)
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
return tzOffset + float64(t.UnixNano())/1e9, nil
|
|
}
|
|
if len(s) == 19 {
|
|
// Parse YYYY-MM-DDTHH:MM:SS
|
|
t, err := time.Parse("2006-01-02T15:04:05", s)
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
return tzOffset + float64(t.UnixNano())/1e9, nil
|
|
}
|
|
// Parse RFC3339
|
|
t, err := time.Parse(time.RFC3339, sOrig)
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
return float64(t.UnixNano()) / 1e9, nil
|
|
}
|