controllerutils

package

v0.1.9 Latest Latest Go to latest Published: Sep 5, 2025 License: Apache-2.0 Imports: 17 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/silogen/kaiwo

Links

Open Source Insights

Documentation ¶

Index ¶

func CleanAMDGPUName(gpuID string) string
func CompareClusterQueues(a, b kueuev1beta1.ClusterQueue) bool
func ComparePriorityClasses(a, b kueuev1beta1.WorkloadPriorityClass) bool
func CompareResourceFlavors(a, b kueuev1beta1.ResourceFlavor) bool
func CompareTopologies(a, b kueuev1alpha1.Topology) bool
func ConvertKaiwoToKueueClusterQueue(kaiwoQueue kaiwo.ClusterQueue) kueuev1beta1.ClusterQueue
func ConvertKaiwoToKueueResourceFlavor(kaiwoFlavor kaiwo.ResourceFlavorSpec) kueuev1beta1.ResourceFlavor
func ConvertKaiwoToKueueResourceFlavors(kaiwoFlavors []kaiwo.ResourceFlavorSpec) []kueuev1beta1.ResourceFlavor
func ConvertKaiwoToKueueSpec(in kaiwo.ClusterQueueSpec) kueuev1beta1.ClusterQueueSpec
func ConvertKaiwoToKueueTopologies(kaiwoTopologies []kaiwo.Topology) []kueuev1alpha1.Topology
func ConvertKaiwoToKueueTopology(kaiwoTopology kaiwo.Topology) kueuev1alpha1.Topology
func CreateClusterQueue(nodePoolResources map[string]kueuev1beta1.FlavorQuotas, name string, ...) kaiwo.ClusterQueue
func CreateDefaultResourceFlavors(ctx context.Context, c client.Client) ([]kaiwo.ResourceFlavorSpec, map[string]kueuev1beta1.FlavorQuotas, error)
func CreateDefaultTopology(ctx context.Context, c client.Client) ([]kaiwo.Topology, error)
func CreateLocalQueue(ctx context.Context, c client.Client, name string, namespace string) error
func EnsureNamespaceKueueManaged(ctx context.Context, k8sClient client.Client, namespaceName string) error
func FindFlavor(flavors []kueuev1beta1.ResourceFlavor, name string) (kueuev1beta1.ResourceFlavor, bool)
func FindTopology(topologies []kueuev1alpha1.Topology, name string) (kueuev1alpha1.Topology, bool)
func LabelNode(ctx context.Context, c client.Client, nodeName, key, value string) error
func RemoveDuplicateResourceFlavors(flavors []kaiwo.ResourceFlavorSpec) []kaiwo.ResourceFlavorSpec
func TaintNode(ctx context.Context, client client.Client, nodeName string, taint corev1.Taint) error
type NodeResourceInfo
- func GetNodeResources(ctx context.Context, c client.Client) []NodeResourceInfo

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func CleanAMDGPUName ¶ added in v0.1.6

func CleanAMDGPUName(gpuID string) string

func CompareClusterQueues ¶

func CompareClusterQueues(a, b kueuev1beta1.ClusterQueue) bool

func ComparePriorityClasses ¶

func ComparePriorityClasses(a, b kueuev1beta1.WorkloadPriorityClass) bool

func CompareResourceFlavors ¶

func CompareResourceFlavors(a, b kueuev1beta1.ResourceFlavor) bool

func CompareTopologies ¶ added in v0.1.6

func CompareTopologies(a, b kueuev1alpha1.Topology) bool

func ConvertKaiwoToKueueClusterQueue ¶

func ConvertKaiwoToKueueClusterQueue(kaiwoQueue kaiwo.ClusterQueue) kueuev1beta1.ClusterQueue

func ConvertKaiwoToKueueResourceFlavor ¶

func ConvertKaiwoToKueueResourceFlavor(kaiwoFlavor kaiwo.ResourceFlavorSpec) kueuev1beta1.ResourceFlavor

func ConvertKaiwoToKueueResourceFlavors ¶

func ConvertKaiwoToKueueResourceFlavors(kaiwoFlavors []kaiwo.ResourceFlavorSpec) []kueuev1beta1.ResourceFlavor

func ConvertKaiwoToKueueSpec ¶ added in v0.1.6

func ConvertKaiwoToKueueSpec(in kaiwo.ClusterQueueSpec) kueuev1beta1.ClusterQueueSpec

ConvertKaiwoToKueueSpec converts from Kaiwo's simplified ClusterQueueSpec to the actual Kueue version

func ConvertKaiwoToKueueTopologies ¶ added in v0.1.6

func ConvertKaiwoToKueueTopologies(kaiwoTopologies []kaiwo.Topology) []kueuev1alpha1.Topology

func ConvertKaiwoToKueueTopology ¶ added in v0.1.6

func ConvertKaiwoToKueueTopology(kaiwoTopology kaiwo.Topology) kueuev1alpha1.Topology

func CreateClusterQueue ¶

func CreateClusterQueue(nodePoolResources map[string]kueuev1beta1.FlavorQuotas, name string, cohort string) kaiwo.ClusterQueue

func CreateDefaultResourceFlavors ¶

func CreateDefaultResourceFlavors(ctx context.Context, c client.Client) ([]kaiwo.ResourceFlavorSpec, map[string]kueuev1beta1.FlavorQuotas, error)

func CreateDefaultTopology ¶ added in v0.1.6

func CreateDefaultTopology(ctx context.Context, c client.Client) ([]kaiwo.Topology, error)

func CreateLocalQueue ¶

func CreateLocalQueue(ctx context.Context, c client.Client, name string, namespace string) error

CreateLocalQueue creates a LocalQueue in the given namespace.

func EnsureNamespaceKueueManaged ¶

func EnsureNamespaceKueueManaged(ctx context.Context, k8sClient client.Client, namespaceName string) error

func FindFlavor ¶

func FindFlavor(flavors []kueuev1beta1.ResourceFlavor, name string) (kueuev1beta1.ResourceFlavor, bool)

func FindTopology ¶ added in v0.1.6

func FindTopology(topologies []kueuev1alpha1.Topology, name string) (kueuev1alpha1.Topology, bool)

func LabelNode ¶

func LabelNode(ctx context.Context, c client.Client, nodeName, key, value string) error

func RemoveDuplicateResourceFlavors ¶

func RemoveDuplicateResourceFlavors(flavors []kaiwo.ResourceFlavorSpec) []kaiwo.ResourceFlavorSpec

func TaintNode ¶

func TaintNode(ctx context.Context, client client.Client, nodeName string, taint corev1.Taint) error

Types ¶

type NodeResourceInfo ¶

type NodeResourceInfo struct {
	Name          string
	CPU           int
	Memory        int
	Labels        map[string]string
	Unschedulable bool
}

func GetNodeResources ¶

func GetNodeResources(ctx context.Context, c client.Client) []NodeResourceInfo

Source Files ¶

View all Source files

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