@Test public void testRemoveInstance() throws NacosException { serviceManager.createEmptyService(TEST_NAMESPACE, TEST_SERVICE_NAME, true); serviceManager.removeInstance(TEST_NAMESPACE, TEST_SERVICE_NAME, true, instance); String instanceListKey = KeyBuilder.buildInstanceListKey(TEST_NAMESPACE, TEST_SERVICE_NAME, true); verify(consistencyService).put(eq(instanceListKey), any(Instances.class)); }
public void removeInstance(String namespaceId, String serviceName, boolean ephemeral, Instance... ips) throws NacosException { Service service = getService(namespaceId, serviceName); synchronized (service) { removeInstance(namespaceId, serviceName, ephemeral, service, ips); } }
ServiceManager implements RecordListener<Service> { public void removeInstance(String namespaceId, String serviceName, boolean ephemeral, Instance... ips) throws NacosException { Service service = getService(namespaceId, serviceName); synchronized (service) { removeInstance(namespaceId, serviceName, ephemeral, service, ips); } } }
ServiceManager implements RecordListener<Service> { public void removeInstance(String namespaceId, String serviceName, boolean ephemeral, Instance... ips) throws NacosException { Service service = getService(namespaceId, serviceName); synchronized (service) { removeInstance(namespaceId, serviceName, ephemeral, service, ips); } } ServiceManager(SwitchDomain switchDomain, DistroMapper distroMapper, ServerMemberManager memberManager,
            PushService pushService, RaftPeerSet raftPeerSet); }
ServiceManager implements RecordListener<Service> { public void removeInstance(String namespaceId, String serviceName, boolean ephemeral, Instance... ips) throws NacosException { Service service = getService(namespaceId, serviceName); synchronized (service) { removeInstance(namespaceId, serviceName, ephemeral, service, ips); } } ServiceManager(SwitchDomain switchDomain, DistroMapper distroMapper, ServerMemberManager memberManager,
            PushService pushService, RaftPeerSet raftPeerSet); @PostConstruct void init(); Map<String, Service> chooseServiceMap(String namespaceId); void addUpdatedServiceToQueue(String namespaceId, String serviceName, String serverIP, String checksum); @Override boolean interests(String key); @Override boolean matchUnlistenKey(String key); @Override void onChange(String key, Service service); @Override void onDelete(String key); RaftPeer getMySelfClusterState(); void updatedHealthStatus(String namespaceId, String serviceName, String serverIP); Set<String> getAllServiceNames(String namespaceId); Map<String, Set<String>> getAllServiceNames(); Set<String> getAllNamespaces(); List<String> getAllServiceNameList(String namespaceId); Map<String, Set<Service>> getResponsibleServices(); int getResponsibleServiceCount(); int getResponsibleInstanceCount(); void easyRemoveService(String namespaceId, String serviceName); void addOrReplaceService(Service service); void createEmptyService(String namespaceId, String serviceName, boolean local); void createServiceIfAbsent(String namespaceId, String serviceName, boolean local, Cluster cluster); void registerInstance(String namespaceId, String serviceName, Instance instance); void updateInstance(String namespaceId, String serviceName, Instance instance); void addInstance(String namespaceId, String serviceName, boolean ephemeral, Instance... ips); void removeInstance(String namespaceId, String serviceName, boolean ephemeral, Instance... ips); Instance getInstance(String namespaceId, String serviceName, String cluster, String ip, int port); List<Instance> updateIpAddresses(Service service, String action, boolean ephemeral, Instance... ips); Service getService(String namespaceId, String serviceName); boolean containService(String namespaceId, String serviceName); void putService(Service service); List<Service> searchServices(String namespaceId, String regex); int getServiceCount(); int getInstanceCount(); int getPagedService(String namespaceId, int startPage, int pageSize, String param, String containedInstance,
            List<Service> serviceList, boolean hasIpCount); }
ServiceManager implements RecordListener<Service> { public void removeInstance(String namespaceId, String serviceName, boolean ephemeral, Instance... ips) throws NacosException { Service service = getService(namespaceId, serviceName); synchronized (service) { removeInstance(namespaceId, serviceName, ephemeral, service, ips); } } ServiceManager(SwitchDomain switchDomain, DistroMapper distroMapper, ServerMemberManager memberManager,
            PushService pushService, RaftPeerSet raftPeerSet); @PostConstruct void init(); Map<String, Service> chooseServiceMap(String namespaceId); void addUpdatedServiceToQueue(String namespaceId, String serviceName, String serverIP, String checksum); @Override boolean interests(String key); @Override boolean matchUnlistenKey(String key); @Override void onChange(String key, Service service); @Override void onDelete(String key); RaftPeer getMySelfClusterState(); void updatedHealthStatus(String namespaceId, String serviceName, String serverIP); Set<String> getAllServiceNames(String namespaceId); Map<String, Set<String>> getAllServiceNames(); Set<String> getAllNamespaces(); List<String> getAllServiceNameList(String namespaceId); Map<String, Set<Service>> getResponsibleServices(); int getResponsibleServiceCount(); int getResponsibleInstanceCount(); void easyRemoveService(String namespaceId, String serviceName); void addOrReplaceService(Service service); void createEmptyService(String namespaceId, String serviceName, boolean local); void createServiceIfAbsent(String namespaceId, String serviceName, boolean local, Cluster cluster); void registerInstance(String namespaceId, String serviceName, Instance instance); void updateInstance(String namespaceId, String serviceName, Instance instance); void addInstance(String namespaceId, String serviceName, boolean ephemeral, Instance... ips); void removeInstance(String namespaceId, String serviceName, boolean ephemeral, Instance... ips); Instance getInstance(String namespaceId, String serviceName, String cluster, String ip, int port); List<Instance> updateIpAddresses(Service service, String action, boolean ephemeral, Instance... ips); Service getService(String namespaceId, String serviceName); boolean containService(String namespaceId, String serviceName); void putService(Service service); List<Service> searchServices(String namespaceId, String regex); int getServiceCount(); int getInstanceCount(); int getPagedService(String namespaceId, int startPage, int pageSize, String param, String containedInstance,
            List<Service> serviceList, boolean hasIpCount);  }