- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for updatedNodes (0.15 sec)
-
pkg/controller/testutil/test_utils.go
return nil, nil } var updatedNode v1.Node if err = json.Unmarshal(patchedObjJS, &updatedNode); err != nil { klog.FromContext(ctx).Error(err, "Failed to unmarshal patched object") return nil, nil } if updatedNodeIndex < 0 { m.UpdatedNodes = append(m.UpdatedNodes, &updatedNode) } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 15.6K bytes - Viewed (0) -
pkg/ledger/smt.go
// dont delete old nodes with atomic updated except when // moving up a shortcut, we dont record every single move s.db.updatedMux.Lock() // mark for expiration? if val, ok := s.db.updatedNodes.Get(node); ok { s.db.updatedNodes.SetWithExpiration(node, val, s.retentionDuration) } s.db.updatedMux.Unlock() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 08 16:43:05 UTC 2023 - 14K bytes - Viewed (0) -
pkg/controller/controller_utils_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 39.4K bytes - Viewed (0) -
pkg/controller/nodeipam/ipam/range_allocator_test.go
// nothing further expected return } for _, updatedNode := range tc.fakeNodeHandler.GetUpdatedNodesCopy() { if len(updatedNode.Spec.PodCIDRs) == 0 { continue // not assigned yet } //match for podCIDRIdx, expectedPodCIDR := range tc.expectedAllocatedCIDR { if updatedNode.Spec.PodCIDRs[podCIDRIdx] != expectedPodCIDR {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 10:06:15 UTC 2024 - 25.2K bytes - Viewed (0) -
pkg/kubelet/kubelet_node_status.go
} kl.lastStatusReportTime = kl.clock.Now() kl.setLastObservedNodeAddresses(updatedNode.Status.Addresses) readyIdx, readyCondition := nodeutil.GetNodeCondition(&updatedNode.Status, v1.NodeReady) if readyIdx >= 0 && readyCondition.Status == v1.ConditionTrue { kl.nodeStartupLatencyTracker.RecordNodeReady() } return updatedNode, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 31.1K bytes - Viewed (0) -
cmd/kube-proxy/app/server_linux_test.go
}, } node := &v1.Node{ ObjectMeta: metav1.ObjectMeta{ Name: nodeName, ResourceVersion: "1", }, } updatedNode := node.DeepCopy() updatedNode.Spec.PodCIDRs = expected updatedNode.Spec.PodCIDR = expected[0] // start with the new node client := clientsetfake.NewSimpleClientset()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 28 15:51:23 UTC 2024 - 21.9K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/isolated/IsolatedProjectsToolingApiIdeaProjectIntegrationTest.groovy
and: originalUpdatedModel.javaLanguageSettings.languageLevel == JavaVersion.VERSION_11 when: executer.withArguments(ENABLE_CLI) def updatedModel = fetchModel(IdeaProject) then: fixture.assertStateUpdated { fileChanged("a/build.gradle")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 20.9K bytes - Viewed (0) -
pkg/volume/csi/nodeinfomanager/nodeinfomanager_test.go
return nil, fmt.Errorf("failed to apply strategic merge patch %q on node %#v: %v", patch, originalNode, err) } updatedNode := &v1.Node{} if err := json.Unmarshal(updated, updatedNode); err != nil { return nil, fmt.Errorf("failed to unmarshal updated node %q: %v", updated, err) } return updatedNode, nil } func hasPatchAction(actions []clienttesting.Action) clienttesting.Action { for _, action := range actions {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Dec 17 02:02:59 UTC 2022 - 34.3K bytes - Viewed (0)