Unpack postgres arrays for process idle times correctly

Signed-off-by: Tom Hughes <[email protected]>

Author: tomhughes

collector/pg_process_idle.go

@@ -18,6 +18,7 @@ import (
 	"database/sql"
 
 	"github.com/go-kit/log"
+	"github.com/lib/pq"
 	"github.com/prometheus/client_golang/prometheus"
 )
 
@@ -84,17 +85,29 @@ func (PGProcessIdleCollector) Update(ctx context.Context, instance *instance, ch
 	var applicationName sql.NullString
 	var secondsSum sql.NullInt64
 	var secondsCount sql.NullInt64
-	var seconds []uint64
-	var secondsBucket []uint64
+	var rawSeconds []byte
+	var rawSecondsBucket []byte
 
-	err := row.Scan(&applicationName, &secondsSum, &secondsCount, &seconds, &secondsBucket)
+	err := row.Scan(&applicationName, &secondsSum, &secondsCount, &rawSeconds, &rawSecondsBucket)
+
+	var seconds []float64
+	err = pq.Array(&seconds).Scan(rawSeconds)
+	if err != nil {
+		return err
+	}
+
+	var secondsBucket []int64
+	err = pq.Array(&secondsBucket).Scan(rawSecondsBucket)
+	if err != nil {
+		return err
+	}
 
 	var buckets = make(map[float64]uint64, len(seconds))
 	for i, second := range seconds {
 		if i >= len(secondsBucket) {
 			break
 		}
-		buckets[float64(second)] = secondsBucket[i]
+		buckets[second] = uint64(secondsBucket[i])
 	}
 	if err != nil {
 		return err