- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 66 for volume_plugin (0.24 sec)
-
cmd/kube-controller-manager/app/plugins.go
// initialization code for kubelet really, really need a through refactor. func ProbeAttachableVolumePlugins(logger klog.Logger) ([]volume.VolumePlugin, error) { var err error allPlugins := []volume.VolumePlugin{} allPlugins, err = appendAttachableLegacyProviderVolumes(logger, allPlugins, utilfeature.DefaultFeatureGate) if err != nil { return allPlugins, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 15:17:15 UTC 2024 - 6.1K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/operation_generator.go
volumePluginName := unknownVolumePlugin volumePlugin, err := og.volumePluginMgr.FindPluginBySpec(volumeToMount.VolumeSpec) if err == nil && volumePlugin != nil { volumePluginName = volumePlugin.GetPluginName() } mountVolumeFunc := func() volumetypes.OperationContext { // Get mounter plugin volumePlugin, err := og.volumePluginMgr.FindPluginBySpec(volumeToMount.VolumeSpec)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 101.4K bytes - Viewed (0) -
pkg/volume/testing/volume_host.go
func NewFakeVolumeHost(t *testing.T, rootDir string, kubeClient clientset.Interface, plugins []VolumePlugin) FakeVolumeHost { return newFakeVolumeHost(t, rootDir, kubeClient, plugins, nil, "", nil, nil) } func NewFakeVolumeHostWithCloudProvider(t *testing.T, rootDir string, kubeClient clientset.Interface, plugins []VolumePlugin) FakeVolumeHost { return newFakeVolumeHost(t, rootDir, kubeClient, plugins, nil, "", nil, nil) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 16.5K bytes - Viewed (0) -
pkg/volume/secret/secret.go
func ProbeVolumePlugins() []volume.VolumePlugin { return []volume.VolumePlugin{&secretPlugin{}} } const ( secretPluginName = "kubernetes.io/secret" ) // secretPlugin implements the VolumePlugin interface. type secretPlugin struct { host volume.VolumeHost getSecret func(namespace, name string) (*v1.Secret, error) } var _ volume.VolumePlugin = &secretPlugin{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 9.1K bytes - Viewed (0) -
cmd/kubelet/app/plugins.go
"k8s.io/kubernetes/pkg/volume/secret" ) // ProbeVolumePlugins collects all volume plugins into an easy to use list. func ProbeVolumePlugins(featureGate featuregate.FeatureGate) ([]volume.VolumePlugin, error) { allPlugins := []volume.VolumePlugin{} // The list of plugins to probe is decided by the kubelet binary, not // by dynamic linking or other "magic". Plugins will be analyzed and // initialized later. //
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 13 21:09:52 UTC 2024 - 3.1K bytes - Viewed (0) -
pkg/volume/util/util.go
func GetUniqueVolumeNameFromSpec( volumePlugin volume.VolumePlugin, volumeSpec *volume.Spec) (v1.UniqueVolumeName, error) { if volumePlugin == nil { return "", fmt.Errorf( "volumePlugin should not be nil. volumeSpec.Name=%q", volumeSpec.Name()) } volumeName, err := volumePlugin.GetVolumeName(volumeSpec) if err != nil || volumeName == "" { return "", fmt.Errorf(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 12:32:15 UTC 2024 - 28.8K bytes - Viewed (0) -
pkg/volume/downwardapi/downwardapi.go
func ProbeVolumePlugins() []volume.VolumePlugin { return []volume.VolumePlugin{&downwardAPIPlugin{}} } const ( downwardAPIPluginName = "kubernetes.io/downward-api" ) // downwardAPIPlugin implements the VolumePlugin interface. type downwardAPIPlugin struct { host volume.VolumeHost } var _ volume.VolumePlugin = &downwardAPIPlugin{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 10.4K bytes - Viewed (0) -
pkg/volume/plugins_test.go
return nil, nil } func (plugin *testPlugins) ConstructVolumeSpec(volumeName, mountPath string) (ReconstructedVolume, error) { return ReconstructedVolume{}, nil } func newTestPlugin() []VolumePlugin { return []VolumePlugin{&testPlugins{}} } func TestVolumePluginMgrFunc(t *testing.T) { vpm := VolumePluginMgr{} var prober DynamicPluginProber = nil // TODO (#51147) inject mock
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 4.3K bytes - Viewed (0) -
pkg/volume/git_repo/git_repo.go
utilstrings "k8s.io/utils/strings" ) // This is the primary entrypoint for volume plugins. func ProbeVolumePlugins() []volume.VolumePlugin { return []volume.VolumePlugin{&gitRepoPlugin{nil}} } type gitRepoPlugin struct { host volume.VolumeHost } var _ volume.VolumePlugin = &gitRepoPlugin{} func wrappedVolumeSpec() volume.Spec { return volume.Spec{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 8.2K bytes - Viewed (0) -
pkg/kubelet/volumemanager/cache/desired_state_of_world.go
dsw.Lock() defer dsw.Unlock() volumePlugin, err := dsw.volumePluginMgr.FindPluginBySpec(volumeSpec) if err != nil || volumePlugin == nil { return "", fmt.Errorf( "failed to get Plugin from volumeSpec for volume %q err=%v", volumeSpec.Name(), err) } volumePluginName := getVolumePluginNameWithDriver(volumePlugin, volumeSpec) accessMode := getVolumeAccessMode(volumeSpec)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 27.1K bytes - Viewed (0)