- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for GetAPIObj (0.16 sec)
-
pkg/scheduler/framework/plugins/volumebinding/assume_cache.go
if !ok { return nil, &assumecache.WrongTypeError{TypeName: "v1.PersistentVolume", Object: obj} } return pv, nil } func (c *PVAssumeCache) GetAPIPV(pvName string) (*v1.PersistentVolume, error) { obj, err := c.GetAPIObj(pvName) if err != nil { return nil, err } pv, ok := obj.(*v1.PersistentVolume) if !ok { return nil, &assumecache.WrongTypeError{TypeName: "v1.PersistentVolume", Object: obj} } return pv, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 09:46:58 UTC 2024 - 3.7K bytes - Viewed (0) -
pkg/scheduler/util/assumecache/assume_cache.go
defer c.rwMutex.RUnlock() objInfo, err := c.getObjInfo(key) if err != nil { return nil, err } return objInfo.latestObj, nil } // GetAPIObj gets the informer cache's version by its key. func (c *AssumeCache) GetAPIObj(key string) (interface{}, error) { c.rwMutex.RLock() defer c.rwMutex.RUnlock() objInfo, err := c.getObjInfo(key) if err != nil { return nil, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 09:46:58 UTC 2024 - 10.6K bytes - Viewed (0) -
pkg/scheduler/util/assumecache/assume_cache_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 09:46:58 UTC 2024 - 9.5K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/binder_test.go
pvs[i] = newPv } return wait.PollUntilContextTimeout(ctx, 100*time.Millisecond, 3*time.Second, false, func(ctx context.Context) (bool, error) { for _, pv := range pvs { obj, err := env.internalBinder.pvCache.GetAPIObj(pv.Name) if obj == nil || err != nil { return false, nil } pvInCache, ok := obj.(*v1.PersistentVolume) if !ok { return false, fmt.Errorf("PV %s invalid object", pvInCache.Name) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 09:46:58 UTC 2024 - 82.8K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/dynamicresources/dynamicresources_test.go
for _, obj := range tc.p.claimAssumeCache.List(nil) { claim := obj.(*resourcev1alpha2.ResourceClaim) obj, _ := tc.p.claimAssumeCache.Get(claim.Namespace + "/" + claim.Name) apiObj, _ := tc.p.claimAssumeCache.GetAPIObj(claim.Namespace + "/" + claim.Name) if obj != apiObj { assumedClaims = append(assumedClaims, claim) } } sortObjects(assumedClaims) return assumedClaims }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 07:57:10 UTC 2024 - 61.9K bytes - Viewed (0)