This is an automated email from the ASF dual-hosted git repository.
zhonghongsheng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push:
new 66196578c1b Refactor ReadwriteSplittingRuleConfigurationChecker
(#30622)
66196578c1b is described below
commit 66196578c1bb5bfb37d8b7908ce418815d2bb585
Author: Liang Zhang <[email protected]>
AuthorDate: Sun Mar 24 12:48:46 2024 +0800
Refactor ReadwriteSplittingRuleConfigurationChecker (#30622)
---
.../checker/ReadwriteSplittingRuleConfigurationChecker.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git
a/features/readwrite-splitting/core/src/main/java/org/apache/shardingsphere/readwritesplitting/checker/ReadwriteSplittingRuleConfigurationChecker.java
b/features/readwrite-splitting/core/src/main/java/org/apache/shardingsphere/readwritesplitting/checker/ReadwriteSplittingRuleConfigurationChecker.java
index cbb00f41115..f6bc2cb4f94 100644
---
a/features/readwrite-splitting/core/src/main/java/org/apache/shardingsphere/readwritesplitting/checker/ReadwriteSplittingRuleConfigurationChecker.java
+++
b/features/readwrite-splitting/core/src/main/java/org/apache/shardingsphere/readwritesplitting/checker/ReadwriteSplittingRuleConfigurationChecker.java
@@ -116,9 +116,9 @@ public final class
ReadwriteSplittingRuleConfigurationChecker implements RuleCon
}
}
- private Map<String, LoadBalanceAlgorithm> getLoadBalancer(final
ReadwriteSplittingRuleConfiguration config) {
- Map<String, LoadBalanceAlgorithm> result = new
LinkedHashMap<>(config.getLoadBalancers().size(), 1F);
- config.getLoadBalancers().forEach((key, value) -> result.put(key,
TypedSPILoader.getService(LoadBalanceAlgorithm.class, value.getType(),
value.getProps())));
+ private Map<String, LoadBalanceAlgorithm> getLoadBalancer(final
ReadwriteSplittingRuleConfiguration ruleConfig) {
+ Map<String, LoadBalanceAlgorithm> result = new
LinkedHashMap<>(ruleConfig.getLoadBalancers().size(), 1F);
+ ruleConfig.getLoadBalancers().forEach((key, value) -> result.put(key,
TypedSPILoader.getService(LoadBalanceAlgorithm.class, value.getType(),
value.getProps())));
return result;
}