- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for NewFlexVolumePlugin (0.28 sec)
-
pkg/volume/flexvolume/plugin.go
// PluginFactory create flex volume plugin type PluginFactory interface { NewFlexVolumePlugin(pluginDir, driverName string, runner exec.Interface) (volume.VolumePlugin, error) } type pluginFactory struct{} func (pluginFactory) NewFlexVolumePlugin(pluginDir, name string, runner exec.Interface) (volume.VolumePlugin, error) { execPath := filepath.Join(pluginDir, name)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 9.7K bytes - Viewed (0) -
pkg/volume/flexvolume/probe.go
probeEvent := volume.ProbeEvent{ Op: op, } if op == volume.ProbeAddOrUpdate { plugin, pluginErr := prober.factory.NewFlexVolumePlugin(prober.pluginDir, driverDirName, prober.runner) if pluginErr != nil { pluginErr = fmt.Errorf( "error creating Flexvolume plugin from directory %s, skipping. Error: %s", driverDirName, pluginErr)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 28 11:14:00 UTC 2023 - 9K bytes - Viewed (0) -
pkg/volume/flexvolume/probe_test.go
} // Fake Flexvolume plugin type fakePluginFactory struct { errorDriver string // the name of the driver in error } var _ PluginFactory = fakePluginFactory{} func (m fakePluginFactory) NewFlexVolumePlugin(_, driverName string, _ exec.Interface) (volume.VolumePlugin, error) { if driverName == m.errorDriver { return nil, fmt.Errorf("Flexvolume plugin error") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 28 11:14:00 UTC 2023 - 10.5K bytes - Viewed (0)