- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 55 for tombstones (0.31 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)