translate

Documentation

Index

• Constants
• Variables
• func GetSecretIfExists(ctx context.Context, pClient client.Client, vPodName, vNamespace string) (*corev1.Secret, bool, error)
• func SATokenSecret(ctx context.Context, pClient client.Client, vPod *corev1.Pod, ...) error
• func SecretNameFromPodName(podName, namespace string) string
• func SetPodAsOwner(ctx context.Context, pPod *corev1.Pod, pClient client.Client, ...) error
• func TranslateContainerEnv(envVar []corev1.EnvVar, envFrom []corev1.EnvFromSource, vPod *corev1.Pod, ...) ([]corev1.EnvVar, []corev1.EnvFromSource)
• func TranslateLabelsAnnotation(obj client.Object) string
• func TranslateServicesToEnvironmentVariables(enableServiceLinks *bool, services []*corev1.Service, kubeIP string) map[string]string
• type ImageTranslator
  • func NewImageTranslator(translateImages []string) (ImageTranslator, error)
• type Translator
  • func NewTranslator(ctx *synccontext.RegisterContext, eventRecorder record.EventRecorder) (Translator, error)

Constants

const (
	VirtualPathTemplate = "/tmp/vcluster/%s/%s"

	PodLoggingHostPath = "/var/log/pods"
	LogHostPath        = "/var/log"

	KubeletPodPath = "/var/lib/kubelet/pods"

	PhysicalVolumeNameSuffix = "vcluster-physical"

	PhysicalLogVolumeMountPath     = "/var/vcluster/physical/log"
	PhysicalPodLogVolumeMountPath  = "/var/vcluster/physical/log/pods"
	PhysicalKubeletVolumeMountPath = "/var/vcluster/physical/kubelet/pods"
)

const (
	DisableSubdomainRewriteAnnotation = "vcluster.loft.sh/disable-subdomain-rewrite"
	HostsRewrittenAnnotation          = "vcluster.loft.sh/hosts-rewritten"
	HostsVolumeName                   = "vcluster-rewrite-hosts"
	HostsRewriteContainerName         = "vcluster-rewrite-hosts"
)

const (
	OwnerSetKind                         = "vcluster.loft.sh/owner-set-kind"
	NamespaceAnnotation                  = "vcluster.loft.sh/namespace"
	NameAnnotation                       = "vcluster.loft.sh/name"
	LabelsAnnotation                     = "vcluster.loft.sh/labels"
	NamespaceLabelPrefix                 = "vcluster.loft.sh/ns-label"
	UIDAnnotation                        = "vcluster.loft.sh/uid"
	ClusterAutoScalerAnnotation          = "cluster-autoscaler.kubernetes.io/safe-to-evict"
	ClusterAutoScalerDaemonSetAnnotation = "cluster-autoscaler.kubernetes.io/daemonset-pod"
	ServiceAccountNameAnnotation         = "vcluster.loft.sh/service-account-name"
	ServiceAccountTokenAnnotation        = "vcluster.loft.sh/token-"
)

const (
	PodKind string = "Pod"
)

Variables

var (
	FieldPathLabelRegEx      = regexp.MustCompile(`^metadata\.labels\['(.+)'\]$`)
	FieldPathAnnotationRegEx = regexp.MustCompile(`^metadata\.annotations\['(.+)'\]$`)
	False                    = false
)

var PodServiceAccountTokenSecretName string

Functions

func GetSecretIfExists

func GetSecretIfExists(ctx context.Context, pClient client.Client, vPodName, vNamespace string) (*corev1.Secret, bool, error)

func SATokenSecret

func SATokenSecret(ctx context.Context, pClient client.Client, vPod *corev1.Pod, tokens map[string]string) error

func SecretNameFromPodName

func SecretNameFromPodName(podName, namespace string) string

func SetPodAsOwner

func SetPodAsOwner(ctx context.Context, pPod *corev1.Pod, pClient client.Client, secret *corev1.Secret) error

func TranslateContainerEnv

func TranslateContainerEnv(envVar []corev1.EnvVar, envFrom []corev1.EnvFromSource, vPod *corev1.Pod, serviceEnvMap map[string]string) ([]corev1.EnvVar, []corev1.EnvFromSource)

func TranslateLabelsAnnotation

func TranslateLabelsAnnotation(obj client.Object) string

func TranslateServicesToEnvironmentVariables

func TranslateServicesToEnvironmentVariables(enableServiceLinks *bool, services []*corev1.Service, kubeIP string) map[string]string

Types

type ImageTranslator

type ImageTranslator interface {
	Translate(image string) string
}

func NewImageTranslator

func NewImageTranslator(translateImages []string) (ImageTranslator, error)

type Translator

type Translator interface {
	Translate(ctx context.Context, vPod *corev1.Pod, services []*corev1.Service, dnsIP string, kubeIP string) (*corev1.Pod, error)
	Diff(ctx context.Context, vPod, pPod *corev1.Pod) (*corev1.Pod, error)
}

func NewTranslator

func NewTranslator(ctx *synccontext.RegisterContext, eventRecorder record.EventRecorder) (Translator, error)