const reconcilerLoopSleepPeriod …
const desiredStateOfWorldPopulatorLoopSleepPeriod …
const podAttachAndMountTimeout …
const podAttachAndMountRetryInterval …
const waitForAttachTimeout …
type VolumeManager …
type PodStateProvider …
type PodManager …
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 { … }
func (vm *volumeManager) getUnattachedVolumes(uniquePodName types.UniquePodName) []string { … }
func (vm *volumeManager) verifyVolumesMountedFunc(podName types.UniquePodName, expectedVolumes []string) wait.ConditionWithContextFunc { … }
func (vm *volumeManager) verifyVolumesUnmountedFunc(podName types.UniquePodName) wait.ConditionWithContextFunc { … }
func (vm *volumeManager) getUnmountedVolumes(podName types.UniquePodName, expectedVolumes []string) []string { … }
func filterUnmountedVolumes(mountedVolumes sets.Set[string], expectedVolumes []string) []string { … }
func getExpectedVolumes(pod *v1.Pod) []string { … }
func getExtraSupplementalGid(volumeGidValue string, pod *v1.Pod) (int64, bool) { … }