public class HostReactor
extends java.lang.Object
| Modifier and Type | Class and Description |
|---|---|
class |
HostReactor.UpdateTask |
| Constructor and Description |
|---|
HostReactor(com.alibaba.nacos.client.naming.core.EventDispatcher eventDispatcher,
com.alibaba.nacos.client.naming.net.NamingProxy serverProxy,
java.lang.String cacheDir) |
HostReactor(com.alibaba.nacos.client.naming.core.EventDispatcher eventDispatcher,
com.alibaba.nacos.client.naming.net.NamingProxy serverProxy,
java.lang.String cacheDir,
boolean loadCacheAtStart,
int pollingThreadCount) |
| Modifier and Type | Method and Description |
|---|---|
java.util.concurrent.ScheduledFuture<?> |
addTask(HostReactor.UpdateTask task) |
com.alibaba.nacos.api.naming.pojo.ServiceInfo |
getServiceInfo(java.lang.String serviceName,
java.lang.String clusters) |
com.alibaba.nacos.api.naming.pojo.ServiceInfo |
getServiceInfoDirectlyFromServer(java.lang.String serviceName,
java.lang.String clusters) |
java.util.Map<java.lang.String,com.alibaba.nacos.api.naming.pojo.ServiceInfo> |
getServiceInfoMap() |
com.alibaba.nacos.api.naming.pojo.ServiceInfo |
processServiceJSON(java.lang.String json) |
void |
refreshOnly(java.lang.String serviceName,
java.lang.String clusters) |
void |
scheduleUpdateIfAbsent(java.lang.String serviceName,
java.lang.String clusters) |
void |
updateServiceNow(java.lang.String serviceName,
java.lang.String clusters) |
public HostReactor(com.alibaba.nacos.client.naming.core.EventDispatcher eventDispatcher,
com.alibaba.nacos.client.naming.net.NamingProxy serverProxy,
java.lang.String cacheDir)
public HostReactor(com.alibaba.nacos.client.naming.core.EventDispatcher eventDispatcher,
com.alibaba.nacos.client.naming.net.NamingProxy serverProxy,
java.lang.String cacheDir,
boolean loadCacheAtStart,
int pollingThreadCount)
public java.util.Map<java.lang.String,com.alibaba.nacos.api.naming.pojo.ServiceInfo> getServiceInfoMap()
public java.util.concurrent.ScheduledFuture<?> addTask(HostReactor.UpdateTask task)
public com.alibaba.nacos.api.naming.pojo.ServiceInfo processServiceJSON(java.lang.String json)
public com.alibaba.nacos.api.naming.pojo.ServiceInfo getServiceInfoDirectlyFromServer(java.lang.String serviceName,
java.lang.String clusters)
throws com.alibaba.nacos.api.exception.NacosException
com.alibaba.nacos.api.exception.NacosExceptionpublic com.alibaba.nacos.api.naming.pojo.ServiceInfo getServiceInfo(java.lang.String serviceName,
java.lang.String clusters)
public void scheduleUpdateIfAbsent(java.lang.String serviceName,
java.lang.String clusters)
public void updateServiceNow(java.lang.String serviceName,
java.lang.String clusters)
public void refreshOnly(java.lang.String serviceName,
java.lang.String clusters)