time_range.go 1.1 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758
  1. package tsdb
  2. import (
  3. "fmt"
  4. "strconv"
  5. "strings"
  6. "time"
  7. )
  8. func NewTimeRange(from, to string) TimeRange {
  9. return TimeRange{
  10. From: from,
  11. To: to,
  12. Now: time.Now(),
  13. }
  14. }
  15. type TimeRange struct {
  16. From string
  17. To string
  18. Now time.Time
  19. }
  20. func (tr TimeRange) FromTime() (time.Time, error) {
  21. if val, err := strconv.ParseInt(tr.From, 10, 64); err == nil {
  22. return time.Unix(val, 0), nil
  23. }
  24. fromRaw := strings.Replace(tr.From, "now-", "", 1)
  25. diff, err := time.ParseDuration("-" + fromRaw)
  26. if err != nil {
  27. return time.Time{}, err
  28. }
  29. return tr.Now.Add(diff), nil
  30. }
  31. func (tr TimeRange) ToTime() (time.Time, error) {
  32. if tr.To == "now" {
  33. return tr.Now, nil
  34. } else if strings.HasPrefix(tr.To, "now-") {
  35. withoutNow := strings.Replace(tr.To, "now-", "", 1)
  36. diff, err := time.ParseDuration("-" + withoutNow)
  37. if err != nil {
  38. return time.Time{}, nil
  39. }
  40. return tr.Now.Add(diff), nil
  41. }
  42. if val, err := strconv.ParseInt(tr.To, 10, 64); err == nil {
  43. return time.Unix(val, 0), nil
  44. }
  45. return time.Time{}, fmt.Errorf("cannot parse to value %s", tr.To)
  46. }