Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for AddTestObject (0.2 sec)

  1. pkg/scheduler/framework/plugins/volumebinding/assume_cache_test.go

    		pvs1[pv.Name] = pv
    		assumecache.AddTestObject(cache.AssumeCache, pv)
    	}
    
    	// Add a bunch of PVs
    	pvs2 := map[string]*v1.PersistentVolume{}
    	for i := 0; i < 10; i++ {
    		pv := makePV(fmt.Sprintf("test2-pv%v", i), "class2").withVersion("1").PersistentVolume
    		pvs2[pv.Name] = pv
    		assumecache.AddTestObject(cache.AssumeCache, pv)
    	}
    
    	// List them
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 09:46:58 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  2. pkg/scheduler/util/assumecache/assume_cache.go

    type Informer interface {
    	AddEventHandler(handler cache.ResourceEventHandler) (cache.ResourceEventHandlerRegistration, error)
    }
    
    // AddTestObject adds an object to the assume cache.
    // Only use this for unit testing!
    func AddTestObject(cache *AssumeCache, obj interface{}) {
    	cache.add(obj)
    }
    
    // UpdateTestObject updates an object in the assume cache.
    // Only use this for unit testing!
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 09:46:58 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/volumebinding/binder_test.go

    	}
    }
    
    func (env *testEnv) initClaims(cachedPVCs []*v1.PersistentVolumeClaim, apiPVCs []*v1.PersistentVolumeClaim) {
    	for _, pvc := range cachedPVCs {
    		assumecache.AddTestObject(env.internalBinder.pvcCache.AssumeCache, pvc)
    		if apiPVCs == nil {
    			env.reactor.AddClaim(pvc)
    		}
    	}
    	for _, pvc := range apiPVCs {
    		env.reactor.AddClaim(pvc)
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 09:46:58 UTC 2024
    - 82.8K bytes
    - Viewed (0)
Back to top