public void init()

in mode/cluster/repository/consul/src/main/java/org/apache/shardingsphere/mode/repository/cluster/consul/ConsulRepository.java [70:76]

• 7 lines of code
• 1 McCabe index (conditional complexity)

    public void init(final ClusterPersistRepositoryConfiguration config, final ComputeNodeInstanceContext computeNodeInstanceContext) {
        consulProps = new ConsulProperties(config.getProps());
        ConsulRawClient rawClient = createConsulRawClient(config.getServerLists());
        consulClient = new ShardingSphereConsulClient(rawClient);
        distributedLockHolder = new DistributedLockHolder(getType(), consulClient, consulProps);
        watchKeyMap = new HashMap<>(6, 1F);
    }