Merge pull request #72 from K-Phoen/stackdriver-group-by

Stackdriver group by

decoder/target.go

@@ -46,6 +46,7 @@ type StackdriverTarget struct {
 	Legend      string                `yaml:",omitempty"`
 	Ref         string                `yaml:",omitempty"`
 	Hidden      bool                  `yaml:",omitempty"`
+	GroupBy     []string              `yaml:",omitempty"`
 }
 
 type StackdriverFilters struct {
@@ -93,6 +94,10 @@ func (t StackdriverTarget) toOptions() ([]stackdriver.Option, error) {
 		opts = append(opts, stackdriver.Filter(filters...))
 	}
 
+	if len(t.GroupBy) != 0 {
+		opts = append(opts, stackdriver.GroupBys(t.GroupBy...))
+	}
+
 	if t.Aggregation != "" {
 		opt, err := t.aggregation()
 		if err != nil {

decoder/target_test.go

@@ -217,3 +217,12 @@ func TestStackdriverHiddenTarget(t *testing.T) {
 	req.NoError(err)
 	req.True(target.Builder.Hide)
 }
+
+func TestStackdriverGroupBy(t *testing.T) {
+	req := require.New(t)
+
+	target, err := StackdriverTarget{Type: "delta", GroupBy: []string{"field", "other"}}.toTarget()
+
+	req.NoError(err)
+	req.ElementsMatch(target.Builder.GroupBys, []string{"field", "other"})
+}

target/stackdriver/stackdriver.go

@@ -156,3 +156,10 @@ func Filter(filters ...FilterOption) Option {
 		}
 	}
 }
+
+// GroupBys defines a list of fields to group the query by.
+func GroupBys(groupBys ...string) Option {
+	return func(stackdriver *Stackdriver) {
+		stackdriver.Builder.GroupBys = groupBys
+	}
+}

target/stackdriver/stackdriver_test.go

@@ -181,3 +181,11 @@ func TestFiltersCanBeConfigured(t *testing.T) {
 		})
 	}
 }
+
+func TestTargetSupportsGroupBys(t *testing.T) {
+	req := require.New(t)
+
+	target := stackdriver.Delta("", stackdriver.GroupBys("field", "other"))
+
+	req.ElementsMatch(target.Builder.GroupBys, []string{"field", "other"})
+}