Merge pull request #845 from sargun/non-blocking-node-status-update

Make node status updates non-blocking
This commit is contained in:
Sargun Dhillon
2020-07-01 12:46:56 -07:00
committed by GitHub

View File

@@ -185,7 +185,7 @@ func (n *NodeController) Run(ctx context.Context) error {
n.statusInterval = DefaultStatusUpdateInterval
}
n.chStatusUpdate = make(chan *corev1.Node)
n.chStatusUpdate = make(chan *corev1.Node, 1)
n.p.NotifyNodeStatus(ctx, func(node *corev1.Node) {
n.chStatusUpdate <- node
})