add secondary size limit for NewTermsAggregation to support limit

querystring.
sapcc · Dec 11, 2017 · 1cd3ca5 · 1cd3ca5
1 parent 1f3f083
commit 1cd3ca5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/storage/elasticsearch.go b/pkg/storage/elasticsearch.go
@@ -192,7 +192,7 @@ func (es ElasticSearch) GetAttributes(filter *AttributeFilter, tenantID string)
 	}
 	util.LogDebug("Mapped Queryname: %s --> %s", filter.QueryName, esName)
 
-	queryAgg := elastic.NewTermsAggregation().Field(esName)
+	queryAgg := elastic.NewTermsAggregation().Size(int(filter.Limit)).Field(esName)
 
 	esSearch := es.client().Search().Index(index).Size(int(filter.Limit)).Aggregation("attributes", queryAgg)
 	searchResult, err := esSearch.Do(context.Background())