func deepEqualWithoutGeneration(actual *nodeInfoListItem, expected *framework.NodeInfo) error { … }
type hostPortInfoParam …
type hostPortInfoBuilder …
func newHostPortInfoBuilder() *hostPortInfoBuilder { … }
func (b *hostPortInfoBuilder) add(protocol, ip string, port int32) *hostPortInfoBuilder { … }
func (b *hostPortInfoBuilder) build() framework.HostPortInfo { … }
func newNodeInfo(requestedResource *framework.Resource,
nonzeroRequest *framework.Resource,
pods []*v1.Pod,
usedPorts framework.HostPortInfo,
imageStates map[string]*framework.ImageStateSummary,
) *framework.NodeInfo { … }
func TestAssumePodScheduled(t *testing.T) { … }
type testExpirePodStruct …
func assumeAndFinishBinding(logger klog.Logger, cache *cacheImpl, pod *v1.Pod, assumedTime time.Time) error { … }
func TestExpirePod(t *testing.T) { … }
func TestAddPodWillConfirm(t *testing.T) { … }
func TestDump(t *testing.T) { … }
func TestAddPodAlwaysUpdatesPodInfoInNodeInfo(t *testing.T) { … }
func TestAddPodWillReplaceAssumed(t *testing.T) { … }
func TestAddPodAfterExpiration(t *testing.T) { … }
func TestUpdatePod(t *testing.T) { … }
func TestUpdatePodAndGet(t *testing.T) { … }
func TestExpireAddUpdatePod(t *testing.T) { … }
func makePodWithEphemeralStorage(nodeName, ephemeralStorage string) *v1.Pod { … }
func TestEphemeralStorageResource(t *testing.T) { … }
func TestRemovePod(t *testing.T) { … }
func TestForgetPod(t *testing.T) { … }
func buildNodeInfo(node *v1.Node, pods []*v1.Pod, imageStates map[string]*framework.ImageStateSummary) *framework.NodeInfo { … }
func buildImageStates(nodes []*v1.Node) map[string]*framework.ImageStateSummary { … }
func TestNodeOperators(t *testing.T) { … }
func TestSchedulerCache_UpdateSnapshot(t *testing.T) { … }
func compareCacheWithNodeInfoSnapshot(t *testing.T, cache *cacheImpl, snapshot *Snapshot) error { … }
func TestSchedulerCache_updateNodeInfoSnapshotList(t *testing.T) { … }
func BenchmarkUpdate1kNodes30kPods(b *testing.B) { … }
func BenchmarkExpirePods(b *testing.B) { … }
func benchmarkExpire(b *testing.B, podNum int) { … }
type testingMode …
func makeBasePod(t testingMode, nodeName, objName, cpu, mem, extended string, ports []v1.ContainerPort) *v1.Pod { … }
func checkImageStateSummary(nodes map[string]*framework.NodeInfo, imageNames ...string) bool { … }
func setupCacheOf1kNodes30kPods(b *testing.B) Cache { … }
func setupCacheWithAssumedPods(b *testing.B, podNum int, assumedTime time.Time) *cacheImpl { … }
func isForgottenFromCache(p *v1.Pod, c *cacheImpl) error { … }
func (cache *cacheImpl) getNodeInfo(nodeName string) (*v1.Node, error) { … }