MCPcopy Create free account
hub / github.com/e2wugui/zeze / addAgent

Method addAgent

ZezeJava/ZezeJava/src/main/java/Zeze/Raft/ProxyAgent.java:100–106  ·  view source on GitHub ↗
(Agent agent)

Source from the content-addressed store, hash-verified

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包装成代理协议,发送出去;

Callers 1

initMethod · 0.80

Calls 5

getRaftConfigMethod · 0.65
valuesMethod · 0.65
putIfAbsentMethod · 0.65
getNameMethod · 0.65
getNodesMethod · 0.45

Tested by

no test coverage detected