@Override
            public void eventReceived(Action action, Pod resource) {
                if (closed) {
                    return;
                }
                numPodFailures = 0;
                withUpdateLock(updateId, () -> {
                    if (!updatePod(action, resource)) {
                        return;
                    }
                    maybeUpdateEndpoints();
                });
            }
Watches the service. {@link Watcher} will retry automatically on failures by {@link KubernetesClient}.
kubernetes/src/main/java/com/linecorp/armeria/client/kubernetes/endpoints/KubernetesEndpointGroup.java