private void watch()

in registry-api/src/main/java/com/alibaba/dubbo/registry/kubernetes/KubernetesRegistry.java [127:150]

• 20 lines of code
• 4 McCabe index (conditional complexity)

    private void watch(final NotifyListener notifyListener, String targetNameSpace, String targetName, int targetPort) {
        kubernetesClient.endpoints().inNamespace(targetNameSpace)
                .withName(targetName)
                .watch(new Watcher<Endpoints>() {
                    @Override
                    public void eventReceived(Action action, Endpoints endpoints) {
                        switch (action) {
                            case MODIFIED:
                            case ADDED:
                                update(endpoints, notifyListener, targetPort);
                                return;
                            case DELETED:
                                //TODO
                                //notifyListener.notify(Collections.emptyList());
                                return;
                        }
                    }

                    @Override
                    public void onClose(KubernetesClientException e) {

                    }
                });
    }