Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Close #381
- Loading branch information
Showing
9 changed files
with
791 additions
and
1 deletion.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,124 @@ | ||
// Copyright 2012-2016 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" | ||
"fmt" | ||
"net/url" | ||
|
||
"golang.org/x/net/context" | ||
|
||
"gopkg.in/olivere/elastic.v5/uritemplates" | ||
) | ||
|
||
// IngestDeletePipelineService deletes pipelines by ID. | ||
// It is documented at https://www.elastic.co/guide/en/elasticsearch/reference/5.0/delete-pipeline-api.html. | ||
type IngestDeletePipelineService struct { | ||
client *Client | ||
pretty bool | ||
id string | ||
masterTimeout string | ||
timeout string | ||
} | ||
|
||
// NewIngestDeletePipelineService creates a new IngestDeletePipelineService. | ||
func NewIngestDeletePipelineService(client *Client) *IngestDeletePipelineService { | ||
return &IngestDeletePipelineService{ | ||
client: client, | ||
} | ||
} | ||
|
||
// Id is documented as: Pipeline ID. | ||
func (s *IngestDeletePipelineService) Id(id string) *IngestDeletePipelineService { | ||
s.id = id | ||
return s | ||
} | ||
|
||
// MasterTimeout is documented as: Explicit operation timeout for connection to master node. | ||
func (s *IngestDeletePipelineService) MasterTimeout(masterTimeout string) *IngestDeletePipelineService { | ||
s.masterTimeout = masterTimeout | ||
return s | ||
} | ||
|
||
// Timeout is documented as: Explicit operation timeout. | ||
func (s *IngestDeletePipelineService) Timeout(timeout string) *IngestDeletePipelineService { | ||
s.timeout = timeout | ||
return s | ||
} | ||
|
||
// Pretty indicates that the JSON response be indented and human readable. | ||
func (s *IngestDeletePipelineService) Pretty(pretty bool) *IngestDeletePipelineService { | ||
s.pretty = pretty | ||
return s | ||
} | ||
|
||
// buildURL builds the URL for the operation. | ||
func (s *IngestDeletePipelineService) buildURL() (string, url.Values, error) { | ||
// Build URL | ||
path, err := uritemplates.Expand("/_ingest/pipeline/{id}", map[string]string{ | ||
"id": s.id, | ||
}) | ||
if err != nil { | ||
return "", url.Values{}, err | ||
} | ||
|
||
// Add query string parameters | ||
params := url.Values{} | ||
if s.pretty { | ||
params.Set("pretty", "1") | ||
} | ||
if s.masterTimeout != "" { | ||
params.Set("master_timeout", s.masterTimeout) | ||
} | ||
if s.timeout != "" { | ||
params.Set("timeout", s.timeout) | ||
} | ||
return path, params, nil | ||
} | ||
|
||
// Validate checks if the operation is valid. | ||
func (s *IngestDeletePipelineService) 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 *IngestDeletePipelineService) Do(ctx context.Context) (*IngestDeletePipelineResponse, error) { | ||
// Check pre-conditions | ||
if err := s.Validate(); err != nil { | ||
return nil, err | ||
} | ||
|
||
// Get URL for request | ||
path, params, err := s.buildURL() | ||
if err != nil { | ||
return nil, err | ||
} | ||
|
||
// Get HTTP response | ||
res, err := s.client.PerformRequest(ctx, "DELETE", path, params, nil) | ||
if err != nil { | ||
return nil, err | ||
} | ||
|
||
// Return operation response | ||
ret := new(IngestDeletePipelineResponse) | ||
if err := json.Unmarshal(res.Body, ret); err != nil { | ||
return nil, err | ||
} | ||
return ret, nil | ||
} | ||
|
||
// IngestDeletePipelineResponse is the response of IngestDeletePipelineService.Do. | ||
type IngestDeletePipelineResponse struct { | ||
Acknowledged bool `json:"acknowledged"` | ||
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,31 @@ | ||
// 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 "testing" | ||
|
||
func TestIngestDeletePipelineURL(t *testing.T) { | ||
client := setupTestClientAndCreateIndex(t) | ||
|
||
tests := []struct { | ||
Id string | ||
Expected string | ||
}{ | ||
{ | ||
"my-pipeline-id", | ||
"/_ingest/pipeline/my-pipeline-id", | ||
}, | ||
} | ||
|
||
for _, test := range tests { | ||
path, _, err := client.IngestDeletePipeline(test.Id).buildURL() | ||
if err != nil { | ||
t.Fatal(err) | ||
} | ||
if path != test.Expected { | ||
t.Errorf("expected %q; got: %q", test.Expected, path) | ||
} | ||
} | ||
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,118 @@ | ||
// Copyright 2012-2016 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" | ||
"net/url" | ||
"strings" | ||
|
||
"golang.org/x/net/context" | ||
|
||
"gopkg.in/olivere/elastic.v5/uritemplates" | ||
) | ||
|
||
// IngestGetPipelineService returns pipelines based on ID. | ||
// See https://www.elastic.co/guide/en/elasticsearch/reference/5.0/get-pipeline-api.html | ||
// for documentation. | ||
type IngestGetPipelineService struct { | ||
client *Client | ||
pretty bool | ||
id []string | ||
masterTimeout string | ||
} | ||
|
||
// NewIngestGetPipelineService creates a new IngestGetPipelineService. | ||
func NewIngestGetPipelineService(client *Client) *IngestGetPipelineService { | ||
return &IngestGetPipelineService{ | ||
client: client, | ||
} | ||
} | ||
|
||
// Id is a list of pipeline ids. Wildcards supported. | ||
func (s *IngestGetPipelineService) Id(id ...string) *IngestGetPipelineService { | ||
s.id = append(s.id, id...) | ||
return s | ||
} | ||
|
||
// MasterTimeout is an explicit operation timeout for connection to master node. | ||
func (s *IngestGetPipelineService) MasterTimeout(masterTimeout string) *IngestGetPipelineService { | ||
s.masterTimeout = masterTimeout | ||
return s | ||
} | ||
|
||
// Pretty indicates that the JSON response be indented and human readable. | ||
func (s *IngestGetPipelineService) Pretty(pretty bool) *IngestGetPipelineService { | ||
s.pretty = pretty | ||
return s | ||
} | ||
|
||
// buildURL builds the URL for the operation. | ||
func (s *IngestGetPipelineService) buildURL() (string, url.Values, error) { | ||
var err error | ||
var path string | ||
|
||
// Build URL | ||
if len(s.id) > 0 { | ||
path, err = uritemplates.Expand("/_ingest/pipeline/{id}", map[string]string{ | ||
"id": strings.Join(s.id, ","), | ||
}) | ||
} else { | ||
path = "/_ingest/pipeline" | ||
} | ||
if err != nil { | ||
return "", url.Values{}, err | ||
} | ||
|
||
// Add query string parameters | ||
params := url.Values{} | ||
if s.pretty { | ||
params.Set("pretty", "1") | ||
} | ||
if s.masterTimeout != "" { | ||
params.Set("master_timeout", s.masterTimeout) | ||
} | ||
return path, params, nil | ||
} | ||
|
||
// Validate checks if the operation is valid. | ||
func (s *IngestGetPipelineService) Validate() error { | ||
return nil | ||
} | ||
|
||
// Do executes the operation. | ||
func (s *IngestGetPipelineService) Do(ctx context.Context) (IngestGetPipelineResponse, error) { | ||
// Check pre-conditions | ||
if err := s.Validate(); err != nil { | ||
return nil, err | ||
} | ||
|
||
// Get URL for request | ||
path, params, err := s.buildURL() | ||
if err != nil { | ||
return nil, err | ||
} | ||
|
||
// Get HTTP response | ||
res, err := s.client.PerformRequest(ctx, "GET", path, params, nil) | ||
if err != nil { | ||
return nil, err | ||
} | ||
|
||
// Return operation response | ||
var ret IngestGetPipelineResponse | ||
if err := json.Unmarshal(res.Body, &ret); err != nil { | ||
return nil, err | ||
} | ||
return ret, nil | ||
} | ||
|
||
// IngestGetPipelineResponse is the response of IngestGetPipelineService.Do. | ||
type IngestGetPipelineResponse map[string]*IngestGetPipeline | ||
|
||
type IngestGetPipeline struct { | ||
ID string `json:"id"` | ||
Config map[string]interface{} `json:"config"` | ||
} |
Oops, something went wrong.