fluence

package
v1.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 5, 2024 License: Apache-2.0 Imports: 23 Imported by: 0

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

View Source
const Name = "Fluence"

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

Variables

This section is empty.

Functions

func New

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL