Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Add method to get shards

pull/743/head
Paul Dix 2014-06-12 16:59:50 -04:00
parent 63c9a5f67d
commit 687a2d99bf
1 changed files with 17 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
influxdb.go
View File

@ -113,7 +113,7 @@ func (self *Client) DeleteDatabase(name string) error {
return responseToError(resp, err, true)
}
func (self *Client) listSomething(url string) ([]map[string]interface{}, error) {
func (self *Client) get(url string) ([]byte, error) {
resp, err := self.httpClient.Get(url)
err = responseToError(resp, err, false)
if err != nil {
@ -121,6 +121,11 @@ func (self *Client) listSomething(url string) ([]map[string]interface{}, error)
}
defer resp.Body.Close()
body, err := ioutil.ReadAll(resp.Body)
return body, err
}
func (self *Client) listSomething(url string) ([]map[string]interface{}, error) {
body, err := self.get(url)
if err != nil {
return nil, err
}
@ -377,3 +382,14 @@ func (self *Client) DeleteContinuousQueries(id int) error {
resp, err := self.del(url)
return responseToError(resp, err, true)
}
func (self *Client) GetShards() (map[string]interface{}, error) {
url := self.getUrlWithUserAndPass("/cluster/shards", self.username, self.password)
body, err := self.get(url)
shards := map[string]interface{}{}
err = json.Unmarshal(body, &shards)
if err != nil {
return nil, err
}
return shards, nil
}