- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for updatedNodes (0.29 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/trie_cache.go
// limitations under the License. package ledger import ( "sync" "time" "istio.io/istio/pkg/cache" ) type cacheDB struct { // updatedNodes that have will be flushed to disk updatedNodes byteCache // updatedMux is a lock for updatedNodes updatedMux sync.RWMutex } // byteCache implements a modified ExpiringCache interface, returning byte arrays // for ease of integration with smt calls.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 2K 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/ledger/smt_test.go
smt := newSMT(hasher, nil, time.Minute) // Add data to empty trie keys := getFreshData(10) values := getFreshData(10) _, err := smt.Update(keys, values) assert.NoError(t, err) smt.db.updatedNodes = byteCache{cache: cache.NewTTL(forever, time.Minute)} smt.loadDefaultHashes() // Check errors are raised is a keys is not in cache nor db for _, key := range keys { _, err := smt.Get(key)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 08 16:43:05 UTC 2023 - 7.9K bytes - Viewed (0) -
pkg/scheduler/internal/cache/cache_test.go
} // Create a few nodes as updated versions of the above nodes var updatedNodes []*v1.Node for _, n := range nodes { updatedNode := n.DeepCopy() updatedNode.Status.Allocatable = v1.ResourceList{ v1.ResourceCPU: resource.MustParse("2000m"), v1.ResourceMemory: resource.MustParse("500m"), } updatedNodes = append(updatedNodes, updatedNode) } // Create a few pods for tests. var pods []*v1.Pod
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/controller/nodelifecycle/node_lifecycle_controller_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 03:26:45 UTC 2024 - 119K 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_test.go
updatedNode.Status.Conditions[i].LastHeartbeatTime = metav1.Time{} updatedNode.Status.Conditions[i].LastTransitionTime = metav1.Time{} } // Version skew workaround. See: https://github.com/kubernetes/kubernetes/issues/16961 assert.Equal(t, v1.NodeReady, updatedNode.Status.Conditions[len(updatedNode.Status.Conditions)-1].Type, "NotReady should be last")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 08 19:23:19 UTC 2024 - 115.8K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/isolated/IsolatedProjectsToolingApiGradleProjectIntegrationTest.groovy
originalUpdatedModel.children.path == [":a", ":b"] originalUpdatedModel.children.all[0].tasks.name.contains("something") when: executer.withArguments(ENABLE_CLI) def updatedModel = fetchModel(GradleProject) then: fixture.assertStateUpdated { fileChanged("a/build.gradle") modelsCreated(":", GradleProject, IsolatedGradleProjectInternal)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 8.4K bytes - Viewed (0)