Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 728 for NodeName (0.31 sec)

  1. cni/pkg/util/podutil_test.go

    )
    
    func TestGetPodIPIfPodIPPresent(t *testing.T) {
    	pod := &corev1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "test",
    			Namespace: "test",
    		},
    		Spec: corev1.PodSpec{
    			NodeName: "derp",
    		},
    		Status: corev1.PodStatus{
    			PodIP: "11.1.1.12",
    		},
    	}
    
    	podIPs := GetPodIPsIfPresent(pod)
    	assert.Equal(t, len(podIPs), 1)
    }
    
    func TestGetPodIPsIfPodIPPresent(t *testing.T) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 03 19:29:42 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  2. plugin/pkg/auth/authorizer/node/node_authorizer_test.go

    			attachment.Spec.NodeName = nodeName
    			attachments = append(attachments, attachment)
    		}
    
    		nodes = append(nodes, &corev1.Node{
    			ObjectMeta: metav1.ObjectMeta{Name: nodeName},
    			Spec:       corev1.NodeSpec{},
    		})
    
    		for p := 0; p <= opts.nodeResourceCapacitiesPerNode; p++ {
    			name := fmt.Sprintf("slice%d-%s", p, nodeName)
    			slice := &resourcev1alpha2.ResourceSlice{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:22:55 UTC 2024
    - 40.5K bytes
    - Viewed (0)
  3. pkg/proxy/nftables/proxier_test.go

    			Conditions: discovery.EndpointConditions{Ready: ptr.To(true)},
    			NodeName:   ptr.To(testHostname),
    		}, {
    			Addresses:  []string{"10.0.1.2"},
    			Conditions: discovery.EndpointConditions{Ready: ptr.To(true)},
    			NodeName:   ptr.To(testHostname),
    		}, {
    			Addresses:  []string{"10.0.1.3"},
    			Conditions: discovery.EndpointConditions{Ready: ptr.To(true)},
    			NodeName:   ptr.To(testHostname),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 01:31:57 UTC 2024
    - 173.5K bytes
    - Viewed (0)
  4. 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)
  5. pkg/scheduler/framework/plugins/registry.go

    		imagelocality.Name:                   imagelocality.New,
    		tainttoleration.Name:                 runtime.FactoryAdapter(fts, tainttoleration.New),
    		nodename.Name:                        nodename.New,
    		nodeports.Name:                       nodeports.New,
    		nodeaffinity.Name:                    nodeaffinity.New,
    		podtopologyspread.Name:               runtime.FactoryAdapter(fts, podtopologyspread.New),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 5K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top