1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18 package org.apache.shardingsphere.sharding.rule.changed;
19
20 import org.apache.shardingsphere.infra.algorithm.core.config.AlgorithmConfiguration;
21 import org.apache.shardingsphere.infra.algorithm.core.processor.AlgorithmChangedProcessor;
22 import org.apache.shardingsphere.mode.spi.rule.RuleChangedItemType;
23 import org.apache.shardingsphere.sharding.api.config.ShardingRuleConfiguration;
24 import org.apache.shardingsphere.sharding.rule.ShardingRule;
25
26 import java.util.Map;
27
28
29
30
31 public final class ShardingAuditorChangedProcessor extends AlgorithmChangedProcessor<ShardingRuleConfiguration> {
32
33 public ShardingAuditorChangedProcessor() {
34 super(ShardingRule.class);
35 }
36
37 @Override
38 protected ShardingRuleConfiguration createEmptyRuleConfiguration() {
39 return new ShardingRuleConfiguration();
40 }
41
42 @Override
43 protected Map<String, AlgorithmConfiguration> getAlgorithmConfigurations(final ShardingRuleConfiguration currentRuleConfig) {
44 return currentRuleConfig.getAuditors();
45 }
46
47 @Override
48 public RuleChangedItemType getType() {
49 return new RuleChangedItemType("sharding", "auditors");
50 }
51 }