程序包 com.alibaba.nacos.client.naming.remote.gprc.redo

类 NamingGrpcRedoService

java.lang.Object
com.alibaba.nacos.client.naming.remote.gprc.redo.NamingGrpcRedoService
所有已实现的接口:
com.alibaba.nacos.common.remote.client.ConnectionEventListener
public class NamingGrpcRedoService extends Object implements com.alibaba.nacos.common.remote.client.ConnectionEventListener
Naming client gprc redo service.

When connection reconnect to server, redo the register and subscribe. TODO refactor to extends from AbstractRedoService

作者:
xiweng.yy

  • 构造器详细资料

  • 方法详细资料

    • getRegisteredInstances

      public ConcurrentMap<String,InstanceRedoData> getRegisteredInstances()

    • isConnected

      public boolean isConnected()

    • onConnected

      public void onConnected(com.alibaba.nacos.common.remote.client.Connection connection)
      指定者:
      onConnected 在接口中 com.alibaba.nacos.common.remote.client.ConnectionEventListener

    • onDisConnect

      public void onDisConnect(com.alibaba.nacos.common.remote.client.Connection connection)
      指定者:
      onDisConnect 在接口中 com.alibaba.nacos.common.remote.client.ConnectionEventListener

    • cacheInstanceForRedo

      public void cacheInstanceForRedo(String serviceName, String groupName, com.alibaba.nacos.api.naming.pojo.Instance instance)
      Cache registered instance for redo.
      参数:
      serviceName - service name
      groupName - group name
      instance - registered instance

    • cacheInstanceForRedo

      public void cacheInstanceForRedo(String serviceName, String groupName, List<com.alibaba.nacos.api.naming.pojo.Instance> instances)
      Cache registered instance for redo.
      参数:
      serviceName - service name
      groupName - group name
      instances - batch registered instance

    • instanceRegistered

      public void instanceRegistered(String serviceName, String groupName)
      Instance register successfully, mark registered status as true.
      参数:
      serviceName - service name
      groupName - group name

    • instanceDeregister

      public void instanceDeregister(String serviceName, String groupName)
      Instance deregister, mark unregistering status as true.
      参数:
      serviceName - service name
      groupName - group name

    • instanceDeregistered

      public void instanceDeregistered(String serviceName, String groupName)
      Instance deregister finished, mark unregistered status.
      参数:
      serviceName - service name
      groupName - group name

    • removeInstanceForRedo

      public void removeInstanceForRedo(String serviceName, String groupName)
      Remove registered instance for redo.
      参数:
      serviceName - service name
      groupName - group name

    • findInstanceRedoData

      public Set<InstanceRedoData> findInstanceRedoData()
      Find all instance redo data which need do redo.
      返回:
      set of InstanceRedoData need to do redo.

    • cacheSubscriberForRedo

      public void cacheSubscriberForRedo(String serviceName, String groupName, String cluster)
      Cache subscriber for redo.
      参数:
      serviceName - service name
      groupName - group name
      cluster - cluster

    • subscriberRegistered

      public void subscriberRegistered(String serviceName, String groupName, String cluster)
      Subscriber register successfully, mark registered status as true.
      参数:
      serviceName - service name
      groupName - group name
      cluster - cluster

    • subscriberDeregister

      public void subscriberDeregister(String serviceName, String groupName, String cluster)
      Subscriber deregister, mark unregistering status as true.
      参数:
      serviceName - service name
      groupName - group name
      cluster - cluster

    • isSubscriberRegistered

      public boolean isSubscriberRegistered(String serviceName, String groupName, String cluster)
      Judge subscriber has registered to server.
      参数:
      serviceName - service name
      groupName - group name
      cluster - cluster
      返回:
      true if subscribed, otherwise false

    • removeSubscriberForRedo

      public void removeSubscriberForRedo(String serviceName, String groupName, String cluster)
      Remove subscriber for redo.
      参数:
      serviceName - service name
      groupName - group name
      cluster - cluster

    • findSubscriberRedoData

      public Set<SubscriberRedoData> findSubscriberRedoData()
      Find all subscriber redo data which need do redo.
      返回:
      set of SubscriberRedoData need to do redo.

    • getRegisteredInstancesByKey

      public InstanceRedoData getRegisteredInstancesByKey(String combinedServiceName)
      get Cache service.
      返回:
      cache service

    • shutdown

      public void shutdown()
      Shutdown redo service.