utils

package

v0.1.0 Latest Latest Go to latest Published: Sep 18, 2025 License: Apache-2.0 Imports: 18 Imported by: 0

Details

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

Repository

github.com/CoHDI/composable-resource-operator

Links

Open Source Insights

Documentation ¶

Index ¶

func CheckGPUVisible(ctx context.Context, client client.Client, clientset *kubernetes.Clientset, ...) (bool, error)
func CheckNoGPULoads(ctx context.Context, client client.Client, clientset *kubernetes.Clientset, ...) error
func CheckNodeCapacitySufficient(ctx context.Context, client client.Client, nodeName string, ...) (bool, error)
func CheckNodeExisted(ctx context.Context, client client.Client, nodeName string) error
func ContainsString(slice []string, s string) bool
func CreateDeviceTaint(ctx context.Context, client client.Client, ...) error
func DrainGPU(ctx context.Context, client client.Client, clientset *kubernetes.Clientset, ...) error
func GenerateComposableResourceName(typeName string) string
func GetAllNodes(ctx context.Context, client client.Client) (*corev1.NodeList, error)
func RestartDaemonset(ctx context.Context, client client.Client, namespace string, name string) error
func RunNvidiaSmi(ctx context.Context, client client.Client, clientset *kubernetes.Clientset, ...) error
func SetNodeSchedulable(ctx context.Context, client client.Client, ...) (bool, error)
type AccountedAppInfo
- func (a AccountedAppInfo) String() string

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func CheckGPUVisible ¶

func CheckGPUVisible(ctx context.Context, client client.Client, clientset *kubernetes.Clientset, restConfig *rest.Config, deviceResourceType string, resource *crov1alpha1.ComposableResource) (bool, error)

func CheckNoGPULoads ¶

func CheckNoGPULoads(ctx context.Context, client client.Client, clientset *kubernetes.Clientset, restConfig *rest.Config, targetNodeName string, targetGPUUUID *string) error

func CheckNodeCapacitySufficient ¶

func CheckNodeCapacitySufficient(ctx context.Context, client client.Client, nodeName string, nodeSpec *v1alpha1.NodeSpec) (bool, error)

func CheckNodeExisted ¶

func CheckNodeExisted(ctx context.Context, client client.Client, nodeName string) error

func ContainsString ¶

func ContainsString(slice []string, s string) bool

func CreateDeviceTaint ¶

func CreateDeviceTaint(ctx context.Context, client client.Client, resource *crov1alpha1.ComposableResource) error

func DrainGPU ¶

func DrainGPU(ctx context.Context, client client.Client, clientset *kubernetes.Clientset, restConfig *rest.Config, targetNodeName string, targetGPUUUID string, deviceResourceType string) error

func GenerateComposableResourceName ¶

func GenerateComposableResourceName(typeName string) string

func GetAllNodes ¶

func GetAllNodes(ctx context.Context, client client.Client) (*corev1.NodeList, error)

func RestartDaemonset ¶

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

func RunNvidiaSmi ¶

func RunNvidiaSmi(ctx context.Context, client client.Client, clientset *kubernetes.Clientset, restConfig *rest.Config, targetNodeName string) error

func SetNodeSchedulable ¶

func SetNodeSchedulable(ctx context.Context, client client.Client, request *v1alpha1.ComposableResource) (bool, error)

Types ¶

type AccountedAppInfo ¶

type AccountedAppInfo struct {
	GPUUUID     string
	ProcessName string
}

func (AccountedAppInfo) String ¶

func (a AccountedAppInfo) String() string

Source Files ¶

View all Source files

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