simpletrackerfakes

Documentation

Index

• type FakeJob
  • func NewFakeJob(endstate drmaa2interface.JobState, errMessage string, timeout time.Duration) (fake FakeJob)
  • func (j FakeJob) GetID() string
  • func (j FakeJob) GetJobInfo() (drmaa2interface.JobInfo, error)
  • func (j FakeJob) GetJobTemplate() (drmaa2interface.JobTemplate, error)
  • func (j FakeJob) GetSessionName() string
  • func (j FakeJob) GetState() drmaa2interface.JobState
  • func (j FakeJob) Hold() error
  • func (j FakeJob) Reap() error
  • func (j FakeJob) Release() error
  • func (j FakeJob) Resume() error
  • func (j FakeJob) Suspend() error
  • func (j FakeJob) Terminate() error
  • func (j FakeJob) WaitStarted(timeout time.Duration) error
  • func (j FakeJob) WaitTerminated(timeout time.Duration) error
• type JobTracker
  • func New(sessionname string) *JobTracker
  • func (jt *JobTracker) AddArrayJob(t drmaa2interface.JobTemplate, begin int, end int, step int, maxParallel int) (string, error)
  • func (jt *JobTracker) AddJob(t drmaa2interface.JobTemplate) (string, error)
  • func (jt *JobTracker) DeleteJob(jobid string) error
  • func (jt *JobTracker) JobControl(jobid, state string) error
  • func (jt *JobTracker) JobInfo(jobid string) (drmaa2interface.JobInfo, error)
  • func (jt *JobTracker) JobState(jobid string) (drmaa2interface.JobState, string, error)
  • func (jt *JobTracker) ListArrayJobs(string) ([]string, error)
  • func (jt *JobTracker) ListJobCategories() ([]string, error)
  • func (jt *JobTracker) ListJobs() ([]string, error)
  • func (jt *JobTracker) Wait(jobid string, d time.Duration, states ...drmaa2interface.JobState) error

Types

type FakeJob

type FakeJob struct {
	// contains filtered or unexported fields
}

func NewFakeJob

func NewFakeJob(endstate drmaa2interface.JobState, errMessage string, timeout time.Duration) (fake FakeJob)

func (FakeJob) GetID

func (j FakeJob) GetID() string

func (FakeJob) GetJobInfo

func (j FakeJob) GetJobInfo() (drmaa2interface.JobInfo, error)

func (FakeJob) GetJobTemplate

func (j FakeJob) GetJobTemplate() (drmaa2interface.JobTemplate, error)

func (FakeJob) GetSessionName

func (j FakeJob) GetSessionName() string

func (FakeJob) GetState

func (j FakeJob) GetState() drmaa2interface.JobState

func (FakeJob) Hold

func (j FakeJob) Hold() error

func (FakeJob) Reap

func (j FakeJob) Reap() error

func (FakeJob) Release

func (j FakeJob) Release() error

func (FakeJob) Resume

func (j FakeJob) Resume() error

func (FakeJob) Suspend

func (j FakeJob) Suspend() error

func (FakeJob) Terminate

func (j FakeJob) Terminate() error

func (FakeJob) WaitStarted

func (j FakeJob) WaitStarted(timeout time.Duration) error

func (FakeJob) WaitTerminated

func (j FakeJob) WaitTerminated(timeout time.Duration) error

type JobTracker

type JobTracker struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func New

func New(sessionname string) *JobTracker

func (*JobTracker) AddArrayJob

func (jt *JobTracker) AddArrayJob(t drmaa2interface.JobTemplate, begin int, end int, step int, maxParallel int) (string, error)

func (*JobTracker) AddJob

func (jt *JobTracker) AddJob(t drmaa2interface.JobTemplate) (string, error)

func (*JobTracker) DeleteJob

func (jt *JobTracker) DeleteJob(jobid string) error

func (*JobTracker) JobControl

func (jt *JobTracker) JobControl(jobid, state string) error

func (*JobTracker) JobInfo

func (jt *JobTracker) JobInfo(jobid string) (drmaa2interface.JobInfo, error)

func (*JobTracker) JobState

func (jt *JobTracker) JobState(jobid string) (drmaa2interface.JobState, string, error)

func (*JobTracker) ListArrayJobs

func (jt *JobTracker) ListArrayJobs(string) ([]string, error)

func (*JobTracker) ListJobCategories

func (jt *JobTracker) ListJobCategories() ([]string, error)

func (*JobTracker) ListJobs

func (jt *JobTracker) ListJobs() ([]string, error)

func (*JobTracker) Wait

func (jt *JobTracker) Wait(jobid string, d time.Duration, states ...drmaa2interface.JobState) error