From 6e2cb00008cbf09e556b00f87603797fcaa47e09 Mon Sep 17 00:00:00 2001 From: Christopher Speller Date: Mon, 16 Apr 2018 05:37:14 -0700 Subject: Depenancy upgrades and movign to dep. (#8630) --- vendor/github.com/olivere/elastic/mget.go | 257 ------------------------------ 1 file changed, 257 deletions(-) delete mode 100644 vendor/github.com/olivere/elastic/mget.go (limited to 'vendor/github.com/olivere/elastic/mget.go') diff --git a/vendor/github.com/olivere/elastic/mget.go b/vendor/github.com/olivere/elastic/mget.go deleted file mode 100644 index 5202a9603..000000000 --- a/vendor/github.com/olivere/elastic/mget.go +++ /dev/null @@ -1,257 +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 - -import ( - "context" - "fmt" - "net/url" - "strings" -) - -// MgetService allows to get multiple documents based on an index, -// type (optional) and id (possibly routing). The response includes -// a docs array with all the fetched documents, each element similar -// in structure to a document provided by the Get API. -// -// See https://www.elastic.co/guide/en/elasticsearch/reference/6.0/docs-multi-get.html -// for details. -type MgetService struct { - client *Client - pretty bool - preference string - realtime *bool - refresh string - routing string - storedFields []string - items []*MultiGetItem -} - -// NewMgetService initializes a new Multi GET API request call. -func NewMgetService(client *Client) *MgetService { - builder := &MgetService{ - client: client, - } - return builder -} - -// Preference specifies the node or shard the operation should be performed -// on (default: random). -func (s *MgetService) Preference(preference string) *MgetService { - s.preference = preference - return s -} - -// Refresh the shard containing the document before performing the operation. -func (s *MgetService) Refresh(refresh string) *MgetService { - s.refresh = refresh - return s -} - -// Realtime specifies whether to perform the operation in realtime or search mode. -func (s *MgetService) Realtime(realtime bool) *MgetService { - s.realtime = &realtime - return s -} - -// Routing is the specific routing value. -func (s *MgetService) Routing(routing string) *MgetService { - s.routing = routing - return s -} - -// StoredFields is a list of fields to return in the response. -func (s *MgetService) StoredFields(storedFields ...string) *MgetService { - s.storedFields = append(s.storedFields, storedFields...) - return s -} - -// Pretty indicates that the JSON response be indented and human readable. -func (s *MgetService) Pretty(pretty bool) *MgetService { - s.pretty = pretty - return s -} - -// Add an item to the request. -func (s *MgetService) Add(items ...*MultiGetItem) *MgetService { - s.items = append(s.items, items...) - return s -} - -// Source returns the request body, which will be serialized into JSON. -func (s *MgetService) Source() (interface{}, error) { - source := make(map[string]interface{}) - items := make([]interface{}, len(s.items)) - for i, item := range s.items { - src, err := item.Source() - if err != nil { - return nil, err - } - items[i] = src - } - source["docs"] = items - return source, nil -} - -// Do executes the request. -func (s *MgetService) Do(ctx context.Context) (*MgetResponse, error) { - // Build url - path := "/_mget" - - params := make(url.Values) - if s.realtime != nil { - params.Add("realtime", fmt.Sprintf("%v", *s.realtime)) - } - if s.preference != "" { - params.Add("preference", s.preference) - } - if s.refresh != "" { - params.Add("refresh", s.refresh) - } - if s.routing != "" { - params.Set("routing", s.routing) - } - if len(s.storedFields) > 0 { - params.Set("stored_fields", strings.Join(s.storedFields, ",")) - } - - // Set body - body, err := s.Source() - if err != nil { - return nil, err - } - - // Get response - res, err := s.client.PerformRequest(ctx, PerformRequestOptions{ - Method: "GET", - Path: path, - Params: params, - Body: body, - }) - if err != nil { - return nil, err - } - - // Return result - ret := new(MgetResponse) - if err := s.client.decoder.Decode(res.Body, ret); err != nil { - return nil, err - } - return ret, nil -} - -// -- Multi Get Item -- - -// MultiGetItem is a single document to retrieve via the MgetService. -type MultiGetItem struct { - index string - typ string - id string - routing string - storedFields []string - version *int64 // see org.elasticsearch.common.lucene.uid.Versions - versionType string // see org.elasticsearch.index.VersionType - fsc *FetchSourceContext -} - -// NewMultiGetItem initializes a new, single item for a Multi GET request. -func NewMultiGetItem() *MultiGetItem { - return &MultiGetItem{} -} - -// Index specifies the index name. -func (item *MultiGetItem) Index(index string) *MultiGetItem { - item.index = index - return item -} - -// Type specifies the type name. -func (item *MultiGetItem) Type(typ string) *MultiGetItem { - item.typ = typ - return item -} - -// Id specifies the identifier of the document. -func (item *MultiGetItem) Id(id string) *MultiGetItem { - item.id = id - return item -} - -// Routing is the specific routing value. -func (item *MultiGetItem) Routing(routing string) *MultiGetItem { - item.routing = routing - return item -} - -// StoredFields is a list of fields to return in the response. -func (item *MultiGetItem) StoredFields(storedFields ...string) *MultiGetItem { - item.storedFields = append(item.storedFields, storedFields...) - return item -} - -// Version can be MatchAny (-3), MatchAnyPre120 (0), NotFound (-1), -// or NotSet (-2). These are specified in org.elasticsearch.common.lucene.uid.Versions. -// The default in Elasticsearch is MatchAny (-3). -func (item *MultiGetItem) Version(version int64) *MultiGetItem { - item.version = &version - return item -} - -// VersionType can be "internal", "external", "external_gt", or "external_gte". -// See org.elasticsearch.index.VersionType in Elasticsearch source. -// It is "internal" by default. -func (item *MultiGetItem) VersionType(versionType string) *MultiGetItem { - item.versionType = versionType - return item -} - -// FetchSource allows to specify source filtering. -func (item *MultiGetItem) FetchSource(fetchSourceContext *FetchSourceContext) *MultiGetItem { - item.fsc = fetchSourceContext - return item -} - -// Source returns the serialized JSON to be sent to Elasticsearch as -// part of a MultiGet search. -func (item *MultiGetItem) Source() (interface{}, error) { - source := make(map[string]interface{}) - - source["_id"] = item.id - - if item.index != "" { - source["_index"] = item.index - } - if item.typ != "" { - source["_type"] = item.typ - } - if item.fsc != nil { - src, err := item.fsc.Source() - if err != nil { - return nil, err - } - source["_source"] = src - } - if item.routing != "" { - source["_routing"] = item.routing - } - if len(item.storedFields) > 0 { - source["stored_fields"] = strings.Join(item.storedFields, ",") - } - if item.version != nil { - source["version"] = fmt.Sprintf("%d", *item.version) - } - if item.versionType != "" { - source["version_type"] = item.versionType - } - - return source, nil -} - -// -- Result of a Multi Get request. - -// MgetResponse is the outcome of a Multi GET API request. -type MgetResponse struct { - Docs []*GetResult `json:"docs,omitempty"` -} -- cgit v1.2.3-1-g7c22