org.noear.solon.cloud.extend.etcd.impl

类 EtcdClient

java.lang.Object

org.noear.solon.cloud.extend.etcd.impl.EtcdClient

public class EtcdClient
extends java.lang.Object

从以下版本开始:

2.2

构造器概要

构造器

构造器和说明
EtcdClient(CloudProps cloudProps, int sessionTimeout)

方法概要

限定符和类型	方法和说明
void	attentionKey(java.lang.String key, io.etcd.jetcd.Watch.Listener listener)
void	attentionKeysWithPrefix(java.lang.String prefix, io.etcd.jetcd.Watch.Listener listener)
void	close() 关闭
io.etcd.jetcd.KeyValue	get(java.lang.String key)
java.util.List<io.etcd.jetcd.KeyValue>	getByPrefix(java.lang.String key)
java.lang.String	getValueString(java.lang.String key)
boolean	put(java.lang.String key, java.lang.String value)
void	putWithLease(java.lang.String key, java.lang.String value)
boolean	remove(java.lang.String key)
java.lang.String[]	toURI(java.lang.String[] endpoints)

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

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

构造器详细资料

EtcdClient

public EtcdClient(CloudProps cloudProps,
                  int sessionTimeout)

方法详细资料

get

public io.etcd.jetcd.KeyValue get(java.lang.String key)

getValueString

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

getByPrefix

public java.util.List<io.etcd.jetcd.KeyValue> getByPrefix(java.lang.String key)
                                                   throws java.util.concurrent.ExecutionException,
                                                          java.lang.InterruptedException

抛出:

java.util.concurrent.ExecutionException

java.lang.InterruptedException

put

public boolean put(java.lang.String key,
                   java.lang.String value)

putWithLease

public void putWithLease(java.lang.String key,
                         java.lang.String value)

remove

public boolean remove(java.lang.String key)

attentionKey

public void attentionKey(java.lang.String key,
                         io.etcd.jetcd.Watch.Listener listener)

attentionKeysWithPrefix

public void attentionKeysWithPrefix(java.lang.String prefix,
                                    io.etcd.jetcd.Watch.Listener listener)

close

public void close()

关闭

toURI

public java.lang.String[] toURI(java.lang.String[] endpoints)