generator

Documentation

Index

• Constants
• func Cleanup(ctx context.Context, c client.Client)
• func Generate(ctx context.Context, c client.Client, cSets []CohortSet) error
• type CohortSet
  • func LoadConfig(mappingFile string) ([]CohortSet, error)
• type QueuesSet
• type WorkloadTemplate
• type WorkloadsSet

Constants

const (
	RunningTimeLabel = "kueue.x-k8s.io/performance-scheduler-running-ms"
	ClassLabel       = "kueue.x-k8s.io/performance-scheduler-class"
	CleanupLabel     = "kueue.x-k8s.io/performance-scheduler-cleanup"
)

Functions

func Cleanup

func Cleanup(ctx context.Context, c client.Client)

func Generate

func Generate(ctx context.Context, c client.Client, cSets []CohortSet) error

Types

type CohortSet

type CohortSet struct {
	ClassName  string      `json:"className"`
	Count      int         `json:"count"`
	QueuesSets []QueuesSet `json:"queuesSets"`
}

func LoadConfig

func LoadConfig(mappingFile string) ([]CohortSet, error)

type QueuesSet

type QueuesSet struct {
	ClassName           string                 `json:"className"`
	Count               int                    `json:"count"`
	NominalQuota        string                 `json:"nominalQuota"`
	BorrowingLimit      string                 `json:"borrowingLimit"`
	ReclaimWithinCohort kueue.PreemptionPolicy `json:"reclaimWithinCohort"`
	WithinClusterQueue  kueue.PreemptionPolicy `json:"withinClusterQueue"`
	WorkloadsSets       []WorkloadsSet         `json:"workloadsSets"`
}

type WorkloadTemplate

type WorkloadTemplate struct {
	ClassName string `json:"className"`
	RuntimeMs uint   `json:"runtimeMs"`
	Priority  int32  `json:"priority"`
	Request   string `json:"request"`
}

type WorkloadsSet

type WorkloadsSet struct {
	Count              int                `json:"count"`
	CreationIntervalMs uint               `json:"creationIntervalMs"`
	Workloads          []WorkloadTemplate `json:"workloads"`
}