drmaa2interface

package module

Go to main page

Versions in this module

v1

v1.2.1

Feb 1, 2024

v1.2.0

Jan 3, 2024

Changes in this version

type CPU

+ func CPUFromString(cpu string) (CPU, bool)

type Capability

+ func CapabilityFromString(cap string) (Capability, bool)

type ErrorID

+ func ErrorIDFromString(id string) (ErrorID, bool)

type JobState

+ func JobStateFromString(state string) (JobState, bool)

type OS

+ func OSFromString(os string) (OS, bool)

v1.1.0

Nov 27, 2022

Changes in this version

type JobTemplate

+ func (jt *JobTemplate) UnmarshalJSON(data []byte) error

+ func (jt JobTemplate) MarshalJSON() ([]byte, error)

v1.0.2

Aug 11, 2020

Changes in this version

type CPU

+ const X64

+ const X86

v1.0.1

Jul 29, 2020

v1.0.0

May 13, 2017

Changes in this version

+ const InfiniteTime

+ const PlaceholderHomeDir

+ const PlaceholderIndex

+ const PlaceholderWorkingDir

+ const UnsetEnum

+ const UnsetNum

+ const UnsetTime

+ const ZeroTime

+ var UnsetDict map[string]string

+ var UnsetList []interface

+ type ArrayJob interface

+ GetID func() string

+ GetJobTemplate func() JobTemplate

+ GetJobs func() []Job

+ GetSessionName func() string

+ Hold func() error

+ Release func() error

+ Resume func() error

+ Suspend func() error

+ Terminate func() error

+ type CPU int

+ const ARM

+ const ARM64

+ const Alpha

+ const Cell

+ const IA64

+ const MIPS

+ const MIPS64

+ const OtherCPU

+ const PARISC

+ const PARISC64

+ const PowerPC

+ const PowerPC64

+ const SPARC

+ const SPARC64

+ func (i CPU) String() string

+ type Capability int

+ const AdvanceReservation

+ const BulkJobsMaxParallel

+ const Callback

+ const JtAccountingID

+ const JtDeadline

+ const JtEmail

+ const JtMaxSlots

+ const JtStaging

+ const ReserveSlots

+ const RtDuration

+ const RtMachineArch

+ const RtMachineOS

+ const RtStartNow

+ func (i Capability) String() string

+ type Error struct

+ ID ErrorID

+ Message string

+ func (ce Error) Error() string

+ func (ce Error) String() string

+ type ErrorID int

+ const DeniedByDrms

+ const DrmCommunication

+ const ImplementationSpecific

+ const Internal

+ const InvalidArgument

+ const InvalidSession

+ const InvalidState

+ const LastError

+ const OutOfResource

+ const SessionManagement

+ const Success

+ const Timeout

+ const TryLater

+ const UnsupportedAttribute

+ const UnsupportedOperation

+ func (i ErrorID) String() string

+ type Event int

+ const AttributeChange

+ const Migrated

+ const NewState

+ type EventChannel <-chan Notification

+ type Extensible interface

+ DescribeExtension func(string) string

+ ListExtensions func() []string

+ type Extension struct

+ ExtensionList map[string]string

+ type Job interface

+ GetID func() string

+ GetJobInfo func() (JobInfo, error)

+ GetJobTemplate func() (JobTemplate, error)

+ GetSessionName func() string

+ GetState func() JobState

+ Hold func() error

+ Reap func() error

+ Release func() error

+ Resume func() error

+ Suspend func() error

+ Terminate func() error

+ WaitStarted func(time.Duration) error

+ WaitTerminated func(time.Duration) error

+ type JobInfo struct

+ AllocatedMachines []string

+ Annotation string

+ CPUTime int64

+ DispatchTime time.Time

+ ExitStatus int

+ FinishTime time.Time

+ ID string

+ JobOwner string

+ QueueName string

+ Slots int64

+ State JobState

+ SubState string

+ SubmissionMachine string

+ SubmissionTime time.Time

+ TerminatingSignal string

+ WallclockTime time.Duration

+ var UnsetJobInfo *JobInfo

+ func CreateJobInfo() (ji JobInfo)

+ type JobSession interface

+ Close func() error

+ GetContact func() (string, error)

+ GetJobArray func(id string) (ArrayJob, error)

+ GetJobCategories func() ([]string, error)

+ GetJobs func(ji JobInfo) ([]Job, error)

+ GetSessionName func() (string, error)

