Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for updatedNodes (0.15 sec)

  1. 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)
  2. 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)
  3. pkg/controller/controller_utils_test.go

    				AsyncCalls: []func(*testutil.FakeNodeHandler){func(m *testutil.FakeNodeHandler) {
    					if len(m.UpdatedNodes) == 0 {
    						m.UpdatedNodes = append(m.UpdatedNodes, &v1.Node{
    							ObjectMeta: metav1.ObjectMeta{
    								Name:            "node1",
    								ResourceVersion: "2",
    							},
    							Spec: v1.NodeSpec{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 39.4K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
Back to top