Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 5,237 for GetPod (0.12 sec)

  1. pkg/kubelet/kubelet_resources_test.go

    		pod      *v1.Pod
    		expected *v1.Pod
    	}{
    		{
    			pod:      getPod("0", "0"),
    			expected: getPod("6", "4Gi"),
    		},
    		{
    			pod:      getPod("1", "0"),
    			expected: getPod("1", "4Gi"),
    		},
    		{
    			pod:      getPod("", ""),
    			expected: getPod("6", "4Gi"),
    		},
    		{
    			pod:      getPod("0", "1Mi"),
    			expected: getPod("6", "1Mi"),
    		},
    	}
    	as := assert.New(t)
    	for idx, tc := range cases {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Oct 24 14:46:59 UTC 2019
    - 2.4K bytes
    - Viewed (0)
  2. pkg/api/v1/resource/helpers_test.go

    		expectedValue int64
    	}{
    		{
    			pod:           getPod("foo", podResources{cpuRequest: "9"}),
    			resourceName:  v1.ResourceCPU,
    			expectedValue: 9000,
    		},
    		{
    			pod:           getPod("foo", podResources{memoryRequest: "90Mi"}),
    			resourceName:  v1.ResourceMemory,
    			expectedValue: 94371840,
    		},
    		{
    			cName:         "just-overhead for cpu",
    			pod:           getPod("foo", podResources{cpuOverhead: "5", memoryOverhead: "5"}),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 07 22:26:13 UTC 2023
    - 38.3K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/runtime/waiting_pods_map.go

    			msg := fmt.Sprintf("rejected due to timeout after waiting %v at plugin %v",
    				waitTime, plugin)
    			wp.Reject(plugin, msg)
    		})
    	}
    
    	return wp
    }
    
    // GetPod returns a reference to the waiting pod.
    func (w *waitingPod) GetPod() *v1.Pod {
    	return w.pod
    }
    
    // GetPendingPlugins returns a list of pending permit plugin's name.
    func (w *waitingPod) GetPendingPlugins() []string {
    	w.mu.RLock()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  4. pkg/scheduler/internal/cache/fake/fake_cache.go

    	return c.IsAssumedPodFunc(pod), nil
    }
    
    // GetPod is a fake method for testing.
    func (c *Cache) GetPod(pod *v1.Pod) (*v1.Pod, error) {
    	return c.GetPodFunc(pod), nil
    }
    
    // AddNode is a fake method for testing.
    func (c *Cache) AddNode(logger klog.Logger, node *v1.Node) *framework.NodeInfo { return nil }
    
    // UpdateNode is a fake method for testing.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 29 05:26:32 UTC 2023
    - 2.8K bytes
    - Viewed (0)
  5. pilot/pkg/serviceregistry/kube/controller/endpointslice.go

    //     correctness and security.
    //
    // Note: this is only used by endpointslice controller
    func getPod(c *Controller, ip string, ep *metav1.ObjectMeta, targetRef *corev1.ObjectReference, host host.Name) (*corev1.Pod, bool) {
    	var expectPod bool
    	pod := c.getPod(ip, ep.Namespace, targetRef)
    	if targetRef != nil && targetRef.Kind == "Pod" {
    		expectPod = true
    		if pod == nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 16.9K bytes
    - Viewed (0)
  6. pkg/scheduler/internal/cache/interface.go

    	// RemovePod removes a pod. The pod's information would be subtracted from assigned node.
    	RemovePod(logger klog.Logger, pod *v1.Pod) error
    
    	// GetPod returns the pod from the cache with the same namespace and the
    	// same name of the specified pod.
    	GetPod(pod *v1.Pod) (*v1.Pod, error)
    
    	// IsAssumedPod returns true if the pod is assumed and not expired.
    	IsAssumedPod(pod *v1.Pod) (bool, error)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 29 05:26:32 UTC 2023
    - 5.2K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/storage/util_test.go

    		key := "pods/" + obj.Namespace + "/" + obj.Name
    		out := &example.Pod{}
    		err := etcdStorage.Create(context.TODO(), key, obj, out, 0)
    		require.NoError(t, err)
    		return out
    	}
    	getPod := func(name, ns string) *example.Pod {
    		key := "pods/" + ns + "/" + name
    		out := &example.Pod{}
    		err := etcdStorage.Get(context.TODO(), key, storage.GetOptions{}, out)
    		require.NoError(t, err)
    		return out
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 11 12:07:39 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  8. pkg/kubelet/cm/memorymanager/policy_static_test.go

    					},
    					Cells: []int{},
    				},
    			},
    			systemReserved: systemReservedMemory{
    				0: map[v1.ResourceName]uint64{
    					v1.ResourceMemory: 512 * mb,
    				},
    			},
    			pod:                   getPod("pod1", "container1", requirementsBurstable),
    			expectedTopologyHints: nil,
    			topologyHint:          &topologymanager.TopologyHint{},
    		},
    		{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Sep 17 05:49:15 UTC 2023
    - 100.4K bytes
    - Viewed (0)
  9. pkg/volume/util/recyclerclient/recycler_client.go

    }
    
    // recyclerClient abstracts access to a Pod by providing a narrower interface.
    // This makes it easier to mock a client for testing.
    type recyclerClient interface {
    	CreatePod(pod *v1.Pod) (*v1.Pod, error)
    	GetPod(name, namespace string) (*v1.Pod, error)
    	DeletePod(name, namespace string) error
    	// WatchPod returns a ListWatch for watching a pod.  The stopChannel is used
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 26 17:14:05 UTC 2022
    - 8.5K bytes
    - Viewed (0)
  10. pkg/controller/statefulset/stateful_pod_control.go

    // with a clientset for writes and listers for reads; for tests we provide stubs.
    type StatefulPodControlObjectManager interface {
    	CreatePod(ctx context.Context, pod *v1.Pod) error
    	GetPod(namespace, podName string) (*v1.Pod, error)
    	UpdatePod(pod *v1.Pod) error
    	DeletePod(pod *v1.Pod) error
    	CreateClaim(claim *v1.PersistentVolumeClaim) error
    	GetClaim(namespace, claimName string) (*v1.PersistentVolumeClaim, error)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 14.9K bytes
    - Viewed (0)
Back to top