Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 790 for ContainerT (0.22 sec)

  1. pkg/kubelet/pleg/generic_test.go

    		// Clear the IP address and mark the container terminated
    		container = createTestContainer("c0", kubecontainer.ContainerStateExited)
    		pod = &kubecontainer.Pod{
    			ID:         id,
    			Containers: []*kubecontainer.Container{container},
    		}
    		status = &kubecontainer.PodStatus{
    			ID:                id,
    			ContainerStatuses: []*kubecontainer.Status{{ID: container.ID, State: kubecontainer.ContainerStateExited}},
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 24.8K bytes
    - Viewed (0)
  2. pkg/kubelet/container/helpers.go

    			return false
    		}
    	}
    	return true
    }
    
    // HashContainer returns the hash of the container. It is used to compare
    // the running container with its desired spec.
    // Note: remember to update hashValues in container_hash_test.go as well.
    func HashContainer(container *v1.Container) uint64 {
    	hash := fnv.New32a()
    	containerJSON, _ := json.Marshal(pickFieldsToHash(container))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  3. pkg/kubelet/kuberuntime/kuberuntime_container_test.go

    			name: "default termination grace period",
    			pod: &v1.Pod{
    				Spec: v1.PodSpec{Containers: []v1.Container{{Name: "foo"}}},
    			},
    			reason:              reasonUnknown,
    			expectedGracePeriod: int64(2),
    		},
    		{
    			name: "use pod termination grace period",
    			pod: &v1.Pod{
    				Spec: v1.PodSpec{
    					Containers:                    []v1.Container{{Name: "foo"}},
    					TerminationGracePeriodSeconds: &longGracePeriod,
    				},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 28K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/devicemanager/manager.go

    		// mutex lock. Note if Allocate call fails, we may leave container resources
    		// partially allocated for the failed container. We rely on UpdateAllocatedDevices()
    		// to garbage collect these resources later. Another side effect is that if
    		// we have X resource A and Y resource B in total, and two containers, container1
    		// and container2 both require X resource A and Y resource B. Both allocation
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 15 12:01:56 UTC 2024
    - 43K bytes
    - Viewed (0)
  5. pkg/kubelet/lifecycle/handlers_test.go

    	pod.ObjectMeta.Name = "podFoo"
    	pod.ObjectMeta.Namespace = "nsFoo"
    	pod.Spec.Containers = []v1.Container{container}
    
    	t.Run("consistent", func(t *testing.T) {
    		container.Lifecycle.PostStart.HTTPGet.Port = intstr.FromString("70")
    		pod.Spec.Containers = []v1.Container{container}
    		_, err := handlerRunner.Run(ctx, containerID, &pod, &container, container.Lifecycle.PostStart)
    
    		if err != nil {
    			t.Errorf("unexpected error: %v", err)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 24.4K bytes
    - Viewed (0)
  6. pkg/api/v1/resource/helpers.go

    }
    
    // findContainerInPod finds a container by its name in the provided pod
    func findContainerInPod(pod *v1.Pod, containerName string) (*v1.Container, error) {
    	for _, container := range pod.Spec.Containers {
    		if container.Name == containerName {
    			return &container, nil
    		}
    	}
    	for _, container := range pod.Spec.InitContainers {
    		if container.Name == containerName {
    			return &container, nil
    		}
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Oct 26 13:58:16 UTC 2023
    - 16.3K bytes
    - Viewed (0)
  7. pkg/kubelet/volumemanager/volume_manager_test.go

    	pod := &v1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "abc",
    			Namespace: "nsA",
    			UID:       "1234",
    		},
    		Spec: v1.PodSpec{
    			Containers: []v1.Container{
    				{
    					Name: "container1",
    					VolumeMounts: []v1.VolumeMount{
    						{
    							Name:      volumetest.FailMountDeviceVolumeName,
    							MountPath: "/vol1",
    						},
    						{
    							Name:      "vol2",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  8. pkg/kubelet/status/status_manager.go

    // state, which is the set of containers that have attempted to start at least once. If all containers
    // are Waiting, the first container is always returned.
    func initializedContainers(containers []v1.ContainerStatus) []v1.ContainerStatus {
    	for i := len(containers) - 1; i >= 0; i-- {
    		if containers[i].State.Waiting == nil || containers[i].LastTerminationState.Terminated != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 02 16:27:19 UTC 2024
    - 44.3K bytes
    - Viewed (0)
  9. pkg/kubelet/cm/cpumanager/cpu_manager_test.go

    	pod.UID = types.UID(podUID)
    	pod.Spec.Containers[0].Name = containerName
    
    	return pod
    }
    
    func makeMultiContainerPod(initCPUs, appCPUs []struct{ request, limit string }) *v1.Pod {
    	pod := &v1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Name: "pod",
    			UID:  "podUID",
    		},
    		Spec: v1.PodSpec{
    			InitContainers: []v1.Container{},
    			Containers:     []v1.Container{},
    		},
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 06 13:16:15 UTC 2023
    - 42.9K bytes
    - Viewed (0)
  10. pkg/quota/v1/evaluator/core/pods_test.go

    						},
    					}},
    				},
    			},
    			required: []corev1.ResourceName{corev1.ResourceMemory},
    			err:      `must specify memory for: bar,foo`,
    		},
    		"container resource missing": {
    			pod: &api.Pod{
    				Spec: api.PodSpec{
    					Containers: []api.Container{{
    						Name: "dummy",
    						Resources: api.ResourceRequirements{
    							Requests: api.ResourceList{api.ResourceCPU: resource.MustParse("1m")},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 41.6K bytes
    - Viewed (0)
Back to top