resource

type KubeResourceManager ¶

type KubeResourceManager struct {
	// contains filtered or unexported fields
}

KubeResourceManager acts as a passthrough to a cache (lister) for pods assigned to the current node. It is also a passthrough to a cache (lister) for Kubernetes secrets and config maps.

func NewResourceManager(kubeClient kubernetes.Interface,
	namespace string,
	podLister corev1listers.PodNamespaceLister,
	secretLister corev1listers.SecretNamespaceLister,
	configMapLister corev1listers.ConfigMapNamespaceLister) *KubeResourceManager

func (rm *KubeResourceManager) GetConfigMap(name string) (*v1.ConfigMap, error)

func (rm *KubeResourceManager) GetNode(name string) (*v1.Node, error)

func (rm *KubeResourceManager) GetPod(name string) (*v1.Pod, error)

func (rm *KubeResourceManager) GetSecret(name string) (*v1.Secret, error)

type VolumeHelper ¶

type VolumeHelper interface {
	GetPodVolumesDir(podUID types.UID) string
}

type VolumeInfo ¶

type VolumeInfo struct {
	HostPath       string
	ReadOnly       bool
	Managed        bool
	SELinuxRelabel bool
}

type VolumeManager ¶

type VolumeManager struct {
	ResourceManager *KubeResourceManager
	// contains filtered or unexported fields
}

VolumeManager Volume has an explicit lifetime - the same as the Pod that encloses it. Consequently, a volume outlives any Containers that run within the Pod, and data is preserved across Container restarts. Of course, when a Pod ceases to exist, the volume will cease to exist, too.

func NewVolumeManager(rm *KubeResourceManager, volumeHelper VolumeHelper) *VolumeManager

func (vm *VolumeManager) GetMountedVolumesForPod(podUID types.UID) VolumeMap

func (vm *VolumeManager) MountVolumesForPod(pod *v1.Pod) error

func (vm *VolumeManager) UnmountVolumesForPod(podUID types.UID)

type VolumeMap ¶

type VolumeMap map[string]VolumeInfo