kubernetes/pkg/volume/downwardapi/downwardapi.go

// ProbeVolumePlugins is the entry point for plugin detection in a package.
func ProbeVolumePlugins() []volume.VolumePlugin { … }

const downwardAPIPluginName …

type downwardAPIPlugin …

var _ …

func getPath(uid types.UID, volName string, host volume.VolumeHost) string { … }

func wrappedVolumeSpec() volume.Spec { … }

func (plugin *downwardAPIPlugin) Init(host volume.VolumeHost) error { … }

func (plugin *downwardAPIPlugin) GetPluginName() string { … }

func (plugin *downwardAPIPlugin) GetVolumeName(spec *volume.Spec) (string, error) { … }

func (plugin *downwardAPIPlugin) CanSupport(spec *volume.Spec) bool { … }

func (plugin *downwardAPIPlugin) RequiresRemount(spec *volume.Spec) bool { … }

func (plugin *downwardAPIPlugin) SupportsMountOption() bool { … }

func (plugin *downwardAPIPlugin) SupportsSELinuxContextMount(spec *volume.Spec) (bool, error) { … }

func (plugin *downwardAPIPlugin) NewMounter(spec *volume.Spec, pod *v1.Pod) (volume.Mounter, error) { … }

func (plugin *downwardAPIPlugin) NewUnmounter(volName string, podUID types.UID) (volume.Unmounter, error) { … }

func (plugin *downwardAPIPlugin) ConstructVolumeSpec(volumeName, mountPath string) (volume.ReconstructedVolume, error) { … }

type downwardAPIVolume …

type downwardAPIVolumeMounter …

var _ …

// downward API volumes are always ReadOnlyManaged
func (d *downwardAPIVolume) GetAttributes() volume.Attributes { … }

// SetUp puts in place the volume plugin.
// This function is not idempotent by design. We want the data to be refreshed periodically.
// The internal sync interval of kubelet will drive the refresh of data.
// TODO: Add volume specific ticker and refresh loop
func (b *downwardAPIVolumeMounter) SetUp(mounterArgs volume.MounterArgs) error { … }

func (b *downwardAPIVolumeMounter) SetUpAt(dir string, mounterArgs volume.MounterArgs) error { … }

// CollectData collects requested downwardAPI in data map.
// Map's key is the requested name of file to dump
// Map's value is the (sorted) content of the field to be dumped in the file.
//
// Note: this function is exported so that it can be called from the projection volume driver
func CollectData(items []v1.DownwardAPIVolumeFile, pod *v1.Pod, host volume.VolumeHost, defaultMode *int32) (map[string]volumeutil.FileProjection, error) { … }

func (d *downwardAPIVolume) GetPath() string { … }

type downwardAPIVolumeUnmounter …

var _ …

func (c *downwardAPIVolumeUnmounter) TearDown() error { … }

func (c *downwardAPIVolumeUnmounter) TearDownAt(dir string) error { … }

func getVolumeSource(spec *volume.Spec) (*v1.DownwardAPIVolumeSource, bool) { … }