Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 549 for NodeName (0.16 sec)

  1. pkg/kubelet/runonce_test.go

    	kb.resourceAnalyzer = stats.NewResourceAnalyzer(kb, volumeStatsAggPeriod, kb.recorder)
    	nodeRef := &v1.ObjectReference{
    		Kind:      "Node",
    		Name:      string(kb.nodeName),
    		UID:       types.UID(kb.nodeName),
    		Namespace: "",
    	}
    	fakeKillPodFunc := func(pod *v1.Pod, evict bool, gracePeriodOverride *int64, fn func(*v1.PodStatus)) error {
    		return nil
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 06:59:54 UTC 2024
    - 6.5K 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/controller/endpointslice/endpointslice_controller_test.go

    	nodeInformer := informerFactory.Core().V1().Nodes()
    	indexer := nodeInformer.Informer().GetIndexer()
    	for _, nodeName := range nodeNames {
    		indexer.Add(&v1.Node{ObjectMeta: metav1.ObjectMeta{Name: nodeName}})
    	}
    
    	esInformer := informerFactory.Discovery().V1().EndpointSlices()
    	esIndexer := esInformer.Informer().GetIndexer()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 08:33:32 UTC 2024
    - 65.5K bytes
    - Viewed (0)
  5. plugin/pkg/admission/noderestriction/admission_test.go

    	nodename := "mynode"
    	mynode := &user.DefaultInfo{Name: "system:node:" + nodename, Groups: []string{"system:nodes"}}
    	err := "can only create ResourceSlice with the same NodeName as the requesting node"
    
    	sliceNode := &resourceapi.ResourceSlice{
    		ObjectMeta: metav1.ObjectMeta{
    			Name: "something",
    		},
    		NodeName: nodename,
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 73.2K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. pkg/apis/storage/validation/validation_test.go

    				PersistentVolumeName: &volumeName,
    			},
    			NodeName: "mynode",
    		},
    	}, {
    		ObjectMeta: metav1.ObjectMeta{Name: "foo-with-inlinespec"},
    		Spec: storage.VolumeAttachmentSpec{
    			Attacher: "myattacher",
    			Source: storage.VolumeAttachmentSource{
    				InlineVolumeSpec: &inlineSpec,
    			},
    			NodeName: "mynode",
    		},
    	}, {
    		ObjectMeta: metav1.ObjectMeta{Name: "foo-with-status"},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 69.7K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top