com.alibaba.nacos.client.naming.core

Class HostReactor

java.lang.Object

com.alibaba.nacos.client.naming.core.HostReactor

public class HostReactor
extends java.lang.Object

Author:

xuanyin

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	HostReactor.UpdateTask

Constructor Summary

Constructors

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)

Method Summary

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)

Methods inherited from class java.lang.Object

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

Constructor Detail

HostReactor

public HostReactor(com.alibaba.nacos.client.naming.core.EventDispatcher eventDispatcher,
                   com.alibaba.nacos.client.naming.net.NamingProxy serverProxy,
                   java.lang.String cacheDir)

HostReactor

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)

Method Detail

getServiceInfoMap

public java.util.Map<java.lang.String,com.alibaba.nacos.api.naming.pojo.ServiceInfo> getServiceInfoMap()

addTask

public java.util.concurrent.ScheduledFuture<?> addTask(HostReactor.UpdateTask task)

processServiceJSON

public com.alibaba.nacos.api.naming.pojo.ServiceInfo processServiceJSON(java.lang.String json)

getServiceInfoDirectlyFromServer

public com.alibaba.nacos.api.naming.pojo.ServiceInfo getServiceInfoDirectlyFromServer(java.lang.String serviceName,
                                                                                      java.lang.String clusters)
                                                                               throws com.alibaba.nacos.api.exception.NacosException

Throws:

com.alibaba.nacos.api.exception.NacosException

getServiceInfo

public com.alibaba.nacos.api.naming.pojo.ServiceInfo getServiceInfo(java.lang.String serviceName,
                                                                    java.lang.String clusters)

scheduleUpdateIfAbsent

public void scheduleUpdateIfAbsent(java.lang.String serviceName,
                                   java.lang.String clusters)

updateServiceNow

public void updateServiceNow(java.lang.String serviceName,
                             java.lang.String clusters)

refreshOnly

public void refreshOnly(java.lang.String serviceName,
                        java.lang.String clusters)