summaryrefslogtreecommitdiffstats
path: root/msb2pilot/src/msb2pilot/pilot
diff options
context:
space:
mode:
authorLvbo163 <lv.bo163@zte.com.cn>2018-08-07 15:12:22 +0800
committerLvbo163 <lv.bo163@zte.com.cn>2018-08-07 15:12:22 +0800
commite782c794c9fe6441120b8d0d239414f9a3421288 (patch)
tree5069f759ac8027ab831f168b5416917761821957 /msb2pilot/src/msb2pilot/pilot
parent38447771f156197521f34f2c89f6b4fb4c42b28c (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.go1
-rw-r--r--msb2pilot/src/msb2pilot/pilot/msb.go10
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 {