pods

Documentation

Index

• Constants
• func AddEphemeralContainer(ctx *synccontext.SyncContext, physicalClusterClient kubernetes.Interface, ...) error
• func ConfigNamesFromContainer(namespace string, container *corev1.Container) []string
• func ConfigNamesFromEphemeralContainer(namespace string, container *corev1.EphemeralContainer) []string
• func ConfigNamesFromPod(pod *corev1.Pod) []string
• func New(ctx *synccontext.RegisterContext) (syncer.Object, error)
• func SecretNamesFromContainer(namespace string, container *corev1.Container) []string
• func SecretNamesFromEphemeralContainer(namespace string, container *corev1.EphemeralContainer) []string
• func SecretNamesFromPod(pod *corev1.Pod) []string
• func SecretNamesFromVolumes(pod *corev1.Pod) []string
• func UpdateConditions(ctx *synccontext.SyncContext, physicalPod *corev1.Pod, virtualPod *corev1.Pod) (bool, error)
• type ContainerPhysicalMountPathRegister
• type FakeMetricsRecorder
  • func (n *FakeMetricsRecorder) RecordError(_ bool, _ api.Attributes)
  • func (n *FakeMetricsRecorder) RecordEvaluation(_ metrics.Decision, _ api.LevelVersion, _ metrics.Mode, _ api.Attributes)
  • func (n *FakeMetricsRecorder) RecordExemption(api.Attributes)
• type PodAttributes
  • func (a *PodAttributes) GetKind() schema.GroupVersionKind
  • func (a *PodAttributes) GetObject() (runtime.Object, error)
  • func (a *PodAttributes) GetOldObject() (runtime.Object, error)
  • func (a *PodAttributes) GetOperation() admissionv1.Operation
  • func (a *PodAttributes) GetResource() schema.GroupVersionResource
  • func (a *PodAttributes) GetSubresource() string
  • func (a *PodAttributes) GetUserName() string

Constants

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

	PodLoggingHostpathPath = "/var/log/pods"
	LogHostpathPath        = "/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"
)

Functions

func AddEphemeralContainer

func AddEphemeralContainer(ctx *synccontext.SyncContext, physicalClusterClient kubernetes.Interface, physicalPod *corev1.Pod, virtualPod *corev1.Pod) error

AddEphemeralContainer runs an EphemeralContainer in the target Pod for use as a debug container

func ConfigNamesFromContainer

func ConfigNamesFromContainer(namespace string, container *corev1.Container) []string

func ConfigNamesFromEphemeralContainer

func ConfigNamesFromEphemeralContainer(namespace string, container *corev1.EphemeralContainer) []string

func ConfigNamesFromPod

func ConfigNamesFromPod(pod *corev1.Pod) []string

func New

func New(ctx *synccontext.RegisterContext) (syncer.Object, error)

func SecretNamesFromContainer

func SecretNamesFromContainer(namespace string, container *corev1.Container) []string

func SecretNamesFromEphemeralContainer

func SecretNamesFromEphemeralContainer(namespace string, container *corev1.EphemeralContainer) []string

func SecretNamesFromPod

func SecretNamesFromPod(pod *corev1.Pod) []string

func SecretNamesFromVolumes

func SecretNamesFromVolumes(pod *corev1.Pod) []string

func UpdateConditions

func UpdateConditions(ctx *synccontext.SyncContext, physicalPod *corev1.Pod, virtualPod *corev1.Pod) (bool, error)

UpdateConditions adds/updates new/old conditions in the physical Pod

Types

type ContainerPhysicalMountPathRegister

type ContainerPhysicalMountPathRegister struct {
	KubeletMountPath map[string]bool
	PodLogMountPath  map[string]bool
	LogMountPath     map[string]bool
}

ContainerPhysicalMountPathRegister is a register that keeps track of the containers that already have a physical mount added to them before, so that we don't append the same mount path more than once to the same container. This is to tackle edge cases like in kubevirt where we had VolumeMounts

• mountPath: /pods name: kubelet-pods-shortened
• mountPath: /var/lib/kubelet/pods mountPropagation: Bidirectional name: kubelet-pods

and Volumes

• hostPath: path: /var/lib/kubelet/pods type: "" name: kubelet-pods-shortened
• hostPath: path: /var/lib/kubelet/pods type: "" name: kubelet-pods

causing the physical physical path to be mounted twice, one for each above virtual volumeMounts ---

• name: kubelet-pods-shortened-vcluster-physical mountPath: "/var/vcluster/physical/kubelet/pods"
• name: kubelet-pods-vcluster-physical mountPath: "/var/vcluster/physical/kubelet/pods" mountPropagation: Bidirectional

type FakeMetricsRecorder

type FakeMetricsRecorder struct{}

func (*FakeMetricsRecorder) RecordError

func (n *FakeMetricsRecorder) RecordError(_ bool, _ api.Attributes)

func (*FakeMetricsRecorder) RecordEvaluation

func (n *FakeMetricsRecorder) RecordEvaluation(_ metrics.Decision, _ api.LevelVersion, _ metrics.Mode, _ api.Attributes)

func (*FakeMetricsRecorder) RecordExemption

func (n *FakeMetricsRecorder) RecordExemption(api.Attributes)

type PodAttributes

type PodAttributes struct {
	*corev1.Pod
}

func (*PodAttributes) GetKind

func (a *PodAttributes) GetKind() schema.GroupVersionKind

func (*PodAttributes) GetObject

func (a *PodAttributes) GetObject() (runtime.Object, error)

func (*PodAttributes) GetOldObject

func (a *PodAttributes) GetOldObject() (runtime.Object, error)

func (*PodAttributes) GetOperation

func (a *PodAttributes) GetOperation() admissionv1.Operation

func (*PodAttributes) GetResource

func (a *PodAttributes) GetResource() schema.GroupVersionResource

func (*PodAttributes) GetSubresource

func (a *PodAttributes) GetSubresource() string

func (*PodAttributes) GetUserName

func (a *PodAttributes) GetUserName() string