const reconcilerLoopSleepPeriod … const desiredStateOfWorldPopulatorLoopSleepPeriod … const podAttachAndMountTimeout … const podAttachAndMountRetryInterval … const waitForAttachTimeout … type VolumeManager … type PodStateProvider … type PodManager … // NewVolumeManager returns a new concrete instance implementing the // VolumeManager interface. // // kubeClient - kubeClient is the kube API client used by DesiredStateOfWorldPopulator // to communicate with the API server to fetch PV and PVC objects // // volumePluginMgr - the volume plugin manager used to access volume plugins. // Must be pre-initialized. func NewVolumeManager( controllerAttachDetachEnabled bool, nodeName k8stypes.NodeName, podManager PodManager, podStateProvider PodStateProvider, kubeClient clientset.Interface, volumePluginMgr *volume.VolumePluginMgr, kubeContainerRuntime container.Runtime, mounter mount.Interface, hostutil hostutil.HostUtils, kubeletPodsDir string, recorder record.EventRecorder, blockVolumePathHandler volumepathhandler.BlockVolumePathHandler) VolumeManager { … } type volumeManager … func (vm *volumeManager) Run(ctx context.Context, sourcesReady config.SourcesReady) { … } func (vm *volumeManager) GetMountedVolumesForPod(podName types.UniquePodName) container.VolumeMap { … } func (vm *volumeManager) GetPossiblyMountedVolumesForPod(podName types.UniquePodName) container.VolumeMap { … } func (vm *volumeManager) GetExtraSupplementalGroupsForPod(pod *v1.Pod) []int64 { … } func (vm *volumeManager) GetVolumesInUse() []v1.UniqueVolumeName { … } func (vm *volumeManager) ReconcilerStatesHasBeenSynced() bool { … } func (vm *volumeManager) VolumeIsAttached( volumeName v1.UniqueVolumeName) bool { … } func (vm *volumeManager) MarkVolumesAsReportedInUse( volumesReportedAsInUse []v1.UniqueVolumeName) { … } func (vm *volumeManager) WaitForAttachAndMount(ctx context.Context, pod *v1.Pod) error { … } func (vm *volumeManager) WaitForUnmount(ctx context.Context, pod *v1.Pod) error { … } func (vm *volumeManager) WaitForAllPodsUnmount(ctx context.Context, pods []*v1.Pod) error { … } func (vm *volumeManager) getVolumesNotInDSW(uniquePodName types.UniquePodName, expectedVolumes []string) []string { … } // getUnattachedVolumes returns a list of the volumes that are expected to be attached but // are not currently attached to the node func (vm *volumeManager) getUnattachedVolumes(uniquePodName types.UniquePodName) []string { … } // verifyVolumesMountedFunc returns a method that returns true when all expected // volumes are mounted. func (vm *volumeManager) verifyVolumesMountedFunc(podName types.UniquePodName, expectedVolumes []string) wait.ConditionWithContextFunc { … } // verifyVolumesUnmountedFunc returns a method that is true when there are no mounted volumes for this // pod. func (vm *volumeManager) verifyVolumesUnmountedFunc(podName types.UniquePodName) wait.ConditionWithContextFunc { … } // getUnmountedVolumes fetches the current list of mounted volumes from // the actual state of the world, and uses it to process the list of // expectedVolumes. It returns a list of unmounted volumes. // The list also includes volume that may be mounted in uncertain state. func (vm *volumeManager) getUnmountedVolumes(podName types.UniquePodName, expectedVolumes []string) []string { … } // filterUnmountedVolumes adds each element of expectedVolumes that is not in // mountedVolumes to a list of unmountedVolumes and returns it. func filterUnmountedVolumes(mountedVolumes sets.Set[string], expectedVolumes []string) []string { … } // getExpectedVolumes returns a list of volumes that must be mounted in order to // consider the volume setup step for this pod satisfied. func getExpectedVolumes(pod *v1.Pod) []string { … } // getExtraSupplementalGid returns the value of an extra supplemental GID as // defined by an annotation on a volume and a boolean indicating whether the // volume defined a GID that the pod doesn't already request. func getExtraSupplementalGid(volumeGidValue string, pod *v1.Pod) (int64, bool) { … }
Codebase Browser
kubernetes