- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 826 for Unreserve (0.14 sec)
-
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) -
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) -
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) -
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) -
pkg/scheduler/framework/plugins/dynamicresources/dynamicresources_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 07:57:10 UTC 2024 - 61.9K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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)