func NewNodeWatcher()

in pkg/k8s/k8s.go [59:71]

• 12 lines of code
• 1 McCabe index (conditional complexity)

func NewNodeWatcher(cs *kubernetes.Clientset, nodeName string) NodeWatcher {
	nodeInformer := informers.NewFilteredNodeInformer(cs, 0, cache.Indexers{}, func(options *metav1.ListOptions) {
		options.FieldSelector = fields.OneTermEqualSelector("metadata.name", nodeName).String()
	})
	podInformer := informers.NewFilteredPodInformer(cs, metav1.NamespaceSystem, 0, cache.Indexers{}, func(options *metav1.ListOptions) {
		options.FieldSelector = fields.OneTermEqualSelector("spec.nodeName", nodeName).String()
	})

	return &nodeWatcher{
		NodeInformer: nodeInformer,
		PodInformer:  podInformer,
	}
}