in kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/instance/InstanceService.java [69:83]
public List<JobInstance> getAvailableJobInstances() {
List<JobInstance> result = new LinkedList<>();
for (String each : jobNodeStorage.getJobNodeChildrenKeys(InstanceNode.ROOT)) {
// TODO It's better to make it atomic
String jobNodeData = jobNodeStorage.getJobNodeData(instanceNode.getInstancePath(each));
if (null == jobNodeData) {
continue;
}
JobInstance jobInstance = YamlEngine.unmarshal(jobNodeData, JobInstance.class);
if (null != jobInstance && serverService.isEnableServer(jobInstance.getServerIp())) {
result.add(jobInstance);
}
}
return result;
}