|
@@ -306,6 +306,7 @@ func (e *StackdriverExecutor) parseResponse(queryRes *tsdb.QueryResult, data Sta
|
|
|
for i := len(series.Points) - 1; i >= 0; i-- {
|
|
for i := len(series.Points) - 1; i >= 0; i-- {
|
|
|
point := series.Points[i]
|
|
point := series.Points[i]
|
|
|
value := point.Value.DoubleValue
|
|
value := point.Value.DoubleValue
|
|
|
|
|
+
|
|
|
if series.ValueType == "INT64" {
|
|
if series.ValueType == "INT64" {
|
|
|
parsedValue, err := strconv.ParseFloat(point.Value.IntValue, 64)
|
|
parsedValue, err := strconv.ParseFloat(point.Value.IntValue, 64)
|
|
|
if err == nil {
|
|
if err == nil {
|
|
@@ -313,6 +314,14 @@ func (e *StackdriverExecutor) parseResponse(queryRes *tsdb.QueryResult, data Sta
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+ if series.ValueType == "BOOL" {
|
|
|
|
|
+ if point.Value.BoolValue {
|
|
|
|
|
+ value = 1
|
|
|
|
|
+ } else {
|
|
|
|
|
+ value = 0
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
points = append(points, tsdb.NewTimePoint(null.FloatFrom(value), float64((point.Interval.EndTime).Unix())*1000))
|
|
points = append(points, tsdb.NewTimePoint(null.FloatFrom(value), float64((point.Interval.EndTime).Unix())*1000))
|
|
|
}
|
|
}
|
|
|
|
|
|