类 NamingGrpcClientProxy
java.lang.Object
com.alibaba.nacos.common.notify.listener.Subscriber<com.alibaba.nacos.client.address.ServerListChangeEvent>
com.alibaba.nacos.client.naming.remote.AbstractNamingClientProxy
com.alibaba.nacos.client.naming.remote.gprc.NamingGrpcClientProxy
- 所有已实现的接口:
NamingClientProxy,com.alibaba.nacos.common.lifecycle.Closeable
Naming grpc client proxy.
- 作者:
- xiweng.yy
-
构造器概要
构造器构造器说明NamingGrpcClientProxy(String namespaceId, SecurityProxy securityProxy, com.alibaba.nacos.common.remote.client.ServerListFactory serverListFactory, com.alibaba.nacos.client.env.NacosClientProperties properties, ServiceInfoHolder serviceInfoHolder, NamingFuzzyWatchServiceListHolder namingFuzzyWatchServiceListHolder) -
方法概要
修饰符和类型方法说明voidbatchDeregisterService(String serviceName, String groupName, List<com.alibaba.nacos.api.naming.pojo.Instance> instances) Batch deRegister instance to service with specified instance properties.voidbatchRegisterService(String serviceName, String groupName, List<com.alibaba.nacos.api.naming.pojo.Instance> instances) Batch register instance to service with specified instance properties.voidcreateService(com.alibaba.nacos.api.naming.pojo.Service service, com.alibaba.nacos.api.selector.AbstractSelector selector) Create service.booleandeleteService(String serviceName, String groupName) Delete service.voidderegisterService(String serviceName, String groupName, com.alibaba.nacos.api.naming.pojo.Instance instance) Deregister instance from a service.voiddoBatchRegisterService(String serviceName, String groupName, List<com.alibaba.nacos.api.naming.pojo.Instance> instances) Execute batch register operation.voiddoDeregisterService(String serviceName, String groupName, com.alibaba.nacos.api.naming.pojo.Instance instance) Execute deregister operation.voiddoDeregisterServiceForPersistent(String serviceName, String groupName, com.alibaba.nacos.api.naming.pojo.Instance instance) Execute deregister operation for persistent instance.voiddoRegisterService(String serviceName, String groupName, com.alibaba.nacos.api.naming.pojo.Instance instance) Execute register operation.voiddoRegisterServiceForPersistent(String serviceName, String groupName, com.alibaba.nacos.api.naming.pojo.Instance instance) Execute register operation for persistent instance.com.alibaba.nacos.api.naming.pojo.ServiceInfodoSubscribe(String serviceName, String groupName, String clusters) Execute subscribe operation.voiddoUnsubscribe(String serviceName, String groupName, String clusters) Execute unsubscribe operation.com.alibaba.nacos.api.naming.remote.response.NamingFuzzyWatchResponsefuzzyWatchRequest(com.alibaba.nacos.api.naming.remote.request.NamingFuzzyWatchRequest namingFuzzyWatchRequest) Execute unsubscribe operation.com.alibaba.nacos.api.naming.pojo.ListView<String>getServiceList(int pageNo, int pageSize, String groupName, com.alibaba.nacos.api.selector.AbstractSelector selector) Get service list.booleanisAbilitySupportedByServer(com.alibaba.nacos.api.ability.constant.AbilityKey abilityKey) Determine whether nacos-server supports the capability.booleanisEnable()booleanisSubscribed(String serviceName, String groupName, String clusters) Judge whether service has been subscribed.voidonEvent(com.alibaba.nacos.client.address.ServerListChangeEvent event) com.alibaba.nacos.api.naming.pojo.ServiceInfoqueryInstancesOfService(String serviceName, String groupName, String clusters, boolean healthyOnly) Query instance list.com.alibaba.nacos.api.naming.pojo.ServicequeryService(String serviceName, String groupName) Query Service.voidregisterService(String serviceName, String groupName, com.alibaba.nacos.api.naming.pojo.Instance instance) Register an instance to service with specified instance properties.booleanCheck Server healthy.voidshutdown()com.alibaba.nacos.api.naming.pojo.ServiceInfoSubscribe service.Class<? extends com.alibaba.nacos.common.notify.Event>voidunsubscribe(String serviceName, String groupName, String clusters) Unsubscribe service.voidupdateInstance(String serviceName, String groupName, com.alibaba.nacos.api.naming.pojo.Instance instance) Update instance to service.voidupdateService(com.alibaba.nacos.api.naming.pojo.Service service, com.alibaba.nacos.api.selector.AbstractSelector selector) Update service.从类继承的方法 com.alibaba.nacos.client.naming.remote.AbstractNamingClientProxy
getAppHeaders, getSecurityHeaders, reLogin从类继承的方法 com.alibaba.nacos.common.notify.listener.Subscriber
executor, ignoreExpireEvent, scopeMatches
-
构造器详细资料
-
NamingGrpcClientProxy
public NamingGrpcClientProxy(String namespaceId, SecurityProxy securityProxy, com.alibaba.nacos.common.remote.client.ServerListFactory serverListFactory, com.alibaba.nacos.client.env.NacosClientProperties properties, ServiceInfoHolder serviceInfoHolder, NamingFuzzyWatchServiceListHolder namingFuzzyWatchServiceListHolder) throws com.alibaba.nacos.api.exception.NacosException - 抛出:
com.alibaba.nacos.api.exception.NacosException
-
-
方法详细资料
-
onEvent
public void onEvent(com.alibaba.nacos.client.address.ServerListChangeEvent event) - 指定者:
onEvent在类中com.alibaba.nacos.common.notify.listener.Subscriber<com.alibaba.nacos.client.address.ServerListChangeEvent>
-
subscribeType
- 指定者:
subscribeType在类中com.alibaba.nacos.common.notify.listener.Subscriber<com.alibaba.nacos.client.address.ServerListChangeEvent>
-
registerService
public void registerService(String serviceName, String groupName, com.alibaba.nacos.api.naming.pojo.Instance instance) throws com.alibaba.nacos.api.exception.NacosException 从接口复制的说明:NamingClientProxyRegister an instance to service with specified instance properties.- 参数:
serviceName- name of servicegroupName- group of serviceinstance- instance to register- 抛出:
com.alibaba.nacos.api.exception.NacosException- nacos exception
-
batchRegisterService
public void batchRegisterService(String serviceName, String groupName, List<com.alibaba.nacos.api.naming.pojo.Instance> instances) throws com.alibaba.nacos.api.exception.NacosException 从接口复制的说明:NamingClientProxyBatch register instance to service with specified instance properties.- 参数:
serviceName- service namegroupName- group nameinstances- instance- 抛出:
com.alibaba.nacos.api.exception.NacosException- nacos exception
-
batchDeregisterService
public void batchDeregisterService(String serviceName, String groupName, List<com.alibaba.nacos.api.naming.pojo.Instance> instances) throws com.alibaba.nacos.api.exception.NacosException 从接口复制的说明:NamingClientProxyBatch deRegister instance to service with specified instance properties.- 参数:
serviceName- service namegroupName- group nameinstances- deRegister instance- 抛出:
com.alibaba.nacos.api.exception.NacosException- nacos exception
-
doBatchRegisterService
public void doBatchRegisterService(String serviceName, String groupName, List<com.alibaba.nacos.api.naming.pojo.Instance> instances) throws com.alibaba.nacos.api.exception.NacosException Execute batch register operation.- 参数:
serviceName- service namegroupName- group nameinstances- instances- 抛出:
com.alibaba.nacos.api.exception.NacosException- NacosException
-
doRegisterService
public void doRegisterService(String serviceName, String groupName, com.alibaba.nacos.api.naming.pojo.Instance instance) throws com.alibaba.nacos.api.exception.NacosException Execute register operation.- 参数:
serviceName- name of servicegroupName- group of serviceinstance- instance to register- 抛出:
com.alibaba.nacos.api.exception.NacosException- nacos exception
-
doRegisterServiceForPersistent
public void doRegisterServiceForPersistent(String serviceName, String groupName, com.alibaba.nacos.api.naming.pojo.Instance instance) throws com.alibaba.nacos.api.exception.NacosException Execute register operation for persistent instance.- 参数:
serviceName- name of servicegroupName- group of serviceinstance- instance to register- 抛出:
com.alibaba.nacos.api.exception.NacosException- nacos exception
-
deregisterService
public void deregisterService(String serviceName, String groupName, com.alibaba.nacos.api.naming.pojo.Instance instance) throws com.alibaba.nacos.api.exception.NacosException 从接口复制的说明:NamingClientProxyDeregister instance from a service.- 参数:
serviceName- name of servicegroupName- group nameinstance- instance- 抛出:
com.alibaba.nacos.api.exception.NacosException- nacos exception
-
doDeregisterService
public void doDeregisterService(String serviceName, String groupName, com.alibaba.nacos.api.naming.pojo.Instance instance) throws com.alibaba.nacos.api.exception.NacosException Execute deregister operation.- 参数:
serviceName- service namegroupName- group nameinstance- instance- 抛出:
com.alibaba.nacos.api.exception.NacosException- nacos exception
-
doDeregisterServiceForPersistent
public void doDeregisterServiceForPersistent(String serviceName, String groupName, com.alibaba.nacos.api.naming.pojo.Instance instance) throws com.alibaba.nacos.api.exception.NacosException Execute deregister operation for persistent instance.- 参数:
serviceName- service namegroupName- group nameinstance- instance- 抛出:
com.alibaba.nacos.api.exception.NacosException- nacos exception
-
updateInstance
public void updateInstance(String serviceName, String groupName, com.alibaba.nacos.api.naming.pojo.Instance instance) throws com.alibaba.nacos.api.exception.NacosException 从接口复制的说明:NamingClientProxyUpdate instance to service.- 参数:
serviceName- service namegroupName- group nameinstance- instance- 抛出:
com.alibaba.nacos.api.exception.NacosException- nacos exception
-
queryInstancesOfService
public com.alibaba.nacos.api.naming.pojo.ServiceInfo queryInstancesOfService(String serviceName, String groupName, String clusters, boolean healthyOnly) throws com.alibaba.nacos.api.exception.NacosException 从接口复制的说明:NamingClientProxyQuery instance list.- 参数:
serviceName- service namegroupName- group nameclusters- clustershealthyOnly- healthy only- 返回:
- service info
- 抛出:
com.alibaba.nacos.api.exception.NacosException- nacos exception
-
queryService
public com.alibaba.nacos.api.naming.pojo.Service queryService(String serviceName, String groupName) throws com.alibaba.nacos.api.exception.NacosException 从接口复制的说明:NamingClientProxyQuery Service.- 参数:
serviceName- service namegroupName- group name- 返回:
- service
- 抛出:
com.alibaba.nacos.api.exception.NacosException- nacos exception
-
createService
public void createService(com.alibaba.nacos.api.naming.pojo.Service service, com.alibaba.nacos.api.selector.AbstractSelector selector) throws com.alibaba.nacos.api.exception.NacosException 从接口复制的说明:NamingClientProxyCreate service.- 参数:
service- serviceselector- selector- 抛出:
com.alibaba.nacos.api.exception.NacosException- nacos exception
-
deleteService
public boolean deleteService(String serviceName, String groupName) throws com.alibaba.nacos.api.exception.NacosException 从接口复制的说明:NamingClientProxyDelete service.- 参数:
serviceName- service namegroupName- group name- 返回:
- true if delete ok
- 抛出:
com.alibaba.nacos.api.exception.NacosException- nacos exception
-
updateService
public void updateService(com.alibaba.nacos.api.naming.pojo.Service service, com.alibaba.nacos.api.selector.AbstractSelector selector) throws com.alibaba.nacos.api.exception.NacosException 从接口复制的说明:NamingClientProxyUpdate service.- 参数:
service- serviceselector- selector- 抛出:
com.alibaba.nacos.api.exception.NacosException- nacos exception
-
getServiceList
public com.alibaba.nacos.api.naming.pojo.ListView<String> getServiceList(int pageNo, int pageSize, String groupName, com.alibaba.nacos.api.selector.AbstractSelector selector) throws com.alibaba.nacos.api.exception.NacosException 从接口复制的说明:NamingClientProxyGet service list.- 参数:
pageNo- page numberpageSize- size per pagegroupName- group name of serviceselector- selector- 返回:
- list of service
- 抛出:
com.alibaba.nacos.api.exception.NacosException- nacos exception
-
subscribe
public com.alibaba.nacos.api.naming.pojo.ServiceInfo subscribe(String serviceName, String groupName, String clusters) throws com.alibaba.nacos.api.exception.NacosException 从接口复制的说明:NamingClientProxySubscribe service.- 参数:
serviceName- service namegroupName- group nameclusters- clusters, current only support subscribe all clusters, maybe deprecated- 返回:
- current service info of subscribe service
- 抛出:
com.alibaba.nacos.api.exception.NacosException- nacos exception
-
doSubscribe
public com.alibaba.nacos.api.naming.pojo.ServiceInfo doSubscribe(String serviceName, String groupName, String clusters) throws com.alibaba.nacos.api.exception.NacosException Execute subscribe operation.- 参数:
serviceName- service namegroupName- group nameclusters- clusters, current only support subscribe all clusters, maybe deprecated- 返回:
- current service info of subscribe service
- 抛出:
com.alibaba.nacos.api.exception.NacosException- nacos exception
-
unsubscribe
public void unsubscribe(String serviceName, String groupName, String clusters) throws com.alibaba.nacos.api.exception.NacosException 从接口复制的说明:NamingClientProxyUnsubscribe service.- 参数:
serviceName- service namegroupName- group nameclusters- clusters, current only support subscribe all clusters, maybe deprecated- 抛出:
com.alibaba.nacos.api.exception.NacosException- nacos exception
-
isSubscribed
public boolean isSubscribed(String serviceName, String groupName, String clusters) throws com.alibaba.nacos.api.exception.NacosException 从接口复制的说明:NamingClientProxyJudge whether service has been subscribed.- 参数:
serviceName- service namegroupName- group nameclusters- clusters, current only support subscribe all clusters, maybe deprecated- 返回:
trueif subscribed, otherwisefalse- 抛出:
com.alibaba.nacos.api.exception.NacosException- nacos exception
-
doUnsubscribe
public void doUnsubscribe(String serviceName, String groupName, String clusters) throws com.alibaba.nacos.api.exception.NacosException Execute unsubscribe operation.- 参数:
serviceName- service namegroupName- group nameclusters- clusters, current only support subscribe all clusters, maybe deprecated- 抛出:
com.alibaba.nacos.api.exception.NacosException- nacos exception
-
serverHealthy
public boolean serverHealthy()从接口复制的说明:NamingClientProxyCheck Server healthy.- 返回:
- true if server is healthy
-
isAbilitySupportedByServer
public boolean isAbilitySupportedByServer(com.alibaba.nacos.api.ability.constant.AbilityKey abilityKey) Determine whether nacos-server supports the capability.- 参数:
abilityKey- ability key- 返回:
- true if supported, otherwise false
-
fuzzyWatchRequest
public com.alibaba.nacos.api.naming.remote.response.NamingFuzzyWatchResponse fuzzyWatchRequest(com.alibaba.nacos.api.naming.remote.request.NamingFuzzyWatchRequest namingFuzzyWatchRequest) throws com.alibaba.nacos.api.exception.NacosException Execute unsubscribe operation.- 参数:
namingFuzzyWatchRequest- namingFuzzyWatchRequest- 抛出:
com.alibaba.nacos.api.exception.NacosException- nacos exception
-
shutdown
public void shutdown() throws com.alibaba.nacos.api.exception.NacosException- 抛出:
com.alibaba.nacos.api.exception.NacosException
-
isEnable
public boolean isEnable() -
getNamespaceId
-