diff options
author | Lvbo163 <lv.bo163@zte.com.cn> | 2018-08-07 15:12:22 +0800 |
---|---|---|
committer | Lvbo163 <lv.bo163@zte.com.cn> | 2018-08-07 15:12:22 +0800 |
commit | e782c794c9fe6441120b8d0d239414f9a3421288 (patch) | |
tree | 5069f759ac8027ab831f168b5416917761821957 /msb2pilot/src/msb2pilot/pilot | |
parent | 38447771f156197521f34f2c89f6b4fb4c42b28c (diff) |
add a test rest api
Issue-ID: MSB-271
Change-Id: Ic3476a98d66ad285f400e7bbdc6e8021be50e980
Signed-off-by: Lvbo163 <lv.bo163@zte.com.cn>
Diffstat (limited to 'msb2pilot/src/msb2pilot/pilot')
-rw-r--r-- | msb2pilot/src/msb2pilot/pilot/controller.go | 1 | ||||
-rw-r--r-- | msb2pilot/src/msb2pilot/pilot/msb.go | 10 |
2 files changed, 7 insertions, 4 deletions
diff --git a/msb2pilot/src/msb2pilot/pilot/controller.go b/msb2pilot/src/msb2pilot/pilot/controller.go index ddb59ec..f0cf87d 100644 --- a/msb2pilot/src/msb2pilot/pilot/controller.go +++ b/msb2pilot/src/msb2pilot/pilot/controller.go @@ -161,6 +161,7 @@ func Update(config *model.Config) (string, error) { } func operate(operation Operation, config *model.Config) (string, error) { + log.Log.Informational("%s %s %s %s", operation, config.Type, config.Name, config.Namespace) switch operation { case OperationCreate: return client.Create(*config) diff --git a/msb2pilot/src/msb2pilot/pilot/msb.go b/msb2pilot/src/msb2pilot/pilot/msb.go index d81b2f1..fb87d08 100644 --- a/msb2pilot/src/msb2pilot/pilot/msb.go +++ b/msb2pilot/src/msb2pilot/pilot/msb.go @@ -47,6 +47,7 @@ func SyncMsbData(newServices []*models.MsbService) { func saveService(operation Operation, services []*models.MsbService) { if len(services) == 0 { + log.Log.Debug("0 services need to %s. \n", operation) return } configs, err := parseServiceToConfig(services) @@ -55,20 +56,21 @@ func saveService(operation Operation, services []*models.MsbService) { return } fails := Save(operation, configs) - log.Log.Debug("%d services need to %s, %d fails. \n", len(services), operation, len(fails)) + log.Log.Debug("%d services %d rules need to %s, %d fails. \n", len(services), len(configs), operation, len(fails)) } func deleteAllMsbRules() { log.Log.Informational("delete all msb rules") - configs, err := List("route-rule", "") + configs, err := List("routerules", "") if err != nil { + log.Log.Error("fail to load rule list", err) return } deleteList := msbRuleFilter(configs) - - Save(OperationDelete, deleteList) + failed := Save(OperationDelete, deleteList) + log.Log.Debug("deleteAllMsbRules total %d rules, fail %d", len(configs), len(failed)) } func msbRuleFilter(configs []istioModel.Config) []istioModel.Config { |