GaoreGo/goes
7
0
Fork 0
Code Pull Requests Releases 2 Activity

Give ES some time to work in tests

Browse Source
This commit is contained in:
Marin Bek 2014-11-15 23:08:40 +01:00
parent 08d26b69e0
commit 1453d3c31c
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
goes_test.go
View File

@ -1035,6 +1035,7 @@ func (s *GoesTestSuite) TestIndicesExist(c *C) {
_, err = conn.CreateIndex(indexName, map[string]interface{}{}) _, err = conn.CreateIndex(indexName, map[string]interface{}{})
c.Assert(err, IsNil) c.Assert(err, IsNil)
defer conn.DeleteIndex(indexName) defer conn.DeleteIndex(indexName)
time.Sleep(200 * time.Millisecond)
exists, err = conn.IndicesExist(indexName) exists, err = conn.IndicesExist(indexName)
c.Assert(exists, Equals, true) c.Assert(exists, Equals, true)
@ -1070,6 +1071,7 @@ func (s *GoesTestSuite) TestUpdate(c *C) {
extraArgs := make(url.Values, 1) extraArgs := make(url.Values, 1)
response, err := conn.Index(d, extraArgs) response, err := conn.Index(d, extraArgs)
c.Assert(err, IsNil) c.Assert(err, IsNil)
time.Sleep(200 * time.Millisecond)
expectedResponse := Response{ expectedResponse := Response{
Index: indexName, Index: indexName,
@ -1099,6 +1101,7 @@ func (s *GoesTestSuite) TestUpdate(c *C) {
c.Skip("Scripting is disabled on server, skipping this test") c.Skip("Scripting is disabled on server, skipping this test")
return return
} }
time.Sleep(200 * time.Millisecond)
c.Assert(err, Equals, nil) c.Assert(err, Equals, nil)
@ -1113,6 +1116,7 @@ func (s *GoesTestSuite) TestUpdate(c *C) {
d.Id = docId d.Id = docId
response, err = conn.Update(d, query, extraArgs) response, err = conn.Update(d, query, extraArgs)
c.Assert(err, Equals, nil) c.Assert(err, Equals, nil)
time.Sleep(200 * time.Millisecond)
response, err = conn.Get(indexName, docType, docId, url.Values{}) response, err = conn.Get(indexName, docType, docId, url.Values{})
c.Assert(err, Equals, nil) c.Assert(err, Equals, nil)
@ -1132,6 +1136,8 @@ func (s *GoesTestSuite) TestGetMapping(c *C) {
c.Assert(err, IsNil) c.Assert(err, IsNil)
defer conn.DeleteIndex(indexName) defer conn.DeleteIndex(indexName)
time.Sleep(300 * time.Millisecond)
response, err := conn.GetMapping([]string{docType}, indexName) response, err := conn.GetMapping([]string{docType}, indexName)
c.Assert(err, Equals, nil) c.Assert(err, Equals, nil)
c.Assert(len(response.Raw), Equals, 0) c.Assert(len(response.Raw), Equals, 0)
@ -1147,6 +1153,7 @@ func (s *GoesTestSuite) TestGetMapping(c *C) {
response, err = conn.Index(d, url.Values{}) response, err = conn.Index(d, url.Values{})
c.Assert(err, IsNil) c.Assert(err, IsNil)
time.Sleep(200 * time.Millisecond)
response, err = conn.GetMapping([]string{docType}, indexName) response, err = conn.GetMapping([]string{docType}, indexName)
c.Assert(err, Equals, nil) c.Assert(err, Equals, nil)