Versions in this module Expand all Collapse all v1 v1.0.0 May 26, 2020 Changes in this version + const Hold + const PlaceholderHomeDirectory + const PlaceholderTaskID + const PlaceholderWorkingDirectory + const Release + const Resume + const Suspend + const Terminate + const TimeoutNoWait + const TimeoutWaitForever + func GetContact() (string, error) + func GetVersion() (int, int, error) + func StrError(id ErrorID) string + type Error struct + ID ErrorID + Message string + func (ce Error) Error() string + type ErrorID int + const AlreadyActiveSession + const AuthFailure + const ConflictingAttributeValues + const DefaultContactStringError + const DeniedByDrm + const DrmCommunicationFailure + const DrmsExitError + const DrmsInitFailed + const ExitTimeout + const HoldInconsistentState + const InternalError + const InvalidArgument + const InvalidAttributeFormat + const InvalidAttributeValue + const InvalidContactString + const InvalidJob + const NoActiveSession + const NoDefaultContactStringSelected + const NoMemory + const NoMoreElements + const NoRusage + const ReleaseInconsistentState + const ResumeInconsistentState + const Success + const SuspendInconsistentState + const TryLater + type FileTransferMode struct + ErrorStream bool + InputStream bool + OutputStream bool + type JobInfo struct + func (ji *JobInfo) ExitStatus() int64 + func (ji *JobInfo) HasAborted() bool + func (ji *JobInfo) HasCoreDump() bool + func (ji *JobInfo) HasExited() bool + func (ji *JobInfo) HasSignaled() bool + func (ji *JobInfo) JobID() string + func (ji *JobInfo) ResourceUsage() map[string]string + func (ji *JobInfo) TerminationSignal() string + type JobTemplate struct + func (jt *JobTemplate) Args() ([]string, error) + func (jt *JobTemplate) BlockEmail() (bool, error) + func (jt *JobTemplate) DeadlineTime() (deadlineTime time.Duration, err error) + func (jt *JobTemplate) Email() ([]string, error) + func (jt *JobTemplate) Env() ([]string, error) + func (jt *JobTemplate) ErrorPath() (string, error) + func (jt *JobTemplate) HardRunDurationLimit() (deadlineTime time.Duration, err error) + func (jt *JobTemplate) HardWallclockTimeLimit() (deadlineTime time.Duration, err error) + func (jt *JobTemplate) InputPath() (string, error) + func (jt *JobTemplate) JobName() (string, error) + func (jt *JobTemplate) JobSubmissionState() (SubmissionState, error) + func (jt *JobTemplate) JoinFiles() (bool, error) + func (jt *JobTemplate) NativeSpecification() (string, error) + func (jt *JobTemplate) OutputPath() (string, error) + func (jt *JobTemplate) RemoteCommand() (string, error) + func (jt *JobTemplate) SetArg(arg string) error + func (jt *JobTemplate) SetArgs(args []string) error + func (jt *JobTemplate) SetBlockEmail(blockmail bool) error + func (jt *JobTemplate) SetDeadlineTime(deadline time.Duration) error + func (jt *JobTemplate) SetEmail(emails []string) error + func (jt *JobTemplate) SetEnv(envs []string) error + func (jt *JobTemplate) SetErrorPath(path string) error + func (jt *JobTemplate) SetHardRunDurationLimit(limit time.Duration) error + func (jt *JobTemplate) SetHardWallclockTimeLimit(limit time.Duration) error + func (jt *JobTemplate) SetInputPath(path string) error + func (jt *JobTemplate) SetJobName(jobname string) error + func (jt *JobTemplate) SetJobSubmissionState(state SubmissionState) error + func (jt *JobTemplate) SetJoinFiles(join bool) error + func (jt *JobTemplate) SetNativeSpecification(native string) error + func (jt *JobTemplate) SetOutputPath(path string) error + func (jt *JobTemplate) SetRemoteCommand(cmd string) error + func (jt *JobTemplate) SetSoftRunDurationLimit(limit time.Duration) error + func (jt *JobTemplate) SetSoftWallclockTimeLimit(limit time.Duration) error + func (jt *JobTemplate) SetStartTime(time time.Time) error + func (jt *JobTemplate) SetTransferFiles(mode FileTransferMode) error + func (jt *JobTemplate) SetWD(dir string) error + func (jt *JobTemplate) SoftRunDurationLimit() (deadlineTime time.Duration, err error) + func (jt *JobTemplate) SoftWallclockTimeLimit() (deadlineTime time.Duration, err error) + func (jt *JobTemplate) StartTime() (time.Time, error) + func (jt *JobTemplate) String() string + func (jt *JobTemplate) TransferFiles() (FileTransferMode, error) + func (jt *JobTemplate) WD() (string, error) + type PsType int + const PsDone + const PsFailed + const PsQueuedActive + const PsRunning + const PsSystemOnHold + const PsSystemSuspended + const PsUndetermined + const PsUserOnHold + const PsUserSuspended + const PsUserSystemOnHold + const PsUserSystemSuspended + func (pt PsType) String() string + type Session struct + func MakeSession() (Session, error) + func (s *Session) AllocateJobTemplate() (jt JobTemplate, err error) + func (s *Session) Control(jobID string, action controlType) error + func (s *Session) DeleteJobTemplate(jt *JobTemplate) error + func (s *Session) Exit() error + func (s *Session) GetAttributeNames() ([]string, error) + func (s *Session) GetDrmSystem() (string, error) + func (s *Session) GetDrmaaImplementation() string + func (s *Session) GetVectorAttributeNames() ([]string, error) + func (s *Session) HoldJob(jobID string) error + func (s *Session) Init(contactString string) error + func (s *Session) JobPs(jobID string) (PsType, error) + func (s *Session) ReleaseJob(jobID string) error + func (s *Session) ResumeJob(jobID string) error + func (s *Session) RunBulkJobs(jt *JobTemplate, start, end, incr int) ([]string, error) + func (s *Session) RunJob(jt *JobTemplate) (string, error) + func (s *Session) SuspendJob(jobID string) error + func (s *Session) Synchronize(jobIds []string, timeout int64, dispose bool) error + func (s *Session) TerminateJob(jobID string) error + func (s *Session) Wait(jobID string, timeout int64) (jobinfo JobInfo, err error) + type SubmissionState int + const ActiveState + const HoldState