com.alibaba.otter.canal.instance.manager.plain

类 PlainCanalConfigClient

java.lang.Object

com.alibaba.otter.canal.common.AbstractCanalLifeCycle

com.alibaba.otter.canal.instance.manager.plain.PlainCanalConfigClient

所有已实现的接口:

com.alibaba.otter.canal.common.CanalLifeCycle

public class PlainCanalConfigClient
extends com.alibaba.otter.canal.common.AbstractCanalLifeCycle
implements com.alibaba.otter.canal.common.CanalLifeCycle

远程配置获取

从以下版本开始:

1.1.4

作者:

rewerma 2019-01-25 下午05:20:16, agapple 2019年8月26日 下午7:52:06

字段概要

从类继承的字段 com.alibaba.otter.canal.common.AbstractCanalLifeCycle

running

构造器概要

构造器

构造器和说明
PlainCanalConfigClient(java.lang.String configURL, java.lang.String user, java.lang.String passwd, java.lang.String localIp, int adminPort)
PlainCanalConfigClient(java.lang.String configURL, java.lang.String user, java.lang.String passwd, java.lang.String localIp, int adminPort, boolean autoRegister, java.lang.String autoCluster)

方法概要

限定符和类型	方法和说明
PlainCanal	findInstance(java.lang.String destination, java.lang.String md5) 加载远程的instance.properties
java.lang.String	findInstances(java.lang.String md5) 返回需要运行的instance列表
PlainCanal	findServer(java.lang.String md5) 加载canal.properties文件

从类继承的方法 com.alibaba.otter.canal.common.AbstractCanalLifeCycle

isStart, start, stop

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 com.alibaba.otter.canal.common.CanalLifeCycle

isStart, start, stop

构造器详细资料

PlainCanalConfigClient

public PlainCanalConfigClient(java.lang.String configURL,
                              java.lang.String user,
                              java.lang.String passwd,
                              java.lang.String localIp,
                              int adminPort,
                              boolean autoRegister,
                              java.lang.String autoCluster)

PlainCanalConfigClient

public PlainCanalConfigClient(java.lang.String configURL,
                              java.lang.String user,
                              java.lang.String passwd,
                              java.lang.String localIp,
                              int adminPort)

方法详细资料

findServer

public PlainCanal findServer(java.lang.String md5)

加载canal.properties文件

返回:

远程配置的properties

findInstance

public PlainCanal findInstance(java.lang.String destination,
                               java.lang.String md5)

加载远程的instance.properties

findInstances

public java.lang.String findInstances(java.lang.String md5)

返回需要运行的instance列表