fluence

README

Overview

Project to manage Flux tasks needed to standardize kubernetes HPC scheduling interfaces

Installing the chart

More detail will be added here about installing the chart. You will be using the install-as-a-second-scheduler charts. Fluence-specific values are detailed below.

Fluence specific values

In values.yaml it is possible to customize the container image, already defaulted to the latest release, and the allocation policy used by the scheduler. Most common options are:

• lonode: choose the nodes with lower ID first. Can be compared to packing
• low: choose cores with lowest IDs from multiple nodes. Can be compared to spread process-to-resource placement

Maturity Level

• Sample (for demonstrating and inspiring purpose)
• Alpha (used in companies for pilot projects)
• Beta (used in companies and developed actively)
• Stable (used in companies for production workloads)

Documentation

Index

• Constants
• func New(_ runtime.Object, handle framework.Handle) (framework.Plugin, error)
• type Fluence
  • func (f *Fluence) AskFlux(ctx context.Context, pod *v1.Pod, count int) (string, error)
  • func (f *Fluence) Filter(ctx context.Context, cycleState *framework.CycleState, pod *v1.Pod, ...) *framework.Status
  • func (f *Fluence) Less(podInfo1, podInfo2 *framework.QueuedPodInfo) bool
  • func (f *Fluence) Name() string
  • func (f *Fluence) PreFilter(ctx context.Context, state *framework.CycleState, pod *v1.Pod) (*framework.PreFilterResult, *framework.Status)
  • func (f *Fluence) PreFilterExtensions() framework.PreFilterExtensions

Constants

const Name = "Fluence"

Name is the name of the plugin used in the Registry and configurations.

Functions

func New

func New(_ runtime.Object, handle framework.Handle) (framework.Plugin, error)

initialize and return a new Flux Plugin Note from vsoch: seems analogous to: https://github.com/kubernetes-sigs/scheduler-plugins/blob/master/pkg/coscheduling/coscheduling.go#L63

Types

type Fluence

type Fluence struct {
	// contains filtered or unexported fields
}

func (*Fluence) AskFlux

func (f *Fluence) AskFlux(ctx context.Context, pod *v1.Pod, count int) (string, error)

func (*Fluence) Filter

func (f *Fluence) Filter(ctx context.Context, cycleState *framework.CycleState, pod *v1.Pod, nodeInfo *framework.NodeInfo) *framework.Status

func (*Fluence) Less

func (f *Fluence) Less(podInfo1, podInfo2 *framework.QueuedPodInfo) bool

Less is used to sort pods in the scheduling queue in the following order. 1. Compare the priorities of Pods. 2. Compare the initialization timestamps of PodGroups or Pods. 3. Compare the keys of PodGroups/Pods: <namespace>/<podname>.

func (*Fluence) Name

func (f *Fluence) Name() string

func (*Fluence) PreFilter

func (f *Fluence) PreFilter(ctx context.Context, state *framework.CycleState, pod *v1.Pod) (*framework.PreFilterResult, *framework.Status)

func (*Fluence) PreFilterExtensions

func (f *Fluence) PreFilterExtensions() framework.PreFilterExtensions