- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 25 for GetOwnerReferences (0.26 sec)
-
pkg/controller/garbagecollector/patch.go
if err != nil { return nil, err } expectedObjectMeta := ObjectMetaForPatch{} expectedObjectMeta.ResourceVersion = accessor.GetResourceVersion() refs := accessor.GetOwnerReferences() for _, ref := range refs { var skip bool for _, ownerUID := range ownerUIDs { if ref.UID == ownerUID { skip = true break } } if !skip {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 05 13:33:52 UTC 2021 - 5.6K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_utils_test.go
claim.SetOwnerReferences(tc.originalRefs) updateClaimOwnerRefForSetAndPod(logger, &claim, &set, &pod) if ownerRefsChanged(tc.expectedRefs, claim.GetOwnerReferences()) { t.Errorf("%s: expected %v, got %v", tc.name, tc.expectedRefs, claim.GetOwnerReferences()) } } } func TestHasOwnerRef(t *testing.T) { target := v1.Pod{} target.SetOwnerReferences([]metav1.OwnerReference{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 50.9K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/api/meta/meta.go
DeletionGracePeriodSeconds: m.GetDeletionGracePeriodSeconds(), Labels: m.GetLabels(), Annotations: m.GetAnnotations(), OwnerReferences: m.GetOwnerReferences(), Finalizers: m.GetFinalizers(), ManagedFields: m.GetManagedFields(), }, } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 25 16:23:43 UTC 2022 - 16.5K bytes - Viewed (0) -
pkg/kube/controllers/common.go
func EnqueueForParentHandler(q Queue, kind config.GroupVersionKind) func(obj Object) { handler := func(obj Object) { for _, ref := range obj.GetOwnerReferences() { refGV, err := schema.ParseGroupVersion(ref.APIVersion) if err != nil { log.Errorf("could not parse OwnerReference api version %q: %v", ref.APIVersion, err) continue }
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/controller/garbagecollector/graph_builder.go
if len(added) != 0 || len(removed) != 0 || len(changed) != 0 { // check if the changed dependency graph unblock owners that are // waiting for the deletion of their dependents. gb.addUnblockedOwnersToDeleteQueue(logger, removed, changed) // update the node itself existingNode.owners = accessor.GetOwnerReferences()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.9K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/helpers.go
meta.SetLabels(existingMeta.GetLabels()) meta.SetAnnotations(existingMeta.GetAnnotations()) meta.SetFinalizers(existingMeta.GetFinalizers()) meta.SetOwnerReferences(existingMeta.GetOwnerReferences()) // managedFields must be preserved since it's been modified to // track changed fields in the status update. //meta.SetManagedFields(existingMeta.GetManagedFields()) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Sep 15 10:58:36 UTC 2022 - 9.6K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_control_test.go
if err != nil { t.Fatalf("%s: %s", test.name, err) } for _, claim := range claims { for _, ref := range claim.GetOwnerReferences() { if strings.HasPrefix(ref.Name, "foo-") { t.Fatalf("Unexpected pod reference on %s: %v", claim.Name, claim.GetOwnerReferences()) } } } replicas := *set.Spec.Replicas *set.Spec.Replicas = 0
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 19:01:47 UTC 2024 - 108.7K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/unstructured/unstructured.go
if u.Object == nil { u.Object = make(map[string]interface{}) } SetNestedStringMap(u.Object, value, fields...) } func (u *Unstructured) GetOwnerReferences() []metav1.OwnerReference { field, found, err := NestedFieldNoCopy(u.Object, "metadata", "ownerReferences") if !found || err != nil { return nil } original, ok := field.([]interface{}) if !ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun May 28 03:26:35 UTC 2023 - 13.7K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/test/api_meta_meta_test.go
} func testGetOwnerReferences(t *testing.T) { obj, expected := getObjectMetaAndOwnerReferences() accessor, err := meta.Accessor(&obj) if err != nil { t.Error(err) } references := accessor.GetOwnerReferences() if !reflect.DeepEqual(references, expected) { t.Errorf("expect %#v\n got %#v", expected, references) } } func testSetOwnerReferences(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 14 10:11:56 UTC 2022 - 12.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/rest.go
accessor, err := meta.Accessor(obj) if err != nil { // The object doesn't have metadata. Nothing we need to do here. return } refs := accessor.GetOwnerReferences() deduped, duplicates := dedupOwnerReferences(refs) if len(duplicates) > 0 { // NOTE: For CREATE and UPDATE requests the API server dedups both before and after mutating admission.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 21:44:00 UTC 2023 - 17K bytes - Viewed (0)