Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for watchObject (0.18 sec)

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