Change cardinality stat to working_cardinality

Witbe · Mar 2, 2017 · bf4ee90 · bf4ee90
1 parent a4bbdb9
commit bf4ee90
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 7 deletions.
diff --git a/node.go b/node.go
@@ -19,9 +19,8 @@ import (
 )
 
 const (
-	statErrorCount = "errors"
-	// TODO: Change to working_cardinality
-	statsCardinalityGauge = "cardinality"
+	statErrorCount        = "errors"
+	statsCardinalityGauge = "working_cardinality"
 	statAverageExecTime   = "avg_exec_time_ns"
 )
 

diff --git a/server/server_test.go b/server/server_test.go
@@ -409,10 +409,10 @@ func TestServer_EnableTask(t *testing.T) {
 	dot := `digraph testTaskID {
 graph [throughput="0.00 points/s"];
 
-stream0 [avg_exec_time_ns="0s" cardinality="0" errors="0" ];
+stream0 [avg_exec_time_ns="0s" errors="0" working_cardinality="0" ];
 stream0 -> from1 [processed="0"];
 
-from1 [avg_exec_time_ns="0s" cardinality="0" errors="0" ];
+from1 [avg_exec_time_ns="0s" errors="0" working_cardinality="0" ];
 }`
 	if ti.Dot != dot {
 		t.Fatalf("unexpected dot\ngot\n%s\nexp\n%s\n", ti.Dot, dot)
@@ -479,10 +479,10 @@ func TestServer_EnableTaskOnCreate(t *testing.T) {
 	dot := `digraph testTaskID {
 graph [throughput="0.00 points/s"];
 
-stream0 [avg_exec_time_ns="0s" cardinality="0" errors="0" ];
+stream0 [avg_exec_time_ns="0s" errors="0" working_cardinality="0" ];
 stream0 -> from1 [processed="0"];
 
-from1 [avg_exec_time_ns="0s" cardinality="0" errors="0" ];
+from1 [avg_exec_time_ns="0s" errors="0" working_cardinality="0" ];
 }`
 	if ti.Dot != dot {
 		t.Fatalf("unexpected dot\ngot\n%s\nexp\n%s\n", ti.Dot, dot)