Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 85 for ContainerStatus (0.31 sec)

  1. pkg/kubelet/util/util.go

    // "containers" with respect to "statuses".
    // It returns true if the container is valid, else returns false.
    func GetContainerByIndex(containers []v1.Container, statuses []v1.ContainerStatus, idx int) (v1.Container, bool) {
    	if idx < 0 || idx >= len(containers) || idx >= len(statuses) {
    		return v1.Container{}, false
    	}
    	if statuses[idx].Name != containers[idx].Name {
    		return v1.Container{}, false
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 17 18:07:39 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  2. pkg/kubelet/container/runtime.go

    func (podStatus *PodStatus) FindContainerStatusByName(containerName string) *Status {
    	for _, containerStatus := range podStatus.ContainerStatuses {
    		if containerStatus.Name == containerName {
    			return containerStatus
    		}
    	}
    	return nil
    }
    
    // GetRunningContainerStatuses returns container status of all the running containers in a pod
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  3. pkg/controller/controller_utils_test.go

    		var conditions []v1.PodCondition
    		var containerStatuses []v1.ContainerStatus
    		if ready {
    			conditions = []v1.PodCondition{{Type: v1.PodReady, Status: v1.ConditionTrue, LastTransitionTime: readySince}}
    			containerStatuses = []v1.ContainerStatus{{RestartCount: restarts}}
    		}
    		return &v1.Pod{
    			ObjectMeta: metav1.ObjectMeta{
    				CreationTimestamp: created,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 39.4K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/cpumanager/cpu_manager.go

    }
    
    func findContainerStatusByName(status *v1.PodStatus, name string) (*v1.ContainerStatus, error) {
    	for _, containerStatus := range append(status.InitContainerStatuses, status.ContainerStatuses...) {
    		if containerStatus.Name == name {
    			return &containerStatus, nil
    		}
    	}
    	return nil, fmt.Errorf("unable to find status for container with name %v in pod status (it may not be running)", name)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 03 16:26:09 UTC 2023
    - 19.9K bytes
    - Viewed (0)
  5. cni/pkg/repair/repair_test.go

    		return makePod(makePodArgs{
    			PodName:     name,
    			Annotations: map[string]string{"sidecar.istio.io/status": "something"},
    			InitContainerStatus: &corev1.ContainerStatus{
    				Name: constants.ValidationContainerName,
    				State: corev1.ContainerState{
    					Waiting: &corev1.ContainerStateWaiting{
    						Reason:  "CrashLoopBackOff",
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Oct 24 03:31:28 UTC 2023
    - 10.6K bytes
    - Viewed (0)
  6. pkg/api/pod/util_test.go

    						},
    					},
    				},
    			},
    			Status: api.PodStatus{
    				Resize: api.PodResizeStatusInProgress,
    				ContainerStatuses: []api.ContainerStatus{
    					{
    						Name:               "c1",
    						Image:              "image",
    						AllocatedResources: api.ResourceList{api.ResourceCPU: resource.MustParse("100m")},
    						Resources: &api.ResourceRequirements{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 108.8K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/responsewriters/writers_test.go

    		randTime(&pod.Status.Conditions[i].LastTransitionTime.Time, r)
    	}
    	for i := range pod.Status.ContainerStatuses {
    		containerStatus := &pod.Status.ContainerStatuses[i]
    		state := &containerStatus.State
    		if state.Running != nil {
    			randTime(&state.Running.StartedAt.Time, r)
    		}
    		containerStatus.ContainerID = fmt.Sprintf("docker://%x%x%x%x", r.Int63(), r.Int63(), r.Int63(), r.Int63())
    	}
    	for i := range pod.ManagedFields {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  8. pkg/kubelet/pleg/generic.go

    					// Get updated podStatus
    					status, err := g.cache.Get(pod.ID)
    					if err == nil {
    						for _, containerStatus := range status.ContainerStatuses {
    							containerExitCode[containerStatus.ID.ID] = containerStatus.ExitCode
    						}
    					}
    				}
    				if containerID, ok := events[i].Data.(string); ok {
    					if exitCode, ok := containerExitCode[containerID]; ok && pod != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 19.3K bytes
    - Viewed (0)
  9. pkg/api/pod/util.go

    		if cmp.Equal(oldPod.Spec.Containers[i].Resources, c.Resources) {
    			continue
    		}
    		findContainerStatus := func(css []api.ContainerStatus, cName string) (api.ContainerStatus, bool) {
    			for i := range css {
    				if css[i].Name == cName {
    					return css[i], true
    				}
    			}
    			return api.ContainerStatus{}, false
    		}
    		if cs, ok := findContainerStatus(newPod.Status.ContainerStatuses, c.Name); ok {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 41.3K bytes
    - Viewed (0)
  10. pkg/kubelet/kuberuntime/instrumented_services.go

    	recordError(operation, err)
    	return out, err
    }
    
    func (in instrumentedRuntimeService) ContainerStatus(ctx context.Context, containerID string, verbose bool) (*runtimeapi.ContainerStatusResponse, error) {
    	const operation = "container_status"
    	defer recordOperation(operation, time.Now())
    
    	out, err := in.service.ContainerStatus(ctx, containerID, verbose)
    	recordError(operation, err)
    	return out, err
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 10:46:06 UTC 2024
    - 13.1K bytes
    - Viewed (0)
Back to top