Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for newNode (0.27 sec)

  1. pkg/scheduler/framework/plugins/interpodaffinity/plugin_test.go

    		name             string
    		pod              *v1.Pod
    		oldNode, newNode *v1.Node
    		expectedHint     framework.QueueingHint
    	}{
    		{
    			name:         "add a new node with matched pod affinity topologyKey",
    			pod:          st.MakePod().Name("p").PodAffinityIn("service", "zone", []string{"securityscan", "value2"}, st.PodAffinityWithRequiredReq).Obj(),
    			newNode:      st.MakeNode().Name("node-a").Label("zone", "zone1").Obj(),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 12 03:08:44 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  2. pkg/registry/core/node/strategy.go

    // PrepareForUpdate clears fields that are not allowed to be set by end users on update.
    func (nodeStrategy) PrepareForUpdate(ctx context.Context, obj, old runtime.Object) {
    	newNode := obj.(*api.Node)
    	oldNode := old.(*api.Node)
    	newNode.Status = oldNode.Status
    
    	dropDisabledFields(newNode, oldNode)
    }
    
    func dropDisabledFields(node *api.Node, oldNode *api.Node) {
    	// Nodes allow *all* fields, including status, to be set on create.
    	// for create
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 13 23:06:39 UTC 2024
    - 9K bytes
    - Viewed (0)
  3. src/runtime/tracemap.go

    			// much activity, or the map gets big and races to insert on
    			// the same node are much less likely.
    			if newNode == nil {
    				newNode = tab.newTraceMapNode(data, size, hash, tab.seq.Add(1))
    			}
    			if m.CompareAndSwapNoWB(nil, unsafe.Pointer(newNode)) {
    				return newNode.id, true
    			}
    			// Reload n. Because pointers are only stored once,
    			// we must have lost the race, and therefore n is not nil
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 15 17:03:35 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  4. testing/smoke-test/src/smokeTest/groovy/org/gradle/smoketests/NodePluginsSmokeTest.groovy

                //'com.moowork.grunt': TestedVersions.node,
                //'com.moowork.gulp': TestedVersions.node,
                'com.moowork.node': TestedVersions.node,
                'com.github.node-gradle.node': TestedVersions.newNode
            ]
        }
    
        @Override
        void configureValidation(String testedPluginId, String version) {
            validatePlugins {
                if (testedPluginId == 'com.moowork.node') {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 04 07:21:38 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  5. platforms/core-configuration/declarative-dsl-core/src/test/kotlin/org/gradle/internal/declarativedsl/demo/demoPlugins/ReflectionDemo.kt

            println("=== version range:")
            println(versionRange)
    
            println("===")
            val newCode = code.replaceRange(versionRange, "\"1.9.20-Beta\"")
            println(newCode)
    
            println("===")
            schema.reflectAndPrint(newCode)
        }
    }
    
    
    private
    fun String.replaceRange(range: IntRange, replacement: String): String {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue May 14 10:08:01 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  6. platforms/core-configuration/configuration-cache-base/src/main/kotlin/org/gradle/internal/cc/base/services/ConfigurationCacheEnvironmentChangeTracker.kt

            private
            inline fun <T : TrackerMode> setMode(transition: (TrackerMode) -> T): T {
                synchronized(this) {
                    val newMode = transition(mode)
                    mode = newMode
                    return newMode
                }
            }
    
            fun toTrackingMode(): Tracking = setMode(TrackerMode::toTracking)
    
            fun toRestoringMode(): Restoring = setMode(TrackerMode::toRestoring)
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Sat Jun 08 11:29:30 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/app/web/api/admin/general/ApiAdminGeneralAction.java

            validateApi(body, messages -> {});
            final EditBody newBody = new EditBody();
            AdminGeneralAction.updateForm(fessConfig, newBody);
            BeanUtil.copyBeanToBean(body, newBody, CopyOptions::excludeNull);
            AdminGeneralAction.updateConfig(fessConfig, newBody);
            return asJson(new ApiResponse().status(Status.OK).result());
        }
    
    Registered: Wed Jun 12 13:08:18 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  8. plugin/pkg/admission/namespace/autoprovision/admission_test.go

    					Name:            ns,
    					ResourceVersion: fmt.Sprintf("%d", i),
    				},
    			})
    		}
    		return true, namespaceList, nil
    	})
    	return mockClient
    }
    
    // newPod returns a new pod for the specified namespace
    func newPod(namespace string) api.Pod {
    	return api.Pod{
    		ObjectMeta: metav1.ObjectMeta{Name: "123", Namespace: namespace},
    		Spec: api.PodSpec{
    			Volumes:    []api.Volume{{Name: "vol"}},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 06 00:00:21 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  9. pilot/pkg/controllers/untaint/nodeuntainter_test.go

    		pod.Status = corev1.PodStatus{}
    		newPod := s.pc.Create(pod)
    		if markReady {
    			setPodReady(newPod)
    		}
    		newPod.Status.PodIP = ip
    		newPod.Status.Phase = corev1.PodRunning
    		newPod.Status.PodIPs = []corev1.PodIP{
    			{
    				IP: ip,
    			},
    		}
    		s.pc.UpdateStatus(newPod)
    	} else {
    		s.pc.Update(pod)
    	}
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat Apr 13 00:50:31 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  10. plugin/pkg/admission/namespace/exists/admission_test.go

    					Name:            ns,
    					ResourceVersion: fmt.Sprintf("%d", i),
    				},
    			})
    		}
    		return true, namespaceList, nil
    	})
    	return mockClient
    }
    
    // newPod returns a new pod for the specified namespace
    func newPod(namespace string) api.Pod {
    	return api.Pod{
    		ObjectMeta: metav1.ObjectMeta{Name: "123", Namespace: namespace},
    		Spec: api.PodSpec{
    			Volumes:    []api.Volume{{Name: "vol"}},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 06 00:00:21 UTC 2024
    - 4.4K bytes
    - Viewed (0)
Back to top