GetAgentPID 获取节点对应的 Agent PID
(nodeID string)
| 169 | |
| 170 | // GetAgentPID 获取节点对应的 Agent PID |
| 171 | func (e *ActorEngine) GetAgentPID(nodeID string) (*actor.PID, bool) { |
| 172 | e.agentPIDsMu.RLock() |
| 173 | defer e.agentPIDsMu.RUnlock() |
| 174 | pid, ok := e.agentPIDs[nodeID] |
| 175 | return pid, ok |
| 176 | } |
| 177 | |
| 178 | // StopAgent 停止指定节点的 Agent |
| 179 | func (e *ActorEngine) StopAgent(nodeID string) { |
no outgoing calls
no test coverage detected