Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

slurm

package

Go to main page

Versions in this module

v0

v0.1.2

Apr 8, 2024

Changes in this version

+ var ErrInvalidJob = errors.New("invalid job id")

+ var ErrRety = errors.New("retry later")

+ var ExcludeNodes = "--exclude="

+ var NewUserEnv = "--get-user-env=10L"

+ var Signal = "--signal=TERM"

+ var SignalChildren = "--full"

+ var SignalParentOnly = "--batch"

+ var Slurm struct

+ func AllocatableResources(ctx context.Context) corev1.ResourceList

+ func CancelJob(args string) (string, error)

+ func ConnectionOK() bool

+ func GetJobID(pod *corev1.Pod) string

+ func HasJobID(pod *corev1.Pod) bool

+ func SetContainerStatusID(status *corev1.ContainerStatus, typedValue string)

+ func SetPodID(pod *corev1.Pod, idType JobIDType, value string)

+ func SubmitJob(scriptFile string) (string, error)

+ func TotalResources() corev1.ResourceList

+ type JobIDType string

+ const JobIDTypeEmpty

+ const JobIDTypeInstance

+ const JobIDTypeProcess

+ const JobIDTypeSlurm

+ type NodeInfo struct

+ Architecture string

+ CPUCores uint64

+ CPUs uint64

+ EphemeralStorage uint64

+ FreeMemory int64

+ KernelVersion string

+ Name string

+ Partitions []string

+ func (i NodeInfo) ResourceList() corev1.ResourceList

+ type Stats struct

+ Nodes []NodeInfo

v0.1.1

Jul 12, 2023

Changes in this version

+ const NobodyGID

+ const NobodyUID

+ const RootGID

+ const RootUID

+ func DetermineEffectiveRunAsUser(sc *corev1.SecurityContext) (uid int64, gid int64)

+ func DetermineEffectiveSecurityContext(pod *corev1.Pod, container *corev1.Container) *corev1.SecurityContext

type Container

+ ExecutionMode string

+ RunAsGroup int64

+ RunAsUser int64

v0.1.0

May 13, 2023

Changes in this version

+ const CustomSlurmFlags

+ const GenerateEnvTemplate

+ const JobScriptTemplate

+ 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 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 SavePodToFile(_ context.Context, pod *corev1.Pod) error

+ func SyncContainerStatuses(pod *corev1.Pod)

+ func SyncPodStatus(pod *corev1.Pod)

+ func WalkPodDirectories(f compute.WalkPodFunc) 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

+ ApptainerMode string

+ Args []string

+ Binds []string

+ Command []string

+ EnvFilePath string

+ ExitCodePath string

+ ImageFilePath string

+ InstanceName string

+ JobIDPath string

+ LogsPath string

+ type GenerateEnvFields = struct

+ Variables []corev1.EnvVar

+ type JobFields struct

+ ComputeEnv compute.HPCEnvironment

+ Containers []Container

+ CustomFlags []string

+ InitContainers []Container

+ Pod types.NamespacedName

+ ResourceRequest resources.ResourceList

+ VirtualEnv VirtualEnvironmentPaths

+ type VirtualEnvironmentPaths struct

+ CgroupFilePath string

+ ConstructorFilePath string

+ IPAddressPath string

+ StderrPath string

+ StdoutPath string

+ SysErrorFilePath string