k8sconv

Documentation

Overview

Converts Kubernetes data models into our own internal data models.

(package name loosely inspired by strconv)

Index

• Variables
• func ContainerForStatus(pod *v1.Pod, cStatus v1.ContainerStatus) (v1alpha1.Container, error)
• func ContainerStatusToRuntimeState(status v1alpha1.Container) model.RuntimeStatus
• func Pod(ctx context.Context, pod *v1.Pod) *v1alpha1.Pod
• func PodConditions(conditions []v1.PodCondition) []v1alpha1.PodCondition
• func PodContainers(ctx context.Context, pod *v1.Pod, containerStatuses []v1.ContainerStatus) []v1alpha1.Container
• func PodStatusErrorMessages(pod v1.Pod) []string
• func PodStatusToString(pod v1.Pod) string
• func SpanIDForPod(podID k8s.PodID) logstore.SpanID

Variables

var ErrorWaitingReasons = map[string]bool{
	"CrashLoopBackOff":  true,
	"ErrImagePull":      true,
	"ImagePullBackOff":  true,
	"RunContainerError": true,
	"StartError":        true,
	"Error":             true,
}

Functions

func ContainerForStatus

func ContainerForStatus(pod *v1.Pod, cStatus v1.ContainerStatus) (v1alpha1.Container, error)

Convert a Kubernetes Pod and ContainerStatus into a simpler Container model to store in the engine state.

func ContainerStatusToRuntimeState

func ContainerStatusToRuntimeState(status v1alpha1.Container) model.RuntimeStatus

func Pod

func Pod(ctx context.Context, pod *v1.Pod) *v1alpha1.Pod

func PodConditions

func PodConditions(conditions []v1.PodCondition) []v1alpha1.PodCondition

func PodContainers

func PodContainers(ctx context.Context, pod *v1.Pod, containerStatuses []v1.ContainerStatus) []v1alpha1.Container

Convert a Kubernetes Pod into a list if simpler Container models to store in the engine state.

func PodStatusErrorMessages

func PodStatusErrorMessages(pod v1.Pod) []string

Pull out interesting error messages from the pod status

func PodStatusToString

func PodStatusToString(pod v1.Pod) string

copied from https://github.com/kubernetes/kubernetes/blob/aedeccda9562b9effe026bb02c8d3c539fc7bb77/pkg/kubectl/resource_printer.go#L692-L764 to match the status column of `kubectl get pods`

func SpanIDForPod

func SpanIDForPod(podID k8s.PodID) logstore.SpanID