Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 55 for tombstones (0.31 sec)

  1. pkg/controller/statefulset/stateful_set.go

    		tombstone, ok := obj.(cache.DeletedFinalStateUnknown)
    		if !ok {
    			utilruntime.HandleError(fmt.Errorf("couldn't get object from tombstone %+v", obj))
    			return
    		}
    		pod, ok = tombstone.Obj.(*v1.Pod)
    		if !ok {
    			utilruntime.HandleError(fmt.Errorf("tombstone contained object that is not a pod %+v", obj))
    			return
    		}
    	}
    
    	controllerRef := metav1.GetControllerOf(pod)
    	if controllerRef == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 18.5K bytes
    - Viewed (0)
  2. pkg/kube/controllers/common.go

    	}
    }
    
    // Extract pulls a T from obj, handling tombstones.
    // This will return nil if the object cannot be extracted.
    func Extract[T Object](obj any) T {
    	var empty T
    	if obj == nil {
    		return empty
    	}
    	o, ok := obj.(T)
    	if !ok {
    		tombstone, ok := obj.(cache.DeletedFinalStateUnknown)
    		if !ok {
    			log.Errorf("couldn't get object from tombstone: %+v", obj)
    			return empty
    		}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Apr 11 08:27:29 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  3. pkg/kubelet/pleg/generic.go

    // container. In the case of relisting failure, the window may become longer.
    // Note that this assumption is not unique -- many kubelet internal components
    // rely on terminated containers as tombstones for bookkeeping purposes. The
    // garbage collector is implemented to work with such situations. However, to
    // guarantee that kubelet can handle missing container events, it is
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 19.3K bytes
    - Viewed (0)
  4. CHANGELOG/CHANGELOG-1.4.md

    * NodeController waits for informer sync before doing anything ([#34809](https://github.com/kubernetes/kubernetes/pull/34809), [@gmarek](https://github.com/gmarek))
    * Make NodeController recognize deletion tombstones ([#34786](https://github.com/kubernetes/kubernetes/pull/34786), [@davidopp](https://github.com/davidopp))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Dec 24 02:28:26 UTC 2020
    - 133.5K bytes
    - Viewed (0)
  5. CHANGELOG/CHANGELOG-1.17.md

    - Fix handling tombstones in pod-disruption-budged controller. ([#83951](https://github.com/kubernetes/kubernetes/pull/83951), [@zouyee](https://github.com/zouyee))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jan 28 10:44:33 UTC 2021
    - 346.2K bytes
    - Viewed (1)
  6. pkg/controller/endpointslicemirroring/utils.go

    	// is unrecorded.
    	tombstone, ok := obj.(cache.DeletedFinalStateUnknown)
    	if !ok {
    		utilruntime.HandleError(fmt.Errorf("couldn't get object from tombstone %#v", obj))
    		return nil
    	}
    	service, ok := tombstone.Obj.(*corev1.Service)
    	if !ok {
    		utilruntime.HandleError(fmt.Errorf("tombstone contained object that is not a Service resource: %#v", obj))
    		return nil
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 11 18:08:12 UTC 2023
    - 8.8K bytes
    - Viewed (0)
  7. plugin/pkg/auth/authorizer/node/graph_populator.go

    		}
    		if claimNameA != nil && *claimNameA != *claimNameB {
    			return false
    		}
    	}
    	return true
    }
    
    func (g *graphPopulator) deletePod(obj interface{}) {
    	if tombstone, ok := obj.(cache.DeletedFinalStateUnknown); ok {
    		obj = tombstone.Obj
    	}
    	pod, ok := obj.(*corev1.Pod)
    	if !ok {
    		klog.Infof("unexpected type %T", obj)
    		return
    	}
    	if len(pod.Spec.NodeName) == 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:22:55 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  8. pkg/controller/deployment/deployment_controller.go

    	d, ok := obj.(*apps.Deployment)
    	if !ok {
    		tombstone, ok := obj.(cache.DeletedFinalStateUnknown)
    		if !ok {
    			utilruntime.HandleError(fmt.Errorf("couldn't get object from tombstone %#v", obj))
    			return
    		}
    		d, ok = tombstone.Obj.(*apps.Deployment)
    		if !ok {
    			utilruntime.HandleError(fmt.Errorf("tombstone contained object that is not a Deployment %#v", obj))
    			return
    		}
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 24.2K bytes
    - Viewed (0)
  9. pkg/controller/certificates/certificate_controller.go

    			csr, ok := obj.(*certificates.CertificateSigningRequest)
    			if !ok {
    				tombstone, ok := obj.(cache.DeletedFinalStateUnknown)
    				if !ok {
    					logger.V(2).Info("Couldn't get object from tombstone", "object", obj)
    					return
    				}
    				csr, ok = tombstone.Obj.(*certificates.CertificateSigningRequest)
    				if !ok {
    					logger.V(2).Info("Tombstone contained object that is not a CSR", "object", obj)
    					return
    				}
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  10. pkg/controller/certificates/rootcacertpublisher/publisher.go

    func convertToCM(obj interface{}) (*v1.ConfigMap, error) {
    	cm, ok := obj.(*v1.ConfigMap)
    	if !ok {
    		tombstone, ok := obj.(cache.DeletedFinalStateUnknown)
    		if !ok {
    			return nil, fmt.Errorf("couldn't get object from tombstone %#v", obj)
    		}
    		cm, ok = tombstone.Obj.(*v1.ConfigMap)
    		if !ok {
    			return nil, fmt.Errorf("tombstone contained object that is not a ConfigMap %#v", obj)
    		}
    	}
    	return cm, nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 6.8K bytes
    - Viewed (0)
Back to top