Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for assumeCache (0.25 sec)

  1. pkg/scheduler/util/assumecache/assume_cache.go

    	} else {
    		c.logger.V(10).Info("Adding object to assume cache", "description", c.description, "cacheKey", name, "assumeCache", obj)
    	}
    }
    
    func (c *AssumeCache) update(oldObj interface{}, newObj interface{}) {
    	c.add(newObj)
    }
    
    func (c *AssumeCache) delete(obj interface{}) {
    	if obj == nil {
    		return
    	}
    
    	name, err := cache.DeletionHandlingMetaNamespaceKeyFunc(obj)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 09:46:58 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/volumebinding/assume_cache_test.go

    		pvs[pv.Name] = pv
    		assumecache.AddTestObject(cache.AssumeCache, pv)
    	}
    
    	// List them
    	verifyListPVs(t, cache, pvs, "")
    
    	// Update a PV
    	updatedPV := makePV("test-pv3", "").withVersion("2").PersistentVolume
    	pvs[updatedPV.Name] = updatedPV
    	assumecache.UpdateTestObject(cache.AssumeCache, updatedPV)
    
    	// List them
    	verifyListPVs(t, cache, pvs, "")
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 09:46:58 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/volumebinding/binder.go

    	"k8s.io/klog/v2"
    	v1helper "k8s.io/kubernetes/pkg/apis/core/v1/helper"
    	"k8s.io/kubernetes/pkg/features"
    	"k8s.io/kubernetes/pkg/scheduler/framework/plugins/volumebinding/metrics"
    	"k8s.io/kubernetes/pkg/scheduler/util/assumecache"
    	"k8s.io/kubernetes/pkg/volume/util"
    )
    
    // ConflictReason is used for the special strings which explain why
    // volume binding is impossible for a node.
    type ConflictReason string
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 09 14:55:34 UTC 2024
    - 42.6K bytes
    - Viewed (0)
Back to top