- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for NewProvisioner (0.31 sec)
-
pkg/volume/hostpath/host_path.go
return newDeleter(spec, plugin.host) } func (plugin *hostPathPlugin) NewProvisioner(logger klog.Logger, options volume.VolumeOptions) (volume.Provisioner, error) { if !plugin.config.ProvisioningEnabled { return nil, fmt.Errorf("provisioning in volume plugin %q is disabled", plugin.GetPluginName()) } return newProvisioner(options, plugin.host, plugin) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 15.3K bytes - Viewed (0) -
pkg/volume/portworx/portworx.go
volName: spec.Name(), volumeID: spec.PersistentVolume.Spec.PortworxVolume.VolumeID, manager: manager, plugin: plugin, }}, nil } func (plugin *portworxVolumePlugin) NewProvisioner(logger klog.Logger, options volume.VolumeOptions) (volume.Provisioner, error) { return plugin.newProvisionerInternal(options, plugin.util) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 13.6K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/provision_test.go
expectedEvents: []string{"Warning ProvisioningFailed"}, errors: noerrors, test: testSyncClaim, }, { // Provision failure - newProvisioner returns error name: "11-3 - newProvisioner failure", initialVolumes: novolumes, expectedVolumes: novolumes, initialClaims: newClaimArray("claim11-3", "uid11-3", "1Gi", "", v1.ClaimPending, &classGold),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 35.3K bytes - Viewed (0) -
pkg/volume/plugins.go
// used to create volumes for the cluster. type ProvisionableVolumePlugin interface { VolumePlugin // NewProvisioner creates a new volume.Provisioner which knows how to // create PersistentVolumes in accordance with the plugin's underlying // storage provider NewProvisioner(logger klog.Logger, options VolumeOptions) (Provisioner, error) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 16:13:15 UTC 2024 - 38.2K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/framework_test.go
} // Provisioner interfaces func (plugin *mockVolumePlugin) NewProvisioner(logger klog.Logger, options volume.VolumeOptions) (volume.Provisioner, error) { if len(plugin.provisionCalls) > 0 { // mockVolumePlugin directly implements Provisioner interface logger.V(4).Info("Mock plugin NewProvisioner called, returning mock provisioner") plugin.provisionOptions = options return plugin, nil } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 09:54:00 UTC 2023 - 38.3K bytes - Viewed (0) -
pkg/volume/hostpath/host_path_test.go
PersistentVolumeReclaimPolicy: v1.PersistentVolumeReclaimDelete, } logger, _ := ktesting.NewTestContext(t) creator, err := plug.NewProvisioner(logger, options) if err != nil { t.Fatalf("Failed to make a new Provisioner: %v", err) } hostPathCreator, ok := creator.(*hostPathProvisioner) if !ok { t.Fatal("Not a hostPathProvisioner") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 00:37:30 UTC 2023 - 20.5K bytes - Viewed (0) -
pkg/volume/testing/testing.go
func (plugin *FakeVolumePlugin) NewDeleter(logger klog.Logger, spec *volume.Spec) (volume.Deleter, error) { return &FakeDeleter{"/attributesTransferredFromSpec", volume.MetricsNil{}}, nil } func (plugin *FakeVolumePlugin) NewProvisioner(logger klog.Logger, options volume.VolumeOptions) (volume.Provisioner, error) { plugin.Lock() defer plugin.Unlock() plugin.LastProvisionerOptions = options
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 12:32:15 UTC 2024 - 53.3K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller.go
return pluginName, fmt.Errorf("provisioner %q doesn't support mount options", plugin.GetPluginName()) } // Provision the volume provisioner, err := plugin.NewProvisioner(logger, options) if err != nil { strerr := fmt.Sprintf("Failed to create provisioner: %v", err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 89.2K bytes - Viewed (0)