containerdtracker

Documentation

Index

• type ContainerDTracker
  • func (dt *ContainerDTracker) AddArrayJob(jt drmaa2interface.JobTemplate, begin int, end int, step int, maxParallel int) (string, error)
  • func (dt *ContainerDTracker) AddJob(jt drmaa2interface.JobTemplate) (string, error)
  • func (dt *ContainerDTracker) DeleteJob(jobid string) error
  • func (dt *ContainerDTracker) JobControl(jobid, state string) error
  • func (dt *ContainerDTracker) JobInfo(jobid string) (drmaa2interface.JobInfo, error)
  • func (dt *ContainerDTracker) JobState(jobid string) (drmaa2interface.JobState, string, error)
  • func (dt *ContainerDTracker) ListArrayJobs(string) ([]string, error)
  • func (dt *ContainerDTracker) ListJobs() ([]string, error)
  • func (dt *ContainerDTracker) Wait(jobid string, timeout time.Duration, state ...drmaa2interface.JobState) error

Types

type ContainerDTracker

type ContainerDTracker struct{}

func (*ContainerDTracker) AddArrayJob

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

func (*ContainerDTracker) AddJob

func (dt *ContainerDTracker) AddJob(jt drmaa2interface.JobTemplate) (string, error)

func (*ContainerDTracker) DeleteJob

func (dt *ContainerDTracker) DeleteJob(jobid string) error

func (*ContainerDTracker) JobControl

func (dt *ContainerDTracker) JobControl(jobid, state string) error

func (*ContainerDTracker) JobInfo

func (dt *ContainerDTracker) JobInfo(jobid string) (drmaa2interface.JobInfo, error)

func (*ContainerDTracker) JobState

func (dt *ContainerDTracker) JobState(jobid string) (drmaa2interface.JobState, string, error)

func (*ContainerDTracker) ListArrayJobs

func (dt *ContainerDTracker) ListArrayJobs(string) ([]string, error)

func (*ContainerDTracker) ListJobs

func (dt *ContainerDTracker) ListJobs() ([]string, error)

func (*ContainerDTracker) Wait

func (dt *ContainerDTracker) Wait(jobid string, timeout time.Duration, state ...drmaa2interface.JobState) error