Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for NewProvisioner (0.2 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
Back to top