Test IndicesExist

This commit is contained in:
Marin Bek 2014-11-11 15:37:50 +01:00
parent e5d37bf945
commit 92d2eb17fa

View File

@ -1012,3 +1012,24 @@ func (s *GoesTestSuite) TestPutMapping(c *C) {
c.Assert(response.Acknowledged, Equals, true) c.Assert(response.Acknowledged, Equals, true)
c.Assert(response.TimedOut, Equals, false) c.Assert(response.TimedOut, Equals, false)
} }
func (s *GoesTestSuite) TestIndicesExist(c *C) {
indexName := "testindicesexist"
conn := NewConnection(ES_HOST, ES_PORT)
// just in case
conn.DeleteIndex(indexName)
exists, err := conn.IndicesExist(indexName)
c.Assert(exists, Equals, false)
_, err = conn.CreateIndex(indexName, map[string]interface{}{})
c.Assert(err, IsNil)
defer conn.DeleteIndex(indexName)
exists, err = conn.IndicesExist(indexName)
c.Assert(exists, Equals, true)
exists, err = conn.IndicesExist(indexName, "nonexistent")
c.Assert(exists, Equals, false)
}