Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 23 for ownerRef (0.21 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top