Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 62 for podB (0.04 sec)

  1. pkg/controller/daemon/daemon_controller.go

    				// Emit an event so that it's discoverable to users.
    				dsc.eventRecorder.Eventf(ds, v1.EventTypeWarning, FailedDaemonPodReason, msg)
    				podsToDelete = append(podsToDelete, pod.Name)
    			} else if pod.Status.Phase == v1.PodSucceeded {
    				msg := fmt.Sprintf("Found succeeded daemon pod %s/%s on node %s, will try to delete it", pod.Namespace, pod.Name, node.Name)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 51.3K bytes
    - Viewed (0)
  2. pkg/kubelet/cm/devicemanager/manager_test.go

    	})
    	pod2 := makePod(v1.ResourceList{
    		v1.ResourceName(res2.resourceName): res2.resourceQuantity,
    	})
    
    	activePods := []*v1.Pod{pod1, pod2}
    	podsStub.updateActivePods(activePods)
    
    	err = testManager.Allocate(pod1, &pod1.Spec.Containers[0])
    	as.Nil(err)
    	err = testManager.Allocate(pod2, &pod2.Spec.Containers[0])
    	as.Nil(err)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 65K bytes
    - Viewed (0)
  3. pkg/controller/podautoscaler/replica_calculator_test.go

    	testPod := "test-pod"
    
    	tests := []struct {
    		name             string
    		pods             []*v1.Pod
    		container        string
    		resource         v1.ResourceName
    		expectedRequests map[string]int64
    		expectedError    error
    	}{
    		{
    			name:             "void",
    			pods:             []*v1.Pod{},
    			container:        "",
    			resource:         v1.ResourceCPU,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Aug 19 03:31:34 UTC 2023
    - 68.4K bytes
    - Viewed (0)
  4. plugin/pkg/admission/limitranger/admission_test.go

    		err := PodMutateLimitFunc(&test.limitRange, &test.pod)
    		if err != nil {
    			t.Errorf("Unexpected error for pod: %s, %v", test.pod.Name, err)
    		}
    		err = PodValidateLimitFunc(&test.limitRange, &test.pod)
    		if err == nil {
    			t.Errorf("Expected error for pod: %s", test.pod.Name)
    		}
    	}
    }
    
    func withRestartableInitContainer(requests, limits api.ResourceList, pod api.Pod) api.Pod {
    	policyAlways := api.ContainerRestartPolicyAlways
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 06 00:00:21 UTC 2024
    - 51.5K bytes
    - Viewed (0)
  5. pkg/controller/statefulset/stateful_set_utils_test.go

    	}
    	pod.Name = "foo"
    	if identityMatches(set, pod) {
    		t.Error("identity matches for a Pod with the wrong name")
    	}
    	pod = newStatefulSetPod(set, 1)
    	pod.Namespace = ""
    	if identityMatches(set, pod) {
    		t.Error("identity matches for a Pod with the wrong namespace")
    	}
    	pod = newStatefulSetPod(set, 1)
    	delete(pod.Labels, apps.StatefulSetPodNameLabel)
    	if identityMatches(set, pod) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 50.9K bytes
    - Viewed (0)
  6. pkg/controller/volume/attachdetach/reconciler/reconciler_test.go

    		},
    		{
    			"pods both in the same and another namespace use the volume",
    			[]nodeWithPods{
    				{"node1", []string{"ns1/pod1"}},
    				{"node2", []string{"ns2/pod2"}},
    				{"node3", []string{"ns1/pod3"}},
    			},
    			[]string{"Warning FailedAttachVolume Multi-Attach error for volume \"volume-name\" Volume is already used by pod(s) pod3 and 1 pod(s) in different namespaces"},
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 07:00:14 UTC 2024
    - 72.8K bytes
    - Viewed (0)
  7. pkg/kubelet/status/status_manager_test.go

    		}
    	}
    
    	testCases := []struct {
    		name     string
    		pod      *v1.Pod
    		updateFn func(*v1.Pod)
    		expectFn func(t *testing.T, status v1.PodStatus)
    	}{
    		{pod: newPod(0, 1, func(pod *v1.Pod) { pod.Status.Phase = v1.PodFailed })},
    		{
    			pod: newPod(0, 1, func(pod *v1.Pod) {
    				pod.Status.Phase = v1.PodRunning
    			}),
    			expectFn: func(t *testing.T, status v1.PodStatus) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 02 16:27:19 UTC 2024
    - 68.1K bytes
    - Viewed (0)
  8. staging/src/k8s.io/api/testdata/v1.30.0/core.v1.Pod.json

    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 08:52:25 UTC 2024
    - 52K bytes
    - Viewed (0)
  9. staging/src/k8s.io/api/testdata/v1.29.0/core.v1.Pod.json

    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 04:12:07 UTC 2023
    - 50.7K bytes
    - Viewed (0)
  10. pkg/kubelet/server/server_test.go

    }
    
    func TestTrimURLPath(t *testing.T) {
    	tests := []struct {
    		path, expected string
    	}{
    		{"", ""},
    		{"//", ""},
    		{"/pods", "pods"},
    		{"pods", "pods"},
    		{"pods/", "pods"},
    		{"good/", "good"},
    		{"pods/probes", "pods"},
    		{"metrics", "metrics"},
    		{"metrics/resource", "metrics/resource"},
    		{"metrics/hello", "metrics/hello"},
    	}
    
    	for _, test := range tests {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 51.5K bytes
    - Viewed (0)
Back to top