type podsByID … func (b podsByID) Len() int { … } func (b podsByID) Swap(i, j int) { … } func (b podsByID) Less(i, j int) bool { … } type containersByID … func (b containersByID) Len() int { … } func (b containersByID) Swap(i, j int) { … } func (b containersByID) Less(i, j int) bool { … } type podSandboxByCreated … func (p podSandboxByCreated) Len() int { … } func (p podSandboxByCreated) Swap(i, j int) { … } func (p podSandboxByCreated) Less(i, j int) bool { … } type containerStatusByCreated … func (c containerStatusByCreated) Len() int { … } func (c containerStatusByCreated) Swap(i, j int) { … } func (c containerStatusByCreated) Less(i, j int) bool { … } // toKubeContainerState converts runtimeapi.ContainerState to kubecontainer.State. func toKubeContainerState(state runtimeapi.ContainerState) kubecontainer.State { … } // toRuntimeProtocol converts v1.Protocol to runtimeapi.Protocol. func toRuntimeProtocol(protocol v1.Protocol) runtimeapi.Protocol { … } // toKubeContainer converts runtimeapi.Container to kubecontainer.Container. func (m *kubeGenericRuntimeManager) toKubeContainer(c *runtimeapi.Container) (*kubecontainer.Container, error) { … } // sandboxToKubeContainer converts runtimeapi.PodSandbox to kubecontainer.Container. // This is only needed because we need to return sandboxes as if they were // kubecontainer.Containers to avoid substantial changes to PLEG. // TODO: Remove this once it becomes obsolete. func (m *kubeGenericRuntimeManager) sandboxToKubeContainer(s *runtimeapi.PodSandbox) (*kubecontainer.Container, error) { … } // getImageUser gets uid or user name that will run the command(s) from image. The function // guarantees that only one of them is set. func (m *kubeGenericRuntimeManager) getImageUser(ctx context.Context, image string) (*int64, string, error) { … } // isInitContainerFailed returns true under the following conditions: // 1. container has exited and exitcode is not zero. // 2. container is in unknown state. // 3. container gets OOMKilled. func isInitContainerFailed(status *kubecontainer.Status) bool { … } // getStableKey generates a key (string) to uniquely identify a // (pod, container) tuple. The key should include the content of the // container, so that any change to the container generates a new key. func getStableKey(pod *v1.Pod, container *v1.Container) string { … } const logPathDelimiter … // buildContainerLogsPath builds log path for container relative to pod logs directory. func buildContainerLogsPath(containerName string, restartCount int) string { … } // BuildContainerLogsDirectory builds absolute log directory path for a container in pod. func BuildContainerLogsDirectory(podLogsDir, podNamespace, podName string, podUID types.UID, containerName string) string { … } // BuildPodLogsDirectory builds absolute log directory path for a pod sandbox. func BuildPodLogsDirectory(podLogsDir, podNamespace, podName string, podUID types.UID) string { … } // parsePodUIDFromLogsDirectory parses pod logs directory name and returns the pod UID. // It supports both the old pod log directory /var/log/pods/UID, and the new pod log // directory /var/log/pods/NAMESPACE_NAME_UID. func parsePodUIDFromLogsDirectory(name string) types.UID { … } // toKubeRuntimeStatus converts the runtimeapi.RuntimeStatus to kubecontainer.RuntimeStatus. func toKubeRuntimeStatus(status *runtimeapi.RuntimeStatus, handlers []*runtimeapi.RuntimeHandler, features *runtimeapi.RuntimeFeatures) *kubecontainer.RuntimeStatus { … } func fieldSeccompProfile(scmp *v1.SeccompProfile, profileRootPath string, fallbackToRuntimeDefault bool) (*runtimeapi.SecurityProfile, error) { … } func (m *kubeGenericRuntimeManager) getSeccompProfile(annotations map[string]string, containerName string, podSecContext *v1.PodSecurityContext, containerSecContext *v1.SecurityContext, fallbackToRuntimeDefault bool) (*runtimeapi.SecurityProfile, error) { … } func getAppArmorProfile(pod *v1.Pod, container *v1.Container) (*runtimeapi.SecurityProfile, string, error) { … }
Codebase Browser
kubernetes