controller

Documentation

Index

• Constants
• type MountPointController
  • func GetMountPointController(nodeID string) *MountPointController
  • func Initialize(nodeID string, masterNodesAware bool) *MountPointController
  • func (m *MountPointController) CheckAndRemountVolumeMount(volumeMount volumeMountInfo) error
  • func (m *MountPointController) RemovePod(podUID string)
  • func (m *MountPointController) Start(stopCh <-chan struct{})
  • func (m *MountPointController) Stop()
  • func (m *MountPointController) UpdateMounts(volumeMount volumeMountInfo) error
  • func (m *MountPointController) UpdatePodMap() error
  • func (m *MountPointController) WaitToUpdatePodMap()
• type SubPath

Constants

const (
	PFSPrefix = "pfs-"
	PVCSuffix = "-pvc"
)

Types

type MountPointController

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

MountPointController will check the status of the mount point and remount unconnected mount point

func GetMountPointController

func GetMountPointController(nodeID string) *MountPointController

func Initialize

func Initialize(nodeID string, masterNodesAware bool) *MountPointController

func (*MountPointController) CheckAndRemountVolumeMount

func (m *MountPointController) CheckAndRemountVolumeMount(volumeMount volumeMountInfo) error

func (*MountPointController) RemovePod

func (m *MountPointController) RemovePod(podUID string)

RemovePod During the pod update interval, add the pod UID that has called NodeUnPublishVolume to the map `removePods`

func (*MountPointController) Start

func (m *MountPointController) Start(stopCh <-chan struct{})

func (*MountPointController) Stop

func (m *MountPointController) Stop()

func (*MountPointController) UpdateMounts

func (m *MountPointController) UpdateMounts(volumeMount volumeMountInfo) error

UpdateMounts update mount

func (*MountPointController) UpdatePodMap

func (m *MountPointController) UpdatePodMap() error

UpdatePodMap Synchronize all pod information of the node from kubelet

func (*MountPointController) WaitToUpdatePodMap

func (m *MountPointController) WaitToUpdatePodMap()

WaitToUpdatePodMap wait to update PodMap

type SubPath

type SubPath struct {
	ReadOnly   bool
	SourcePath string
	TargetPath string
}

The SubPath is a volumeMount with subPath param in the pod's spec