|
|
@@ -142,9 +142,17 @@ public class MachineServiceImpl implements MachineService {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * mgr 进程结束时将所有 Online 状态的 agent 节点设置为 Offline
|
|
|
+ *
|
|
|
+ * @param
|
|
|
+ * @return
|
|
|
+ * @date 2025-06-05 11:34:21
|
|
|
+ */
|
|
|
@Override
|
|
|
public void shutdown() {
|
|
|
List<MachineInfo> list = machineQuery.getMachineInfos(NodeStatus.Online.getCode()).stream()
|
|
|
+ .filter(machineInfo -> !machineInfo.getMachineId().startsWith("oss"))
|
|
|
.peek(machineInfo -> machineInfo.setStat(NodeStatus.Offline.getCode()))
|
|
|
.collect(Collectors.toList());
|
|
|
machineInfoRepository.saveAll(list);
|