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

类 CuratorZookeeperRepository

java.lang.Object

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

所有已实现的接口:

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

public final class CuratorZookeeperRepository
extends Object
implements ClusterPersistRepository, org.apache.shardingsphere.infra.instance.InstanceContextAware

Registry repository of ZooKeeper.

字段概要

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

PATH_SEPARATOR

构造器概要

构造器

构造器和说明
CuratorZookeeperRepository()

方法概要

限定符和类型	方法和说明
void	addCacheData(String cachePath)
void	close()
void	delete(String key)
void	evictCacheData(String cachePath)
void	executeInLeader(String key, LeaderExecutionCallback callback)
String	get(String key)
List<String>	getChildrenKeys(String key)
String	getDirectly(String key)
int	getNumChildren(String key)
Object	getRawCache(String cachePath)
Object	getRawClient()
long	getRegistryCenterTime(String key)
String	getType()
void	init(ClusterPersistRepositoryConfiguration config)
boolean	isExisted(String key)
void	persist(String key, String value)
void	persistEphemeral(String key, String value)
void	persistExclusiveEphemeral(String key, String value)
void	setInstanceContext(org.apache.shardingsphere.infra.instance.InstanceContext instanceContext)
boolean	tryLock(String lockKey, long timeoutMillis)
void	unlock(String lockKey)
void	update(String key, String value)
void	updateInTransaction(String key, String value)
void	watch(String key, DataChangedEventListener listener, Executor executor)

从类继承的方法 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

getNumChildren

public int getNumChildren(String key)

指定者:

getNumChildren 在接口中 ClusterPersistRepository

addCacheData

public void addCacheData(String cachePath)

指定者:

addCacheData 在接口中 ClusterPersistRepository

evictCacheData

public void evictCacheData(String cachePath)

指定者:

evictCacheData 在接口中 ClusterPersistRepository

getRawCache

public Object getRawCache(String cachePath)

指定者:

getRawCache 在接口中 ClusterPersistRepository

executeInLeader

public void executeInLeader(String key,
                            LeaderExecutionCallback callback)

指定者:

executeInLeader 在接口中 ClusterPersistRepository

updateInTransaction

public void updateInTransaction(String key,
                                String value)

指定者:

updateInTransaction 在接口中 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

update

public void update(String key,
                   String value)

指定者:

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

getDirectly

public String getDirectly(String key)

指定者:

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

isExisted

public boolean isExisted(String key)

指定者:

isExisted 在接口中 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

getRegistryCenterTime

public long getRegistryCenterTime(String key)

指定者:

getRegistryCenterTime 在接口中 ClusterPersistRepository

getRawClient

public Object getRawClient()

指定者:

getRawClient 在接口中 ClusterPersistRepository

watch

public void watch(String key,
                  DataChangedEventListener listener,
                  Executor executor)

指定者:

watch 在接口中 ClusterPersistRepository

tryLock

public boolean tryLock(String lockKey,
                       long timeoutMillis)

指定者:

tryLock 在接口中 ClusterPersistRepository

unlock

public void unlock(String lockKey)

指定者:

unlock 在接口中 ClusterPersistRepository

close

public void close()

指定者:

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

setInstanceContext

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

指定者:

setInstanceContext 在接口中 org.apache.shardingsphere.infra.instance.InstanceContextAware

getType

public String getType()

指定者:

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