- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 40 for seenNode (0.3 sec)
-
pkg/scheduler/testing/framework/framework_helpers.go
func BuildNodeInfos(nodes []*v1.Node) []*framework.NodeInfo { res := make([]*framework.NodeInfo, len(nodes)) for i := 0; i < len(nodes); i++ { res[i] = framework.NewNodeInfo() res[i].SetNode(nodes[i]) } return res
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 03:30:06 UTC 2023 - 6.3K bytes - Viewed (0) -
android/guava/src/com/google/common/graph/DirectedGraphConnections.java
Set<N> seenNodes = new HashSet<>(); return new AbstractIterator<N>() { @Override @CheckForNull protected N computeNext() { while (nodeConnections.hasNext()) { NodeConnection<N> nodeConnection = nodeConnections.next(); boolean added = seenNodes.add(nodeConnection.node); if (added) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 20 17:00:05 UTC 2024 - 18K bytes - Viewed (0) -
okhttp-tls/src/test/java/okhttp3/tls/internal/der/DerCertificatesTest.kt
val encoded = CertificateAdapters.time.toDer(decoded) assertThat(decoded).isEqualTo(date("1949-12-31T23:59:59.000+0000").time) assertThat(encoded).isEqualTo(generalizedTimeDer) } @Test fun `reencode golden EC certificate`() { val certificateByteString = ( "MIIBkjCCATmgAwIBAgIBETAKBggqhkjOPQQDAjAwMRYwFAYDVQQLDA1HZW5lIFJ" +
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 43.9K bytes - Viewed (0) -
pkg/scheduler/internal/cache/snapshot.go
for _, node := range nodes { if _, ok := nodeNameToInfo[node.Name]; !ok { nodeNameToInfo[node.Name] = framework.NewNodeInfo() } nodeInfo := nodeNameToInfo[node.Name] nodeInfo.SetNode(node) nodeInfo.ImageStates = getNodeImageStates(node, imageExistenceMap) } return nodeNameToInfo } func createUsedPVCSet(pods []*v1.Pod) sets.Set[string] { usedPVCSet := sets.New[string]()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 17 01:38:03 UTC 2023 - 6.6K bytes - Viewed (0) -
src/net/http/httputil/reverseproxy.go
errc <- err } func cleanQueryParams(s string) string { reencode := func(s string) string { v, _ := url.ParseQuery(s) return v.Encode() } for i := 0; i < len(s); { switch s[i] { case ';': return reencode(s) case '%': if i+2 >= len(s) || !ishex(s[i+1]) || !ishex(s[i+2]) { return reencode(s) } i += 3 default: i++ } } return s }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 27 23:37:42 UTC 2024 - 24.9K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/noderesources/fit_test.go
t.Run(test.name, func(t *testing.T) { node := v1.Node{Status: v1.NodeStatus{Capacity: makeResources(10, 20, 32, 5, 20, 5), Allocatable: makeAllocatableResources(10, 20, 32, 5, 20, 5)}} test.nodeInfo.SetNode(&node) if test.args.ScoringStrategy == nil { test.args.ScoringStrategy = defaultScoringStrategy } _, ctx := ktesting.NewTestContext(t) ctx, cancel := context.WithCancel(ctx)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 57.4K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/resolve/ResolveTestFixture.groovy
return result } private visitEdges(NodeBuilder node, Set<NodeBuilder> seenNodes, Set<EdgeBuilder> edges) { for (EdgeBuilder edge : node.deps) { edges.add(edge) if (seenNodes.add(edge.selected)) { visitEdges(edge.selected, seenNodes, edges) } } } /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 37.8K bytes - Viewed (0) -
pkg/scheduler/eventhandlers_test.go
}, want: []bool{false, true, false, false}, }, } for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { nodeInfo := framework.NewNodeInfo(tt.existingPods...) nodeInfo.SetNode(tt.nodeFn()) preCheckFn := preCheckForNode(nodeInfo) var got []bool for _, pod := range tt.pods { got = append(got, preCheckFn(pod)) } if diff := cmp.Diff(tt.want, got); diff != "" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 10 14:38:54 UTC 2024 - 21.5K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodeports/node_ports_test.go
} }) } } func TestPreFilterDisabled(t *testing.T) { _, ctx := ktesting.NewTestContext(t) pod := &v1.Pod{} nodeInfo := framework.NewNodeInfo() node := v1.Node{} nodeInfo.SetNode(&node) p, err := New(ctx, nil, nil) if err != nil { t.Fatalf("creating plugin: %v", err) } cycleState := framework.NewCycleState()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 19 11:02:11 UTC 2023 - 10.1K bytes - Viewed (0) -
pkg/kubelet/lifecycle/predicate.go
Reason: "PodOSNotSupported", Message: "Failed to admit pod as the OS field doesn't match node OS", } } pods := attrs.OtherPods nodeInfo := schedulerframework.NewNodeInfo(pods...) nodeInfo.SetNode(node) // TODO: Remove this after the SidecarContainers feature gate graduates to GA. if !utilfeature.DefaultFeatureGate.Enabled(features.SidecarContainers) { for _, c := range admitPod.Spec.InitContainers {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 19 00:47:50 UTC 2023 - 10.9K bytes - Viewed (0)