Function waitForContainerdContainer

integration/tests/api/containerd_test.go:33–58

Waits up to 10s for a containerd container with the specified ID to appear in cAdvisor.

(containerID string, fm framework.Framework)

// Waits up to 10s for a containerd container with the specified ID to appear in cAdvisor.
func waitForContainerdContainer(containerID string, fm framework.Framework) {
	err := framework.RetryForDuration(func() error {
		// Query all containers via SubcontainersInfo - containerd containers are in "containerd" namespace
		allInfo, err := fm.Cadvisor().Client().SubcontainersInfo("/", &info.ContainerInfoRequest{
			NumStats: 1,
		})
		if err != nil {
			return err
		}

		// Look for container by ID
		for _, container := range allInfo {
			for _, alias := range container.Aliases {
				if alias == containerID {
					return nil
				}
			}
			// Also check if the container name contains the ID
			if len(container.Name) > 0 && containsString(container.Name, containerID) {
				return nil
			}
		}
		return fmt.Errorf("container %q not found in cAdvisor", containerID)
	}, 10*time.Second)
	require.NoError(fm.T(), err, "Timed out waiting for containerd container %q to be available in cAdvisor", containerID)
}

func containsString(s, substr string) bool {
	for i := 0; i <= len(s)-len(substr); i++ {