+ RunBulkJobs func(jt JobTemplate, begin int, end int, step int, maxParallel int) (ArrayJob, error)

+ RunJob func(jt JobTemplate) (Job, error)

+ WaitAnyStarted func(jobs []Job, timeout time.Duration) (Job, error)

+ WaitAnyTerminated func(jobs []Job, timeout time.Duration) (Job, error)

+ type JobState int

+ const Done

+ const Failed

+ const Queued

+ const QueuedHeld

+ const Requeued

+ const RequeuedHeld

+ const Running

+ const Suspended

+ const Undetermined

+ const Unset

+ func (i JobState) String() string

+ type JobTemplate struct

+ AccountingID string

+ Args []string

+ CandidateMachines []string

+ DeadlineTime time.Time

+ Email []string

+ EmailOnStarted bool

+ EmailOnTerminated bool

+ ErrorPath string

+ InputPath string

+ JobCategory string

+ JobEnvironment map[string]string

+ JobName string

+ JoinFiles bool

+ MachineArch string

+ MachineOs string

+ MaxSlots int64

+ MinPhysMemory int64

+ MinSlots int64

+ OutputPath string

+ Priority int64

+ QueueName string

+ ReRunnable bool

+ RemoteCommand string

+ ReservationID string

+ ResourceLimits map[string]string

+ StageInFiles map[string]string

+ StageOutFiles map[string]string

+ StartTime time.Time

+ SubmitAsHold bool

+ WorkingDirectory string

+ type Machine struct

+ Architecture CPU

+ Available bool

+ CoresPerSocket int64

+ Load float64

+ Name string

+ OS OS

+ OSVersion Version

+ PhysicalMemory int64

+ Sockets int64

+ ThreadsPerCore int64

+ VirtualMemory int64

+ type MonitoringSession interface

+ CloseMonitoringSession func() error

+ GetAllJobs func(filter JobInfo) ([]Job, error)

+ GetAllMachines func(names []string) ([]Machine, error)

+ GetAllQueues func(names []string) ([]Queue, error)

+ GetAllReservations func() ([]Reservation, error)

+ type Notification struct

+ Evt Event

+ JobID string

+ SessionName string

+ State JobState

+ type OS int

+ const AIX

+ const BSD

+ const HPUX

+ const IRIX

+ const Linux

+ const MacOS

+ const OtherOS

+ const SunOS

+ const TRU64

+ const UnixWare

+ const Win

+ const WinNT

+ func (i OS) String() string

+ type Queue struct

+ Name string

+ type Reservation interface

+ GetID func() (string, error)

+ GetInfo func() (ReservationInfo, error)

+ GetSessionName func() (string, error)

+ GetTemplate func() (ReservationTemplate, error)

+ Terminate func() error

+ type ReservationInfo struct

+ ACL []string

+ ReservationEndTime time.Time

+ ReservationID string

+ ReservationName string

+ ReservationStartTime time.Time

+ ReservedMachines []string

+ ReservedSlots int64

+ type ReservationSession interface

+ Close func() error

+ GetContact func() (string, error)

+ GetReservation func(string) (Reservation, error)

+ GetReservations func() ([]Reservation, error)

+ GetSessionName func() (string, error)

+ RequestReservation func(ReservationTemplate) (Reservation, error)

+ type ReservationTemplate struct

+ CandidateMachines []string

+ Duration time.Duration

+ EndTime time.Time

+ JobCategory string

+ MachineArch string

+ MachineOs string

+ MaxSlots int64

+ MinPhysMemory int64

+ MinSlots int64

+ Name string

+ StartTime time.Time

+ UsersACL []string

+ type SessionManager interface

+ CreateJobSession func(name, contact string) (JobSession, error)

+ CreateReservationSession func(sessionName, contact string) (ReservationSession, error)

+ DestroyJobSession func(sessionName string) error

+ DestroyReservationSession func(sessionName string) error

+ GetDrmsName func() (string, error)

+ GetDrmsVersion func() (Version, error)

+ GetJobSessionNames func() ([]string, error)

+ GetReservationSessionNames func() ([]string, error)

+ OpenJobSession func(sessionName string) (JobSession, error)

+ OpenMonitoringSession func(sessionName string) (MonitoringSession, error)

+ OpenReservationSession func(name string) (ReservationSession, error)

+ RegisterEventNotification func() (EventChannel, error)

+ Supports func(Capability) bool

+ type Version struct

+ Major string

+ Minor string

+ func (v Version) String() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL