File tree 1 file changed +2
-2
lines changed
1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -106,7 +106,7 @@ func (ds *OpenSergoDataSource) ReadSource() ([]byte, error) {
106
106
func (ds * OpenSergoDataSource ) RegisterSubscribeInfoOfFaulttoleranceRule () {
107
107
// registry SubscribeInfo of FaultToleranceRule
108
108
faultToleranceRuleSubscribeKey := subscribe .NewSubscribeKey (ds .namespace , ds .app , configkind.ConfigKindRefFaultToleranceRule {})
109
- faultToleranceRuleSubscribeInfo := client .NewSubscribeInfo (* faultToleranceRuleSubscribeKey )
109
+ faultToleranceRuleSubscribeInfo := client .NewSubscribeInfo (faultToleranceRuleSubscribeKey )
110
110
faulttoleranceRuleSubscriber := NewFaulttoleranceRuleSubscriber (ds .opensergoRuleAggregator )
111
111
faultToleranceRuleSubscribeInfo .AppendSubscriber (faulttoleranceRuleSubscriber )
112
112
// log data for test
@@ -118,7 +118,7 @@ func (ds *OpenSergoDataSource) RegisterSubscribeInfoOfFaulttoleranceRule() {
118
118
func (ds * OpenSergoDataSource ) RegisterSubscribeInfoOfFlowRuleStrategy () {
119
119
// registry SubscribeInfo of RateLimitStrategy
120
120
rateLimitStrategySubscribeKey := subscribe .NewSubscribeKey (ds .namespace , ds .app , configkind.ConfigKindRefRateLimitStrategy {})
121
- rateLimitStrategySubscribeInfo := client .NewSubscribeInfo (* rateLimitStrategySubscribeKey )
121
+ rateLimitStrategySubscribeInfo := client .NewSubscribeInfo (rateLimitStrategySubscribeKey )
122
122
rateLimitStrategySubscriber := NewFlowruleStrategySubscriber (ds .opensergoRuleAggregator )
123
123
rateLimitStrategySubscribeInfo .AppendSubscriber (rateLimitStrategySubscriber )
124
124
// log data for test
You can’t perform that action at this time.
0 commit comments