summaryrefslogtreecommitdiffstats
path: root/vendor/github.com/olivere/elastic/search_aggs_pipeline_serial_diff.go
diff options
context:
space:
mode:
authorChristopher Speller <crspeller@gmail.com>2018-04-16 05:37:14 -0700
committerJoram Wilander <jwawilander@gmail.com>2018-04-16 08:37:14 -0400
commit6e2cb00008cbf09e556b00f87603797fcaa47e09 (patch)
tree3c0eb55ff4226a3f024aad373140d1fb860a6404 /vendor/github.com/olivere/elastic/search_aggs_pipeline_serial_diff.go
parentbf24f51c4e1cc6286885460672f7f449e8c6f5ef (diff)
downloadchat-6e2cb00008cbf09e556b00f87603797fcaa47e09.tar.gz
chat-6e2cb00008cbf09e556b00f87603797fcaa47e09.tar.bz2
chat-6e2cb00008cbf09e556b00f87603797fcaa47e09.zip
Depenancy upgrades and movign to dep. (#8630)
Diffstat (limited to 'vendor/github.com/olivere/elastic/search_aggs_pipeline_serial_diff.go')
-rw-r--r--vendor/github.com/olivere/elastic/search_aggs_pipeline_serial_diff.go124
1 files changed, 0 insertions, 124 deletions
diff --git a/vendor/github.com/olivere/elastic/search_aggs_pipeline_serial_diff.go b/vendor/github.com/olivere/elastic/search_aggs_pipeline_serial_diff.go
deleted file mode 100644
index e13b94ea9..000000000
--- a/vendor/github.com/olivere/elastic/search_aggs_pipeline_serial_diff.go
+++ /dev/null
@@ -1,124 +0,0 @@
-// 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
-
-// SerialDiffAggregation implements serial differencing.
-// Serial differencing is a technique where values in a time series are
-// subtracted from itself at different time lags or periods.
-//
-// For more details, see
-// https://www.elastic.co/guide/en/elasticsearch/reference/6.0/search-aggregations-pipeline-serialdiff-aggregation.html
-type SerialDiffAggregation struct {
- format string
- gapPolicy string
- lag *int
-
- subAggregations map[string]Aggregation
- meta map[string]interface{}
- bucketsPaths []string
-}
-
-// NewSerialDiffAggregation creates and initializes a new SerialDiffAggregation.
-func NewSerialDiffAggregation() *SerialDiffAggregation {
- return &SerialDiffAggregation{
- subAggregations: make(map[string]Aggregation),
- bucketsPaths: make([]string, 0),
- }
-}
-
-func (a *SerialDiffAggregation) Format(format string) *SerialDiffAggregation {
- a.format = format
- return a
-}
-
-// GapPolicy defines what should be done when a gap in the series is discovered.
-// Valid values include "insert_zeros" or "skip". Default is "insert_zeros".
-func (a *SerialDiffAggregation) GapPolicy(gapPolicy string) *SerialDiffAggregation {
- a.gapPolicy = gapPolicy
- return a
-}
-
-// GapInsertZeros inserts zeros for gaps in the series.
-func (a *SerialDiffAggregation) GapInsertZeros() *SerialDiffAggregation {
- a.gapPolicy = "insert_zeros"
- return a
-}
-
-// GapSkip skips gaps in the series.
-func (a *SerialDiffAggregation) GapSkip() *SerialDiffAggregation {
- a.gapPolicy = "skip"
- return a
-}
-
-// Lag specifies the historical bucket to subtract from the current value.
-// E.g. a lag of 7 will subtract the current value from the value 7 buckets
-// ago. Lag must be a positive, non-zero integer.
-func (a *SerialDiffAggregation) Lag(lag int) *SerialDiffAggregation {
- a.lag = &lag
- return a
-}
-
-// SubAggregation adds a sub-aggregation to this aggregation.
-func (a *SerialDiffAggregation) SubAggregation(name string, subAggregation Aggregation) *SerialDiffAggregation {
- a.subAggregations[name] = subAggregation
- return a
-}
-
-// Meta sets the meta data to be included in the aggregation response.
-func (a *SerialDiffAggregation) Meta(metaData map[string]interface{}) *SerialDiffAggregation {
- a.meta = metaData
- return a
-}
-
-// BucketsPath sets the paths to the buckets to use for this pipeline aggregator.
-func (a *SerialDiffAggregation) BucketsPath(bucketsPaths ...string) *SerialDiffAggregation {
- a.bucketsPaths = append(a.bucketsPaths, bucketsPaths...)
- return a
-}
-
-func (a *SerialDiffAggregation) Source() (interface{}, error) {
- source := make(map[string]interface{})
- params := make(map[string]interface{})
- source["serial_diff"] = params
-
- if a.format != "" {
- params["format"] = a.format
- }
- if a.gapPolicy != "" {
- params["gap_policy"] = a.gapPolicy
- }
- if a.lag != nil {
- params["lag"] = *a.lag
- }
-
- // Add buckets paths
- switch len(a.bucketsPaths) {
- case 0:
- case 1:
- params["buckets_path"] = a.bucketsPaths[0]
- default:
- params["buckets_path"] = a.bucketsPaths
- }
-
- // AggregationBuilder (SubAggregations)
- if len(a.subAggregations) > 0 {
- aggsMap := make(map[string]interface{})
- source["aggregations"] = aggsMap
- for name, aggregate := range a.subAggregations {
- src, err := aggregate.Source()
- if err != nil {
- return nil, err
- }
- aggsMap[name] = src
- }
- }
-
- // Add Meta data if available
- if len(a.meta) > 0 {
- source["meta"] = a.meta
- }
-
- return source, nil
-}