type DesiredStateOfWorld …
type VolumeToMount …
func NewDesiredStateOfWorld(volumePluginMgr *volume.VolumePluginMgr, seLinuxTranslator util.SELinuxLabelTranslator) DesiredStateOfWorld { … }
type desiredStateOfWorld …
type volumeToMount …
type podToMount …
const maxPodErrors …
func (dsw *desiredStateOfWorld) AddPodToVolume(
podName types.UniquePodName,
pod *v1.Pod,
volumeSpec *volume.Spec,
outerVolumeSpecName string,
volumeGidValue string,
seLinuxContainerContexts []*v1.SELinuxOptions) (v1.UniqueVolumeName, error) { … }
func (dsw *desiredStateOfWorld) getSELinuxLabel(volumeSpec *volume.Spec, seLinuxContainerContexts []*v1.SELinuxOptions) (string, bool, error) { … }
func (dsw *desiredStateOfWorld) MarkVolumesReportedInUse(
reportedVolumes []v1.UniqueVolumeName) { … }
func (dsw *desiredStateOfWorld) DeletePodFromVolume(
podName types.UniquePodName, volumeName v1.UniqueVolumeName) { … }
func (dsw *desiredStateOfWorld) UpdatePersistentVolumeSize(volumeName v1.UniqueVolumeName, size resource.Quantity) { … }
func (dsw *desiredStateOfWorld) VolumeExists(
volumeName v1.UniqueVolumeName, seLinuxMountContext string) bool { … }
func (dsw *desiredStateOfWorld) PodExistsInVolume(
podName types.UniquePodName, volumeName v1.UniqueVolumeName, seLinuxMountOption string) bool { … }
func (dsw *desiredStateOfWorld) VolumeExistsWithSpecName(podName types.UniquePodName, volumeSpecName string) bool { … }
func (dsw *desiredStateOfWorld) GetPods() map[types.UniquePodName]bool { … }
func (dsw *desiredStateOfWorld) GetVolumesToMount() []VolumeToMount { … }
func (dsw *desiredStateOfWorld) AddErrorToPod(podName types.UniquePodName, err string) { … }
func (dsw *desiredStateOfWorld) PopPodErrors(podName types.UniquePodName) []string { … }
func (dsw *desiredStateOfWorld) GetPodsWithErrors() []types.UniquePodName { … }
func (dsw *desiredStateOfWorld) MarkVolumeAttachability(volumeName v1.UniqueVolumeName, attachable bool) { … }
func (dsw *desiredStateOfWorld) getSELinuxMountSupport(volumeSpec *volume.Spec) (bool, error) { … }
func handleSELinuxMetricError(err error, seLinuxSupported bool, warningMetric, errorMetric metrics.GaugeMetric) error { … }
func getVolumePluginNameWithDriver(plugin volume.VolumePlugin, spec *volume.Spec) string { … }
func getVolumeAccessMode(spec *volume.Spec) string { … }