Versions in this module Expand all Collapse all v0 v0.4.0 Dec 5, 2024 Changes in this version + const DefaultAdapterVolumePath + const DefaultConfigMapMountPath + const DefaultDataVolumePath + const DefaultVolumeMountPath + func BuildCmdStr(baseCommand string, runParams ...map[string]string) string + func ConfigAdapterVolume() (corev1.Volume, corev1.VolumeMount) + func ConfigCMVolume(cmName string) (corev1.Volume, corev1.VolumeMount) + func ConfigDataVolume(hostPath *string) (corev1.Volume, corev1.VolumeMount) + func ConfigImagePushSecretVolume(imagePushSecret string) (corev1.Volume, corev1.VolumeMount) + func ConfigResultsVolume(outputPath string) (corev1.Volume, corev1.VolumeMount) + func ConfigSHMVolume(instanceCount int) (corev1.Volume, corev1.VolumeMount) + func Contains(s []string, e string) bool + func ExtractAndValidateRepoName(image string) error + func FetchGPUCountFromNodes(ctx context.Context, kubeClient client.Client, nodeNames []string) (string, error) + func GetPerNodeGPUCountFromNodes(nodeList *v1.NodeList) string + func GetReleaseNamespace() (string, error) + func GetSKUHandler() (sku.CloudSKUHandler, error) + func GetSKUNumGPUs(ctx context.Context, kubeClient client.Client, workerNodes []string, ...) (string, error) + func MergeConfigMaps(baseMap, overrideMap map[string]string) map[string]string + func SearchMap(m map[string]interface{}, key string) (value interface{}, exists bool) + func SearchRawExtension(raw runtime.RawExtension, key string) (interface{}, bool, error) + func SelectNodes(qualified []*v1.Node, preferred []string, previous []string, count int) []*v1.Node + func ShellCmd(command string) []string
Go to main page