feat:调整服务间调用指标监控上报

pull/942/head
chuntaojun 3 years ago
parent c36f35d442
commit 01c41f644a

@ -59,7 +59,7 @@ public class PolarisCircuitBreakerFactory
public CircuitBreaker create(String id) { public CircuitBreaker create(String id) {
PolarisCircuitBreakerConfigBuilder.PolarisCircuitBreakerConfiguration conf = getConfigurations() PolarisCircuitBreakerConfigBuilder.PolarisCircuitBreakerConfiguration conf = getConfigurations()
.computeIfAbsent(id, defaultConfiguration); .computeIfAbsent(id, defaultConfiguration);
return new PolarisCircuitBreaker(conf, circuitBreakAPI); return new PolarisCircuitBreaker(conf, consumerAPI, circuitBreakAPI);
} }
@Override @Override

@ -58,7 +58,7 @@ public class ReactivePolarisCircuitBreakerFactory extends
public ReactiveCircuitBreaker create(String id) { public ReactiveCircuitBreaker create(String id) {
PolarisCircuitBreakerConfigBuilder.PolarisCircuitBreakerConfiguration conf = getConfigurations() PolarisCircuitBreakerConfigBuilder.PolarisCircuitBreakerConfiguration conf = getConfigurations()
.computeIfAbsent(id, defaultConfiguration); .computeIfAbsent(id, defaultConfiguration);
return new ReactivePolarisCircuitBreaker(conf, circuitBreakAPI); return new ReactivePolarisCircuitBreaker(conf, consumerAPI, circuitBreakAPI);
} }
@Override @Override

@ -97,7 +97,7 @@ public class QuotaCheckReactiveFilterTest {
return new QuotaResponse(new QuotaResult(QuotaResult.Code.QuotaResultLimited, 0, "QuotaResultLimited")); return new QuotaResponse(new QuotaResult(QuotaResult.Code.QuotaResultLimited, 0, "QuotaResultLimited"));
} }
else { else {
return new QuotaResponse(new QuotaResult(null, 0, null)); return new QuotaResponse(new QuotaResult(QuotaResult.Code.QuotaResultOk, 0, null));
} }
}); });

Loading…
Cancel
Save