// Copyright 2012-present Oliver Eilhard. All rights reserved. // Use of this source code is governed by a MIT-license. // See http://olivere.mit-license.org/license.txt for details. package elastic import ( "encoding/json" "testing" ) func TestHistogramAggregation(t *testing.T) { agg := NewHistogramAggregation().Field("price").Interval(50) src, err := agg.Source() if err != nil { t.Fatal(err) } data, err := json.Marshal(src) if err != nil { t.Fatalf("marshaling to JSON failed: %v", err) } got := string(data) expected := `{"histogram":{"field":"price","interval":50}}` if got != expected { t.Errorf("expected\n%s\n,got:\n%s", expected, got) } } func TestHistogramAggregationWithMetaData(t *testing.T) { agg := NewHistogramAggregation().Field("price").Offset(10).Interval(50).Meta(map[string]interface{}{"name": "Oliver"}) src, err := agg.Source() if err != nil { t.Fatal(err) } data, err := json.Marshal(src) if err != nil { t.Fatalf("marshaling to JSON failed: %v", err) } got := string(data) expected := `{"histogram":{"field":"price","interval":50,"offset":10},"meta":{"name":"Oliver"}}` if got != expected { t.Errorf("expected\n%s\n,got:\n%s", expected, got) } } func TestHistogramAggregationWithMissing(t *testing.T) { agg := NewHistogramAggregation().Field("price").Interval(50).Missing("n/a") src, err := agg.Source() if err != nil { t.Fatal(err) } data, err := json.Marshal(src) if err != nil { t.Fatalf("marshaling to JSON failed: %v", err) } got := string(data) expected := `{"histogram":{"field":"price","interval":50,"missing":"n/a"}}` if got != expected { t.Errorf("expected\n%s\n,got:\n%s", expected, got) } }