diff --git a/store/boltdb/circuitbreaker_rule.go b/store/boltdb/circuitbreaker_rule.go index 2d90e4fbd..5fbc3417c 100644 --- a/store/boltdb/circuitbreaker_rule.go +++ b/store/boltdb/circuitbreaker_rule.go @@ -73,14 +73,24 @@ func (c *circuitBreakerStore) CreateCircuitBreakerRule(cbRule *model.CircuitBrea // UpdateCircuitBreakerRule update general circuitbreaker rule func (c *circuitBreakerStore) UpdateCircuitBreakerRule(cbRule *model.CircuitBreakerRule) error { dbOp := c.handler - cbRule.Valid = true - cbRule.ModifyTime = time.Now() - - if err := dbOp.SaveValue(tblCircuitBreakerRule, cbRule.ID, cbRule); err != nil { + properties := map[string]interface{}{ + CommonFieldName: cbRule.Name, + CommonFieldNamespace: cbRule.Namespace, + CommonFieldRevision: cbRule.Revision, + CommonFieldDescription: cbRule.Description, + CommonFieldModifyTime: time.Now(), + CbFieldLevel: cbRule.Level, + CbFieldSrcService: cbRule.SrcService, + CbFieldSrcNamespace: cbRule.SrcNamespace, + CbFieldDstService: cbRule.DstService, + CbFieldDstNamespace: cbRule.DstNamespace, + CbFieldDstMethod: cbRule.DstMethod, + CbFieldRule: cbRule.Rule, + } + if err := dbOp.UpdateValue(tblCircuitBreakerRule, cbRule.ID, properties); err != nil { log.Errorf("[Store][CircuitBreaker] update rule(%s) exec err: %s", cbRule.ID, err.Error()) return store.Error(err) } - return nil } @@ -176,6 +186,7 @@ const ( CbFieldDstService = "DstService" CbFieldDstNamespace = "DstNamespace" CbFieldDstMethod = "DstMethod" + CbFieldRule = "Rule" ) var (