private ClusterData reloadCluster()

in src/main/java/org/apache/pulsar/manager/service/impl/EnvironmentCacheServiceImpl.java [216:236]

• 21 lines of code
• 2 McCabe index (conditional complexity)

    private ClusterData reloadCluster(EnvironmentEntity environment, String cluster) {
        log.info("Reloading cluster data for cluster {} @ environment {} ...",
                cluster, environment.getName());
        ClusterData clusterData;
        try {
            clusterData = pulsarAdminService.clusters(environment.getBroker()).getCluster(cluster);
        } catch(PulsarAdminException e) {
            log.error("Failed to get cluster data.", e);
            return null;
        }
        log.info("Loaded cluster data for cluster {} @ environment {} : {}",
                cluster, environment.getName(), clusterData.toString());
        Map<String, ClusterData> clusters = environments.computeIfAbsent(
                environment.getName(),
                (e) -> new ConcurrentHashMap<>());
        clusters.put(cluster, clusterData);
        serviceUrlEnvironmentMap.put(environment.getBroker(), environment.getName());
        log.info("Successfully loaded cluster data for cluster {} @ environment {} : {}",
                cluster, environment.getName(), clusterData);
        return clusterData;
    }