Make ginkgo build from vendor dir work

.travis.yml

@@ -1,34 +1,31 @@
 language: go
 
-addons:
-  apt:
-    packages:
-      - oracle-java8-set-default
-
 go:
-  - 1.6.4
+  - 1.5.4
-  - 1.7.5
+  - 1.6.3
+  - 1.7.1
 
 env:
   global:
-    - JAVA_HOME=/usr/lib/jvm/java-8-oracle
+    - GO15VENDOREXPERIMENT=1
   matrix:
-    - ES_VERSION=1.7.5 ES_URL=https://download.elastic.co/elasticsearch/elasticsearch/elasticsearch-1.7.5.tar.gz
+    - ES_VERSION=1.3.4
-    - ES_VERSION=2.4.4 ES_URL=https://download.elastic.co/elasticsearch/release/org/elasticsearch/distribution/tar/elasticsearch/2.4.4/elasticsearch-2.4.4.tar.gz
+    - ES_VERSION=1.4.4
-    - ES_VERSION=5.2.0 ES_URL=https://artifacts.elastic.co/downloads/elasticsearch/elasticsearch-5.2.0.tar.gz
+    - ES_VERSION=1.5.2
+    - ES_VERSION=1.6.0
+    - ES_VERSION=1.7.0
 
 before_script:
-  - java -version
-  - echo $JAVA_HOME
   - mkdir ${HOME}/elasticsearch
-  - wget $ES_URL
+  - wget https://download.elastic.co/elasticsearch/elasticsearch/elasticsearch-${ES_VERSION}.tar.gz
   - tar -xzf elasticsearch-${ES_VERSION}.tar.gz -C ${HOME}/elasticsearch
-  - "echo 'script.inline: true' >> ${HOME}/elasticsearch/elasticsearch-${ES_VERSION}/config/elasticsearch.yml"
+  - "echo 'script.groovy.sandbox.enabled: true' >> ${HOME}/elasticsearch/elasticsearch-${ES_VERSION}/config/elasticsearch.yml"
-  - ${HOME}/elasticsearch/elasticsearch-${ES_VERSION}/bin/elasticsearch &
+  - ${HOME}/elasticsearch/elasticsearch-${ES_VERSION}/bin/elasticsearch >/dev/null &
-  - wget --retry-connrefused http://127.0.0.1:9200/ # Wait for ES to start up
+  - sleep 10 # Wait for ES to start up
 
 install:
   - go get github.com/Masterminds/glide
 
 script:
+  - pwd
   - make test

goes.go

