- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for StateKey (0.33 sec)
-
pkg/scheduler/framework/cycle_state.go
// clone should make shallow copies for members (e.g., slices or maps) that are not // impacted by PreFilter's optional AddPod/RemovePod methods. Clone() StateData } // StateKey is the type of keys stored in CycleState. type StateKey string // CycleState provides a mechanism for plugins to store and retrieve arbitrary data. // StateData stored by one plugin can be read, altered, or deleted by another plugin.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 18 06:48:20 UTC 2023 - 4K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/examples/multipoint/multipoint.go
if pod == nil { return framework.NewStatus(framework.Error, "pod cannot be nil") } 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.
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/framework/plugins/volumebinding/volume_binding.go
"k8s.io/kubernetes/pkg/scheduler/framework/plugins/feature" "k8s.io/kubernetes/pkg/scheduler/framework/plugins/helper" "k8s.io/kubernetes/pkg/scheduler/framework/plugins/names" ) const ( stateKey framework.StateKey = Name maxUtilization = 100 ) // the state is initialized in PreFilter phase. because we save the pointer in // framework.CycleState, in the later phases we don't need to call Write method
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/cycle_state_test.go
import ( "fmt" "testing" ) type fakeData struct { data string } func (f *fakeData) Clone() StateData { copy := &fakeData{ data: f.data, } return copy } var key StateKey = "fakedata_key" // createCycleStateWithFakeData creates *CycleState with fakeData. // The given data is used in stored fakeData. func createCycleStateWithFakeData(data string, recordPluginMetrics bool) *CycleState {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 14 15:26:20 UTC 2022 - 3.9K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumezone/volume_zone.go
var _ framework.EnqueueExtensions = &VolumeZone{} const ( // Name is the name of the plugin used in the plugin registry and configurations. Name = names.VolumeZone preFilterStateKey framework.StateKey = "PreFilter" + Name // ErrReasonConflict is used for NoVolumeZoneConflict predicate error. ErrReasonConflict = "node(s) had no available volume zone" ) // pvTopology holds the value of a pv's topologyLabel
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:13:06 UTC 2024 - 10.9K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/dynamicresources/dynamicresources.go
"k8s.io/kubernetes/pkg/scheduler/util/assumecache" "k8s.io/utils/ptr" ) const ( // Name is the name of the plugin used in Registry and configurations. Name = names.DynamicResources stateKey framework.StateKey = Name // generatedFromIndex is the lookup name for the index function // which indexes by other resource which generated the parameters object. generatedFromIndex = "generated-from-index" )
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/interface.go
// activated (i.e., moved to activeQ) in two phases: // - end of a scheduling cycle if it succeeds (will be cleared from `PodsToActivate` if activated) // - end of a binding cycle if it succeeds var PodsToActivateKey StateKey = "kubernetes.io/pods-to-activate" // PodsToActivate stores pods to be activated. type PodsToActivate struct { sync.Mutex // Map is keyed with namespaced pod name, and valued with the pod.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 35.4K bytes - Viewed (0)