From 34aed0b3677bdcf7ca2a55e502382d8c83db35f5 Mon Sep 17 00:00:00 2001 From: Pengyuan Bian Date: Tue, 19 Feb 2019 18:34:46 -0800 Subject: [PATCH] merge timeseries before sending --- mixer/adapter/stackdriver/metric/bufferedClient.go | 1 + 1 file changed, 1 insertion(+) diff --git a/mixer/adapter/stackdriver/metric/bufferedClient.go b/mixer/adapter/stackdriver/metric/bufferedClient.go index 14d3082ee4e5..f3df3a2422a9 100644 --- a/mixer/adapter/stackdriver/metric/bufferedClient.go +++ b/mixer/adapter/stackdriver/metric/bufferedClient.go @@ -84,6 +84,7 @@ func batchTimeSeries(series []*monitoringpb.TimeSeries, tsLimit int) [][]*monito func (b *buffered) start(env adapter.Env, ticker *time.Ticker) { env.ScheduleDaemon(func() { for range ticker.C { + b.mergeTimeSeries() b.Send() } })