Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for StateKey (0.33 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
Back to top