Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for defaultPodLimitsForDownwardAPI (0.45 sec)

  1. pkg/kubelet/kubelet_resources.go

    limitations under the License.
    */
    
    package kubelet
    
    import (
    	"fmt"
    
    	"k8s.io/klog/v2"
    
    	"k8s.io/api/core/v1"
    	"k8s.io/kubernetes/pkg/api/v1/resource"
    )
    
    // defaultPodLimitsForDownwardAPI copies the input pod, and optional container,
    // and applies default resource limits. it returns a copy of the input pod,
    // and a copy of the input container (if specified) with default limits
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 15 22:42:34 UTC 2021
    - 1.9K bytes
    - Viewed (0)
  2. pkg/kubelet/kubelet_resources_test.go

    			expected: getPod("6", "4Gi"),
    		},
    		{
    			pod:      getPod("0", "1Mi"),
    			expected: getPod("6", "1Mi"),
    		},
    	}
    	as := assert.New(t)
    	for idx, tc := range cases {
    		actual, _, err := tk.kubelet.defaultPodLimitsForDownwardAPI(tc.pod, nil)
    		as.Nil(err, "failed to default pod limits: %v", err)
    		if !apiequality.Semantic.DeepEqual(tc.expected, actual) {
    			as.Fail("test case [%d] failed.  Expected: %+v, Got: %+v", idx, tc.expected, actual)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Oct 24 14:46:59 UTC 2019
    - 2.4K bytes
    - Viewed (0)
  3. pkg/kubelet/kubelet_pods.go

    				if err != nil {
    					return result, err
    				}
    			case envVar.ValueFrom.ResourceFieldRef != nil:
    				defaultedPod, defaultedContainer, err := kl.defaultPodLimitsForDownwardAPI(pod, container)
    				if err != nil {
    					return result, err
    				}
    				runtimeVal, err = containerResourceRuntimeValue(envVar.ValueFrom.ResourceFieldRef, defaultedPod, defaultedContainer)
    				if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
Back to top