summaryrefslogtreecommitdiffstats
path: root/vendor/github.com/olivere/elastic/v7/script_get.go
diff options
context:
space:
mode:
authorLunny Xiao <xiaolunwen@gmail.com>2020-02-13 14:06:17 +0800
committerGitHub <noreply@github.com>2020-02-13 14:06:17 +0800
commit5dbf36f356e67c6eb7df68727417702fa100bec5 (patch)
tree7c624c1302be1515a7c63a4e86ebda75d1d3b580 /vendor/github.com/olivere/elastic/v7/script_get.go
parent17656021f165f8011e5f462f0336a083321c9e20 (diff)
downloadgitea-5dbf36f356e67c6eb7df68727417702fa100bec5.tar.gz
gitea-5dbf36f356e67c6eb7df68727417702fa100bec5.zip
Issue search support elasticsearch (#9428)
* Issue search support elasticsearch * Fix lint * Add indexer name on app.ini * add a warnning on SearchIssuesByKeyword * improve code
Diffstat (limited to 'vendor/github.com/olivere/elastic/v7/script_get.go')
-rw-r--r--vendor/github.com/olivere/elastic/v7/script_get.go169
1 files changed, 169 insertions, 0 deletions
diff --git a/vendor/github.com/olivere/elastic/v7/script_get.go b/vendor/github.com/olivere/elastic/v7/script_get.go
new file mode 100644
index 0000000000..81cedac710
--- /dev/null
+++ b/vendor/github.com/olivere/elastic/v7/script_get.go
@@ -0,0 +1,169 @@
+// 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"
+ "encoding/json"
+ "fmt"
+ "net/http"
+ "net/url"
+ "strings"
+
+ "github.com/olivere/elastic/v7/uritemplates"
+)
+
+// GetScriptService reads a stored script in Elasticsearch.
+//
+// See https://www.elastic.co/guide/en/elasticsearch/reference/7.0/modules-scripting.html
+// for details.
+type GetScriptService struct {
+ client *Client
+
+ pretty *bool // pretty format the returned JSON response
+ human *bool // return human readable values for statistics
+ errorTrace *bool // include the stack trace of returned errors
+ filterPath []string // list of filters used to reduce the response
+ headers http.Header // custom request-level HTTP headers
+
+ id string
+}
+
+// NewGetScriptService creates a new GetScriptService.
+func NewGetScriptService(client *Client) *GetScriptService {
+ return &GetScriptService{
+ client: client,
+ }
+}
+
+// Pretty tells Elasticsearch whether to return a formatted JSON response.
+func (s *GetScriptService) Pretty(pretty bool) *GetScriptService {
+ s.pretty = &pretty
+ return s
+}
+
+// Human specifies whether human readable values should be returned in
+// the JSON response, e.g. "7.5mb".
+func (s *GetScriptService) Human(human bool) *GetScriptService {
+ s.human = &human
+ return s
+}
+
+// ErrorTrace specifies whether to include the stack trace of returned errors.
+func (s *GetScriptService) ErrorTrace(errorTrace bool) *GetScriptService {
+ s.errorTrace = &errorTrace
+ return s
+}
+
+// FilterPath specifies a list of filters used to reduce the response.
+func (s *GetScriptService) FilterPath(filterPath ...string) *GetScriptService {
+ s.filterPath = filterPath
+ return s
+}
+
+// Header adds a header to the request.
+func (s *GetScriptService) Header(name string, value string) *GetScriptService {
+ if s.headers == nil {
+ s.headers = http.Header{}
+ }
+ s.headers.Add(name, value)
+ return s
+}
+
+// Headers specifies the headers of the request.
+func (s *GetScriptService) Headers(headers http.Header) *GetScriptService {
+ s.headers = headers
+ return s
+}
+
+// Id is the script ID.
+func (s *GetScriptService) Id(id string) *GetScriptService {
+ s.id = id
+ return s
+}
+
+// buildURL builds the URL for the operation.
+func (s *GetScriptService) buildURL() (string, string, url.Values, error) {
+ var (
+ err error
+ method = "GET"
+ path string
+ )
+
+ path, err = uritemplates.Expand("/_scripts/{id}", map[string]string{
+ "id": s.id,
+ })
+ if err != nil {
+ return "", "", url.Values{}, err
+ }
+
+ // Add query string parameters
+ params := url.Values{}
+ if v := s.pretty; v != nil {
+ params.Set("pretty", fmt.Sprint(*v))
+ }
+ if v := s.human; v != nil {
+ params.Set("human", fmt.Sprint(*v))
+ }
+ if v := s.errorTrace; v != nil {
+ params.Set("error_trace", fmt.Sprint(*v))
+ }
+ if len(s.filterPath) > 0 {
+ params.Set("filter_path", strings.Join(s.filterPath, ","))
+ }
+ return method, path, params, nil
+}
+
+// Validate checks if the operation is valid.
+func (s *GetScriptService) Validate() error {
+ var invalid []string
+ if s.id == "" {
+ invalid = append(invalid, "Id")
+ }
+ if len(invalid) > 0 {
+ return fmt.Errorf("missing required fields: %v", invalid)
+ }
+ return nil
+}
+
+// Do executes the operation.
+func (s *GetScriptService) Do(ctx context.Context) (*GetScriptResponse, error) {
+ // Check pre-conditions
+ if err := s.Validate(); err != nil {
+ return nil, err
+ }
+
+ // Get URL for request
+ method, path, params, err := s.buildURL()
+ if err != nil {
+ return nil, err
+ }
+
+ // Get HTTP response
+ res, err := s.client.PerformRequest(ctx, PerformRequestOptions{
+ Method: method,
+ Path: path,
+ Params: params,
+ Headers: s.headers,
+ })
+ if err != nil {
+ return nil, err
+ }
+
+ // Return operation response
+ ret := new(GetScriptResponse)
+ if err := s.client.decoder.Decode(res.Body, ret); err != nil {
+ return nil, err
+ }
+ return ret, nil
+}
+
+// GetScriptResponse is the result of getting a stored script
+// in Elasticsearch.
+type GetScriptResponse struct {
+ Id string `json:"_id"`
+ Found bool `json:"found"`
+ Script json.RawMessage `json:"script"`
+}