Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 313 for Pods (1.3 sec)

  1. pkg/kubeapiserver/admission/exclusion/resources.go

    // in either include or excluded list.
    var included = []schema.GroupResource{
    	{Group: "", Resource: "bindings"},
    	{Group: "", Resource: "pods/attach"},
    	{Group: "", Resource: "pods/binding"},
    	{Group: "", Resource: "pods/eviction"},
    	{Group: "", Resource: "pods/exec"},
    	{Group: "", Resource: "pods/portforward"},
    
    	// ref: https://github.com/kubernetes/kubernetes/issues/122205#issuecomment-1927390823
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 23:31:18 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  2. pkg/kubelet/apis/podresources/server_v1alpha1_test.go

    	mockCtrl := gomock.NewController(t)
    	defer mockCtrl.Finish()
    
    	for _, tc := range []struct {
    		desc             string
    		pods             []*v1.Pod
    		devices          []*podresourcesv1.ContainerDevices
    		expectedResponse *v1alpha1.ListPodResourcesResponse
    	}{
    		{
    			desc:             "no pods",
    			pods:             []*v1.Pod{},
    			devices:          []*podresourcesv1.ContainerDevices{},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  3. pkg/kubelet/kubelet_getters_test.go

    	assert.Equal(t, exp, got)
    
    	got = kubelet.getPodVolumeDeviceDir("abc123", "plugin")
    	exp = filepath.Join(root, "pods/abc123/volumeDevices/plugin")
    	assert.Equal(t, exp, got)
    
    	got = kubelet.getPodPluginsDir("abc123")
    	exp = filepath.Join(root, "pods/abc123/plugins")
    	assert.Equal(t, exp, got)
    
    	got = kubelet.getPodPluginDir("abc123", "foobar")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 09 00:48:07 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  4. pkg/controller/volume/ephemeral/controller_test.go

    			podKey: podKey(testPodWithEphemeral),
    		},
    		{
    			name: "pod-deleted",
    			pods: func() []*v1.Pod {
    				deleted := metav1.Now()
    				pods := []*v1.Pod{testPodWithEphemeral.DeepCopy()}
    				pods[0].DeletionTimestamp = &deleted
    				return pods
    			}(),
    			podKey: podKey(testPodWithEphemeral),
    		},
    		{
    			name:   "no-volumes",
    			pods:   []*v1.Pod{testPod},
    			podKey: podKey(testPod),
    		},
    		{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 06:51:56 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  5. istioctl/pkg/util/handlers/handlers.go

    	}
    
    	options := metav1.ListOptions{LabelSelector: selector}
    	podList, err := client.Pods(namespace).List(context.TODO(), options)
    	if err != nil {
    		return []string{}, "", err
    	}
    	pods := []string{}
    	for i := range podList.Items {
    		pods = append(pods, podList.Items[i].Name)
    	}
    
    	return pods, namespace, nil
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Feb 06 15:01:41 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  6. pkg/kubelet/types/pod_update.go

    	SET PodOperation = iota
    	// ADD signifies pods that are new to this source.
    	ADD
    	// DELETE signifies pods that are gracefully deleted from this source.
    	DELETE
    	// REMOVE signifies pods that have been removed from this source.
    	REMOVE
    	// UPDATE signifies pods have been updated in this source.
    	UPDATE
    	// RECONCILE signifies pods that have unexpected status in this source,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 07 22:26:12 UTC 2023
    - 6.4K bytes
    - Viewed (0)
  7. pkg/scheduler/internal/cache/snapshot.go

    	s.usedPVCSet = createUsedPVCSet(pods)
    
    	return s
    }
    
    // createNodeInfoMap obtains a list of pods and pivots that list into a map
    // where the keys are node names and the values are the aggregated information
    // for that node.
    func createNodeInfoMap(pods []*v1.Pod, nodes []*v1.Node) map[string]*framework.NodeInfo {
    	nodeNameToInfo := make(map[string]*framework.NodeInfo)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 17 01:38:03 UTC 2023
    - 6.6K bytes
    - Viewed (0)
  8. pkg/kube/krt/bench_test.go

    	}
    	c.pods = kclient.New[*v1.Pod](cl)
    	c.services = kclient.New[*v1.Service](cl)
    	c.queue = controllers.NewQueue("pods", controllers.WithReconciler(c.Reconcile))
    	c.pods.AddEventHandler(controllers.ObjectHandler(c.queue.AddObject))
    	c.services.AddEventHandler(controllers.FromEventHandler(func(e controllers.Event) {
    		o := e.Latest()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 09 19:55:53 UTC 2024
    - 7K bytes
    - Viewed (0)
  9. pkg/scheduler/util/pod_resources.go

    // of computing priority only. This ensures that when scheduling zero-request pods, such
    // pods will not all be scheduled to the node with the smallest in-use request,
    // and that when scheduling regular pods, such pods will not see zero-request pods as
    // consuming no resources whatsoever. We chose these values to be similar to the
    // resources that we give to cluster addon pods (#10653). But they are pretty arbitrary.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 01 06:25:30 UTC 2023
    - 3K bytes
    - Viewed (0)
  10. tools/bug-report/pkg/config/config.go

    		}
    		if !defaultListSetting(ss.Deployments) {
    			st += fmt.Sprintf("/Deployments: %s", strings.Join(ss.Deployments, ","))
    		}
    		if !defaultListSetting(ss.Pods) {
    			st += fmt.Sprintf("/Pods:%s", strings.Join(ss.Pods, ","))
    		}
    		if !defaultListSetting(ss.Containers) {
    			st += fmt.Sprintf("/Containers: %s", strings.Join(ss.Containers, ","))
    		}
    		if len(ss.Labels) > 0 {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat Nov 04 12:07:50 UTC 2023
    - 9.3K bytes
    - Viewed (0)
Back to top