get data from consul

Issue-ID: MSB-243

Change-Id: I00cc63ef47d107c98e8fc9a46f668eae876e7381
Signed-off-by: Lvbo163 <lv.bo163@zte.com.cn>

diff --git a/msb2pilot/src/msb2pilot/consul/controller.go b/msb2pilot/src/msb2pilot/consul/controller.go
index ca57bd2..1ba2cd8 100644 (file)
--- a/msb2pilot/src/msb2pilot/consul/controller.go
+++ b/msb2pilot/src/msb2pilot/consul/controller.go
@@ -71,3 +71,21 @@ func loadCfgInfo(path string) (map[interface{}]interface{}, error) {
        }
        return result, nil
 }
+
+func GetServices() (map[string][]string, error) {
+       data, _, err := client.Catalog().Services(nil)
+
+       if err != nil {
+               return nil, err
+       }
+       return data, nil
+}
+
+func GetInstances(serviceName string) ([]*api.CatalogService, error) {
+       endpoints, _, err := client.Catalog().Service(serviceName, "", nil)
+       if err != nil {
+               log.Log.Error("can not get endpoints of ", serviceName)
+               return nil, err
+       }
+       return endpoints, nil
+}