kubernetes/pkg/kubelet/volume_host.go

// NewInitializedVolumePluginMgr returns a new instance of
// volume.VolumePluginMgr initialized with kubelets implementation of the
// volume.VolumeHost interface.
//
// kubelet - used by VolumeHost methods to expose kubelet specific parameters
// plugins - used to initialize volumePluginMgr
func NewInitializedVolumePluginMgr(
	kubelet *Kubelet,
	secretManager secret.Manager,
	configMapManager configmap.Manager,
	tokenManager *token.Manager,
	clusterTrustBundleManager clustertrustbundle.Manager,
	plugins []volume.VolumePlugin,
	prober volume.DynamicPluginProber) (*volume.VolumePluginMgr, error) { … }

var _ …

var _ …

func (kvh *kubeletVolumeHost) GetPluginDir(pluginName string) string { … }

type kubeletVolumeHost …

func (kvh *kubeletVolumeHost) SetKubeletError(err error) { … }

func (kvh *kubeletVolumeHost) GetVolumeDevicePluginDir(pluginName string) string { … }

func (kvh *kubeletVolumeHost) GetPodsDir() string { … }

func (kvh *kubeletVolumeHost) GetPodVolumeDir(podUID types.UID, pluginName string, volumeName string) string { … }

func (kvh *kubeletVolumeHost) GetPodVolumeDeviceDir(podUID types.UID, pluginName string) string { … }

func (kvh *kubeletVolumeHost) GetPodPluginDir(podUID types.UID, pluginName string) string { … }

func (kvh *kubeletVolumeHost) GetKubeClient() clientset.Interface { … }

func (kvh *kubeletVolumeHost) GetSubpather() subpath.Interface { … }

func (kvh *kubeletVolumeHost) GetHostUtil() hostutil.HostUtils { … }

func (kvh *kubeletVolumeHost) GetInformerFactory() informers.SharedInformerFactory { … }

func (kvh *kubeletVolumeHost) CSIDriverLister() storagelisters.CSIDriverLister { … }

func (kvh *kubeletVolumeHost) CSIDriversSynced() cache.InformerSynced { … }

// WaitForCacheSync is a helper function that waits for cache sync for CSIDriverLister
func (kvh *kubeletVolumeHost) WaitForCacheSync() error { … }

func (kvh *kubeletVolumeHost) NewWrapperMounter(
	volName string,
	spec volume.Spec,
	pod *v1.Pod) (volume.Mounter, error) { … }

func (kvh *kubeletVolumeHost) NewWrapperUnmounter(volName string, spec volume.Spec, podUID types.UID) (volume.Unmounter, error) { … }

func (kvh *kubeletVolumeHost) GetMounter(pluginName string) mount.Interface { … }

func (kvh *kubeletVolumeHost) GetHostName() string { … }

func (kvh *kubeletVolumeHost) GetHostIP() (net.IP, error) { … }

func (kvh *kubeletVolumeHost) GetNodeAllocatable() (v1.ResourceList, error) { … }

func (kvh *kubeletVolumeHost) GetSecretFunc() func(namespace, name string) (*v1.Secret, error) { … }

func (kvh *kubeletVolumeHost) GetConfigMapFunc() func(namespace, name string) (*v1.ConfigMap, error) { … }

func (kvh *kubeletVolumeHost) GetServiceAccountTokenFunc() func(namespace, name string, tr *authenticationv1.TokenRequest) (*authenticationv1.TokenRequest, error) { … }

func (kvh *kubeletVolumeHost) DeleteServiceAccountTokenFunc() func(podUID types.UID) { … }

func (kvh *kubeletVolumeHost) GetTrustAnchorsByName(name string, allowMissing bool) ([]byte, error) { … }

func (kvh *kubeletVolumeHost) GetTrustAnchorsBySigner(signerName string, labelSelector *metav1.LabelSelector, allowMissing bool) ([]byte, error) { … }

func (kvh *kubeletVolumeHost) GetNodeLabels() (map[string]string, error) { … }

func (kvh *kubeletVolumeHost) GetAttachedVolumesFromNodeStatus() (map[v1.UniqueVolumeName]string, error) { … }

func (kvh *kubeletVolumeHost) GetNodeName() types.NodeName { … }

func (kvh *kubeletVolumeHost) GetEventRecorder() record.EventRecorder { … }

func (kvh *kubeletVolumeHost) GetExec(pluginName string) utilexec.Interface { … }