@@ -34,7 +34,7 @@ func (err *SearchError) Error() string {
 // This function is pretty useless for now but might be useful in a near future
 // if wee need more features like connection pooling or load balancing.
 func NewClient(host string, port string) *Client {
-	return &Client{host, port, http.DefaultClient, "", "", ""}
+	return &Client{host, port, http.DefaultClient}
 }
 
 // WithHTTPClient sets the http.Client to be used with the connection. Returns the original client.
@@ -43,116 +43,93 @@ func (c *Client) WithHTTPClient(cl *http.Client) *Client {
 	return c
 }
 
-// Version returns the detected version of the connected ES server
-func (c *Client) Version() (string, error) {
-	// Use cached version if it was already fetched
-	if c.version != "" {
-		return c.version, nil
-	}
-
-	// Get the version if it was not cached
-	r := Request{Method: "GET"}
-	res, err := c.Do(&r)
-	if err != nil {
-		return "", err
-	}
-	if version, ok := res.Raw["version"].(map[string]interface{}); ok {
-		if number, ok := version["number"].(string); ok {
-			c.version = number
-			return number, nil
-		}
-	}
-	return "", errors.New("No version returned by ElasticSearch Server")
-}
-
 // CreateIndex creates a new index represented by a name and a mapping
 func (c *Client) CreateIndex(name string, mapping interface{}) (*Response, error) {
 	r := Request{
+		Conn:      c,
 		Query:     mapping,
 		IndexList: []string{name},
 		Method:    "PUT",
 	}
 
-	return c.Do(&r)
+	return r.Run()
 }
 
 // DeleteIndex deletes an index represented by a name
 func (c *Client) DeleteIndex(name string) (*Response, error) {
 	r := Request{
+		Conn:      c,
 		IndexList: []string{name},
 		Method:    "DELETE",
 	}
 
-	return c.Do(&r)
+	return r.Run()
 }
 
 // RefreshIndex refreshes an index represented by a name
 func (c *Client) RefreshIndex(name string) (*Response, error) {
 	r := Request{
+		Conn:      c,
 		IndexList: []string{name},
 		Method:    "POST",
 		API:       "_refresh",
 	}
 
-	return c.Do(&r)
+	return r.Run()
 }
 
 // UpdateIndexSettings updates settings for existing index represented by a name and a settings
 // as described here: https://www.elastic.co/guide/en/elasticsearch/reference/current/indices-update-settings.html
 func (c *Client) UpdateIndexSettings(name string, settings interface{}) (*Response, error) {
 	r := Request{
+		Conn:      c,
 		Query:     settings,
 		IndexList: []string{name},
 		Method:    "PUT",
 		API:       "_settings",
 	}
 
-	return c.Do(&r)
+	return r.Run()
 }
 
 // Optimize an index represented by a name, extra args are also allowed please check:
 // http://www.elasticsearch.org/guide/en/elasticsearch/reference/current/indices-optimize.html#indices-optimize
 func (c *Client) Optimize(indexList []string, extraArgs url.Values) (*Response, error) {
 	r := Request{
+		Conn:      c,
 		IndexList: indexList,
 		ExtraArgs: extraArgs,
 		Method:    "POST",
 		API:       "_optimize",
 	}
-	if version, _ := c.Version(); version > "2.1" {
-		r.API = "_forcemerge"
-	}
 
-	return c.Do(&r)
+	return r.Run()
-}
-
-// ForceMerge is the same as Optimize, but matches the naming of the endpoint as of ES 2.1.0
-func (c *Client) ForceMerge(indexList []string, extraArgs url.Values) (*Response, error) {
-	return c.Optimize(indexList, extraArgs)
 }
 
 // Stats fetches statistics (_stats) for the current elasticsearch server
 func (c *Client) Stats(indexList []string, extraArgs url.Values) (*Response, error) {
 	r := Request{
+		Conn:      c,
 		IndexList: indexList,
 		ExtraArgs: extraArgs,
 		Method:    "GET",
 		API:       "_stats",
 	}
 
-	return c.Do(&r)
+	return r.Run()
 }
 
 // IndexStatus fetches the status (_status) for the indices defined in
 // indexList. Use _all in indexList to get stats for all indices
 func (c *Client) IndexStatus(indexList []string) (*Response, error) {
 	r := Request{
+		Conn:      c,
 		IndexList: indexList,
 		Method:    "GET",
 		API:       "_status",
 	}
 
-	return c.Do(&r)
+	return r.Run()
 }
 
 // BulkSend bulk adds multiple documents in bulk mode
@@ -175,7 +152,7 @@ func (c *Client) BulkSend(documents []Document) (*Response, error) {
 
 	// len(documents) * 2 : action + optional_sources
 	// + 1 : room for the trailing \n
-	bulkData := make([][]byte, 0, len(documents)*2+1)
+	bulkData := make([][]byte, len(documents)*2+1)
 	i := 0
 
 	for _, doc := range documents {
@@ -191,7 +168,7 @@ func (c *Client) BulkSend(documents []Document) (*Response, error) {
 			return &Response{}, err
 		}
 
-		bulkData = append(bulkData, action)
+		bulkData[i] = action
 		i++
 
 		if doc.Fields != nil {
@@ -217,42 +194,28 @@ func (c *Client) BulkSend(documents []Document) (*Response, error) {
 				return &Response{}, err
 			}
 
-			bulkData = append(bulkData, sources)
+			bulkData[i] = sources
 			i++
 		}
 	}
 
 	// forces an extra trailing \n absolutely necessary for elasticsearch
-	bulkData = append(bulkData, []byte(nil))
+	bulkData[len(bulkData)-1] = []byte(nil)
 
 	r := Request{
+		Conn:     c,
 		Method:   "POST",
 		API:      "_bulk",
 		BulkData: bytes.Join(bulkData, []byte("\n")),
 	}
 
-	resp, err := c.Do(&r)
+	return r.Run()
-	if err != nil {
-		return resp, err
-	}
-
-	if resp.Errors {
-		for _, item := range resp.Items {
-			for _, i := range item {
-				if i.Error != "" {
-					return resp, &SearchError{i.Error, i.Status}
-				}
-			}
-		}
-		return resp, &SearchError{Msg: "Unknown error while bulk indexing"}
-	}
-
-	return resp, err
 }
 
 // Search executes a search query against an index
 func (c *Client) Search(query interface{}, indexList []string, typeList []string, extraArgs url.Values) (*Response, error) {
 	r := Request{
+		Conn:      c,
 		Query:     query,
 		IndexList: indexList,
 		TypeList:  typeList,
@@ -261,12 +224,13 @@ func (c *Client) Search(query interface{}, indexList []string, typeList []string
 		ExtraArgs: extraArgs,
 	}
 
-	return c.Do(&r)
+	return r.Run()
 }
 
 // Count executes a count query against an index, use the Count field in the response for the result
 func (c *Client) Count(query interface{}, indexList []string, typeList []string, extraArgs url.Values) (*Response, error) {
 	r := Request{
+		Conn:      c,
 		Query:     query,
 		IndexList: indexList,
 		TypeList:  typeList,
@@ -275,7 +239,7 @@ func (c *Client) Count(query interface{}, indexList []string, typeList []string,
 		ExtraArgs: extraArgs,
 	}
 
-	return c.Do(&r)
+	return r.Run()
 }
 
 //Query runs a query against an index using the provided http method.
@@ -283,6 +247,7 @@ func (c *Client) Count(query interface{}, indexList []string, typeList []string,
 //for the HTTP method.
 func (c *Client) Query(query interface{}, indexList []string, typeList []string, httpMethod string, extraArgs url.Values) (*Response, error) {
 	r := Request{
+		Conn:      c,
 		Query:     query,
 		IndexList: indexList,
 		TypeList:  typeList,
@@ -291,56 +256,18 @@ func (c *Client) Query(query interface{}, indexList []string, typeList []string,
 		ExtraArgs: extraArgs,
 	}
 
-	return c.Do(&r)
+	return r.Run()
 }
 
-// DeleteByQuery deletes documents matching the specified query. It will return an error for ES 2.x,
+// Scan starts scroll over an index
-// because delete by query support was removed in those versions.
-func (c *Client) DeleteByQuery(query interface{}, indexList []string, typeList []string, extraArgs url.Values) (*Response, error) {
-	version, err := c.Version()
-	if err != nil {
-		return nil, err
-	}
-	if version > "2" && version < "5" {
-		return nil, errors.New("ElasticSearch 2.x does not support delete by query")
-	}
-
-	r := Request{
-		Query:     query,
-		IndexList: indexList,
-		TypeList:  typeList,
-		Method:    "DELETE",
-		API:       "_query",
-		ExtraArgs: extraArgs,
-	}
-
-	if version > "5" {
-		r.API = "_delete_by_query"
-		r.Method = "POST"
-	}
-
-	return c.Do(&r)
-}
-
-// Scan starts scroll over an index.
-// For ES versions < 5.x, it uses search_type=scan; for 5.x it uses sort=_doc. This means that data
-// will  be returned in the initial response for 5.x versions, but not for older versions. Code
-// wishing to be compatible with both should be written to handle either case.
 func (c *Client) Scan(query interface{}, indexList []string, typeList []string, timeout string, size int) (*Response, error) {
 	v := url.Values{}
-	version, err := c.Version()
+	v.Add("search_type", "scan")
-	if err != nil {
-		return nil, err
-	}
-	if version > "5" {
-		v.Add("sort", "_doc")
-	} else {
-		v.Add("search_type", "scan")
-	}
 	v.Add("scroll", timeout)
 	v.Add("size", strconv.Itoa(size))
 
 	r := Request{
+		Conn:      c,
 		Query:     query,
 		IndexList: indexList,
 		TypeList:  typeList,
@@ -349,44 +276,36 @@ func (c *Client) Scan(query interface{}, indexList []string, typeList []string,
 		ExtraArgs: v,
 	}
 
-	return c.Do(&r)
+	return r.Run()
 }
 
 // Scroll fetches data by scroll id
 func (c *Client) Scroll(scrollID string, timeout string) (*Response, error) {
+	v := url.Values{}
+	v.Add("scroll", timeout)
+
 	r := Request{
-		Method: "POST",
+		Conn:      c,
-		API:    "_search/scroll",
+		Method:    "POST",
+		API:       "_search/scroll",
+		ExtraArgs: v,
+		Body:      []byte(scrollID),
 	}
 
-	if version, err := c.Version(); err != nil {
+	return r.Run()
-		return nil, err
-	} else if version > "2" {
-		r.Body, err = json.Marshal(map[string]string{"scroll": timeout, "scroll_id": scrollID})
-		if err != nil {
-			return nil, err
-		}
-	} else {
-		v := url.Values{}
-		v.Add("scroll", timeout)
-		v.Add("scroll_id", scrollID)
-
-		r.ExtraArgs = v
-	}
-
-	return c.Do(&r)
 }
 
 // Get a typed document by its id
 func (c *Client) Get(index string, documentType string, id string, extraArgs url.Values) (*Response, error) {
 	r := Request{
+		Conn:      c,
 		IndexList: []string{index},
 		Method:    "GET",
 		API:       documentType + "/" + id,
 		ExtraArgs: extraArgs,
 	}
 
-	return c.Do(&r)
+	return r.Run()
 }
 
 // Index indexes a Document
@@ -394,6 +313,7 @@ func (c *Client) Get(index string, documentType string, id string, extraArgs url
 // URL arguments, for example, to control routing, ttl, version, op_type, etc.
 func (c *Client) Index(d Document, extraArgs url.Values) (*Response, error) {
 	r := Request{
+		Conn:      c,
 		Query:     d.Fields,
 		IndexList: []string{d.Index.(string)},
 		TypeList:  []string{d.Type},
@@ -406,7 +326,7 @@ func (c *Client) Index(d Document, extraArgs url.Values) (*Response, error) {
 		r.ID = d.ID.(string)
 	}
 
-	return c.Do(&r)
+	return r.Run()
 }
 
 // Delete deletes a Document d
@@ -414,6 +334,7 @@ func (c *Client) Index(d Document, extraArgs url.Values) (*Response, error) {
 // URL arguments, for example, to control routing.
 func (c *Client) Delete(d Document, extraArgs url.Values) (*Response, error) {
 	r := Request{
+		Conn:      c,
 		IndexList: []string{d.Index.(string)},
 		TypeList:  []string{d.Type},
 		ExtraArgs: extraArgs,
@@ -421,7 +342,117 @@ func (c *Client) Delete(d Document, extraArgs url.Values) (*Response, error) {
 		ID:        d.ID.(string),
 	}
 
-	return c.Do(&r)
+	return r.Run()
+}
+
+// Run executes an elasticsearch Request. It converts data to Json, sends the
+// request and returns the Response obtained
+func (req *Request) Run() (*Response, error) {
+	body, statusCode, err := req.run()
+	esResp := &Response{Status: statusCode}
+
+	if err != nil {
+		return esResp, err
+	}
+
+	if req.Method != "HEAD" {
+		err = json.Unmarshal(body, &esResp)
+		if err != nil {
+			return esResp, err
+		}
+		err = json.Unmarshal(body, &esResp.Raw)
+		if err != nil {
+			return esResp, err
+		}
+	}
+
+	if req.API == "_bulk" && esResp.Errors {
+		for _, item := range esResp.Items {
+			for _, i := range item {
+				if i.Error != "" {
+					return esResp, &SearchError{i.Error, i.Status}
+				}
+			}
+		}
+		return esResp, &SearchError{Msg: "Unknown error while bulk indexing"}
+	}
+
+	if esResp.Error != "" {
+		return esResp, &SearchError{esResp.Error, esResp.Status}
+	}
+
+	return esResp, nil
+}
+
+func (req *Request) run() ([]byte, uint64, error) {
+	postData := []byte{}
+
+	// XXX : refactor this
+	if len(req.Body) > 0 {
+		postData = req.Body
+	} else if req.API == "_bulk" {
+		postData = req.BulkData
+	} else {
+		b, err := json.Marshal(req.Query)
+		if err != nil {
+			return nil, 0, err
+		}
+		postData = b
+	}
+
+	reader := bytes.NewReader(postData)
+
+	newReq, err := http.NewRequest(req.Method, req.URL(), reader)
+	if err != nil {
+		return nil, 0, err
+	}
+
+	if req.Method == "POST" || req.Method == "PUT" {
+		newReq.Header.Set("Content-Type", "application/json")
+	}
+
+	resp, err := req.Conn.Client.Do(newReq)
+	if err != nil {
+		return nil, 0, err
+	}
+
+	defer resp.Body.Close()
+
+	body, err := ioutil.ReadAll(resp.Body)
+	if err != nil {
+		return nil, uint64(resp.StatusCode), err
+	}
+
+	if resp.StatusCode > 201 && resp.StatusCode < 400 {
+		return nil, uint64(resp.StatusCode), errors.New(string(body))
+	}
+
+	return body, uint64(resp.StatusCode), nil
+}
+
+// URL builds a Request for a URL
+func (req *Request) URL() string {
+	path := "/" + strings.Join(req.IndexList, ",")
+
+	if len(req.TypeList) > 0 {
+		path += "/" + strings.Join(req.TypeList, ",")
+	}
+
+	// XXX : for indexing documents using the normal (non bulk) API
+	if len(req.ID) > 0 {
+		path += "/" + req.ID
+	}
+
+	path += "/" + req.API
+
+	u := url.URL{
+		Scheme:   "http",
+		Host:     fmt.Sprintf("%s:%s", req.Conn.Host, req.Conn.Port),
+		Path:     path,
+		RawQuery: req.ExtraArgs.Encode(),
+	}
+
+	return u.String()
 }
 
 // Buckets returns list of buckets in aggregation
@@ -458,36 +489,39 @@ func (b Bucket) Aggregation(name string) Aggregation {
 func (c *Client) PutMapping(typeName string, mapping interface{}, indexes []string) (*Response, error) {
 
 	r := Request{
+		Conn:      c,
 		Query:     mapping,
 		IndexList: indexes,
 		Method:    "PUT",
 		API:       "_mappings/" + typeName,
 	}
 
-	return c.Do(&r)
+	return r.Run()
 }
 
 // GetMapping returns the mappings for the specified types
 func (c *Client) GetMapping(types []string, indexes []string) (*Response, error) {
 
 	r := Request{
+		Conn:      c,
 		IndexList: indexes,
 		Method:    "GET",
 		API:       "_mapping/" + strings.Join(types, ","),
 	}
 
-	return c.Do(&r)
+	return r.Run()
 }
 
 // IndicesExist checks whether index (or indices) exist on the server
 func (c *Client) IndicesExist(indexes []string) (bool, error) {
 
 	r := Request{
+		Conn:      c,
 		IndexList: indexes,
 		Method:    "HEAD",
 	}
 
-	resp, err := c.Do(&r)
+	resp, err := r.Run()
 
 	return resp.Status == 200, err
 }
@@ -495,6 +529,7 @@ func (c *Client) IndicesExist(indexes []string) (bool, error) {
 // Update updates the specified document using the _update endpoint
 func (c *Client) Update(d Document, query interface{}, extraArgs url.Values) (*Response, error) {
 	r := Request{
+		Conn:      c,
 		Query:     query,
 		IndexList: []string{d.Index.(string)},
 		TypeList:  []string{d.Type},
@@ -507,29 +542,25 @@ func (c *Client) Update(d Document, query interface{}, extraArgs url.Values) (*R
 		r.ID = d.ID.(string)
 	}
 
-	return c.Do(&r)
+	return r.Run()
 }
 
 // DeleteMapping deletes a mapping along with all data in the type
 func (c *Client) DeleteMapping(typeName string, indexes []string) (*Response, error) {
-	if version, err := c.Version(); err != nil {
-		return nil, err
-	} else if version > "2" {
-		return nil, errors.New("Deletion of mappings is not supported in ES 2.x and above.")
-	}
 
 	r := Request{
+		Conn:      c,
 		IndexList: indexes,
 		Method:    "DELETE",
 		API:       "_mappings/" + typeName,
 	}
 
-	return c.Do(&r)
+	return r.Run()
 }
 
 func (c *Client) modifyAlias(action string, alias string, indexes []string) (*Response, error) {
 	command := map[string]interface{}{
-		"actions": make([]map[string]interface{}, 0, 1),
+		"actions": make([]map[string]interface{}, 1),
 	}
 
 	for _, index := range indexes {
@@ -542,12 +573,13 @@ func (c *Client) modifyAlias(action string, alias string, indexes []string) (*Re
 	}
 
 	r := Request{
+		Conn:   c,
 		Query:  command,
 		Method: "POST",
 		API:    "_aliases",
 	}
 
-	return c.Do(&r)
+	return r.Run()
 }
 
 // AddAlias creates an alias to one or more indexes
@@ -564,94 +596,12 @@ func (c *Client) RemoveAlias(alias string, indexes []string) (*Response, error)
 func (c *Client) AliasExists(alias string) (bool, error) {
 
 	r := Request{
+		Conn:   c,
 		Method: "HEAD",
 		API:    "_alias/" + alias,
 	}
 
-	resp, err := c.Do(&r)
+	resp, err := r.Run()
 
 	return resp.Status == 200, err
 }
-
-func (c *Client) replaceHost(req *http.Request) {
-	req.URL.Scheme = "http"
-	req.URL.Host = fmt.Sprintf("%s:%s", c.Host, c.Port)
-}
-
-// DoRaw Does the provided requeset and returns the raw bytes and the status code of the response
-func (c *Client) DoRaw(r Requester) ([]byte, uint64, error) {
-	req, err := r.Request()
-	if err != nil {
-		return nil, 0, err
-	}
-	c.replaceHost(req)
-
-	if c.AuthUsername != "" {
-		req.SetBasicAuth(c.AuthUsername, c.AuthPassword)
-	}
-
-	return c.doRequest(req)
-}
-
-// Do runs the request returned by the requestor and returns the parsed response
-func (c *Client) Do(r Requester) (*Response, error) {
-	req, err := r.Request()
-	if err != nil {
-		return &Response{}, err
-	}
-	c.replaceHost(req)
-
-	if c.AuthUsername != "" {
-		req.SetBasicAuth(c.AuthUsername, c.AuthPassword)
-	}
-
-	body, statusCode, err := c.doRequest(req)
-	esResp := &Response{Status: statusCode}
-
-	if err != nil {
-		return esResp, err
-	}
-
-	if req.Method != "HEAD" {
-		err = json.Unmarshal(body, &esResp)
-		if err != nil {
-			return esResp, err
-		}
-		err = json.Unmarshal(body, &esResp.Raw)
-		if err != nil {
-			return esResp, err
-		}
-	}
-
-	if len(esResp.RawError) > 0 && esResp.RawError[0] == '"' {
-		json.Unmarshal(esResp.RawError, &esResp.Error)
-	} else {
-		esResp.Error = string(esResp.RawError)
-	}
-	esResp.RawError = nil
-
-	if esResp.Error != "" {
-		return esResp, &SearchError{esResp.Error, esResp.Status}
-	}
-
-	return esResp, nil
-}
-
-func (c *Client) doRequest(req *http.Request) ([]byte, uint64, error) {
-	resp, err := c.Client.Do(req)
-	if err != nil {
-		return nil, 0, err
-	}
-	defer resp.Body.Close()
-
-	body, err := ioutil.ReadAll(resp.Body)
-	if err != nil {
-		return nil, uint64(resp.StatusCode), err
-	}
-
-	if resp.StatusCode > 201 && resp.StatusCode < 400 {
-		return nil, uint64(resp.StatusCode), errors.New(string(body))
-	}
-
-	return body, uint64(resp.StatusCode), nil
-}

goes_test.go

@@ -5,13 +5,14 @@
 package goes
 
 import (
-	. "gopkg.in/check.v1"
 	"net/http"
 	"net/url"
 	"os"
 	"strings"
 	"testing"
 	"time"
+
+	. "github.com/go-check/check"
 )
 
 var (
@@ -40,7 +41,7 @@ func (s *GoesTestSuite) SetUpTest(c *C) {
 
 func (s *GoesTestSuite) TestNewClient(c *C) {
 	conn := NewClient(ESHost, ESPort)
-	c.Assert(conn, DeepEquals, &Client{ESHost, ESPort, http.DefaultClient, "", "", ""})
+	c.Assert(conn, DeepEquals, &Client{ESHost, ESPort, http.DefaultClient})
 }
 
 func (s *GoesTestSuite) TestWithHTTPClient(c *C) {
@@ -53,13 +54,16 @@ func (s *GoesTestSuite) TestWithHTTPClient(c *C) {
 	}
 	conn := NewClient(ESHost, ESPort).WithHTTPClient(cl)
 
-	c.Assert(conn, DeepEquals, &Client{ESHost, ESPort, cl, "", "", ""})
+	c.Assert(conn, DeepEquals, &Client{ESHost, ESPort, cl})
 	c.Assert(conn.Client.Transport.(*http.Transport).DisableCompression, Equals, true)
 	c.Assert(conn.Client.Transport.(*http.Transport).ResponseHeaderTimeout, Equals, 1*time.Second)
 }
 
 func (s *GoesTestSuite) TestUrl(c *C) {
+	conn := NewClient(ESHost, ESPort)
+
 	r := Request{
+		Conn:      conn,
 		Query:     "q",
 		IndexList: []string{"i"},
 		TypeList:  []string{},
@@ -67,21 +71,21 @@ func (s *GoesTestSuite) TestUrl(c *C) {
 		API:       "_search",
 	}
 
-	c.Assert(r.URL().String(), Equals, "/i/_search")
+	c.Assert(r.URL(), Equals, "http://"+ESHost+":"+ESPort+"/i/_search")
 
 	r.IndexList = []string{"a", "b"}
-	c.Assert(r.URL().String(), Equals, "/a,b/_search")
+	c.Assert(r.URL(), Equals, "http://"+ESHost+":"+ESPort+"/a,b/_search")
 
 	r.TypeList = []string{"c", "d"}
-	c.Assert(r.URL().String(), Equals, "/a,b/c,d/_search")
+	c.Assert(r.URL(), Equals, "http://"+ESHost+":"+ESPort+"/a,b/c,d/_search")
 
 	r.ExtraArgs = make(url.Values, 1)
 	r.ExtraArgs.Set("version", "1")
-	c.Assert(r.URL().String(), Equals, "/a,b/c,d/_search?version=1")
+	c.Assert(r.URL(), Equals, "http://"+ESHost+":"+ESPort+"/a,b/c,d/_search?version=1")
 
 	r.ID = "1234"
 	r.API = ""
-	c.Assert(r.URL().String(), Equals, "/a,b/c,d/1234/?version=1")
+	c.Assert(r.URL(), Equals, "http://"+ESHost+":"+ESPort+"/a,b/c,d/1234/?version=1")
 }
 
 func (s *GoesTestSuite) TestEsDown(c *C) {
@@ -90,12 +94,13 @@ func (s *GoesTestSuite) TestEsDown(c *C) {
 	var query = map[string]interface{}{"query": "foo"}
 
 	r := Request{
+		Conn:      conn,
 		Query:     query,
 		IndexList: []string{"i"},
 		Method:    "GET",
 		API:       "_search",
 	}
-	_, err := conn.Do(&r)
+	_, err := r.Run()
 
 	c.Assert(err, ErrorMatches, ".* no such host")
 }
@@ -106,14 +111,15 @@ func (s *GoesTestSuite) TestRunMissingIndex(c *C) {
 	var query = map[string]interface{}{"query": "foo"}
 
 	r := Request{
+		Conn:      conn,
 		Query:     query,
 		IndexList: []string{"i"},
 		Method:    "GET",
 		API:       "_search",
 	}
-	_, err := conn.Do(&r)
+	_, err := r.Run()
 
-	c.Assert(err.Error(), Matches, "\\[40.\\] .*i.*")
+	c.Assert(err.Error(), Equals, "[404] IndexMissingException[[i] missing]")
 }
 
 func (s *GoesTestSuite) TestCreateIndex(c *C) {
@@ -149,10 +155,9 @@ func (s *GoesTestSuite) TestDeleteIndexInexistantIndex(c *C) {
 	conn := NewClient(ESHost, ESPort)
 	resp, err := conn.DeleteIndex("foobar")
 
-	c.Assert(err.Error(), Matches, "\\[404\\] .*foobar.*")
+	c.Assert(err.Error(), Equals, "[404] IndexMissingException[[foobar] missing]")
 	resp.Raw = nil // Don't make us have to duplicate this.
-	c.Assert(resp.Status, Equals, uint64(404))
+	c.Assert(resp, DeepEquals, &Response{Status: 404, Error: "IndexMissingException[[foobar] missing]"})
-	c.Assert(resp.Error, Matches, ".*foobar.*")
 }
 
 func (s *GoesTestSuite) TestDeleteIndexExistingIndex(c *C) {
@@ -161,7 +166,6 @@ func (s *GoesTestSuite) TestDeleteIndexExistingIndex(c *C) {
 	indexName := "testdeleteindexexistingindex"
 
 	_, err := conn.CreateIndex(indexName, map[string]interface{}{})
-	defer conn.DeleteIndex(indexName)
 
 	c.Assert(err, IsNil)
 
@@ -180,12 +184,8 @@ func (s *GoesTestSuite) TestUpdateIndexSettings(c *C) {
 	conn := NewClient(ESHost, ESPort)
 	indexName := "testupdateindex"
 
-	// Just in case
-	conn.DeleteIndex(indexName)
-
 	_, err := conn.CreateIndex(indexName, map[string]interface{}{})
 	c.Assert(err, IsNil)
-	defer conn.DeleteIndex(indexName)
 
 	_, err = conn.UpdateIndexSettings(indexName, map[string]interface{}{
 		"index": map[string]interface{}{
@@ -204,7 +204,6 @@ func (s *GoesTestSuite) TestRefreshIndex(c *C) {
 
 	_, err := conn.CreateIndex(indexName, map[string]interface{}{})
 	c.Assert(err, IsNil)
-	defer conn.DeleteIndex(indexName)
 
 	_, err = conn.RefreshIndex(indexName)
 	c.Assert(err, IsNil)
@@ -220,7 +219,6 @@ func (s *GoesTestSuite) TestOptimize(c *C) {
 	conn.DeleteIndex(indexName)
 	_, err := conn.CreateIndex(indexName, map[string]interface{}{})
 	c.Assert(err, IsNil)
-	defer conn.DeleteIndex(indexName)
 
 	// we must wait for a bit otherwise ES crashes
 	time.Sleep(1 * time.Second)
@@ -267,7 +265,6 @@ func (s *GoesTestSuite) TestBulkSend(c *C) {
 	conn.DeleteIndex(indexName)
 	_, err := conn.CreateIndex(indexName, nil)
 	c.Assert(err, IsNil)
-	defer conn.DeleteIndex(indexName)
 
 	response, err := conn.BulkSend(tweets)
 	i := Item{
@@ -358,7 +355,6 @@ func (s *GoesTestSuite) TestStats(c *C) {
 	conn.DeleteIndex(indexName)
 	_, err := conn.CreateIndex(indexName, map[string]interface{}{})
 	c.Assert(err, IsNil)
-	defer conn.DeleteIndex(indexName)
 
 	// we must wait for a bit otherwise ES crashes
 	time.Sleep(1 * time.Second)
@@ -398,7 +394,9 @@ func (s *GoesTestSuite) TestIndexWithFieldsInStruct(c *C) {
 		},
 	}
 
-	response, err := conn.Index(d, nil)
+	extraArgs := make(url.Values, 1)
+	extraArgs.Set("ttl", "86400000")
+	response, err := conn.Index(d, extraArgs)
 	c.Assert(err, IsNil)
 
 	expectedResponse := &Response{
@@ -410,7 +408,6 @@ func (s *GoesTestSuite) TestIndexWithFieldsInStruct(c *C) {
 	}
 
 	response.Raw = nil
-	response.Shards = Shard{}
 	c.Assert(response, DeepEquals, expectedResponse)
 }
 
@@ -434,7 +431,9 @@ func (s *GoesTestSuite) TestIndexWithFieldsNotInMapOrStruct(c *C) {
 		Fields: "test",
 	}
 
-	_, err = conn.Index(d, nil)
+	extraArgs := make(url.Values, 1)
+	extraArgs.Set("ttl", "86400000")
+	_, err = conn.Index(d, extraArgs)
 	c.Assert(err, Not(IsNil))
 }
 
@@ -461,7 +460,9 @@ func (s *GoesTestSuite) TestIndexIdDefined(c *C) {
 		},
 	}
 
-	response, err := conn.Index(d, nil)
+	extraArgs := make(url.Values, 1)
+	extraArgs.Set("ttl", "86400000")
+	response, err := conn.Index(d, extraArgs)
 	c.Assert(err, IsNil)
 
 	expectedResponse := &Response{
@@ -473,7 +474,6 @@ func (s *GoesTestSuite) TestIndexIdDefined(c *C) {
 	}
 
 	response.Raw = nil
-	response.Shards = Shard{}
 	c.Assert(response, DeepEquals, expectedResponse)
 }
 
@@ -545,7 +545,6 @@ func (s *GoesTestSuite) TestDelete(c *C) {
 		Version: 2,
 	}
 	response.Raw = nil
-	response.Shards = Shard{}
 	c.Assert(response, DeepEquals, expectedResponse)
 
 	response, err = conn.Delete(d, url.Values{})
@@ -561,7 +560,6 @@ func (s *GoesTestSuite) TestDelete(c *C) {
 		Version: 3,
 	}
 	response.Raw = nil
-	response.Shards = Shard{}
 	c.Assert(response, DeepEquals, expectedResponse)
 }
 
@@ -571,8 +569,6 @@ func (s *GoesTestSuite) TestDeleteByQuery(c *C) {
 	docID := "1234"
 
 	conn := NewClient(ESHost, ESPort)
-	version, _ := conn.Version()
-
 	// just in case
 	conn.DeleteIndex(indexName)
 
@@ -612,13 +608,7 @@ func (s *GoesTestSuite) TestDeleteByQuery(c *C) {
 	c.Assert(err, IsNil)
 	c.Assert(response.Hits.Total, Equals, uint64(1))
 
-	response, err = conn.DeleteByQuery(query, []string{indexName}, []string{docType}, url.Values{})
+	response, err = conn.Query(query, []string{indexName}, []string{docType}, "DELETE", url.Values{})
-
-	// There's no delete by query in ES 2.x
-	if version > "2" && version < "5" {
-		c.Assert(err, ErrorMatches, ".* does not support delete by query")
-		return
-	}
 
 	c.Assert(err, IsNil)
 
@@ -631,13 +621,8 @@ func (s *GoesTestSuite) TestDeleteByQuery(c *C) {
 		Version: 0,
 	}
 	response.Raw = nil
-	response.Shards = Shard{}
-	response.Took = 0
 	c.Assert(response, DeepEquals, expectedResponse)
 
-	_, err = conn.RefreshIndex(indexName)
-	c.Assert(err, IsNil)
-
 	//should be 0 docs after delete by query
 	response, err = conn.Search(query, []string{indexName}, []string{docType}, url.Values{})
 	c.Assert(err, IsNil)
@@ -654,7 +639,6 @@ func (s *GoesTestSuite) TestGet(c *C) {
 	}
 
 	conn := NewClient(ESHost, ESPort)
-	version, _ := conn.Version()
 	conn.DeleteIndex(indexName)
 
 	_, err := conn.CreateIndex(indexName, map[string]interface{}{})
@@ -687,6 +671,11 @@ func (s *GoesTestSuite) TestGet(c *C) {
 	response.Raw = nil
 	c.Assert(response, DeepEquals, expectedResponse)
 
+	fields := make(url.Values, 1)
+	fields.Set("fields", "f1")
+	response, err = conn.Get(indexName, docType, docID, fields)
+	c.Assert(err, IsNil)
+
 	expectedResponse = &Response{
 		Status:  200,
 		Index:   indexName,
@@ -699,18 +688,6 @@ func (s *GoesTestSuite) TestGet(c *C) {
 		},
 	}
 
-	fields := make(url.Values, 1)
-	// The fields param is no longer supported in ES 5.x
-	if version < "5" {
-		fields.Set("fields", "f1")
-	} else {
-		expectedResponse.Source = map[string]interface{}{"f1": "foo"}
-		expectedResponse.Fields = nil
-		fields.Set("_source", "f1")
-	}
-	response, err = conn.Get(indexName, docType, docID, fields)
-	c.Assert(err, IsNil)
-
 	response.Raw = nil
 	c.Assert(response, DeepEquals, expectedResponse)
 }
@@ -824,12 +801,6 @@ func (s *GoesTestSuite) TestCount(c *C) {
 func (s *GoesTestSuite) TestIndexStatus(c *C) {
 	indexName := "testindexstatus"
 	conn := NewClient(ESHost, ESPort)
-
-	// _status endpoint was removed in ES 2.0
-	if version, _ := conn.Version(); version > "2" {
-		return
-	}
-
 	conn.DeleteIndex(indexName)
 
 	mapping := map[string]interface{}{
@@ -958,43 +929,24 @@ func (s *GoesTestSuite) TestScroll(c *C) {
 	_, err = conn.RefreshIndex(indexName)
 	c.Assert(err, IsNil)
 
-	var query map[string]interface{}
+	query := map[string]interface{}{
-	version, _ := conn.Version()
+		"query": map[string]interface{}{
-	if version > "5" {
+			"filtered": map[string]interface{}{
-		query = map[string]interface{}{
+				"filter": map[string]interface{}{
-			"query": map[string]interface{}{
+					"term": map[string]interface{}{
-				"bool": map[string]interface{}{
+						"user": "foo",
-					"filter": map[string]interface{}{
-						"term": map[string]interface{}{
-							"user": "foo",
-						},
 					},
 				},
 			},
-		}
+		},
-	} else {
-		query = map[string]interface{}{
-			"query": map[string]interface{}{
-				"filtered": map[string]interface{}{
-					"filter": map[string]interface{}{
-						"term": map[string]interface{}{
-							"user": "foo",
-						},
-					},
-				},
-			},
-		}
 	}
 
-	searchResults, err := conn.Scan(query, []string{indexName}, []string{docType}, "1m", 1)
+	scan, err := conn.Scan(query, []string{indexName}, []string{docType}, "1m", 1)
 	c.Assert(err, IsNil)
-	c.Assert(len(searchResults.ScrollID) > 0, Equals, true)
+	c.Assert(len(scan.ScrollID) > 0, Equals, true)
 
-	// Versions < 5.x don't include results in the initial response
+	searchResults, err := conn.Scroll(scan.ScrollID, "1m")
-	if version < "5" {
+	c.Assert(err, IsNil)
-		searchResults, err = conn.Scroll(searchResults.ScrollID, "1m")
-		c.Assert(err, IsNil)
-	}
 
 	// some data in first chunk
 	c.Assert(searchResults.Hits.Total, Equals, uint64(2))
@@ -1066,16 +1018,6 @@ func (s *GoesTestSuite) TestAggregations(c *C) {
 			"index.number_of_shards":   1,
 			"index.number_of_replicas": 0,
 		},
-		"mappings": map[string]interface{}{
-			docType: map[string]interface{}{
-				"properties": map[string]interface{}{
-					"user": map[string]interface{}{
-						"type":  "string",
-						"index": "not_analyzed",
-					},
-				},
-			},
-		},
 	}
 
 	defer conn.DeleteIndex(indexName)
@@ -1241,44 +1183,23 @@ func (s *GoesTestSuite) TestUpdate(c *C) {
 	}
 
 	response.Raw = nil
-	response.Shards.Successful = 0
-	response.Shards.Total = 0
 	c.Assert(response, DeepEquals, expectedResponse)
 
 	// Now that we have an ordinary document indexed, try updating it
-	var query map[string]interface{}
+	query := map[string]interface{}{
-	if version, _ := conn.Version(); version > "5" {
+		"script": "ctx._source.counter += count",
-		query = map[string]interface{}{
+		"lang":   "groovy",
-			"script": map[string]interface{}{
+		"params": map[string]interface{}{
-				"inline": "ctx._source.counter += params.count",
+			"count": 5,
-				"lang":   "painless",
+		},
-				"params": map[string]interface{}{
+		"upsert": map[string]interface{}{
-					"count": 5,
+			"message": "candybar",
-				},
+			"user":    "admin",
-			},
+			"counter": 1,
-			"upsert": map[string]interface{}{
+		},
-				"message": "candybar",
-				"user":    "admin",
-				"counter": 1,
-			},
-		}
-	} else {
-		query = map[string]interface{}{
-			"script": "ctx._source.counter += count",
-			"lang":   "groovy",
-			"params": map[string]interface{}{
-				"count": 5,
-			},
-			"upsert": map[string]interface{}{
-				"message": "candybar",
-				"user":    "admin",
-				"counter": 1,
-			},
-		}
 	}
 
 	response, err = conn.Update(d, query, extraArgs)
-
 	if err != nil && strings.Contains(err.(*SearchError).Msg, "dynamic scripting") {
 		c.Skip("Scripting is disabled on server, skipping this test")
 		return
@@ -1382,10 +1303,6 @@ func (s *GoesTestSuite) TestDeleteMapping(c *C) {
 	time.Sleep(200 * time.Millisecond)
 
 	response, err = conn.DeleteMapping("tweet", []string{indexName})
-	if version, _ := conn.Version(); version > "2" {
-		c.Assert(err, ErrorMatches, ".*not supported.*")
-		return
-	}
 	c.Assert(err, IsNil)
 
 	c.Assert(response.Acknowledged, Equals, true)
@@ -1480,7 +1397,7 @@ func (s *GoesTestSuite) TestRemoveAlias(c *C) {
 
 	// Get document via alias
 	_, err = conn.Get(aliasName, docType, docID, url.Values{})
-	c.Assert(err.Error(), Matches, "\\[404\\] .*"+aliasName+".*")
+	c.Assert(err.Error(), Equals, "[404] IndexMissingException[["+aliasName+"] missing]")
 }
 
 func (s *GoesTestSuite) TestAliasExists(c *C) {

request.go

@@ -1,113 +0,0 @@
-package goes
-
-import (
-	"bytes"
-	"encoding/json"
-	"io/ioutil"
-	"net/http"
-	"net/url"
-	"strings"
-)
-
-// Requester implements Request which builds an HTTP request for Elasticsearch
-type Requester interface {
-	// Request should set the URL and Body (if needed). The host of the URL will be overwritten by the client.
-	Request() (*http.Request, error)
-}
-
-// Request holds a single request to elasticsearch
-type Request struct {
-	// A search query
-	Query interface{}
-
-	// Which index to search into
-	IndexList []string
-
-	// Which type to search into
-	TypeList []string
-
-	// HTTP Method to user (GET, POST ...)
-	Method string
-
-	// Which api keyword (_search, _bulk, etc) to use
-	API string
-
-	// Bulk data
-	BulkData []byte
-
-	// Request body
-	Body []byte
-
-	// A list of extra URL arguments
-	ExtraArgs url.Values
-
-	// Used for the id field when indexing a document
-	ID string
-
-	// Auth username
-	AuthUsername string
-
-	// Auth password
-	AuthPassword string
-}
-
-// URL builds a URL for a Request
-func (req *Request) URL() *url.URL {
-	var path string
-	if len(req.IndexList) > 0 {
-		path = "/" + strings.Join(req.IndexList, ",")
-	}
-
-	if len(req.TypeList) > 0 {
-		path += "/" + strings.Join(req.TypeList, ",")
-	}
-
-	// XXX : for indexing documents using the normal (non bulk) API
-	if len(req.ID) > 0 {
-		path += "/" + req.ID
-	}
-
-	path += "/" + req.API
-
-	u := url.URL{
-		//Scheme:   "http",
-		//Host:     fmt.Sprintf("%s:%s", req.Conn.Host, req.Conn.Port),
-		Path:     path,
-		RawQuery: req.ExtraArgs.Encode(),
-	}
-
-	return &u
-}
-
-// Request generates an http.Request based on the contents of the Request struct
-func (req *Request) Request() (*http.Request, error) {
-	postData := []byte{}
-
-	// XXX : refactor this
-	if len(req.Body) > 0 {
-		postData = req.Body
-	} else if req.API == "_bulk" {
-		postData = req.BulkData
-	} else if req.Query != nil {
-		b, err := json.Marshal(req.Query)
-		if err != nil {
-			return nil, err
-		}
-		postData = b
-	}
-
-	newReq, err := http.NewRequest(req.Method, "", nil)
-	if err != nil {
-		return nil, err
-	}
-	newReq.URL = req.URL()
-	newReq.Body = ioutil.NopCloser(bytes.NewReader(postData))
-	newReq.ContentLength = int64(len(postData))
-
-	if req.Method == "POST" || req.Method == "PUT" {
-		newReq.Header.Set("Content-Type", "application/json")
-	}
-	return newReq, nil
-}
-
-var _ Requester = (*Request)(nil)

structs.go

@@ -5,8 +5,8 @@
 package goes
 
 import (
-	"encoding/json"
 	"net/http"
+	"net/url"
 )
 
 // Client represents a connection to elasticsearch
@@ -20,22 +20,45 @@ type Client struct {
 	// Client is the http client used to make requests, allowing settings things
 	// such as timeouts etc
 	Client *http.Client
+}
 
-	// Detected version of ES
+// Request holds a single request to elasticsearch
-	version string
+type Request struct {
+	// Which connection will be used
+	Conn *Client
 
-	// user name for http basic auth
+	// A search query
-	AuthUsername string `json:"username"`
+	Query interface{}
 
-	// pass word  for http basic auth
+	// Which index to search into
-	AuthPassword string `json:"password"`
+	IndexList []string
+
+	// Which type to search into
+	TypeList []string
+
+	// HTTP Method to user (GET, POST ...)
+	Method string
+
+	// Which api keyword (_search, _bulk, etc) to use
+	API string
+
+	// Bulk data
+	BulkData []byte
+
+	// Request body
+	Body []byte
+
+	// A list of extra URL arguments
+	ExtraArgs url.Values
+
+	// Used for the id field when indexing a document
+	ID string
 }
 
 // Response holds an elasticsearch response
 type Response struct {
 	Acknowledged bool
 	Error        string
-	RawError     json.RawMessage `json:"error"`
 	Errors       bool
 	Status       uint64
 	Took         uint64