- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for watchObject (0.22 sec)
-
pkg/kubelet/util/manager/watch_based_manager.go
maxIdleTime = minIdleTime } store := &objectCache{ listObject: listObject, watchObject: watchObject, newObject: newObject, isImmutable: isImmutable, groupResource: groupResource, clock: clock, maxIdleTime: maxIdleTime, items: make(map[objectKey]*objectCacheItem), } go wait.Until(store.startRecycleIdleWatch, time.Minute, stopCh)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 11.6K bytes - Viewed (0) -
pkg/kubelet/util/manager/watch_based_manager_test.go
} return false } func newSecretCache(fakeClient clientset.Interface, fakeClock clock.Clock, maxIdleTime time.Duration) *objectCache { return &objectCache{ listObject: listSecret(fakeClient), watchObject: watchSecret(fakeClient), newObject: func() runtime.Object { return &v1.Secret{} }, isImmutable: isSecretImmutable, groupResource: corev1.Resource("secret"), clock: fakeClock,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 09 10:05:43 UTC 2023 - 17.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/predicates/object/matcher.go
selector, err := p.GetParsedObjectSelector() if err != nil { return false, apierrors.NewInternalError(err) } if selector.Empty() { return true, nil } return matchObject(attr.GetObject(), selector) || matchObject(attr.GetOldObject(), selector), nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 26 00:41:14 UTC 2022 - 1.8K bytes - Viewed (0) -
pkg/controller/garbagecollector/patch.go
smpResult, err := gc.patchObject(item.identity, smp, types.StrategicMergePatchType) if err == nil { return smpResult, nil } if !errors.IsUnsupportedMediaType(err) { return nil, err } // StrategicMergePatch is not supported, use JSON merge patch instead patch, err := jmp(item) if err != nil { return nil, err } return gc.patchObject(item.identity, patch, types.MergePatchType) }
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/garbagecollector/operations.go
return nil, namespacedOwnerOfClusterScopedObjectErr } return gc.metadataClient.Resource(resource).Namespace(namespace).Get(context.TODO(), item.Name, metav1.GetOptions{}) } func (gc *GarbageCollector) patchObject(item objectReference, patch []byte, pt types.PatchType) (*metav1.PartialObjectMetadata, error) { resource, namespaced, err := gc.apiResource(item.APIVersion, item.Kind) if err != nil { return nil, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 13:37:56 UTC 2023 - 4.9K bytes - Viewed (0)