shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/status/compute/subscriber/ComputeNodeStatusSubscriber.java
/**
     * Update compute node status.
     *
     * @param event compute node status changed event
     */
Update compute node status.
@param event compute node status changed event
Update compute node status . @param event compute node status changed event
@Subscribe
    public void update(final ComputeNodeStatusChangedEvent event) {
        String computeNodePath = ComputeStatusNode.getStatusPath(ComputeNodeStatus.CIRCUIT_BREAKER, ClusterInstance.getInstance().getInstanceId(event.getIp(), event.getPort()));
        if (event.getStatus() == ComputeNodeStatus.CIRCUIT_BREAKER) {
            repository.persist(computeNodePath, "");
        } else {
            repository.delete(computeNodePath);
        }
    }
@ Subscribe public void update ( final ComputeNodeStatusChangedEvent event ) { String computeNodePath = ComputeStatusNode . getStatusPath ( ComputeNodeStatus . CIRCUIT_BREAKER , ClusterInstance . getInstance ( ) . getInstanceId ( event . getIp ( ) , event . getPort ( ) ) ) ; if ( event . getStatus ( ) == ComputeNodeStatus . CIRCUIT_BREAKER ) { repository . persist ( computeNodePath , "" ) ; } else { repository . delete ( computeNodePath ) ; } }
Update compute node status.
Update compute node status .