diff --git a/probe/docker/container.go b/probe/docker/container.go index 7cacce98f..c88288d7d 100644 --- a/probe/docker/container.go +++ b/probe/docker/container.go @@ -360,21 +360,27 @@ func (c *container) NetworkInfo(localAddrs []net.IP) report.Sets { } func (c *container) memoryUsageMetric(stats []docker.Stats) report.Metric { - result := report.MakeMetric() - for _, s := range stats { - result = result.Add(s.Read, float64(s.MemoryStats.Usage)).WithMax(float64(s.MemoryStats.Limit)) + var max float64 + samples := make([]report.Sample, len(stats)) + for i, s := range stats { + samples[i].Timestamp = s.Read + samples[i].Value = float64(s.MemoryStats.Usage) + if float64(s.MemoryStats.Limit) > max { + max = float64(s.MemoryStats.Limit) + } } - return result + return report.MakeMetric(samples).WithMax(max) } func (c *container) cpuPercentMetric(stats []docker.Stats) report.Metric { - result := report.MakeMetric() if len(stats) < 2 { - return result + return report.MakeMetric(nil) } + samples := make([]report.Sample, len(stats)-1) + var max float64 previous := stats[0] - for _, s := range stats[1:] { + for i, s := range stats[1:] { // Copies from docker/api/client/stats.go#L205 cpuDelta := float64(s.CPUStats.CPUUsage.TotalUsage - previous.CPUStats.CPUUsage.TotalUsage) systemDelta := float64(s.CPUStats.SystemCPUUsage - previous.CPUStats.SystemCPUUsage) @@ -382,14 +388,15 @@ func (c *container) cpuPercentMetric(stats []docker.Stats) report.Metric { if systemDelta > 0.0 && cpuDelta > 0.0 { cpuPercent = (cpuDelta / systemDelta) * float64(len(s.CPUStats.CPUUsage.PercpuUsage)) * 100.0 } - result = result.Add(s.Read, cpuPercent) + samples[i].Timestamp = s.Read + samples[i].Value = cpuPercent available := float64(len(s.CPUStats.CPUUsage.PercpuUsage)) * 100.0 - if available >= result.Max { - result.Max = available + if available >= max { + max = available } previous = s } - return result + return report.MakeMetric(samples).WithMax(max) } func (c *container) metrics() report.Metrics { diff --git a/probe/docker/container_test.go b/probe/docker/container_test.go index 3ed5f78d8..3d200a337 100644 --- a/probe/docker/container_test.go +++ b/probe/docker/container_test.go @@ -92,8 +92,8 @@ func TestContainer(t *testing.T) { docker.RestartContainer, docker.StopContainer, docker.PauseContainer, docker.AttachContainer, docker.ExecContainer, ).WithMetrics(report.Metrics{ - "docker_cpu_total_usage": report.MakeMetric(), - "docker_memory_usage": report.MakeMetric().Add(now, 12345).WithMax(45678), + "docker_cpu_total_usage": report.MakeMetric(nil), + "docker_memory_usage": report.MakeSingletonMetric(now, 12345).WithMax(45678), }).WithParents(report.EmptySets. Add(report.ContainerImage, report.MakeStringSet(report.MakeContainerImageNodeID("baz"))), ) diff --git a/probe/host/reporter.go b/probe/host/reporter.go index e93538b5e..ce68a387d 100644 --- a/probe/host/reporter.go +++ b/probe/host/reporter.go @@ -125,9 +125,9 @@ func (r *Reporter) Report() (report.Report, error) { now := mtime.Now() metrics := GetLoad(now) cpuUsage, max := GetCPUUsagePercent() - metrics[CPUUsage] = report.MakeMetric().Add(now, cpuUsage).WithMax(max) + metrics[CPUUsage] = report.MakeSingletonMetric(now, cpuUsage).WithMax(max) memoryUsage, max := GetMemoryUsageBytes() - metrics[MemoryUsage] = report.MakeMetric().Add(now, memoryUsage).WithMax(max) + metrics[MemoryUsage] = report.MakeSingletonMetric(now, memoryUsage).WithMax(max) rep.Host.AddNode( report.MakeNodeWith(report.MakeHostNodeID(r.hostID), map[string]string{ diff --git a/probe/host/reporter_test.go b/probe/host/reporter_test.go index 0893cce31..bd1d2d823 100644 --- a/probe/host/reporter_test.go +++ b/probe/host/reporter_test.go @@ -20,9 +20,9 @@ func TestReporter(t *testing.T) { hostname = "hostname" timestamp = time.Now() metrics = report.Metrics{ - host.Load1: report.MakeMetric().Add(timestamp, 1.0), - host.CPUUsage: report.MakeMetric().Add(timestamp, 30.0).WithMax(100.0), - host.MemoryUsage: report.MakeMetric().Add(timestamp, 60.0).WithMax(100.0), + host.Load1: report.MakeSingletonMetric(timestamp, 1.0), + host.CPUUsage: report.MakeSingletonMetric(timestamp, 30.0).WithMax(100.0), + host.MemoryUsage: report.MakeSingletonMetric(timestamp, 60.0).WithMax(100.0), } uptime = "278h55m43s" kernel = "release version" diff --git a/probe/host/system_darwin.go b/probe/host/system_darwin.go index ba682f1d1..33b3db5b6 100644 --- a/probe/host/system_darwin.go +++ b/probe/host/system_darwin.go @@ -45,7 +45,7 @@ var GetLoad = func(now time.Time) report.Metrics { return nil } return report.Metrics{ - Load1: report.MakeMetric().Add(now, one), + Load1: report.MakeSingletonMetric(now, one), } } diff --git a/probe/host/system_linux.go b/probe/host/system_linux.go index 02c0a231b..cde84a3f2 100644 --- a/probe/host/system_linux.go +++ b/probe/host/system_linux.go @@ -45,7 +45,7 @@ var GetLoad = func(now time.Time) report.Metrics { return nil } return report.Metrics{ - Load1: report.MakeMetric().Add(now, one), + Load1: report.MakeSingletonMetric(now, one), } } diff --git a/probe/process/reporter.go b/probe/process/reporter.go index 9087fb150..4b7bfc400 100644 --- a/probe/process/reporter.go +++ b/probe/process/reporter.go @@ -99,11 +99,11 @@ func (r *Reporter) processTopology() (report.Topology, error) { if deltaTotal > 0 { cpuUsage := float64(p.Jiffies-prev.Jiffies) / float64(deltaTotal) * 100. - node = node.WithMetric(CPUUsage, report.MakeMetric().Add(now, cpuUsage).WithMax(maxCPU)) + node = node.WithMetric(CPUUsage, report.MakeSingletonMetric(now, cpuUsage).WithMax(maxCPU)) } - node = node.WithMetric(MemoryUsage, report.MakeMetric().Add(now, float64(p.RSSBytes)).WithMax(float64(p.RSSBytesLimit))) - node = node.WithMetric(OpenFilesCount, report.MakeMetric().Add(now, float64(p.OpenFilesCount)).WithMax(float64(p.OpenFilesLimit))) + node = node.WithMetric(MemoryUsage, report.MakeSingletonMetric(now, float64(p.RSSBytes)).WithMax(float64(p.RSSBytesLimit))) + node = node.WithMetric(OpenFilesCount, report.MakeSingletonMetric(now, float64(p.OpenFilesCount)).WithMax(float64(p.OpenFilesLimit))) t.AddNode(node) }) diff --git a/render/detailed/metrics_test.go b/render/detailed/metrics_test.go index c233ec4ee..22c12f2a6 100644 --- a/render/detailed/metrics_test.go +++ b/render/detailed/metrics_test.go @@ -117,7 +117,7 @@ func TestNodeMetrics(t *testing.T) { func TestMetricRowSummary(t *testing.T) { var ( now = time.Now() - metric = report.MakeMetric().Add(now, 1.234) + metric = report.MakeSingletonMetric(now, 1.234) row = report.MetricRow{ ID: "id", Format: "format", diff --git a/render/detailed/summary_test.go b/render/detailed/summary_test.go index 5fe3de9f7..514416c26 100644 --- a/render/detailed/summary_test.go +++ b/render/detailed/summary_test.go @@ -47,10 +47,10 @@ func TestSummaries(t *testing.T) { // It should summarize nodes' metrics { t1, t2 := mtime.Now().Add(-1*time.Minute), mtime.Now() - metric := report.MakeMetric().Add(t1, 1).Add(t2, 2) + metric := report.MakeMetric([]report.Sample{{t1, 1}, {t2, 2}}) input := fixture.Report.Copy() - input.Process.Nodes[fixture.ClientProcess1NodeID] = input.Process.Nodes[fixture.ClientProcess1NodeID].WithMetrics(report.Metrics{process.CPUUsage: metric}) + input.Process.Nodes[fixture.ClientProcess1NodeID].Metrics[process.CPUUsage] = metric have := detailed.Summaries(input, render.ProcessRenderer.Render(input, nil)) node, ok := have[fixture.ClientProcess1NodeID] diff --git a/render/metrics_test.go b/render/metrics_test.go index 8f0212cd0..ef5be6ffb 100644 --- a/render/metrics_test.go +++ b/render/metrics_test.go @@ -31,20 +31,20 @@ func TestPropagateSingleMetrics(t *testing.T) { report.MakeNode("child1"). WithTopology(report.Container). WithMetrics(report.Metrics{ - "metric1": report.MakeMetric(), + "metric1": report.MakeMetric(nil), }), ), ), topology: report.Container, output: report.Nodes{ "a": report.MakeNode("a").WithMetrics(report.Metrics{ - "metric1": report.MakeMetric(), + "metric1": report.MakeMetric(nil), }).WithChildren( report.MakeNodeSet( report.MakeNode("child1"). WithTopology(report.Container). WithMetrics(report.Metrics{ - "metric1": report.MakeMetric(), + "metric1": report.MakeMetric(nil), }), ), ), @@ -57,30 +57,30 @@ func TestPropagateSingleMetrics(t *testing.T) { report.MakeNode("child1"). WithTopology(report.Container). WithMetrics(report.Metrics{ - "metric1": report.MakeMetric(), + "metric1": report.MakeMetric(nil), }), report.MakeNode("child2"). WithTopology("otherTopology"). WithMetrics(report.Metrics{ - "metric2": report.MakeMetric(), + "metric2": report.MakeMetric(nil), }), ), ), topology: report.Container, output: report.Nodes{ "a": report.MakeNode("a").WithMetrics(report.Metrics{ - "metric1": report.MakeMetric(), + "metric1": report.MakeMetric(nil), }).WithChildren( report.MakeNodeSet( report.MakeNode("child1"). WithTopology(report.Container). WithMetrics(report.Metrics{ - "metric1": report.MakeMetric(), + "metric1": report.MakeMetric(nil), }), report.MakeNode("child2"). WithTopology("otherTopology"). WithMetrics(report.Metrics{ - "metric2": report.MakeMetric(), + "metric2": report.MakeMetric(nil), }), ), ), @@ -93,12 +93,12 @@ func TestPropagateSingleMetrics(t *testing.T) { report.MakeNode("child1"). WithTopology(report.Container). WithMetrics(report.Metrics{ - "metric1": report.MakeMetric(), + "metric1": report.MakeMetric(nil), }), report.MakeNode("child2"). WithTopology(report.Container). WithMetrics(report.Metrics{ - "metric2": report.MakeMetric(), + "metric2": report.MakeMetric(nil), }), ), ), @@ -109,12 +109,12 @@ func TestPropagateSingleMetrics(t *testing.T) { report.MakeNode("child1"). WithTopology(report.Container). WithMetrics(report.Metrics{ - "metric1": report.MakeMetric(), + "metric1": report.MakeMetric(nil), }), report.MakeNode("child2"). WithTopology(report.Container). WithMetrics(report.Metrics{ - "metric2": report.MakeMetric(), + "metric2": report.MakeMetric(nil), }), ), ), @@ -127,32 +127,32 @@ func TestPropagateSingleMetrics(t *testing.T) { report.MakeNode("child1"). WithTopology(report.Container). WithMetrics(report.Metrics{ - "metric1": report.MakeMetric(), + "metric1": report.MakeMetric(nil), }), report.MakeNode("child2"). WithLatest(report.DoesNotMakeConnections, now, ""). WithTopology(report.Container). WithMetrics(report.Metrics{ - "metric2": report.MakeMetric(), + "metric2": report.MakeMetric(nil), }), ), ), topology: report.Container, output: report.Nodes{ "a": report.MakeNode("a").WithMetrics(report.Metrics{ - "metric1": report.MakeMetric(), + "metric1": report.MakeMetric(nil), }).WithChildren( report.MakeNodeSet( report.MakeNode("child1"). WithTopology(report.Container). WithMetrics(report.Metrics{ - "metric1": report.MakeMetric(), + "metric1": report.MakeMetric(nil), }), report.MakeNode("child2"). WithLatest(report.DoesNotMakeConnections, now, ""). WithTopology(report.Container). WithMetrics(report.Metrics{ - "metric2": report.MakeMetric(), + "metric2": report.MakeMetric(nil), }), ), ), diff --git a/report/controls.go b/report/controls.go index 6e21b9959..9b0a89487 100644 --- a/report/controls.go +++ b/report/controls.go @@ -52,8 +52,8 @@ func (cs Controls) AddControls(controls []Control) { // node at a given point in time. It's immutable. A zero-value for Timestamp // indicated this NodeControls is 'not set'. type NodeControls struct { - Timestamp time.Time `json:"timestamp,omitempty"` - Controls StringSet `json:"controls,omitempty"` + Timestamp time.Time + Controls StringSet } // MakeNodeControls makes a new NodeControls @@ -85,15 +85,17 @@ func (nc NodeControls) Add(ids ...string) NodeControls { } } -// WireNodeControls is the intermediate type for json encoding. -type WireNodeControls struct { +// WireNodeControls is the intermediate type for encoding/decoding. +// Only needed for backwards compatibility with probes +// (time.Time is encoded in binary in MsgPack) +type wireNodeControls struct { Timestamp string `json:"timestamp,omitempty"` Controls StringSet `json:"controls,omitempty"` } // CodecEncodeSelf implements codec.Selfer func (nc *NodeControls) CodecEncodeSelf(encoder *codec.Encoder) { - encoder.Encode(WireNodeControls{ + encoder.Encode(wireNodeControls{ Timestamp: renderTime(nc.Timestamp), Controls: nc.Controls, }) @@ -101,7 +103,7 @@ func (nc *NodeControls) CodecEncodeSelf(encoder *codec.Encoder) { // CodecDecodeSelf implements codec.Selfer func (nc *NodeControls) CodecDecodeSelf(decoder *codec.Decoder) { - in := WireNodeControls{} + in := wireNodeControls{} if err := decoder.Decode(&in); err != nil { return } diff --git a/report/metric_row.go b/report/metric_row.go index ad965175e..f92bdae1f 100644 --- a/report/metric_row.go +++ b/report/metric_row.go @@ -54,6 +54,8 @@ func (*MetricRow) UnmarshalJSON(b []byte) error { panic("UnmarshalJSON shouldn't be used, use CodecDecodeSelf instead") } +// Needed to flatten the fields for backwards compatibility with probes +// (time.Time is encoded in binary in MsgPack) type wiredMetricRow struct { ID string `json:"id"` Label string `json:"label"` diff --git a/report/metrics.go b/report/metrics.go index ef684437f..da11215e0 100644 --- a/report/metrics.go +++ b/report/metrics.go @@ -21,7 +21,11 @@ func (m Metrics) Lookup(key string) (Metric, bool) { func (m Metrics) Merge(other Metrics) Metrics { result := m.Copy() for k, v := range other { - result[k] = result[k].Merge(v) + if rv, ok := result[k]; ok { + result[k] = rv.Merge(v) + } else { + result[k] = v.Copy() + } } return result } @@ -49,10 +53,45 @@ type Sample struct { Value float64 `json:"value"` } -// MakeMetric makes a new Metric. -// TODO: Specialized version adding the first sample to avoid generating garbage? -func MakeMetric() Metric { - return Metric{} +// MakeSingletonMetric makes a metric with a single value +func MakeSingletonMetric(t time.Time, v float64) Metric { + return Metric{ + Samples: []Sample{{t, v}}, + Min: v, + Max: v, + First: t, + Last: t, + } + +} + +// MakeMetric makes a new Metric from unique samples incrementally ordered in +// time. +func MakeMetric(samples []Sample) Metric { + if len(samples) < 1 { + return Metric{} + } + + var ( + min = samples[0].Value + max = samples[0].Value + ) + + for i := 1; i < len(samples); i++ { + if samples[i].Value < min { + min = samples[i].Value + } else if samples[i].Value > max { + max = samples[i].Value + } + } + + return Metric{ + Samples: samples, + Min: min, + Max: max, + First: samples[0].Timestamp, + Last: samples[len(samples)-1].Timestamp, + } } // Copy returns a copy of the Metric. @@ -107,42 +146,6 @@ func last(t1, t2 time.Time) time.Time { return t2 } -// Add returns a new Metric with (t, v) added to its Samples. Add is the only -// valid way to grow a Metric. -// TODO: join t and v into a Sample to avoid extra allocations? -// TODO: This seems to be too elaborate, Add() only seems to be used to add ordered Samples. -// Replace this by a specialized version getting a slice of ordered Samples -// without duplicates? -func (m Metric) Add(t time.Time, v float64) Metric { - // Find the first element which is before you element, and insert - // your new element in the list. NB we want to dedupe entries with - // equal timestamps. - samplesOut := make([]Sample, 0, len(m.Samples)+1) - var i int - // TODO: use binary search + copy() to improve performance - for i = 0; i < len(m.Samples); i++ { - if m.Samples[i].Timestamp.Equal(t) { - i++ - break - } - if m.Samples[i].Timestamp.After(t) { - break - } - samplesOut = append(samplesOut, m.Samples[i]) - } - samplesOut = append(samplesOut, Sample{t, v}) - if i < len(m.Samples) { - samplesOut = append(samplesOut, m.Samples[i:]...) - } - return Metric{ - Samples: samplesOut, - Max: math.Max(m.Max, v), - Min: math.Min(m.Min, v), - First: first(m.First, t), - Last: last(m.Last, t), - } -} - // Merge combines the two Metrics and returns a new result. func (m Metric) Merge(other Metric) Metric { // Merge two lists of Samples in O(n) @@ -208,9 +211,11 @@ func (m Metric) LastSample() (Sample, bool) { } // WireMetrics is the on-the-wire representation of Metrics. +// Only needed for backwards compatibility with probes +// (time.Time is encoded in binary in MsgPack) type WireMetrics struct { - Samples []Sample `json:"samples,omitempty"` // On the wire, samples are sorted oldest to newest, - Min float64 `json:"min"` // the opposite order to how we store them internally. + Samples []Sample `json:"samples,omitempty"` + Min float64 `json:"min"` Max float64 `json:"max"` First string `json:"first,omitempty"` Last string `json:"last,omitempty"` diff --git a/report/metrics_test.go b/report/metrics_test.go index 9398d4bf3..012c3c42d 100644 --- a/report/metrics_test.go +++ b/report/metrics_test.go @@ -19,17 +19,17 @@ func TestMetricsMerge(t *testing.T) { t4 := time.Now().Add(3 * time.Minute) metrics1 := report.Metrics{ - "metric1": report.MakeMetric().Add(t1, 0.1).Add(t2, 0.2), - "metric2": report.MakeMetric().Add(t3, 0.3), + "metric1": report.MakeMetric([]report.Sample{{t1, 0.1}, {t2, 0.2}}), + "metric2": report.MakeSingletonMetric(t3, 0.3), } metrics2 := report.Metrics{ - "metric2": report.MakeMetric().Add(t4, 0.4), - "metric3": report.MakeMetric().Add(t1, 0.1).Add(t2, 0.2), + "metric2": report.MakeSingletonMetric(t4, 0.4), + "metric3": report.MakeMetric([]report.Sample{{t1, 0.1}, {t2, 0.2}}), } want := report.Metrics{ - "metric1": report.MakeMetric().Add(t1, 0.1).Add(t2, 0.2), - "metric2": report.MakeMetric().Add(t3, 0.3).Add(t4, 0.4), - "metric3": report.MakeMetric().Add(t1, 0.1).Add(t2, 0.2), + "metric1": report.MakeMetric([]report.Sample{{t1, 0.1}, {t2, 0.2}}), + "metric2": report.MakeMetric([]report.Sample{{t3, 0.3}, {t4, 0.4}}), + "metric3": report.MakeMetric([]report.Sample{{t1, 0.1}, {t2, 0.2}}), } have := metrics1.Merge(metrics2) if !reflect.DeepEqual(want, have) { @@ -40,7 +40,7 @@ func TestMetricsMerge(t *testing.T) { func TestMetricsCopy(t *testing.T) { t1 := time.Now() want := report.Metrics{ - "metric1": report.MakeMetric().Add(t1, 0.1), + "metric1": report.MakeSingletonMetric(t1, 0.1), } delete(want.Copy(), "metric1") // Modify a copy have := want.Copy() // Check the original wasn't affected @@ -65,66 +65,24 @@ func checkMetric(t *testing.T, metric report.Metric, first, last time.Time, min, } func TestMetricFirstLastMinMax(t *testing.T) { - metric := report.MakeMetric() - var zero time.Time + + checkMetric(t, report.MakeMetric(nil), time.Time{}, time.Time{}, 0.0, 0.0) + t1 := time.Now() t2 := time.Now().Add(1 * time.Minute) + + metric1 := report.MakeMetric([]report.Sample{{t1, -0.1}, {t2, 0.2}}) + + checkMetric(t, metric1, t1, t2, -0.1, 0.2) + checkMetric(t, metric1.Merge(metric1), t1, t2, -0.1, 0.2) + t3 := time.Now().Add(2 * time.Minute) t4 := time.Now().Add(3 * time.Minute) - other := report.MakeMetric() - other.Max = 5 - other.Min = -5 - other.First = t1.Add(-1 * time.Minute) - other.Last = t4.Add(1 * time.Minute) + metric2 := report.MakeMetric([]report.Sample{{t3, 0.31}, {t4, 0.4}}) - tests := []struct { - f func(report.Metric) report.Metric - first, last time.Time - min, max float64 - }{ - {nil, zero, zero, 0, 0}, - {func(m report.Metric) report.Metric { return m.Add(t2, 2) }, t2, t2, 0, 2}, - {func(m report.Metric) report.Metric { return m.Add(t1, 1) }, t1, t2, 0, 2}, - {func(m report.Metric) report.Metric { return m.Add(t3, -1) }, t1, t3, -1, 2}, - {func(m report.Metric) report.Metric { return m.Add(t4, 3) }, t1, t4, -1, 3}, - {func(m report.Metric) report.Metric { return m.Merge(other) }, t1.Add(-1 * time.Minute), t4.Add(1 * time.Minute), -5, 5}, - } - for _, test := range tests { - oldFirst, oldLast, oldMin, oldMax := metric.First, metric.Last, metric.Min, metric.Max - oldMetric := metric - if test.f != nil { - metric = test.f(metric) - } - - // Check it didn't modify the old one - checkMetric(t, oldMetric, oldFirst, oldLast, oldMin, oldMax) - - // Check the new one is as expected - checkMetric(t, metric, test.first, test.last, test.min, test.max) - } -} - -func TestMetricAdd(t *testing.T) { - s := []report.Sample{ - {time.Now(), 0.1}, - {time.Now().Add(1 * time.Minute), 0.2}, - {time.Now().Add(2 * time.Minute), 0.3}, - } - - have := report.MakeMetric(). - Add(s[0].Timestamp, s[0].Value). - Add(s[2].Timestamp, s[2].Value). // Keeps sorted - Add(s[1].Timestamp, s[1].Value). - Add(s[2].Timestamp, 0.5) // Overwrites duplicate timestamps - - want := report.MakeMetric(). - Add(s[0].Timestamp, s[0].Value). - Add(s[1].Timestamp, s[1].Value). - Add(s[2].Timestamp, 0.5) - - if !reflect.DeepEqual(want, have) { - t.Errorf("diff: %s", test.Diff(want, have)) - } + checkMetric(t, metric2, t3, t4, 0.31, 0.4) + checkMetric(t, metric1.Merge(metric2), t1, t4, -0.1, 0.4) + checkMetric(t, metric2.Merge(metric1), t1, t4, -0.1, 0.4) } func TestMetricMerge(t *testing.T) { @@ -133,20 +91,12 @@ func TestMetricMerge(t *testing.T) { t3 := time.Now().Add(2 * time.Minute) t4 := time.Now().Add(3 * time.Minute) - metric1 := report.MakeMetric(). - Add(t2, 0.2). - Add(t3, 0.31) + metric1 := report.MakeMetric([]report.Sample{{t2, 0.2}, {t3, 0.31}}) - metric2 := report.MakeMetric(). - Add(t1, -0.1). - Add(t3, 0.3). - Add(t4, 0.4) + metric2 := report.MakeMetric([]report.Sample{{t1, -0.1}, {t3, 0.3}, {t4, 0.4}}) + + want := report.MakeMetric([]report.Sample{{t1, -0.1}, {t2, 0.2}, {t3, 0.31}, {t4, 0.4}}) - want := report.MakeMetric(). - Add(t1, -0.1). - Add(t2, 0.2). - Add(t3, 0.31). - Add(t4, 0.4) have := metric1.Merge(metric2) if !reflect.DeepEqual(want, have) { t.Errorf("diff: %s", test.Diff(want, have)) @@ -159,8 +109,8 @@ func TestMetricMerge(t *testing.T) { if !metric1.Last.Equal(t3) { t.Errorf("Expected metric1.Last == %q, but was: %q", t3, metric1.Last) } - if metric1.Min != 0.0 { - t.Errorf("Expected metric1.Min == %f, but was: %f", 0.0, metric1.Min) + if metric1.Min != 0.2 { + t.Errorf("Expected metric1.Min == %f, but was: %f", 0.2, metric1.Min) } if metric1.Max != 0.31 { t.Errorf("Expected metric1.Max == %f, but was: %f", 0.31, metric1.Max) @@ -173,13 +123,13 @@ func TestMetricMerge(t *testing.T) { } func TestMetricCopy(t *testing.T) { - want := report.MakeMetric() + want := report.MakeMetric(nil) have := want.Copy() if !reflect.DeepEqual(want, have) { t.Errorf("diff: %s", test.Diff(want, have)) } - want = report.MakeMetric().Add(time.Now(), 1) + want = report.MakeSingletonMetric(time.Now(), 1) have = want.Copy() if !reflect.DeepEqual(want, have) { t.Errorf("diff: %s", test.Diff(want, have)) @@ -190,12 +140,8 @@ func TestMetricDiv(t *testing.T) { t1 := time.Now() t2 := time.Now().Add(1 * time.Minute) - want := report.MakeMetric(). - Add(t1, -2). - Add(t2, 2) - beforeDiv := report.MakeMetric(). - Add(t1, -2048). - Add(t2, 2048) + want := report.MakeMetric([]report.Sample{{t1, -2}, {t2, 2}}) + beforeDiv := report.MakeMetric([]report.Sample{{t1, -2048}, {t2, 2048}}) have := beforeDiv.Div(1024) if !reflect.DeepEqual(want, have) { t.Errorf("diff: %s", test.Diff(want, have)) @@ -218,10 +164,7 @@ func TestMetricMarshalling(t *testing.T) { {Timestamp: t4, Value: 0.4}, } - want := report.MakeMetric() - for _, sample := range wantSamples { - want = want.Add(sample.Timestamp, sample.Value) - } + want := report.MakeMetric(wantSamples) for _, h := range []codec.Handle{ codec.Handle(&codec.MsgpackHandle{}), diff --git a/test/fixture/report_fixture.go b/test/fixture/report_fixture.go index c02e1c76a..fa1110e20 100644 --- a/test/fixture/report_fixture.go +++ b/test/fixture/report_fixture.go @@ -101,22 +101,22 @@ var ( ServiceUID = "service1234" ServiceNodeID = report.MakeServiceNodeID(ServiceUID) - ClientProcess1CPUMetric = report.MakeMetric().Add(Now, 0.01).WithFirst(Now.Add(-1 * time.Second)) - ClientProcess1MemoryMetric = report.MakeMetric().Add(Now, 0.02).WithFirst(Now.Add(-2 * time.Second)) + ClientProcess1CPUMetric = report.MakeSingletonMetric(Now, 0.01).WithFirst(Now.Add(-1 * time.Second)) + ClientProcess1MemoryMetric = report.MakeSingletonMetric(Now, 0.02).WithFirst(Now.Add(-2 * time.Second)) - ClientContainerCPUMetric = report.MakeMetric().Add(Now, 0.03).WithFirst(Now.Add(-3 * time.Second)) - ClientContainerMemoryMetric = report.MakeMetric().Add(Now, 0.04).WithFirst(Now.Add(-4 * time.Second)) + ClientContainerCPUMetric = report.MakeSingletonMetric(Now, 0.03).WithFirst(Now.Add(-3 * time.Second)) + ClientContainerMemoryMetric = report.MakeSingletonMetric(Now, 0.04).WithFirst(Now.Add(-4 * time.Second)) - ServerContainerCPUMetric = report.MakeMetric().Add(Now, 0.05).WithFirst(Now.Add(-5 * time.Second)) - ServerContainerMemoryMetric = report.MakeMetric().Add(Now, 0.06).WithFirst(Now.Add(-6 * time.Second)) + ServerContainerCPUMetric = report.MakeSingletonMetric(Now, 0.05).WithFirst(Now.Add(-5 * time.Second)) + ServerContainerMemoryMetric = report.MakeSingletonMetric(Now, 0.06).WithFirst(Now.Add(-6 * time.Second)) - ClientHostCPUMetric = report.MakeMetric().Add(Now, 0.07).WithFirst(Now.Add(-7 * time.Second)) - ClientHostMemoryMetric = report.MakeMetric().Add(Now, 0.08).WithFirst(Now.Add(-8 * time.Second)) - ClientHostLoad1Metric = report.MakeMetric().Add(Now, 0.09).WithFirst(Now.Add(-9 * time.Second)) + ClientHostCPUMetric = report.MakeSingletonMetric(Now, 0.07).WithFirst(Now.Add(-7 * time.Second)) + ClientHostMemoryMetric = report.MakeSingletonMetric(Now, 0.08).WithFirst(Now.Add(-8 * time.Second)) + ClientHostLoad1Metric = report.MakeSingletonMetric(Now, 0.09).WithFirst(Now.Add(-9 * time.Second)) - ServerHostCPUMetric = report.MakeMetric().Add(Now, 0.12).WithFirst(Now.Add(-12 * time.Second)) - ServerHostMemoryMetric = report.MakeMetric().Add(Now, 0.13).WithFirst(Now.Add(-13 * time.Second)) - ServerHostLoad1Metric = report.MakeMetric().Add(Now, 0.14).WithFirst(Now.Add(-14 * time.Second)) + ServerHostCPUMetric = report.MakeSingletonMetric(Now, 0.12).WithFirst(Now.Add(-12 * time.Second)) + ServerHostMemoryMetric = report.MakeSingletonMetric(Now, 0.13).WithFirst(Now.Add(-13 * time.Second)) + ServerHostLoad1Metric = report.MakeSingletonMetric(Now, 0.14).WithFirst(Now.Add(-14 * time.Second)) Report = report.Report{ ID: "test-report",