Watch for changes in Endpoints using K8s native Python client

gistfile1.txt

from kubernetes import client, config, watch

config.load_kube_config()
api_v1 = client.CoreV1Api()

def watch_endpoints():
    w = watch.Watch()
    for event in w.stream(api_v1.list_namespaced_endpoints, "default"):
        print(event)
                    
if __name__ == '__main__':
    watch_endpoints()