Merge pull request #123834 from alvaroaleman/emit-err
Nodelifecycle: Emit event when deletion failed
This commit is contained in:
		@@ -43,6 +43,7 @@ import (
 | 
				
			|||||||
 | 
					
 | 
				
			||||||
const (
 | 
					const (
 | 
				
			||||||
	deleteNodeEvent       = "DeletingNode"
 | 
						deleteNodeEvent       = "DeletingNode"
 | 
				
			||||||
 | 
						deleteNodeFailedEvent = "DeletingNodeFailed"
 | 
				
			||||||
)
 | 
					)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
var ShutdownTaint = &v1.Taint{
 | 
					var ShutdownTaint = &v1.Taint{
 | 
				
			||||||
@@ -175,6 +176,8 @@ func (c *CloudNodeLifecycleController) MonitorNodes(ctx context.Context) {
 | 
				
			|||||||
 | 
					
 | 
				
			||||||
			if err := c.kubeClient.CoreV1().Nodes().Delete(ctx, node.Name, metav1.DeleteOptions{}); err != nil {
 | 
								if err := c.kubeClient.CoreV1().Nodes().Delete(ctx, node.Name, metav1.DeleteOptions{}); err != nil {
 | 
				
			||||||
				klog.Errorf("unable to delete node %q: %v", node.Name, err)
 | 
									klog.Errorf("unable to delete node %q: %v", node.Name, err)
 | 
				
			||||||
 | 
									c.recorder.Eventf(ref, v1.EventTypeWarning, deleteNodeFailedEvent,
 | 
				
			||||||
 | 
										"Failed deleting node %s: %v", node.Name, err)
 | 
				
			||||||
			}
 | 
								}
 | 
				
			||||||
		} else {
 | 
							} else {
 | 
				
			||||||
			// Node exists. We need to check this to get taint working in similar in all cloudproviders
 | 
								// Node exists. We need to check this to get taint working in similar in all cloudproviders
 | 
				
			||||||
 
 | 
				
			|||||||
		Reference in New Issue
	
	Block a user