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) CheckIfNeedRemount(path string) bool
  • func (m *MountPointController) Remount(fsID, mountPath string, readOnly bool) 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()

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) CheckIfNeedRemount

func (m *MountPointController) CheckIfNeedRemount(path string) bool

CheckIfNeedRemount The conditions for remount: the path is the mount point and the error message returned by the `mountpoint` command contains "Transport endpoint is not connected"

func (*MountPointController) Remount

func (m *MountPointController) Remount(fsID, mountPath string, readOnly bool) 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