kube

Documentation

Index

• func GetPvName(pvObj *corev1.PersistentVolume) string
• type KubeController
  • func NewKubeController(kubeClient kubernetes.Interface, ...) *KubeController
  • func (k *KubeController) GetPvMap() map[string]*corev1.PersistentVolume
  • func (c *KubeController) GetPvcIndex(pvcObj *corev1.PersistentVolumeClaim) string
  • func (k *KubeController) GetPvcMap() map[string]*corev1.PersistentVolumeClaim
  • func (k *KubeController) SetPvMap(pvName string, pvObj *corev1.PersistentVolume)
  • func (k *KubeController) SetPvcMap(pvcName string, pvcObj *corev1.PersistentVolumeClaim)

Functions

func GetPvName

func GetPvName(pvObj *corev1.PersistentVolume) string

Types

type KubeController

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

func NewKubeController

func NewKubeController(kubeClient kubernetes.Interface,
	pvInformer coreinformers.PersistentVolumeInformer,
	pvcInformer coreinformers.PersistentVolumeClaimInformer,
	recorder record.EventRecorder) *KubeController

func (*KubeController) GetPvMap

func (k *KubeController) GetPvMap() map[string]*corev1.PersistentVolume

func (*KubeController) GetPvcIndex

func (c *KubeController) GetPvcIndex(pvcObj *corev1.PersistentVolumeClaim) string

func (*KubeController) GetPvcMap

func (k *KubeController) GetPvcMap() map[string]*corev1.PersistentVolumeClaim

func (*KubeController) SetPvMap

func (k *KubeController) SetPvMap(pvName string, pvObj *corev1.PersistentVolume)

func (*KubeController) SetPvcMap

func (k *KubeController) SetPvcMap(pvcName string, pvcObj *corev1.PersistentVolumeClaim)