Versions in this module Expand all Collapse all v0 v0.1.2 Apr 8, 2024 Changes in this version + const CustomSlurmFlags + const GenerateEnvTemplate + const HostScriptTemplate + const NobodyGID + const NobodyUID + const PauseScriptTemplate + const RootGID + const RootUID + var NotFoundBackoff = wait.Backoff + func CreatePod(ctx context.Context, pod *corev1.Pod, watcher filenotify.FileWatcher) + func DeletePod(podKey client.ObjectKey, watcher filenotify.FileWatcher) bool + func DetermineEffectiveRunAsUser(sc *corev1.SecurityContext) (uid int64, gid int64) + func DetermineEffectiveSecurityContext(pod *corev1.Pod, container *corev1.Container) *corev1.SecurityContext + func EscapeSingleQuote(str ...interface{}) string + func FromServices(ctx context.Context, namespace string) []corev1.EnvVar + func HumanReadableCode(code int) string + func LoadPodFromFile(filePath string) (*corev1.Pod, error) + func LoadPodFromKey(podRef client.ObjectKey) (*corev1.Pod, error) + func ParseTemplate(text string) (*template.Template, error) + func SavePodToFile(_ context.Context, pod *corev1.Pod) error + func SyncContainerStatuses(pod *corev1.Pod) + func UpdateStatusFromRuntime(pod *corev1.Pod) + func ValidateScript(filepath string) error + type Classifier struct + func (in *Classifier) Classify(name string, status *corev1.ContainerStatus) + func (in *Classifier) GetFailedJobs(jobNames ...string) []*corev1.ContainerStatus + func (in *Classifier) GetPendingJobs(jobNames ...string) []*corev1.ContainerStatus + func (in *Classifier) GetRunningJobs(jobNames ...string) []*corev1.ContainerStatus + func (in *Classifier) GetSuccessfulJobs(jobNames ...string) []*corev1.ContainerStatus + func (in *Classifier) ListAll() string + func (in *Classifier) ListFailedJobs() []string + func (in *Classifier) ListPendingJobs() []string + func (in *Classifier) ListRunningJobs() []string + func (in *Classifier) ListSuccessfulJobs() []string + func (in *Classifier) NumAll() string + func (in *Classifier) NumFailedJobs() int + func (in *Classifier) NumPendingJobs() int + func (in *Classifier) NumRunningJobs() int + func (in *Classifier) NumSuccessfulJobs() int + func (in *Classifier) Reset() + type Container struct + Args []string + Binds []string + Command []string + EnvFilePath string + ExecutionMode string + ExitCodePath string + ImageFilePath string + InstanceName string + JobIDPath string + LogsPath string + RunAsGroup int64 + RunAsUser int64 + type GenerateEnvFields = struct + Variables []corev1.EnvVar + type JobFields struct + Containers []Container + CustomFlags []string + HostEnv compute.HostEnvironment + InitContainers []Container + PauseImageFilePath string + Pod types.NamespacedName + ResourceRequest resources.ResourceList + VirtualEnv compute.VirtualEnvironment