- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 66 for volume_plugin (0.27 sec)
-
pkg/volume/csi/csi_plugin.go
} // ProbeVolumePlugins returns implemented plugins func ProbeVolumePlugins() []volume.VolumePlugin { p := &csiPlugin{ host: nil, } return []volume.VolumePlugin{p} } // volume.VolumePlugin methods var _ volume.VolumePlugin = &csiPlugin{} // RegistrationHandler is the handler which is fed to the pluginwatcher API. type RegistrationHandler struct { }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 29.2K bytes - Viewed (0) -
pkg/volume/iscsi/iscsi.go
) // ProbeVolumePlugins is the primary entrypoint for volume plugins. func ProbeVolumePlugins() []volume.VolumePlugin { return []volume.VolumePlugin{&iscsiPlugin{}} } type iscsiPlugin struct { host volume.VolumeHost targetLocks keymutex.KeyMutex } var _ volume.VolumePlugin = &iscsiPlugin{} var _ volume.PersistentVolumePlugin = &iscsiPlugin{} var _ volume.BlockVolumePlugin = &iscsiPlugin{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 23.4K bytes - Viewed (0) -
pkg/volume/local/local.go
) // ProbeVolumePlugins is the primary entrypoint for volume plugins. func ProbeVolumePlugins() []volume.VolumePlugin { return []volume.VolumePlugin{&localVolumePlugin{}} } type localVolumePlugin struct { host volume.VolumeHost volumeLocks keymutex.KeyMutex recorder record.EventRecorder } var _ volume.VolumePlugin = &localVolumePlugin{} var _ volume.PersistentVolumePlugin = &localVolumePlugin{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 22.2K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/testing/testvolumespec.go
ret[nodeName] = make([]string, len(volumeList)) copy(ret[nodeName], volumeList) } return ret } func CreateTestPlugin() []volume.VolumePlugin { attachedVolumes := make(map[string][]string) detachedVolumes := make(map[string][]string) return []volume.VolumePlugin{&TestPlugin{ ErrorEncountered: false, attachedVolumeMap: attachedVolumes, detachedVolumeMap: detachedVolumes,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 17 08:48:30 UTC 2023 - 16.5K bytes - Viewed (0) -
pkg/kubelet/runonce_test.go
plug := &volumetest.FakeVolumePlugin{PluginName: "fake", Host: nil} kb.volumePluginMgr, err = NewInitializedVolumePluginMgr(kb, fakeSecretManager, fakeConfigMapManager, nil, clusterTrustBundleManager, []volume.VolumePlugin{plug}, nil /* prober */) if err != nil { t.Fatalf("failed to initialize VolumePluginMgr: %v", err) } kb.volumeManager = volumemanager.NewVolumeManager( true, kb.nodeName, kb.podManager,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 06:59:54 UTC 2024 - 6.5K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/node_expander.go
msg := ne.vmt.GenerateErrorDetailed("MountVolume.NodeExpandVolume failed to mark node expansion in progress: %v", err) klog.Errorf(msg.Error()) return false, err, testResponseData{} } } _, resizeErr := ne.volumePlugin.NodeExpand(ne.pluginResizeOpts) if resizeErr != nil { if volumetypes.IsOperationFinishedError(resizeErr) { var markFailedError error ne.pvc, markFailedError = util.MarkNodeExpansionFailed(ne.pvc, ne.kubeClient)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 17 19:30:35 UTC 2023 - 5.9K bytes - Viewed (0) -
pkg/controller/volume/expand/expand_controller_test.go
} if tc.pvc != nil { informerFactory.Core().V1().PersistentVolumeClaims().Informer().GetIndexer().Add(pvc) } allPlugins := []volume.VolumePlugin{} translator := csitrans.New() expc, err := NewExpandController(tCtx, fakeKubeClient, pvcInformer, allPlugins, translator, csimigration.NewPluginManager(translator, utilfeature.DefaultFeatureGate)) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 7.9K bytes - Viewed (0) -
pkg/volume/nfs/nfs_test.go
tmpDir, err := utiltesting.MkTmpdir("nfs_test") if err != nil { t.Fatalf("error creating temp dir: %v", err) } defer os.RemoveAll(tmpDir) plugMgr := volume.VolumePluginMgr{} plugMgr.InitPlugins([]volume.VolumePlugin{&nfsPlugin{nil, volume.VolumeConfig{}}}, nil, volumetest.NewFakeVolumeHost(t, tmpDir, nil, nil))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 01 15:56:32 UTC 2022 - 9K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller_test.go
) func createADC(t testing.TB, tCtx ktesting.TContext, fakeKubeClient *fake.Clientset, informerFactory informers.SharedInformerFactory, plugins []volume.VolumePlugin) *attachDetachController { adcObj, err := NewAttachDetachController( tCtx, fakeKubeClient, informerFactory.Core().V1().Pods(), informerFactory.Core().V1().Nodes(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 24.2K bytes - Viewed (0) -
pkg/volume/local/local_test.go
testPodPath = "pods/poduid/volumeDevices/kubernetes.io~local-volume" testBlockFormattingToFSGlobalPath = "plugins/kubernetes.io/local-volume/mounts/pvA" ) func getPlugin(t *testing.T) (string, volume.VolumePlugin) { tmpDir, err := utiltesting.MkTmpdir("localVolumeTest") if err != nil { t.Fatalf("can't make a temp dir: %v", err) } plugMgr := volume.VolumePluginMgr{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 08 10:53:39 UTC 2023 - 22.5K bytes - Viewed (0)