mirror of
https://github.com/grafana/grafana.git
synced 2025-07-29 12:32:17 +08:00
d61530941a
* Add errorsource * Migrate to individually build metric queries * Migrate logs queries to be built individually * Migrate to individually build resource graph queries
52 lines
1.4 KiB
Go
52 lines
1.4 KiB
Go
package time
|
|
|
|
import (
|
|
"fmt"
|
|
"strconv"
|
|
"strings"
|
|
"time"
|
|
|
|
"github.com/grafana/grafana-plugin-sdk-go/backend/gtime"
|
|
"github.com/grafana/grafana-plugin-sdk-go/experimental/errorsource"
|
|
)
|
|
|
|
// TimeGrain handles conversions between
|
|
// the ISO 8601 Duration format (PT1H), Kbn units (1h) and Time Grains (1 hour)
|
|
// Also handles using the automatic Grafana interval to calculate a ISO 8601 Duration.
|
|
var (
|
|
smallTimeUnits = []string{"hour", "minute", "h", "m"}
|
|
)
|
|
|
|
func CreateISO8601DurationFromIntervalMS(it int64) (string, error) {
|
|
formatted := gtime.FormatInterval(time.Duration(it) * time.Millisecond)
|
|
|
|
if strings.Contains(formatted, "ms") {
|
|
return "PT1M", nil
|
|
}
|
|
|
|
timeValueString := formatted[0 : len(formatted)-1]
|
|
timeValue, err := strconv.Atoi(timeValueString)
|
|
if err != nil {
|
|
return "", errorsource.DownstreamError(fmt.Errorf("could not parse interval %q to an ISO 8061 duration: %w", it, err), false)
|
|
}
|
|
|
|
unit := formatted[len(formatted)-1:]
|
|
|
|
if unit == "s" && timeValue < 60 {
|
|
// minimum interval is 1m for Azure Monitor
|
|
return "PT1M", nil
|
|
}
|
|
|
|
return createISO8601Duration(timeValue, unit), nil
|
|
}
|
|
|
|
func createISO8601Duration(timeValue int, timeUnit string) string {
|
|
for _, smallTimeUnit := range smallTimeUnits {
|
|
if timeUnit == smallTimeUnit {
|
|
return fmt.Sprintf("PT%v%v", timeValue, strings.ToUpper(timeUnit[0:1]))
|
|
}
|
|
}
|
|
|
|
return fmt.Sprintf("P%v%v", timeValue, strings.ToUpper(timeUnit[0:1]))
|
|
}
|