diff options
Diffstat (limited to 'vendor/gopkg.in/olivere/elastic.v5/search_aggs_test.go')
-rw-r--r-- | vendor/gopkg.in/olivere/elastic.v5/search_aggs_test.go | 28 |
1 files changed, 28 insertions, 0 deletions
diff --git a/vendor/gopkg.in/olivere/elastic.v5/search_aggs_test.go b/vendor/gopkg.in/olivere/elastic.v5/search_aggs_test.go index 9bdcc75a2..c730e3b43 100644 --- a/vendor/gopkg.in/olivere/elastic.v5/search_aggs_test.go +++ b/vendor/gopkg.in/olivere/elastic.v5/search_aggs_test.go @@ -3067,6 +3067,34 @@ func TestAggsPipelineDerivative(t *testing.T) { } } +func TestAggsPipelinePercentilesBucket(t *testing.T) { + s := `{ + "sales_percentiles": { + "values": { + "25.0": 100, + "50.0": 200, + "75.0": 300 + } + } +}` + aggs := new(Aggregations) + err := json.Unmarshal([]byte(s), &aggs) + if err != nil { + t.Fatalf("expected no error decoding; got: %v", err) + } + + agg, found := aggs.PercentilesBucket("sales_percentiles") + if !found { + t.Fatalf("expected aggregation to be found; got: %v", found) + } + if agg == nil { + t.Fatalf("expected aggregation != nil; got: %v", agg) + } + if len(agg.Values) != 3 { + t.Fatalf("expected aggregation map with three entries; got: %v", agg.Values) + } +} + func TestAggsPipelineStatsBucket(t *testing.T) { s := `{ "stats_monthly_sales": { |