Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 335 for containerId (0.16 sec)

  1. pkg/kubelet/cm/containermap/container_map.go

    	return "", fmt.Errorf("container %s not in ContainerMap for pod %s", containerName, podUID)
    }
    
    // GetContainerRef retrieves a (podUID, containerName) pair from the ContainerMap
    func (cm ContainerMap) GetContainerRef(containerID string) (string, string, error) {
    	if _, exists := cm[containerID]; !exists {
    		return "", "", fmt.Errorf("containerID %s not in ContainerMap", containerID)
    	}
    	return cm[containerID].podUID, cm[containerID].containerName, nil
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 30 15:25:05 UTC 2022
    - 2.5K bytes
    - Viewed (0)
  2. staging/src/k8s.io/api/testdata/HEAD/core.v1.PodStatusResult.json

                "startedAt": "2005-01-01T01:01:01Z",
                "finishedAt": "2006-01-01T01:01:01Z",
                "containerID": "containerIDValue"
              }
            },
            "ready": true,
            "restartCount": 5,
            "image": "imageValue",
            "imageID": "imageIDValue",
            "containerID": "containerIDValue",
            "started": true,
            "allocatedResources": {
              "allocatedResourcesKey": "0"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  3. pkg/kubelet/prober/worker.go

    		}
    	}
    
    	if w.containerID.String() != c.ContainerID {
    		if !w.containerID.IsEmpty() {
    			w.resultsManager.Remove(w.containerID)
    		}
    		w.containerID = kubecontainer.ParseContainerID(c.ContainerID)
    		w.resultsManager.Set(w.containerID, w.initialValue, w.pod)
    		// We've got a new container; resume probing.
    		w.onHold = false
    	}
    
    	if w.onHold {
    		// Worker is on hold until there is a new container.
    		return true
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jul 27 01:28:06 UTC 2023
    - 10.7K bytes
    - Viewed (0)
  4. pkg/kubelet/kuberuntime/kuberuntime_container.go

    	if err != nil {
    		s, _ := grpcstatus.FromError(err)
    		m.recordContainerEvent(pod, container, containerID, v1.EventTypeWarning, events.FailedToStartContainer, "Internal PreStartContainer hook failed: %v", s.Message())
    		return s.Message(), ErrPreStartHook
    	}
    	m.recordContainerEvent(pod, container, containerID, v1.EventTypeNormal, events.CreatedContainer, fmt.Sprintf("Created container %s", container.Name))
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 54.7K bytes
    - Viewed (0)
  5. pkg/kubelet/cm/internal_container_lifecycle.go

    }
    
    func (i *internalContainerLifecycleImpl) PreStartContainer(pod *v1.Pod, container *v1.Container, containerID string) error {
    	if i.cpuManager != nil {
    		i.cpuManager.AddContainer(pod, container, containerID)
    	}
    
    	if i.memoryManager != nil {
    		i.memoryManager.AddContainer(pod, container, containerID)
    	}
    
    	i.topologyManager.AddContainer(pod, container, containerID)
    
    	return nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 10 06:43:12 UTC 2023
    - 1.8K bytes
    - Viewed (0)
  6. pkg/kubelet/cm/containermap/container_map_test.go

    		for i := range tc.containerNames {
    			cm.Add(tc.podUID, tc.containerNames[i], tc.containerIDs[i])
    
    			containerID, err := cm.GetContainerID(tc.podUID, tc.containerNames[i])
    			if err != nil {
    				t.Errorf("error adding and retrieving containerID: %v", err)
    			}
    			if containerID != tc.containerIDs[i] {
    				t.Errorf("mismatched containerIDs %v, %v", containerID, tc.containerIDs[i])
    			}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jan 02 13:40:55 UTC 2023
    - 2.6K bytes
    - Viewed (0)
  7. pkg/kubelet/cm/memorymanager/fake_memory_manager.go

    }
    
    func (m *fakeManager) Allocate(pod *v1.Pod, container *v1.Container) error {
    	klog.InfoS("Allocate", "pod", klog.KObj(pod), "containerName", container.Name)
    	return nil
    }
    
    func (m *fakeManager) AddContainer(pod *v1.Pod, container *v1.Container, containerID string) {
    	klog.InfoS("Add container", "pod", klog.KObj(pod), "containerName", container.Name, "containerID", containerID)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 27 13:02:15 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  8. pkg/kubelet/pod_container_deletor_test.go

    			},
    			{
    				ID:        kubecontainer.ContainerID{Type: "test", ID: "2"},
    				Name:      "bar",
    				CreatedAt: time.Now().Add(time.Second),
    				State:     kubecontainer.ContainerStateExited,
    			},
    			{
    				ID:        kubecontainer.ContainerID{Type: "test", ID: "3"},
    				Name:      "bar",
    				CreatedAt: time.Now().Add(2 * time.Second),
    				State:     kubecontainer.ContainerStateExited,
    			},
    			{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 19 15:48:08 UTC 2020
    - 5.8K bytes
    - Viewed (0)
  9. staging/src/k8s.io/api/testdata/v1.29.0/core.v1.PodStatusResult.json

                "startedAt": "2005-01-01T01:01:01Z",
                "finishedAt": "2006-01-01T01:01:01Z",
                "containerID": "containerIDValue"
              }
            },
            "ready": true,
            "restartCount": 5,
            "image": "imageValue",
            "imageID": "imageIDValue",
            "containerID": "containerIDValue",
            "started": true,
            "allocatedResources": {
              "allocatedResourcesKey": "0"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 04:12:07 UTC 2023
    - 6.9K bytes
    - Viewed (0)
  10. pkg/kubelet/kuberuntime/legacy_test.go

    	containerName := randStringBytes(70)
    	containerID := randStringBytes(80)
    	// The file name cannot exceed 255 characters. Since .log suffix is required, the prefix cannot exceed 251 characters.
    	expectedPath := filepath.Join(containerLogsDir, fmt.Sprintf("%s_%s-%s", podFullName, containerName, containerID)[:251]+".log")
    	as.Equal(expectedPath, logSymlink(containerLogsDir, podFullName, containerName, containerID))
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 10 12:34:58 UTC 2023
    - 3.4K bytes
    - Viewed (0)
Back to top