kubernetes/pkg/kubelet/kubelet_pods_test.go

var containerRestartPolicyAlways

func TestNodeHostsFileContent(t *testing.T) {}

// writeHostsFile will write a hosts file into a temporary dir, and return that dir.
// Caller is responsible for deleting the dir and its contents.
func writeHostsFile(filename string, cfg string) (string, error) {}

func TestManagedHostsFileContent(t *testing.T) {}

func TestRunInContainerNoSuchPod(t *testing.T) {}

func TestRunInContainer(t *testing.T) {}

type testServiceLister

func (ls testServiceLister) List(labels.Selector) ([]*v1.Service, error) {}

type envs

func (e envs) Len() int {}

func (e envs) Swap(i, j int) {}

func (e envs) Less(i, j int) bool {}

func buildService(name, namespace, clusterIP, protocol string, port int) *v1.Service {}

func TestMakeEnvironmentVariables(t *testing.T) {}

func waitingState(cName string) v1.ContainerStatus {}

func waitingStateWithReason(cName, reason string) v1.ContainerStatus {}

func waitingStateWithLastTermination(cName string) v1.ContainerStatus {}

func waitingStateWithNonZeroTermination(cName string) v1.ContainerStatus {}

func runningState(cName string) v1.ContainerStatus {}

func startedState(cName string) v1.ContainerStatus {}

func runningStateWithStartedAt(cName string, startedAt time.Time) v1.ContainerStatus {}

func stoppedState(cName string) v1.ContainerStatus {}

func succeededState(cName string) v1.ContainerStatus {}

func failedState(cName string) v1.ContainerStatus {}

func waitingWithLastTerminationUnknown(cName string, restartCount int32) v1.ContainerStatus {}

func ready(status v1.ContainerStatus) v1.ContainerStatus {}

func withID(status v1.ContainerStatus, id string) v1.ContainerStatus {}

func TestPodPhaseWithRestartAlways(t *testing.T) {}

func TestPodPhaseWithRestartAlwaysInitContainers(t *testing.T) {}

func TestPodPhaseWithRestartAlwaysRestartableInitContainers(t *testing.T) {}

func TestPodPhaseWithRestartNever(t *testing.T) {}

func TestPodPhaseWithRestartNeverInitContainers(t *testing.T) {}

func TestPodPhaseWithRestartNeverRestartableInitContainers(t *testing.T) {}

func TestPodPhaseWithRestartOnFailure(t *testing.T) {}

func TestConvertToAPIContainerStatuses(t *testing.T) {}

func Test_generateAPIPodStatus(t *testing.T) {}

func Test_generateAPIPodStatusForInPlaceVPAEnabled(t *testing.T) {}

func findContainerStatusByName(status v1.PodStatus, name string) *v1.ContainerStatus {}

func TestGetExec(t *testing.T) {}

func TestGetPortForward(t *testing.T) {}

func TestTruncatePodHostname(t *testing.T) {}

func TestGenerateAPIPodStatusHostNetworkPodIPs(t *testing.T) {}

func TestNodeAddressUpdatesGenerateAPIPodStatusHostNetworkPodIPs(t *testing.T) {}

func TestGenerateAPIPodStatusPodIPs(t *testing.T) {}

func TestSortPodIPs(t *testing.T) {}

func TestConvertToAPIContainerStatusesDataRace(t *testing.T) {}

func TestConvertToAPIContainerStatusesForResources(t *testing.T) {}

func TestConvertToAPIContainerStatusesForUser(t *testing.T) {}

func TestKubelet_HandlePodCleanups(t *testing.T) {}

func testMetric(t *testing.T, metricName string, expectedMetric string) {}

func TestGetNonExistentImagePullSecret(t *testing.T) {}

func TestParseGetSubIdsOutput(t *testing.T) {}

func TestResolveRecursiveReadOnly(t *testing.T) {}