Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 287 for containerB (0.2 sec)

  1. pkg/kubelet/cm/dra/manager.go

    	for _, c := range container.Resources.Claims {
    		if c.Name == podClaim.Name {
    			return true
    		}
    	}
    	return false
    }
    
    // GetResources gets a ContainerInfo object from the claimInfo cache.
    // This information is used by the caller to update a container config.
    func (m *ManagerImpl) GetResources(pod *v1.Pod, container *v1.Container) (*ContainerInfo, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 03 13:23:29 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/types_test.go

    		})
    	}
    }
    
    func TestNewNodeInfo(t *testing.T) {
    	nodeName := "test-node"
    	pods := []*v1.Pod{
    		st.MakePod().UID("test-1").Namespace("node_info_cache_test").Name("test-1").Node(nodeName).
    			Containers([]v1.Container{st.MakeContainer().ResourceRequests(map[v1.ResourceName]string{
    				v1.ResourceCPU:    "100m",
    				v1.ResourceMemory: "500",
    			}).ContainerPort([]v1.ContainerPort{{
    				HostIP:   "127.0.0.1",
    				HostPort: 80,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 45.9K bytes
    - Viewed (0)
  3. pkg/kubelet/logs/container_log_manager.go

    	defer c.mutex.Unlock()
    	klog.V(4).InfoS("Starting container log rotation sequence")
    	// TODO(#59998): Use kubelet pod cache.
    	containers, err := c.runtimeService.ListContainers(ctx, &runtimeapi.ContainerFilter{})
    	if err != nil {
    		return fmt.Errorf("failed to list containers: %v", err)
    	}
    	for _, container := range containers {
    		// Only rotate logs for running containers. Non-running containers won't
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 15K bytes
    - Viewed (0)
  4. manifests/charts/istiod-remote/files/injection-template.yaml

        {{- end }}
      {{- end }}
    {{- end }}
    {{ $nativeSidecar := (eq (env "ENABLE_NATIVE_SIDECARS" "false") "true") }}
    {{- $containers := list }}
    {{- range $index, $container := .Spec.Containers }}{{ if not (eq $container.Name "istio-proxy") }}{{ $containers = append $containers $container.Name }}{{end}}{{- end}}
    metadata:
      labels:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 10 21:01:52 UTC 2024
    - 23.8K bytes
    - Viewed (0)
  5. manifests/charts/istio-control/istio-discovery/files/injection-template.yaml

        {{- end }}
      {{- end }}
    {{- end }}
    {{ $nativeSidecar := (eq (env "ENABLE_NATIVE_SIDECARS" "false") "true") }}
    {{- $containers := list }}
    {{- range $index, $container := .Spec.Containers }}{{ if not (eq $container.Name "istio-proxy") }}{{ $containers = append $containers $container.Name }}{{end}}{{- end}}
    metadata:
      labels:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 10 21:01:52 UTC 2024
    - 23.8K bytes
    - Viewed (0)
  6. pkg/kubelet/cm/container_manager_linux.go

    	}
    	if quotaExists && periodExists {
    		f.cpuHardcapping = true
    	}
    	return f, nil
    }
    
    // TODO(vmarmol): Add limits to the system containers.
    // Takes the absolute name of the specified containers.
    // Empty container name disables use of the specified container.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 10:18:16 UTC 2024
    - 35.1K bytes
    - Viewed (0)
  7. cmd/kubelet/app/options/options.go

    	fs.MarkDeprecated("maximum-dead-containers-per-container", "Use --eviction-hard or --eviction-soft instead. Will be removed in a future version.")
    	fs.Int32Var(&f.MaxContainerCount, "maximum-dead-containers", f.MaxContainerCount, "Maximum number of old instances of containers to retain globally.  Each container takes up some disk space. To disable, set to a negative number.")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 07:00:05 UTC 2024
    - 41.6K bytes
    - Viewed (0)
  8. pkg/kube/inject/inject.go

    		return req.pod
    	}
    	// We found a previous status annotation. Possibly we are re-injecting the pod
    	// To ensure idempotency, remove our injected containers first
    	for _, c := range prevStatus.Containers {
    		pod.Spec.Containers = modifyContainers(pod.Spec.Containers, c, Remove)
    	}
    	for _, c := range prevStatus.InitContainers {
    		pod.Spec.InitContainers = modifyContainers(pod.Spec.InitContainers, c, Remove)
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 31 20:35:11 UTC 2024
    - 28.8K bytes
    - Viewed (0)
  9. pkg/kubelet/config/config_test.go

    	config.Sync()
    	expectPodUpdate(t, ch, CreatePodUpdate(kubetypes.SET, kubetypes.AllSource, CreateValidPod("foo", "new")))
    
    	// container updates are separated as UPDATE
    	pod := *podUpdate.Pods[0]
    	pod.Spec.Containers = []v1.Container{{Name: "bar", Image: "test", ImagePullPolicy: v1.PullIfNotPresent, TerminationMessagePolicy: v1.TerminationMessageReadFile}}
    	channel <- CreatePodUpdate(kubetypes.ADD, TestSource, &pod)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 17.1K bytes
    - Viewed (0)
  10. pkg/kube/util.go

    	t.GetObjectMeta().SetManagedFields(nil)
    	// only container ports can be used
    	if pod := obj.(*corev1.Pod); pod != nil {
    		containers := []corev1.Container{}
    		for _, c := range pod.Spec.Containers {
    			if len(c.Ports) > 0 {
    				containers = append(containers, corev1.Container{
    					Ports: c.Ports,
    				})
    			}
    		}
    		oldSpec := pod.Spec
    		newSpec := corev1.PodSpec{
    			Containers:         containers,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 05:10:23 UTC 2024
    - 18.6K bytes
    - Viewed (0)
Back to top