Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for PostBind (0.17 sec)

  1. pkg/scheduler/apis/config/v1/default_plugins.go

    	defaultPlugins.PreBind = mergePluginSet(logger, defaultPlugins.PreBind, customPlugins.PreBind)
    	defaultPlugins.Bind = mergePluginSet(logger, defaultPlugins.Bind, customPlugins.Bind)
    	defaultPlugins.PostBind = mergePluginSet(logger, defaultPlugins.PostBind, customPlugins.PostBind)
    	return defaultPlugins
    }
    
    type pluginIndex struct {
    	index  int
    	plugin v1.Plugin
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 06:27:01 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  2. pkg/scheduler/metrics/metrics.go

    	Score                       = "Score"
    	ScoreExtensionNormalize     = "ScoreExtensionNormalize"
    	PreBind                     = "PreBind"
    	Bind                        = "Bind"
    	PostBind                    = "PostBind"
    	Reserve                     = "Reserve"
    	Unreserve                   = "Unreserve"
    	Permit                      = "Permit"
    )
    
    // All the histogram based metrics have 1ms as size for the smallest bucket.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 08:22:53 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  3. pkg/scheduler/testing/framework/framework_helpers.go

    	case "Bind":
    		return &plugins.Bind
    	case "Reserve":
    		return &plugins.Reserve
    	case "Permit":
    		return &plugins.Permit
    	case "PreBind":
    		return &plugins.PreBind
    	case "PostBind":
    		return &plugins.PostBind
    	default:
    		return nil
    	}
    }
    
    // BuildNodeInfos build NodeInfo slice from a v1.Node slice
    func BuildNodeInfos(nodes []*v1.Node) []*framework.NodeInfo {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 6.3K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/plugins/dynamicresources/dynamicresources_test.go

    						initialObjects = testCtx.listAll(t)
    						initialObjects = testCtx.updateAPIServer(t, initialObjects, tc.prepare.postbind)
    						testCtx.p.PostBind(testCtx.ctx, testCtx.state, tc.pod, selectedNode.Node().Name)
    						t.Run("postbind", func(t *testing.T) {
    							testCtx.verify(t, tc.want.postbind, initialObjects, nil, nil)
    						})
    					}
    				}
    			} else {
    				initialObjects = testCtx.listAll(t)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 07:57:10 UTC 2024
    - 61.9K bytes
    - Viewed (0)
  5. pkg/scheduler/apis/config/validation/validation.go

    			"reserve":    profile.Plugins.Reserve,
    			"permit":     profile.Plugins.Permit,
    			"preBind":    profile.Plugins.PreBind,
    			"bind":       profile.Plugins.Bind,
    			"postBind":   profile.Plugins.PostBind,
    		}
    
    		pluginsPath := path.Child("plugins")
    		for s, p := range stagesToPluginSet {
    			errs = append(errs, validatePluginSetForInvalidPlugins(
    				pluginsPath.Child(s), apiVersion, p)...)
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 06:27:01 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/runtime/framework.go

    	if !state.ShouldRecordPluginMetrics() {
    		pl.PostBind(ctx, state, pod, nodeName)
    		return
    	}
    	startTime := time.Now()
    	pl.PostBind(ctx, state, pod, nodeName)
    	f.metricsRecorder.ObservePluginDurationAsync(metrics.PostBind, pl.Name(), framework.Success.String(), metrics.SinceInSeconds(startTime))
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 60.9K bytes
    - Viewed (0)
  7. pkg/scheduler/apis/config/types.go

    	// The scheduler call these plugins in order. Scheduler skips the rest of these plugins as soon as one returns success.
    	Bind PluginSet
    
    	// PostBind is a list of plugins that should be invoked after a pod is successfully bound.
    	PostBind PluginSet
    
    	// MultiPoint is a simplified config field for enabling plugins for all valid extension points
    	MultiPoint PluginSet
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 19 18:47:23 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/runtime/framework_test.go

    			wantExtensionPoint: "Bind",
    			wantStatus:         framework.Success,
    		},
    		{
    			name:               "PostBind - Success",
    			action:             func(f framework.Framework) { f.RunPostBindPlugins(context.Background(), state, pod, "") },
    			wantExtensionPoint: "PostBind",
    			wantStatus:         framework.Success,
    		},
    		{
    			name:               "Permit - Success",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 103K bytes
    - Viewed (0)
  9. pkg/scheduler/framework/interface.go

    	PreBind(ctx context.Context, state *CycleState, p *v1.Pod, nodeName string) *Status
    }
    
    // PostBindPlugin is an interface that must be implemented by "PostBind" plugins.
    // These plugins are called after a pod is successfully bound to a node.
    type PostBindPlugin interface {
    	Plugin
    	// PostBind is called after a pod is successfully bound. These plugins are
    	// informational. A common application of this extension point is for cleaning
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 35.4K bytes
    - Viewed (0)
  10. pkg/scheduler/apis/config/v1/defaults.go

    	if p == nil {
    		return nil
    	}
    	extensions := []configv1.PluginSet{
    		p.MultiPoint,
    		p.PreFilter,
    		p.Filter,
    		p.PostFilter,
    		p.Reserve,
    		p.PreScore,
    		p.Score,
    		p.PreBind,
    		p.Bind,
    		p.PostBind,
    		p.Permit,
    		p.PreEnqueue,
    		p.QueueSort,
    	}
    	n := sets.New[string]()
    	for _, e := range extensions {
    		for _, pg := range e.Enabled {
    			n.Insert(pg.Name)
    		}
    	}
    	return sets.List(n)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 13 07:42:19 UTC 2023
    - 7.2K bytes
    - Viewed (0)
Back to top