Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 826 for Unreserve (0.14 sec)

  1. pkg/scheduler/framework/plugins/examples/stateful/stateful.go

    	return nil
    }
    
    // Unreserve is the function invoked by the framework when any error happens
    // during "reserve" extension point or later. In this example, the Unreserve
    // method loses its reference to the string slice, allowing it to be garbage
    // collected, and thereby "unallocating" the reserved resources.
    func (mp *MultipointExample) Unreserve(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 09 03:43:17 UTC 2023
    - 3.3K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/examples/multipoint/multipoint.go

    	}
    	if pod.Name == "my-test-pod" {
    		state.Write(framework.StateKey(pod.Name), &stateData{data: "never bind"})
    	}
    	return nil
    }
    
    // Unreserve is the function invoked by the framework when any error happens
    // during "reserve" extension point or later.
    func (mc CommunicatingPlugin) Unreserve(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) {
    	if pod.Name == "my-test-pod" {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 09 03:43:17 UTC 2023
    - 3K bytes
    - Viewed (0)
  3. pkg/scheduler/testing/framework/fake_plugins.go

    		}, nil
    	}
    }
    
    // FakeReservePlugin is a test reserve plugin.
    type FakeReservePlugin struct {
    	Status *framework.Status
    }
    
    // Name returns name of the plugin.
    func (pl *FakeReservePlugin) Name() string {
    	return "FakeReserve"
    }
    
    // Reserve invoked at the Reserve extension point.
    func (pl *FakeReservePlugin) Reserve(_ context.Context, _ *framework.CycleState, _ *v1.Pod, _ string) *framework.Status {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 19:07:19 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  4. pkg/scheduler/metrics/metrics.go

    	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.
    var (
    	scheduleAttempts = metrics.NewCounterVec(
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 08:22:53 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/plugins/dynamicresources/dynamicresources_test.go

    					testCtx.p.Unreserve(testCtx.ctx, testCtx.state, tc.pod, selectedNode.Node().Name)
    					t.Run("unreserve", func(t *testing.T) {
    						testCtx.verify(t, tc.want.unreserve, initialObjects, nil, status)
    					})
    				} else {
    					if tc.want.unreserveBeforePreBind != nil {
    						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)
  6. pkg/scheduler/framework/interface.go

    // rejection of the pod.
    type ReservePlugin interface {
    	Plugin
    	// Reserve is called by the scheduling framework when the scheduler cache is
    	// updated. If this method returns a failed Status, the scheduler will call
    	// the Unreserve method for all enabled ReservePlugins.
    	Reserve(ctx context.Context, state *CycleState, p *v1.Pod, nodeName string) *Status
    	// Unreserve is called by the scheduling framework when a reserved pod was
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 35.4K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/runtime/framework.go

    	defer func() {
    		metrics.FrameworkExtensionPointDuration.WithLabelValues(metrics.Unreserve, framework.Success.String(), f.profileName).Observe(metrics.SinceInSeconds(startTime))
    	}()
    	// Execute the Unreserve operation of each reserve plugin in the
    	// *reverse* order in which the Reserve operation was executed.
    	logger := klog.FromContext(ctx)
    	verboseLogs := logger.V(4).Enabled()
    	if verboseLogs {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 60.9K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/plugins/volumebinding/volume_binding.go

    	return nil
    }
    
    // Unreserve clears assumed PV and PVC cache.
    // It's idempotent, and does nothing if no cache found for the given pod.
    func (pl *VolumeBinding) Unreserve(ctx context.Context, cs *framework.CycleState, pod *v1.Pod, nodeName string) {
    	s, err := getStateData(cs)
    	if err != nil {
    		return
    	}
    	// we don't need to hold the lock as only one node may be unreserved
    	podVolumes, ok := s.podVolumesByNode[nodeName]
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 16 14:13:06 UTC 2024
    - 16.4K bytes
    - Viewed (0)
  9. pkg/scheduler/framework/plugins/dynamicresources/dynamicresources.go

    // that the pod should get bound to this node. Because Reserve did not actually
    // reserve claims, we need to do it now. For claims with the builtin controller,
    // we also handle the allocation.
    //
    // If anything fails, we return an error and
    // the pod will have to go into the backoff queue. The scheduler will call
    // Unreserve as part of the error handling.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 30 15:22:37 UTC 2024
    - 75.9K bytes
    - Viewed (0)
  10. pkg/scheduler/framework/runtime/framework_test.go

    			wantStatus:         framework.Success,
    		},
    		{
    			name:               "Reserve - Success",
    			action:             func(f framework.Framework) { f.RunReservePluginsReserve(context.Background(), state, pod, "") },
    			wantExtensionPoint: "Reserve",
    			wantStatus:         framework.Success,
    		},
    		{
    			name:               "Unreserve - Success",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 103K bytes
    - Viewed (0)
Back to top