(Service service, RaftConfig raftConf)
| 160 | } |
| 161 | |
| 162 | public static void createConnector(Service service, RaftConfig raftConf) { |
| 163 | for (var node : raftConf.getNodes().values()) { |
| 164 | if (raftConf.getName().equals(node.getName())) |
| 165 | continue; // skip self. |
| 166 | service.getConfig().addConnector(new ConnectorEx(node.getHost(), node.getPort())); |
| 167 | } |
| 168 | } |
| 169 | |
| 170 | public static void createAcceptor(Service service, RaftConfig raftConf) { |
| 171 | var node = raftConf.getNodes().get(raftConf.getName()); |