org.apache.shenyu.sync.data.etcd

类 EtcdClient

java.lang.Object

org.apache.shenyu.sync.data.etcd.EtcdClient

public class EtcdClient
extends java.lang.Object

Etcd client of Bootstrap.

构造器概要

构造器

构造器和说明
EtcdClient(io.etcd.jetcd.Client client)

方法概要

限定符和类型	方法和说明
io.etcd.jetcd.ByteSequence	bytesOf(java.lang.String val) bytesOf string.
void	close() close client.
java.lang.String	get(java.lang.String key) get node value.
java.util.List<java.lang.String>	getChildrenKeys(java.lang.String prefix, java.lang.String separator) get node sub nodes.
java.util.List<java.lang.String>	getChildrenKeysByMap(java.lang.String prefix, java.lang.String separator, java.util.Map<java.lang.String,java.lang.String> map) get keyPrefix map.
java.util.Map<java.lang.String,java.lang.String>	getKeysMapByPrefix(java.lang.String prefix) get keys by prefix.
void	watchChildChange(java.lang.String key, java.util.function.BiConsumer<java.lang.String,java.lang.String> updateHandler, java.util.function.Consumer<java.lang.String> deleteHandler) subscribe sub node change.
void	watchClose(java.lang.String key) cancel subscribe.
void	watchDataChange(java.lang.String key, java.util.function.BiConsumer<java.lang.String,java.lang.String> updateHandler, java.util.function.Consumer<java.lang.String> deleteHandler) subscribe data change.

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

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

构造器详细资料

EtcdClient

public EtcdClient(io.etcd.jetcd.Client client)

方法详细资料

close

public void close()

close client.

get

public java.lang.String get(java.lang.String key)

get node value.

参数:

key - node name

返回:

string

getKeysMapByPrefix

public java.util.Map<java.lang.String,java.lang.String> getKeysMapByPrefix(java.lang.String prefix)

get keys by prefix.

参数:

prefix - key prefix.

返回:

key valuesMap.

bytesOf

public io.etcd.jetcd.ByteSequence bytesOf(java.lang.String val)

bytesOf string.

参数:

val - val.

返回:

bytes val.

getChildrenKeys

public java.util.List<java.lang.String> getChildrenKeys(java.lang.String prefix,
                                                        java.lang.String separator)
                                                 throws java.util.concurrent.ExecutionException,
                                                        java.lang.InterruptedException

get node sub nodes.

参数:

prefix - node prefix.

separator - separator char

返回:

sub nodes

抛出:

java.util.concurrent.ExecutionException - the exception

java.lang.InterruptedException - the exception

getChildrenKeysByMap

public java.util.List<java.lang.String> getChildrenKeysByMap(java.lang.String prefix,
                                                             java.lang.String separator,
                                                             java.util.Map<java.lang.String,java.lang.String> map)

get keyPrefix map.

参数:

prefix - key prefix.

separator - separator char

map - prefix map

返回:

sub map

watchDataChange

public void watchDataChange(java.lang.String key,
                            java.util.function.BiConsumer<java.lang.String,java.lang.String> updateHandler,
                            java.util.function.Consumer<java.lang.String> deleteHandler)

subscribe data change.

参数:

key - node name

updateHandler - node value handler of update

deleteHandler - node value handler of delete

watchChildChange

public void watchChildChange(java.lang.String key,
                             java.util.function.BiConsumer<java.lang.String,java.lang.String> updateHandler,
                             java.util.function.Consumer<java.lang.String> deleteHandler)

subscribe sub node change.

参数:

key - param node name.

updateHandler - sub node handler of update

deleteHandler - sub node delete of delete

watchClose

public void watchClose(java.lang.String key)

cancel subscribe.

参数:

key - node name