Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 284 for NodeName (0.15 sec)

  1. pkg/scheduler/testing/framework/fake_extender.go

    func (pl *node2PrioritizerPlugin) Name() string {
    	return "Node2Prioritizer"
    }
    
    // Score return score 100 if the given nodeName is "node2"; otherwise return score 10.
    func (pl *node2PrioritizerPlugin) Score(_ context.Context, _ *framework.CycleState, _ *v1.Pod, nodeName string) (int64, *framework.Status) {
    	score := 10
    	if nodeName == "node2" {
    		score = 100
    	}
    	return int64(score), nil
    }
    
    // ScoreExtensions returns nil.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 19:07:19 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  2. cmd/kubeadm/app/cmd/phases/join/kubelet.go

    	klog.V(1).Infof("[kubelet-start] Checking for an existing Node in the cluster with name %q and status %q", nodeName, v1.NodeReady)
    	node, err := bootstrapClient.CoreV1().Nodes().Get(context.TODO(), nodeName, metav1.GetOptions{})
    	if err != nil && !apierrors.IsNotFound(err) {
    		return errors.Wrapf(err, "cannot get Node %q", nodeName)
    	}
    	for _, cond := range node.Status.Conditions {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 01 07:10:31 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  3. pkg/volume/volume.go

    	// node.
    	Attach(spec *Spec, nodeName types.NodeName) (string, error)
    
    	// VolumesAreAttached checks whether the list of volumes still attached to the specified
    	// node. It returns a map which maps from the volume spec to the checking result.
    	// If an error is occurred during checking, the error will be returned
    	VolumesAreAttached(specs []*Spec, nodeName types.NodeName) (map[*Spec]bool, error)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  4. pkg/kubelet/kubelet_node_status.go

    		originalNode, err = kl.nodeLister.Get(string(kl.nodeName))
    	} else {
    		opts := metav1.GetOptions{}
    		originalNode, err = kl.heartbeatClient.CoreV1().Nodes().Get(ctx, string(kl.nodeName), opts)
    	}
    	if err != nil {
    		return fmt.Errorf("error getting node %q: %v", kl.nodeName, err)
    	}
    	if originalNode == nil {
    		return fmt.Errorf("nil %q node object", kl.nodeName)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 31.1K bytes
    - Viewed (0)
  5. pkg/scheduler/eventhandlers_test.go

    func TestUpdatePodInCache(t *testing.T) {
    	ttl := 10 * time.Second
    	nodeName := "node"
    
    	tests := []struct {
    		name   string
    		oldObj interface{}
    		newObj interface{}
    	}{
    		{
    			name:   "pod updated with the same UID",
    			oldObj: withPodName(podWithPort("oldUID", nodeName, 80), "pod"),
    			newObj: withPodName(podWithPort("oldUID", nodeName, 8080), "pod"),
    		},
    		{
    			name:   "pod updated with different UIDs",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jan 10 14:38:54 UTC 2024
    - 21.5K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/preemption/preemption.go

    		}
    		// Check if the returned victims are valid.
    		for nodeName, victims := range nodeNameToVictims {
    			if victims == nil || len(victims.Pods) == 0 {
    				if extender.IsIgnorable() {
    					delete(nodeNameToVictims, nodeName)
    					logger.Info("Ignored node for which the extender didn't report victims", "node", klog.KRef("", nodeName), "extender", extender.Name())
    					continue
    				}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 25.1K bytes
    - Viewed (0)
  7. pkg/volume/csi/csi_mounter.go

    	}
    
    	// Save volume info in pod dir
    	// persist volume info data for teardown
    	nodeName := string(c.plugin.host.GetNodeName())
    	volData := map[string]string{
    		volDataKey.specVolID:           c.spec.Name(),
    		volDataKey.volHandle:           volumeHandle,
    		volDataKey.driverName:          string(c.driverName),
    		volDataKey.nodeName:            nodeName,
    		volDataKey.volumeLifecycleMode: string(c.volumeLifecycleMode),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jan 30 10:47:59 UTC 2024
    - 21K bytes
    - Viewed (1)
  8. plugin/pkg/auth/authorizer/node/graph.go

    	g.deleteVertex_locked(vaVertexType, "", attachmentName)
    
    	// if we have a node, establish new edges
    	if len(nodeName) > 0 {
    		vaVertex := g.getOrCreateVertex_locked(vaVertexType, "", attachmentName)
    		nodeVertex := g.getOrCreateVertex_locked(nodeVertexType, "", nodeName)
    		g.graph.SetEdge(newDestinationEdge(vaVertex, nodeVertex, nodeVertex))
    	}
    }
    func (g *Graph) DeleteVolumeAttachment(name string) {
    	start := time.Now()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:22:55 UTC 2024
    - 17.5K bytes
    - Viewed (0)
  9. platforms/core-configuration/kotlin-dsl/src/main/kotlin/org/gradle/kotlin/dsl/ConfigurationDeprecatedExtensions.kt

     */
    @Deprecated(deprecationMessage, replaceWith = ReplaceWith("get().addToAntBuilder(builder, nodeName, type)"), level = DeprecationLevel.HIDDEN)
    fun <T : Configuration> NamedDomainObjectProvider<T>.addToAntBuilder(builder: Any, nodeName: String, type: FileCollection.AntType): Unit =
        get().addToAntBuilder(builder, nodeName, type)
    
    
    /**
     * See [Configuration.addToAntBuilder].
     */
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Mar 28 18:18:46 UTC 2024
    - 17.5K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache_test.go

    }
    
    func makeTestPodDetails(name string, resourceVersion uint64, nodeName string, labels map[string]string) *v1.Pod {
    	return &v1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Namespace:       "ns",
    			Name:            name,
    			ResourceVersion: strconv.FormatUint(resourceVersion, 10),
    			Labels:          labels,
    		},
    		Spec: v1.PodSpec{
    			NodeName: nodeName,
    		},
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 09:20:10 UTC 2024
    - 35.4K bytes
    - Viewed (0)
Back to top