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 (t *ContainerDTracker) JobControl(id string, action drmaa2.JobControlAction) error
  • func (dt *ContainerDTracker) JobInfo(jobID string) (drmaa2interface.JobInfo, error)
  • func (t *ContainerDTracker) JobState(id string) (drmaa2.JobState, 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 {
	// contains filtered or unexported fields
}

ContainerDTracker is an implementation of the drmaa2.JobTracker interface for containerd

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 (t *ContainerDTracker) JobControl(id string, action drmaa2.JobControlAction) error

JobControl allows control actions to be performed on the job with the given ID

func (*ContainerDTracker) JobInfo

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

func (*ContainerDTracker) JobState

func (t *ContainerDTracker) JobState(id string) (drmaa2.JobState, error)

JobState returns the current state of the job with the given ID

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