Merge branch 'master' of https://192.168.1.14/r/dbapi

panlei

2019-08-22 590c075d30a61f9ecb380a908860d6c827526e09

Merge branch 'master' of https://192.168.1.14/r/dbapi

 cluster.go

New file
@@ -0,0 +1,100 @@
package dbapi

import "encoding/json"

type ClusterApi struct {

}

func (api ClusterApi) Create(clusterName string, password string) (bool,interface{}) {
    url := BASIC_URL + DATA_URL_PREFIX + "/cluster/create"
    client := NewClient()
    paramBody := map[string]interface{}{
        "clusterName": clusterName,
        "password": password,
    }
    body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil)
    if err != nil {
        return false,nil
    }

    var res Result
    if err = json.Unmarshal(body, &res); err != nil {
        return false,nil
    }

    return res.Success,res.Data
}

func (api ClusterApi) Search(searchNum string, password string) (bool,interface{}) {
    url := BASIC_URL + DATA_URL_PREFIX + "/cluster/search"
    client := NewClient()
    paramBody := map[string]interface{}{
        "searchNum": searchNum,
        "password": password,
    }
    body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil)
    if err != nil {
        return false,nil
    }

    var res Result
    if err = json.Unmarshal(body, &res); err != nil {
        return false,nil
    }

    return res.Success,res.Data
}

func (api ClusterApi) GetSearchNodes() (bool,interface{}) {
    url := BASIC_URL + DATA_URL_PREFIX + "/cluster/getNodesByNum"
    client := NewClient()
    body,err := client.DoGetRequest(url, nil,nil)
    if err != nil {
        return false,nil
    }

    var res Result
    if err = json.Unmarshal(body, &res); err != nil {
        return false,nil
    }

    return res.Success,res.Data
}

func (api ClusterApi) StopSearching(searchNum string) (bool,interface{}) {
    url := BASIC_URL + DATA_URL_PREFIX + "/cluster/stopSearching"
    client := NewClient()
    paramBody := map[string]interface{}{
        "searchNum": searchNum,
    }
    body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil)
    if err != nil {
        return false,nil
    }

    var res Result
    if err = json.Unmarshal(body, &res); err != nil {
        return false,nil
    }

    return res.Success,res.Data
}

func (api ClusterApi) JoinCluster(paramBody map[string]interface{}) (bool,interface{}) {
    url := BASIC_URL + DATA_URL_PREFIX + "/cluster/joinCluster"
    client := NewClient()
    body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil)
    if err != nil {
        return false,nil
    }

    var res Result
    if err = json.Unmarshal(body, &res); err != nil {
        return false,nil
    }

    return res.Success,res.Data
}