Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for KubeletVolumeHost (0.47 sec)

  1. pkg/kubelet/volume_host.go

    }
    
    // Compile-time check to ensure kubeletVolumeHost implements the VolumeHost interface
    var _ volume.VolumeHost = &kubeletVolumeHost{}
    var _ volume.KubeletVolumeHost = &kubeletVolumeHost{}
    
    func (kvh *kubeletVolumeHost) GetPluginDir(pluginName string) string {
    	return kvh.kubelet.getPluginDir(pluginName)
    }
    
    type kubeletVolumeHost struct {
    	kubelet                   *Kubelet
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 11:00:37 UTC 2024
    - 10K bytes
    - Viewed (0)
  2. pkg/volume/local/local.go

    		return nil, err
    	}
    
    	globalLocalPath, err := plugin.getGlobalLocalPath(spec)
    	if err != nil {
    		return nil, err
    	}
    
    	kvh, ok := plugin.host.(volume.KubeletVolumeHost)
    	if !ok {
    		return nil, fmt.Errorf("plugin volume host does not implement KubeletVolumeHost interface")
    	}
    
    	return &localVolumeMounter{
    		localVolume: &localVolume{
    			pod:             pod,
    			podUID:          pod.UID,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 22.2K bytes
    - Viewed (0)
  3. pkg/volume/csi/csi_plugin.go

    				klog.Error(log("VolumeAttachmentLister not found on AttachDetachVolumeHost"))
    			}
    		}
    		kletHost, ok := host.(volume.KubeletVolumeHost)
    		if ok {
    			p.csiDriverLister = kletHost.CSIDriverLister()
    			if p.csiDriverLister == nil {
    				klog.Error(log("CSIDriverLister not found on KubeletVolumeHost"))
    			}
    			p.serviceAccountTokenGetter = host.GetServiceAccountTokenFunc()
    			if p.serviceAccountTokenGetter == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 29.2K bytes
    - Viewed (0)
  4. pkg/volume/projected/projected.go

    }
    
    const (
    	projectedPluginName = "kubernetes.io/projected"
    )
    
    type projectedPlugin struct {
    	host                      volume.VolumeHost
    	kvHost                    volume.KubeletVolumeHost
    	getSecret                 func(namespace, name string) (*v1.Secret, error)
    	getConfigMap              func(namespace, name string) (*v1.ConfigMap, error)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  5. pkg/volume/fc/fc.go

    		},
    	}
    
    	var mountContext string
    	if utilfeature.DefaultFeatureGate.Enabled(features.SELinuxMountReadWriteOncePod) {
    		kvh, ok := plugin.host.(volume.KubeletVolumeHost)
    		if !ok {
    			return volume.ReconstructedVolume{}, fmt.Errorf("plugin volume host does not implement KubeletVolumeHost interface")
    		}
    		hu := kvh.GetHostUtil()
    		mountContext, err = hu.GetSELinuxMountContext(mountPath)
    		if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 17.4K bytes
    - Viewed (0)
  6. pkg/volume/hostpath/host_path.go

    	if hostPathVolumeSource.Type == nil {
    		*pathType = v1.HostPathUnset
    	} else {
    		pathType = hostPathVolumeSource.Type
    	}
    	kvh, ok := plugin.host.(volume.KubeletVolumeHost)
    	if !ok {
    		return nil, fmt.Errorf("plugin volume host does not implement KubeletVolumeHost interface")
    	}
    	return &hostPathMounter{
    		hostPath:      &hostPath{path: path, pathType: pathType},
    		readOnly:      readOnly,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 15.3K bytes
    - Viewed (0)
  7. pkg/volume/iscsi/iscsi.go

    		},
    	}
    
    	var mountContext string
    	if utilfeature.DefaultFeatureGate.Enabled(features.SELinuxMountReadWriteOncePod) {
    		kvh, ok := plugin.host.(volume.KubeletVolumeHost)
    		if !ok {
    			return volume.ReconstructedVolume{}, fmt.Errorf("plugin volume host does not implement KubeletVolumeHost interface")
    		}
    		hu := kvh.GetHostUtil()
    		mountContext, err = hu.GetSELinuxMountContext(mountPath)
    		if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 23.4K bytes
    - Viewed (0)
  8. pkg/volume/plugins.go

    // to the specific functions they are needed in (instead of using a catch-all
    // VolumeHost interface)
    
    // KubeletVolumeHost is a Kubelet specific interface that plugins can use to access the kubelet.
    type KubeletVolumeHost interface {
    	// SetKubeletError lets plugins set an error on the Kubelet runtime status
    	// that will cause the Kubelet to post NotReady status with the error message provided
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 16:13:15 UTC 2024
    - 38.2K bytes
    - Viewed (0)
  9. pkg/volume/testing/volume_host.go

    	return f.volumeAttachmentLister
    }
    
    func (f *fakeAttachDetachVolumeHost) IsAttachDetachController() bool {
    	return true
    }
    
    type fakeKubeletVolumeHost struct {
    	fakeVolumeHost
    }
    
    var _ KubeletVolumeHost = &fakeKubeletVolumeHost{}
    var _ FakeVolumeHost = &fakeKubeletVolumeHost{}
    
    func NewFakeKubeletVolumeHost(t *testing.T, rootDir string, kubeClient clientset.Interface, plugins []VolumePlugin) *fakeKubeletVolumeHost {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 11 09:02:45 UTC 2024
    - 16.5K bytes
    - Viewed (0)
  10. pkg/volume/util/operationexecutor/operation_generator.go

    		// AttachFileDevice will fail. If kubelet is not containerized, eval it anyway.
    		kvh, ok := og.GetVolumePluginMgr().Host.(volume.KubeletVolumeHost)
    		if !ok {
    			eventErr, detailedErr := volumeToMount.GenerateError("MapVolume type assertion error", fmt.Errorf("volume host does not implement KubeletVolumeHost interface"))
    			return volumetypes.NewOperationContext(eventErr, detailedErr, migrated)
    		}
    		hu := kvh.GetHostUtil()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 101.4K bytes
    - Viewed (0)
Back to top