Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for pluginFactory (0.13 sec)

  1. pkg/volume/flexvolume/plugin.go

    var _ volume.DeviceMountableVolumePlugin = &flexVolumeAttachablePlugin{}
    
    // 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) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  2. pkg/scheduler/scheduler_test.go

    	testingclock "k8s.io/utils/clock/testing"
    	"k8s.io/utils/ptr"
    )
    
    func TestSchedulerCreation(t *testing.T) {
    	invalidRegistry := map[string]frameworkruntime.PluginFactory{
    		defaultbinder.Name: defaultbinder.New,
    	}
    	validRegistry := map[string]frameworkruntime.PluginFactory{
    		"Foo": defaultbinder.New,
    	}
    	cases := []struct {
    		name          string
    		opts          []Option
    		wantErr       string
    		wantProfiles  []string
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 42K bytes
    - Viewed (0)
  3. cmd/kube-scheduler/app/server.go

    // hence there are no references to it from the kubernetes scheduler code base.
    func WithPlugin(name string, factory runtime.PluginFactory) Option {
    	return func(registry runtime.Registry) error {
    		return registry.Register(name, factory)
    	}
    }
    
    // Setup creates a completed config and a scheduler based on the command args and options
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 19:11:24 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  4. pkg/scheduler/schedule_one_test.go

    	return f.isPrioritizer
    }
    
    func (f *fakeExtender) IsFilter() bool {
    	return f.isFilter
    }
    
    type falseMapPlugin struct{}
    
    func newFalseMapPlugin() frameworkruntime.PluginFactory {
    	return func(_ context.Context, _ runtime.Object, _ framework.Handle) (framework.Plugin, error) {
    		return &falseMapPlugin{}, nil
    	}
    }
    
    func (pl *falseMapPlugin) Name() string {
    	return "FalseMap"
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 128.1K bytes
    - Viewed (0)
Back to top