Align timestamps

librato.go

@@ -9,12 +9,14 @@ import (
 	"math"
 	"net/http"
 	"sort"
+	"time"
 )
 
 type Measurement struct {
 	Counters []*Counter    `json:"counters"`
 	Gauges   []interface{} `json:"gauges"`
 	Source   string        `json:"source,omitempty"`
+	Time     int64         `json:"measure_time"`
 }
 
 func (m *Measurement) Count() int {
@@ -80,7 +82,7 @@ func submitLibrato() (err error) {
 		return fmt.Errorf("%s: %s", resp.Status, string(raw))
 	}
 
-	log.Printf("%d measurements sent to librato\n", m.Count())
+	log.Printf("%d measurements sent to librato, timestamp: %d\n", m.Count(), m.Time)
 
 	resetTimers()
 
@@ -93,6 +95,13 @@ func buildMeasurement() (m *Measurement) {
 		m.Source = *libratoSource
 	}
 
+	t := time.Now().Unix()
+	if *snapTime {
+		// unix timestamp, matching our interval
+		t = t - (t % *interval)
+	}
+	m.Time = t
+
 	m.Counters = make([]*Counter, len(counters))
 	m.Gauges = make([]interface{}, len(gauges))
 

main.go

@@ -17,6 +17,7 @@ var (
 	libratoToken  = flag.String("token", "", "librato api token (LIBRATO_TOKEN)")
 	libratoSource = flag.String("source", "", "librato api source (LIBRATO_SOURCE)")
 	interval      = flag.Int64("flush", 60, "interval at which data is sent to librato (in seconds)")
+	snapTime      = flag.Bool("snaptime", false, "snap timestamps to interval, to align with other servers started at different offsets")
 	percentiles   = flag.String("percentiles", "", "comma separated list of percentiles to calculate for timers (eg. \"95,99.5\")")
 	proxy         = flag.String("proxy", "", "send metrics to a proxy rather than directly to librato")
 	debug         = flag.Bool("debug", false, "enable logging of inputs and submissions")