- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 178 for zoneinfo (0.15 sec)
-
pkg/scheduler/testing/framework/fake_plugins.go
} // Filter invoked at the filter extension point. func (pl *FakeFilterPlugin) Filter(_ context.Context, _ *framework.CycleState, pod *v1.Pod, nodeInfo *framework.NodeInfo) *framework.Status { atomic.AddInt32(&pl.NumFilterCalled, 1) if returnCode, ok := pl.FailedNodeReturnCodeMap[nodeInfo.Node().Name]; ok { return framework.NewStatus(returnCode, fmt.Sprintf("injecting failure for pod %v", pod.Name)) } return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 19:07:19 UTC 2024 - 9.5K bytes - Viewed (0) -
pkg/kubelet/winstats/perfcounter_nodestats_test.go
return true, nil } return false, nil }); pollErr != nil { t.Fatalf("Encountered error: `%v'", pollErr) } } func TestGetMachineInfo(t *testing.T) { p := perfCounterNodeStatsClient{ nodeInfo: nodeInfo{ memoryPhysicalCapacityBytes: 100, }, } machineInfo, err := p.getMachineInfo() assert.NoError(t, err) assert.Equal(t, uint64(100), machineInfo.MemoryCapacity) hostname, _ := os.Hostname()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 26 18:37:21 UTC 2024 - 5.7K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodename/node_name_test.go
} for _, test := range tests { t.Run(test.name, func(t *testing.T) { nodeInfo := framework.NewNodeInfo() nodeInfo.SetNode(test.node) _, ctx := ktesting.NewTestContext(t) p, err := New(ctx, nil, nil) if err != nil { t.Fatalf("creating plugin: %v", err) } gotStatus := p.(framework.FilterPlugin).Filter(ctx, nil, test.pod, nodeInfo) if !reflect.DeepEqual(gotStatus, test.wantStatus) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 20 09:49:54 UTC 2023 - 1.8K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumerestrictions/volume_restrictions.go
// existing volumes. func satisfyVolumeConflicts(pod *v1.Pod, nodeInfo *framework.NodeInfo) bool { for i := range pod.Spec.Volumes { v := pod.Spec.Volumes[i] if !needsRestrictionsCheck(v) { continue } for _, ev := range nodeInfo.Pods { if isVolumeConflict(&v, ev.Pod) { return false } } } return true }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 20 17:40:39 UTC 2023 - 12.5K bytes - Viewed (1) -
pkg/scheduler/internal/cache/cache_test.go
usedPorts framework.HostPortInfo, imageStates map[string]*framework.ImageStateSummary, ) *framework.NodeInfo { nodeInfo := framework.NewNodeInfo(pods...) nodeInfo.Requested = requestedResource nodeInfo.NonZeroRequested = nonzeroRequest nodeInfo.UsedPorts = usedPorts nodeInfo.ImageStates = imageStates return nodeInfo } // TestAssumePodScheduled tests that after a pod is assumed, its information is aggregated
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 17 01:38:03 UTC 2023 - 63.8K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/framework.go
// 3) augmented nodeInfo. func addNominatedPods(ctx context.Context, fh framework.Handle, pod *v1.Pod, state *framework.CycleState, nodeInfo *framework.NodeInfo) (bool, *framework.CycleState, *framework.NodeInfo, error) { if fh == nil { // This may happen only in tests. return false, state, nodeInfo, nil } nominatedPodInfos := fh.NominatedPodsForNode(nodeInfo.Node().Name) if len(nominatedPodInfos) == 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 60.9K bytes - Viewed (0) -
src/internal/profile/graph.go
objfile = m.File } if ni := nodeInfo(l, li, objfile, o); ni != nil { return nm.FindOrInsertNode(*ni, o.KeptNodes) } return nil } func nodeInfo(l *Location, line Line, objfile string, o *Options) *NodeInfo { if line.Function == nil { return &NodeInfo{Address: l.Address} } ni := &NodeInfo{ Address: l.Address, Lineno: int(line.Line),
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 05 20:59:15 UTC 2024 - 13.1K bytes - Viewed (0) -
src/net/http/httptrace/example_test.go
"log" "net/http" "net/http/httptrace" ) func Example() { req, _ := http.NewRequest("GET", "http://example.com", nil) trace := &httptrace.ClientTrace{ GotConn: func(connInfo httptrace.GotConnInfo) { fmt.Printf("Got Conn: %+v\n", connInfo) }, DNSDone: func(dnsInfo httptrace.DNSDoneInfo) { fmt.Printf("DNS Info: %+v\n", dnsInfo) }, } req = req.WithContext(httptrace.WithClientTrace(req.Context(), trace))
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Sep 20 05:11:45 UTC 2016 - 712 bytes - Viewed (0) -
pkg/scheduler/framework/plugins/podtopologyspread/scoring.go
} // Ignore parsing errors for backwards compatibility. requiredNodeAffinity := nodeaffinity.GetRequiredNodeAffinity(pod) processAllNode := func(i int) { nodeInfo := allNodes[i] node := nodeInfo.Node() if !pl.enableNodeInclusionPolicyInPodTopologySpread { // `node` should satisfy incoming pod's NodeSelector/NodeAffinity if match, _ := requiredNodeAffinity.Match(node); !match {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 03:30:06 UTC 2023 - 10.1K bytes - Viewed (0) -
pkg/scheduler/internal/cache/debugger/comparer.go
func (c *CacheComparer) ComparePods(pods, waitingPods []*v1.Pod, nodeinfos map[string]*framework.NodeInfo) (missed, redundant []string) { actual := []string{} for _, pod := range pods { actual = append(actual, string(pod.UID)) } cached := []string{} for _, nodeinfo := range nodeinfos { for _, p := range nodeinfo.Pods { cached = append(cached, string(p.Pod.UID)) } } for _, pod := range waitingPods {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 29 05:26:32 UTC 2023 - 3.5K bytes - Viewed (0)