Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 873 for NodeName (0.16 sec)

  1. pkg/controller/tainteviction/taint_eviction.go

    	podName := ""
    	podNamespace := ""
    	nodeName := ""
    	oldTolerations := []v1.Toleration{}
    	if oldPod != nil {
    		podName = oldPod.Name
    		podNamespace = oldPod.Namespace
    		nodeName = oldPod.Spec.NodeName
    		oldTolerations = oldPod.Spec.Tolerations
    	}
    	newTolerations := []v1.Toleration{}
    	if newPod != nil {
    		podName = newPod.Name
    		podNamespace = newPod.Namespace
    		nodeName = newPod.Spec.NodeName
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  2. pkg/controller/volume/attachdetach/statusupdater/node_status_updater.go

    	needsUpdate, attachedVolumes := nsu.actualStateOfWorld.GetVolumesToReportAttachedForNode(logger, nodeName)
    	if !needsUpdate {
    		return nil
    	}
    	return nsu.processNodeVolumes(logger, nodeName, attachedVolumes)
    }
    
    func (nsu *nodeStatusUpdater) processNodeVolumes(logger klog.Logger, nodeName types.NodeName, attachedVolumes []v1.AttachedVolume) error {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 14 00:37:30 UTC 2023
    - 4.8K bytes
    - Viewed (0)
  3. pkg/volume/util/nestedpendingoperations/nestedpendingoperations.go

    		podNameExactMatch := previousOp.key.podName == key.podName
    
    		nodeNameMatch := previousOp.key.nodeName == EmptyNodeName ||
    			key.nodeName == EmptyNodeName ||
    			previousOp.key.nodeName == key.nodeName
    
    		nodeNameExactMatch := previousOp.key.nodeName == key.nodeName
    
    		if volumeNameMatch && podNameMatch && nodeNameMatch {
    			// nonExactMatch pending first
    			if previousOp.operationPending {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Aug 26 01:29:17 UTC 2022
    - 12.6K bytes
    - Viewed (0)
  4. pkg/controller/volume/attachdetach/testing/testvolumespec.go

    		nodeNamePrefix := "mynode"
    		for i := 0; i < 5; i++ {
    			var nodeName string
    			if i != 0 {
    				nodeName = fmt.Sprintf("%s-%d", nodeNamePrefix, i)
    			} else {
    				// We want also the "mynode" node since all the testing pods live there
    				nodeName = nodeNamePrefix
    			}
    			csiNode := storagev1.CSINode{
    				ObjectMeta: metav1.ObjectMeta{
    					Name: nodeName,
    				},
    			}
    			obj.Items = append(obj.Items, csiNode)
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Nov 17 08:48:30 UTC 2023
    - 16.5K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/plugins/nodename/node_name.go

    limitations under the License.
    */
    
    package nodename
    
    import (
    	"context"
    
    	v1 "k8s.io/api/core/v1"
    	"k8s.io/apimachinery/pkg/runtime"
    	"k8s.io/kubernetes/pkg/scheduler/framework"
    	"k8s.io/kubernetes/pkg/scheduler/framework/plugins/names"
    )
    
    // NodeName is a plugin that checks if a pod spec node name matches the current node.
    type NodeName struct{}
    
    var _ framework.FilterPlugin = &NodeName{}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 20 09:49:54 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  6. pkg/apis/discovery/v1beta1/conversion_test.go

    				Zone: utilpointer.String("zone1"),
    			},
    		},
    		{
    			desc: "nodeName and topology[hostname] are populated with different values",
    			external: v1beta1.Endpoint{
    				NodeName: utilpointer.String("node-1"),
    				Topology: map[string]string{
    					corev1.LabelHostname: "node-2",
    				},
    			},
    			internal: discovery.Endpoint{
    				NodeName: utilpointer.String("node-1"),
    				DeprecatedTopology: map[string]string{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jan 05 10:48:05 UTC 2023
    - 3.8K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/plugins/interpodaffinity/scoring_test.go

    			pod: &v1.Pod{Spec: v1.PodSpec{NodeName: "", Affinity: stayWithS1InRegion}, ObjectMeta: metav1.ObjectMeta{Labels: podLabelSecurityS1}},
    			pods: []*v1.Pod{
    				{Spec: v1.PodSpec{NodeName: "node1"}, ObjectMeta: metav1.ObjectMeta{Labels: podLabelSecurityS1}},
    				{Spec: v1.PodSpec{NodeName: "node2"}, ObjectMeta: metav1.ObjectMeta{Labels: podLabelSecurityS2}},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 44.8K bytes
    - Viewed (0)
  8. plugin/pkg/admission/noderestriction/admission.go

    		if existingPod.Spec.NodeName != nodeName {
    			return admission.NewForbidden(a, fmt.Errorf("node %q can only delete pods with spec.nodeName set to itself", nodeName))
    		}
    		return nil
    
    	default:
    		return admission.NewForbidden(a, fmt.Errorf("unexpected operation %q, node %q can only create and delete mirror pods", a.GetOperation(), nodeName))
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:22:55 UTC 2024
    - 23.6K bytes
    - Viewed (0)
  9. pkg/controller/endpointslicemirroring/reconciler_test.go

    		}
    
    		if expectedEndpoint.epAddress.NodeName != nil {
    			if endpoint.NodeName == nil {
    				t.Errorf("Expected nodeName to be set")
    			}
    			if *expectedEndpoint.epAddress.NodeName != *endpoint.NodeName {
    				t.Errorf("Expected nodeName to be %s, got %s", *expectedEndpoint.epAddress.NodeName, *endpoint.NodeName)
    			}
    		}
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 06:51:56 UTC 2024
    - 42.7K bytes
    - Viewed (0)
  10. pkg/controller/volume/attachdetach/reconciler/reconciler.go

    func (rc *reconciler) hasOutOfServiceTaint(nodeName types.NodeName) (bool, error) {
    	node, err := rc.nodeLister.Get(string(nodeName))
    	if err != nil {
    		return false, err
    	}
    	return taints.TaintKeyExists(node.Spec.Taints, v1.TaintNodeOutOfService), nil
    }
    
    // nodeIsHealthy returns true if the node looks healthy.
    func (rc *reconciler) nodeIsHealthy(nodeName types.NodeName) (bool, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 22 21:02:38 UTC 2024
    - 21.1K bytes
    - Viewed (0)
Back to top