未验证 提交 310e2ac3 编写于 作者: kimmking's avatar kimmking 提交者: GitHub

modify for orchestration refactoring (#4705)

上级 808ccb7b
......@@ -17,7 +17,7 @@
package org.apache.shardingsphere.ui.servcie;
import org.apache.shardingsphere.orchestration.center.api.RegistryCenterRepository;
import org.apache.shardingsphere.orchestration.center.RegistryCenterRepository;
import org.apache.shardingsphere.orchestration.internal.registry.config.node.ConfigurationNode;
import org.apache.shardingsphere.orchestration.internal.registry.state.node.StateNode;
......
......@@ -17,7 +17,7 @@
package org.apache.shardingsphere.ui.servcie.impl;
import org.apache.shardingsphere.orchestration.center.api.RegistryCenterRepository;
import org.apache.shardingsphere.orchestration.center.RegistryCenterRepository;
import org.apache.shardingsphere.orchestration.internal.registry.config.node.ConfigurationNode;
import org.apache.shardingsphere.orchestration.internal.registry.state.node.StateNode;
import org.apache.shardingsphere.ui.common.domain.RegistryCenterConfig;
......
......@@ -20,11 +20,11 @@ package org.apache.shardingsphere.ui.util;
import java.util.concurrent.ConcurrentHashMap;
import lombok.AccessLevel;
import lombok.NoArgsConstructor;
import org.apache.shardingsphere.orchestration.center.api.RegistryCenterRepository;
import org.apache.shardingsphere.orchestration.center.configuration.InstanceConfiguration;
import org.apache.shardingsphere.orchestration.center.instance.CuratorZookeeperInstance;
import org.apache.shardingsphere.orchestration.center.RegistryCenterRepository;
import org.apache.shardingsphere.orchestration.center.instance.CuratorZookeeperCenterRepository;
import org.apache.shardingsphere.ui.common.constant.RegistryCenterType;
import org.apache.shardingsphere.ui.common.domain.RegistryCenterConfig;
import org.apache.shardingsphere.underlying.common.config.orchestration.CenterConfiguration;
/**
* Registry center factory.
......@@ -48,7 +48,7 @@ public final class RegistryCenterRepositoryFactory {
RegistryCenterType registryCenterType = RegistryCenterType.nameOf(config.getRegistryCenterType());
switch (registryCenterType) {
case ZOOKEEPER:
result = new CuratorZookeeperInstance();
result = new CuratorZookeeperCenterRepository();
break;
default:
throw new UnsupportedOperationException(config.getName());
......@@ -58,8 +58,8 @@ public final class RegistryCenterRepositoryFactory {
return result;
}
private static InstanceConfiguration convert(final RegistryCenterConfig config) {
InstanceConfiguration result = new InstanceConfiguration(config.getRegistryCenterType());
private static CenterConfiguration convert(final RegistryCenterConfig config) {
CenterConfiguration result = new CenterConfiguration(config.getRegistryCenterType());
result.setServerLists(config.getServerLists());
result.setNamespace(config.getNamespace());
result.getProperties().put("digest", config.getDigest());
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册