观看k8s golang api手表并获取事件，但一段时间后不再获得任何事件

Question

I'm using AKS and K8s golang API.

I'm creating a Kubernetes watcher for watching jobs like

watchres, error := jobsClient.Watch(metav1.ListOptions{})

After that i'm getting the events channel like

eventres := watchres.ResultChan()

After that i'm getting events in a loop using

we := <-eventres

then on the basis of these event i'm performing some action (for example delete a resource when kubernetes job gets successful)

The issue i am facing is that everything seems to work fine but after some period of time the watcher does not delete resources however the jobs gets successful, what might be the issue, is there a timeout for the channel?? however i'm not closing the channel implicitly.

Answer 1

There is a default timeout on the watch. I believe it is set to 30 minutes.

You can override this value in ListOptions. So for example, to set the timeout to an hour:

timeout := int64(3600)
watchres, error := jobsClient.Watch(metav1.ListOptions{
    TimeoutSeconds: &timeout,
})