k8s-pod-restart-info-collector.go

// Watch Pod update events
podInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
	UpdateFunc: func(old interface{}, new interface{}) {
		oldPod, newPod := old.(*v1.Pod), new.(*v1.Pod)
		oldPodRestartCount := getPodRestartCount(oldPod)
		newPodRestartCount := getPodRestartCount(newPod)
		// Compare the RestartCount 
		if newPodRestartCount > oldPodRestartCount {
			key, err := cache.MetaNamespaceKeyFunc(new)
			if err == nil {
				queue.Add(key)
			}
			klog.Infof("Found: %s/%s restarted, restartCount: %d -> %d\n", newPod.Namespace, newPod.Name, oldPodRestartCount, newPodRestartCount)
		}
	},
})

// getPodRestartCount gets Pod RestartCount from Pod Status
func getPodRestartCount(pod *v1.Pod) int {
	var restarts int = 0
	for i := range pod.Status.ContainerStatuses {
		container := pod.Status.ContainerStatuses[i]
		restarts += int(container.RestartCount)
	}
	return restarts
}