- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 23 for ownerRef (0.21 sec)
-
pkg/kube/controllers/common.go
found, ok := gvk.ToGVR(gk) if !ok { return schema.GroupVersionResource{}, fmt.Errorf("unknown gvk: %v", gk) } return found, nil } // EnqueueForParentHandler returns a handler that will enqueue the parent (by ownerRef) resource func EnqueueForParentHandler(q Queue, kind config.GroupVersionKind) func(obj Object) { handler := func(obj Object) { for _, ref := range obj.GetOwnerReferences() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 11 08:27:29 UTC 2024 - 8.9K bytes - Viewed (0) -
plugin/pkg/admission/gc/gc_admission_test.go
func newGCPermissionsEnforcement() (*gcPermissionsEnforcement, error) { // the pods/status endpoint is ignored by this plugin since old kubelets // corrupt them. the pod status strategy ensures status updates cannot mutate // ownerRef. whiteList := []whiteListItem{ { groupResource: schema.GroupResource{Resource: "pods"}, subresource: "status", }, } gcAdmit := &gcPermissionsEnforcement{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 21:28:42 UTC 2024 - 24.5K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller_test.go
gvk := schema.GroupVersionKind{Version: "v1", Kind: "Service"} ownerRef := metav1.NewControllerRef(service, gvk) deletedTs := metav1.Now() endpointSlice := &discovery.EndpointSlice{ ObjectMeta: metav1.ObjectMeta{ Name: "epSlice-1", Namespace: ns, OwnerReferences: []metav1.OwnerReference{*ownerRef}, Labels: map[string]string{ discovery.LabelServiceName: serviceName,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 65.5K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_pod_control.go
return fmt.Errorf("could not update claim %s for delete policy ownerRefs: %w", claimName, err) } } } } return nil } // PodClaimIsStale returns true for a stale PVC that should block pod creation. If the scaling // policy is deletion, and a PVC has an ownerRef that does not match the pod, the PVC is stale. This // includes pods whose UID has not been created.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 14.9K bytes - Viewed (0) -
pkg/controller/garbagecollector/garbagecollector_test.go
events: []string{`Warning OwnerRefInvalidNamespace ownerRef [v1/Pod, namespace: ns1, name: podname2, uid: poduid2] does not exist in namespace "ns1" involvedObject{kind=Pod,apiVersion=v1}`}, }), // 6,7: handle queued delete of virtual parent processAttemptToDelete(1),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.6K bytes - Viewed (0) -
pkg/controller/disruption/disruption_test.go
APIResources: tc.apiResources, }, } trueVal := true ownerRef := &metav1.OwnerReference{ Kind: customGVK.Kind, APIVersion: customGVK.GroupVersion().String(), Controller: &trueVal, UID: customResourceUID, } _, err := dc.getScaleController(ctx, ownerRef, "default") if tc.expectError && err == nil { t.Error("expected error, but didn't get one")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 50K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_control_test.go
} func (om *fakeObjectManager) UpdateClaim(claim *v1.PersistentVolumeClaim) error { // Validate ownerRefs. refs := claim.GetOwnerReferences() for _, ref := range refs { if ref.APIVersion == "" || ref.Kind == "" || ref.Name == "" { return fmt.Errorf("invalid ownerRefs: %s %v", claim.Name, refs) } } om.claimsIndexer.Update(claim) return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 19:01:47 UTC 2024 - 108.7K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
} return fresh, nil }) cm := controller.NewPodControllerRefManager(jm.podControl, j, selector, controllerKind, canAdoptFunc, batch.JobTrackingFinalizer) // When adopting Pods, this operation adds an ownerRef and finalizers. pods, err = cm.ClaimPods(ctx, pods) if err != nil { return pods, err } // Set finalizer on adopted pods for the remaining calculations. for i, p := range pods { adopted := true
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
pkg/controller/job/job_controller_test.go
pb.Namespace = j.Namespace pb.OwnerReferences = []metav1.OwnerReference{*metav1.NewControllerRef(j, controllerKind)} return pb } func (pb podBuilder) owner(ownerRef metav1.OwnerReference) podBuilder { pb.OwnerReferences = append(pb.OwnerReferences, ownerRef) return pb } func (pb podBuilder) clearOwner() podBuilder { pb.OwnerReferences = nil return pb }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 229.2K bytes - Viewed (0) -
pkg/registry/rbac/helpers.go
*/ package rbac import ( "reflect" "k8s.io/apimachinery/pkg/api/meta" "k8s.io/apimachinery/pkg/conversion" "k8s.io/apimachinery/pkg/runtime" ) // IsOnlyMutatingGCFields checks finalizers and ownerrefs which GC manipulates // and indicates that only those fields are changing func IsOnlyMutatingGCFields(obj, old runtime.Object, equalities conversion.Equalities) bool { if old == nil || reflect.ValueOf(old).IsNil() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 29 16:29:43 UTC 2020 - 1.5K bytes - Viewed (0)