Documentation
¶
Index ¶
- Constants
- type GPUFit
- func (s *GPUFit) Filter(ctx context.Context, state *framework.CycleState, pod *v1.Pod, ...) *framework.Status
- func (s *GPUFit) Name() string
- func (s *GPUFit) PostBind(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string)
- func (s *GPUFit) PreFilter(ctx context.Context, state *framework.CycleState, pod *v1.Pod) (*framework.PreFilterResult, *framework.Status)
- func (s *GPUFit) PreFilterExtensions() framework.PreFilterExtensions
- func (s *GPUFit) Reserve(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) *framework.Status
- func (s *GPUFit) Score(ctx context.Context, state *framework.CycleState, pod *v1.Pod, ...) (int64, *framework.Status)
- func (s *GPUFit) ScoreExtensions() framework.ScoreExtensions
- func (s *GPUFit) Unreserve(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string)
- type GPUSchedulingStateData
- type PluginFactoryFunc
Constants ¶
View Source
const CycleStateAllocateRequest = "allocateRequest"
View Source
const CycleStateGPUSchedulingResult = "gpuSchedulingResult"
View Source
const Name = "GPUResourcesFit"
View Source
const SchedulerSimulationKey = "schedulerSimulation"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GPUFit ¶
type GPUFit struct {
// contains filtered or unexported fields
}
func (*GPUFit) PreFilterExtensions ¶
func (s *GPUFit) PreFilterExtensions() framework.PreFilterExtensions
func (*GPUFit) ScoreExtensions ¶
func (s *GPUFit) ScoreExtensions() framework.ScoreExtensions
type GPUSchedulingStateData ¶
type GPUSchedulingStateData struct {
// PreFilter stage compose valid nodes and their GPUs
NodeGPUs map[string][]tfv1.GPU
// Score stage compose each node's each GPU's score,
// node store is sum of GPU score
ValidNodeGPUScore map[string]map[string]int
// In Reserve stage, bind GPUs to pod, update allocator cache
// In PostBind stage, fetch final GPUs call Pod patch API to update annotation
FinalGPUs []string
}
func (*GPUSchedulingStateData) Clone ¶
func (p *GPUSchedulingStateData) Clone() framework.StateData
type PluginFactoryFunc ¶
type PluginFactoryFunc func(ctx context.Context, obj runtime.Object, handle framework.Handle) (framework.Plugin, error)
func NewWithDeps ¶
func NewWithDeps(allocator *gpuallocator.GpuAllocator, client client.Client) PluginFactoryFunc
Click to show internal directories.
Click to hide internal directories.