jobtracker

type Allocator ¶ added in v0.3.0

type Allocator interface {
	New(jobSessionName string, jobTrackerInitParams interface{}) (JobTracker, error)
}

Allocator contains all what is required to create a new JobTacker instance. A JobTracker implementation needs to register the Allocator implementation in its init method where it needs to call RegisterJobTracker() of the drmaa2os SessionManager. The jobTrackerInitParams are an optional way for parameterize the JobTracker creation method.

type Closer ¶ added in v0.3.14

type Closer interface {
	Close() error
}

Closer is a JobTracker which needs to disengage from the backend when the session is closed so that a new JobTracker with using the same session name can be created again.

type ContactStringer ¶ added in v0.3.13

type ContactStringer interface {
	Contact() (string, error)
}

ContactStringer is a JobTracker which offers the Contact() method which returns the contact string. Used in the DRMAA1 JobTracker.

type JobTemplater ¶ added in v0.3.14

type JobTemplater interface {
	JobTemplate(jobid string) (drmaa2interface.JobTemplate, error)
}

JobTemplater is a JobTracker which can retrieve the JobTemplate of a job.

type JobTracker ¶

type JobTracker interface {
	ListJobs() ([]string, error)
	ListArrayJobs(string) ([]string, error)
	AddJob(jt drmaa2interface.JobTemplate) (string, error)
	AddArrayJob(jt drmaa2interface.JobTemplate, begin int, end int, step int, maxParallel int) (string, error)
	JobState(jobid string) (drmaa2interface.JobState, string, error)
	JobInfo(jobid string) (drmaa2interface.JobInfo, error)
	JobControl(jobid, state string) error
	Wait(jobid string, timeout time.Duration, state ...drmaa2interface.JobState) error
	DeleteJob(jobid string) error
	ListJobCategories() ([]string, error)
}