INNER CODE UNIT · Go
isNodeBeingDrained
kubernetes-sigs/aws-ebs-csi-driver · cmd/hooks/prestop.go:91
func isNodeBeingDrained(node *v1.Node) bool {
for _, taint := range node.Spec.Taints {
if _, isDrainTaint := drainTaints[taint.Key]; isDrainTaint {
return true
}
}
return false
}
func waitForVolumeAttachments(clientset kubernetes.Interface, nodeName string) error {
allAttachmentsDeleted := make(chan struct{})
factory := informers.NewSharedInformerFactory(clientset, 0)
informer := factory.Storage().V1().VolumeAttachments().Informer()
_, err := informer.AddEventHandler(cache.ResourceEventHandlerFuncs{
DeleteFunc: func(obj any) {
klog.V(5).InfoS("DeleteFunc: VolumeAttachment deleted", "node", nodeName)