From 2919645aa79e54f9a3f0da8d799dc266f961f64f Mon Sep 17 00:00:00 2001 From: Lvbo163 Date: Thu, 2 Aug 2018 09:15:56 +0800 Subject: get data from consul Issue-ID: MSB-243 Change-Id: I00cc63ef47d107c98e8fc9a46f668eae876e7381 Signed-off-by: Lvbo163 --- msb2pilot/src/msb2pilot/consul/controller.go | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+) (limited to 'msb2pilot/src') diff --git a/msb2pilot/src/msb2pilot/consul/controller.go b/msb2pilot/src/msb2pilot/consul/controller.go index ca57bd2..1ba2cd8 100644 --- 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 +} -- cgit