(Agent agent)
| 98 | private final ConcurrentHashMap<String, Agent> agents = new ConcurrentHashMap<>(); |
| 99 | |
| 100 | public void addAgent(Agent agent) { |
| 101 | var raftConfig = agent.getRaftConfig(); |
| 102 | for (var node : raftConfig.getNodes().values()) { |
| 103 | if (null != agents.putIfAbsent(node.getName(), agent)) |
| 104 | throw new RuntimeException("duplicate agent node " + node.getName()); |
| 105 | } |
| 106 | } |
| 107 | |
| 108 | /** |
| 109 | * 如果启用了代理,则把rpc包装成代理协议,发送出去; |
no test coverage detected