const perm … // ProbeVolumePlugins is the primary entrypoint for volume plugins. func ProbeVolumePlugins() []volume.VolumePlugin { … } type emptyDirPlugin … var _ … const emptyDirPluginName … const hugePagesPageSizeMountOption … func getPath(uid types.UID, volName string, host volume.VolumeHost) string { … } func (plugin *emptyDirPlugin) Init(host volume.VolumeHost) error { … } func (plugin *emptyDirPlugin) GetPluginName() string { … } func (plugin *emptyDirPlugin) GetVolumeName(spec *volume.Spec) (string, error) { … } func (plugin *emptyDirPlugin) CanSupport(spec *volume.Spec) bool { … } func (plugin *emptyDirPlugin) RequiresRemount(spec *volume.Spec) bool { … } func (plugin *emptyDirPlugin) SupportsMountOption() bool { … } func (plugin *emptyDirPlugin) SupportsSELinuxContextMount(spec *volume.Spec) (bool, error) { … } func (plugin *emptyDirPlugin) NewMounter(spec *volume.Spec, pod *v1.Pod) (volume.Mounter, error) { … } func calculateEmptyDirMemorySize(nodeAllocatableMemory *resource.Quantity, spec *volume.Spec, pod *v1.Pod) *resource.Quantity { … } func (plugin *emptyDirPlugin) newMounterInternal(spec *volume.Spec, pod *v1.Pod, mounter mount.Interface, mountDetector mountDetector) (volume.Mounter, error) { … } func (plugin *emptyDirPlugin) NewUnmounter(volName string, podUID types.UID) (volume.Unmounter, error) { … } func (plugin *emptyDirPlugin) newUnmounterInternal(volName string, podUID types.UID, mounter mount.Interface, mountDetector mountDetector) (volume.Unmounter, error) { … } func (plugin *emptyDirPlugin) ConstructVolumeSpec(volName, mountPath string) (volume.ReconstructedVolume, error) { … } type mountDetector … type emptyDir … func (ed *emptyDir) GetAttributes() volume.Attributes { … } // SetUp creates new directory. func (ed *emptyDir) SetUp(mounterArgs volume.MounterArgs) error { … } // SetUpAt creates new directory. func (ed *emptyDir) SetUpAt(dir string, mounterArgs volume.MounterArgs) error { … } // assignQuota checks if the underlying medium supports quotas and if so, sets func (ed *emptyDir) assignQuota(dir string, mounterSize *resource.Quantity) error { … } // setupTmpfs creates a tmpfs mount at the specified directory. func (ed *emptyDir) setupTmpfs(dir string) error { … } // setupHugepages creates a hugepage mount at the specified directory. func (ed *emptyDir) setupHugepages(dir string) error { … } // getPageSizeMountOption retrieves pageSize mount option from Pod's resources // and medium and validates pageSize options in all containers of given Pod. func getPageSizeMountOption(medium v1.StorageMedium, pod *v1.Pod) (string, error) { … } // setupDir creates the directory with the default permissions specified by the perm constant. func (ed *emptyDir) setupDir(dir string) error { … } func (ed *emptyDir) GetPath() string { … } // TearDown simply discards everything in the directory. func (ed *emptyDir) TearDown() error { … } // TearDownAt simply discards everything in the directory. func (ed *emptyDir) TearDownAt(dir string) error { … } func (ed *emptyDir) teardownDefault(dir string) error { … } func (ed *emptyDir) teardownTmpfsOrHugetlbfs(dir string) error { … } func (ed *emptyDir) getMetaDir() string { … } func getVolumeSource(spec *volume.Spec) (*v1.EmptyDirVolumeSource, bool) { … } func (ed *emptyDir) generateTmpfsMountOptions(noswapSupported bool) (options []string) { … }
Codebase Browser
kubernetes