@Override
    public void start() {
        initHealthChecker();
        NamespacedPodListInformer.INFORMER.init(config, new K8sResourceEventHandler());
    }
@Test
    public void queryRemoteNodesWhenInformerWork() throws Exception {
        withEnvironmentVariable(SELF_UID + "0", SELF_UID + "0")
                .execute(() -> {
                    ModuleProvider provider = createProvider(SELF_UID + "0");
                    KubernetesCoordinator coordinator = getClusterCoordinator(provider);
                    coordinator.start();
                    doReturn(Optional.of(mockPodList())).when(NamespacedPodListInformer.INFORMER).listPods();
                    List<RemoteInstance> remoteInstances = Whitebox.invokeMethod(coordinator, "queryRemoteNodes");
                    Assertions.assertEquals(5, remoteInstances.size());
                    List<RemoteInstance> self = remoteInstances.stream()
                            .filter(item -> item.getAddress().isSelf())
                            .collect(Collectors.toList());
                    List<RemoteInstance> others = remoteInstances.stream()
                            .filter(item -> !item.getAddress().isSelf())
                            .collect(Collectors.toList());

                    Assertions.assertEquals(1, self.size());
                    Assertions.assertEquals(4, others.size());
                });
    }