Versions in this module Expand all Collapse all v0 v0.0.2 Jan 4, 2024 v0.0.1 Mar 27, 2020 Changes in this version + const ErrInvalidTaskRangeIdentifier + const TASKRANGEIDENTIFIERREGEX + var TaskRangeRegex *regexp.Regexp = regexp.MustCompile(TASKRANGEIDENTIFIERREGEX) + func DeleteQueuedJobByID(targets []string) (string, error) + func DeleteQueuedJobByUsernames(targets []string) (string, error) + func DoesJobContainTaskGroup(j Job) bool + func DoesJobContainTaskRange(j Job) bool + func GetQstatOutput(filters map[string]string) (string, error) + func IsJobInErrorState(job Job) int + func IsJobRunning(job Job) int + type Error string + func (e Error) Error() string + type Host struct + JobList []Job + LoadAverage float64 + Name string + QType string + Resources ResourceList + SlotsReserved int32 + SlotsTotal int32 + SlotsUsed int32 + XMLName xml.Name + type Job struct + JATPriority float64 + JBJobNumber int64 + JobName string + JobOwner string + Slots int32 + StartTime string + State string + StateAttribute string + SubmittedTime string + Tasks Task + XMLName xml.Name + type JobInfo struct + PendingJobs PendingJob + QueueInfo QueueInfo + XMLName xml.Name + func NewJobInfo(input string) (JobInfo, error) + func (q JobInfo) GetXML() (string, error) + type JobList []Job + func ExtrapolateTasksToJobs(original Job) (JobList, error) + func FilterJobs(jobs JobList, filter func(j Job) bool) JobList + func GetJobs() (JobList, error) + func GetJobsWithFilter(filterfunc func(j Job) bool) (JobList, error) + func (jl JobList) Filter(filter func(j Job) bool) JobList + func (jl JobList) Sort(sorter func(i, j int) bool) JobList + type PendingJob struct + JobList []Job + XMLName xml.Name + type QueueInfo struct + Queues []Host + XMLName xml.Name + type Resource struct + Name string + Type string + Value string + XMLName xml.Name + type ResourceList []Resource + func (r ResourceList) CPU() (float64, error) + func (r ResourceList) FreeMemory() (StorageValue, error) + func (r ResourceList) FreeSwap() (StorageValue, error) + func (r ResourceList) FreeVirtualMemory() (StorageValue, error) + func (r ResourceList) Load(window string) (float64, error) + func (r ResourceList) MCoreCount() (int64, error) + func (r ResourceList) MSocketCount() (int64, error) + func (r ResourceList) MThreadCount() (int64, error) + func (r ResourceList) MemoryUsed() (StorageValue, error) + func (r ResourceList) NPLoadAverage() (float64, error) + func (r ResourceList) NPLoadLong() (float64, error) + func (r ResourceList) NPLoadMedium() (float64, error) + func (r ResourceList) NPLoadShort() (float64, error) + func (r ResourceList) NumberofProcessors() (int32, error) + func (r ResourceList) ProcessorCount() (int64, error) + func (r ResourceList) SwapUsed() (StorageValue, error) + func (r ResourceList) TotalMemory() (StorageValue, error) + func (r ResourceList) TotalSwap() (StorageValue, error) + func (r ResourceList) TotalVirtual() (StorageValue, error) + func (r ResourceList) VirtualUsed() (StorageValue, error) + type StorageValue struct + Bytes int64 + Scale string + Size float64 + type Task struct + Source string + TaskID int64 + func (t *Task) MarshalXML(e *xml.Encoder, start xml.StartElement) error + func (t *Task) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error + type XMLDataSource struct + func (d *XMLDataSource) Get() (string, error) + type XmlContentReader struct + func (x *XmlContentReader) Read() (string, error) + type XmlResourceGetter interface + Get func() (string, error) + type XmlResourceReader interface + Read func() (string, error)