org.apache.shardingsphere.mode.repository.cluster.zookeeper

类 CuratorZookeeperRepository

java.lang.Object

org.apache.shardingsphere.mode.repository.cluster.zookeeper.CuratorZookeeperRepository

所有已实现的接口:

org.apache.shardingsphere.infra.util.spi.type.typed.TypedSPI, org.apache.shardingsphere.mode.persist.PersistRepository, ClusterPersistRepository

public final class CuratorZookeeperRepository
extends Object
implements ClusterPersistRepository

Registry repository of ZooKeeper.

字段概要

从接口继承的字段 org.apache.shardingsphere.mode.persist.PersistRepository

PATH_SEPARATOR

构造器概要

构造器

构造器和说明
CuratorZookeeperRepository()

方法概要

限定符和类型	方法和说明
void	close()
void	delete(String key)
String	get(String key)
List<String>	getChildrenKeys(String key)
String	getType()
void	init(ClusterPersistRepositoryConfiguration config)
void	persist(String key, String value)
void	persistEphemeral(String key, String value)
void	persistExclusiveEphemeral(String key, String value)
boolean	persistLock(String lockKey, long timeoutMillis)
void	watch(String key, DataChangedEventListener listener)
void	watchSessionConnection(org.apache.shardingsphere.infra.instance.InstanceContext instanceContext)

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

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

从接口继承的方法 org.apache.shardingsphere.infra.util.spi.type.typed.TypedSPI

getTypeAliases

构造器详细资料

CuratorZookeeperRepository

public CuratorZookeeperRepository()

方法详细资料

init

public void init(ClusterPersistRepositoryConfiguration config)

指定者:

init 在接口中 ClusterPersistRepository

get

public String get(String key)

指定者:

get 在接口中 org.apache.shardingsphere.mode.persist.PersistRepository

getChildrenKeys

public List<String> getChildrenKeys(String key)

指定者:

getChildrenKeys 在接口中 org.apache.shardingsphere.mode.persist.PersistRepository

persist

public void persist(String key,
                    String value)

指定者:

persist 在接口中 org.apache.shardingsphere.mode.persist.PersistRepository

persistEphemeral

public void persistEphemeral(String key,
                             String value)

指定者:

persistEphemeral 在接口中 ClusterPersistRepository

persistExclusiveEphemeral

public void persistExclusiveEphemeral(String key,
                                      String value)

指定者:

persistExclusiveEphemeral 在接口中 ClusterPersistRepository

delete

public void delete(String key)

指定者:

delete 在接口中 org.apache.shardingsphere.mode.persist.PersistRepository

watch

public void watch(String key,
                  DataChangedEventListener listener)

指定者:

watch 在接口中 ClusterPersistRepository

persistLock

public boolean persistLock(String lockKey,
                           long timeoutMillis)

指定者:

persistLock 在接口中 ClusterPersistRepository

close

public void close()

指定者:

close 在接口中 org.apache.shardingsphere.mode.persist.PersistRepository

watchSessionConnection

public void watchSessionConnection(org.apache.shardingsphere.infra.instance.InstanceContext instanceContext)

指定者:

watchSessionConnection 在接口中 ClusterPersistRepository

getType

public String getType()

指定者:

getType 在接口中 org.apache.shardingsphere.infra.util.spi.type.typed.TypedSPI