client

Documentation

Index

• func ConvertJobInfoToDRMAA2(in genclient.JobInfo) drmaa2interface.JobInfo
• func ConvertJobStateToDRMAA2(in string) drmaa2interface.JobState
• func ConvertJobTemplate(in drmaa2interface.JobTemplate) genclient.JobTemplate
• func ConvertJobTemplateToDRMAA2(in genclient.JobTemplate) drmaa2interface.JobTemplate
• func NewAllocator() *allocator
• func ToStringArray(in []*string) []string
• type ClientJobTracker
  • func New(jobSessionName string, params ClientTrackerParams) (*ClientJobTracker, error)
  • func (c *ClientJobTracker) AddArrayJob(jt drmaa2interface.JobTemplate, begin int, end int, step int, maxParallel int) (string, error)
  • func (c *ClientJobTracker) AddJob(template drmaa2interface.JobTemplate) (string, error)
  • func (c *ClientJobTracker) DeleteJob(jobid string) error
  • func (c *ClientJobTracker) JobControl(jobid, action string) error
  • func (c *ClientJobTracker) JobInfo(jobid string) (drmaa2interface.JobInfo, error)
  • func (c *ClientJobTracker) JobState(jobid string) (drmaa2interface.JobState, string, error)
  • func (c *ClientJobTracker) ListArrayJobs(arrayjobid string) ([]string, error)
  • func (c *ClientJobTracker) ListJobCategories() ([]string, error)
  • func (c *ClientJobTracker) ListJobs() ([]string, error)
  • func (p *ClientJobTracker) Wait(jobid string, timeout time.Duration, states ...drmaa2interface.JobState) error
• type ClientTrackerParams

Functions

func ConvertJobInfoToDRMAA2

func ConvertJobInfoToDRMAA2(in genclient.JobInfo) drmaa2interface.JobInfo

func ConvertJobStateToDRMAA2

func ConvertJobStateToDRMAA2(in string) drmaa2interface.JobState

func ConvertJobTemplate

func ConvertJobTemplate(in drmaa2interface.JobTemplate) genclient.JobTemplate

func ConvertJobTemplateToDRMAA2

func ConvertJobTemplateToDRMAA2(in genclient.JobTemplate) drmaa2interface.JobTemplate

func NewAllocator

func NewAllocator() *allocator

func ToStringArray

func ToStringArray(in []*string) []string

Types

type ClientJobTracker

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

func New

func New(jobSessionName string, params ClientTrackerParams) (*ClientJobTracker, error)

New creates a new remote client job tracker.

func (*ClientJobTracker) AddArrayJob

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

func (*ClientJobTracker) AddJob

func (c *ClientJobTracker) AddJob(template drmaa2interface.JobTemplate) (string, error)

func (*ClientJobTracker) DeleteJob

func (c *ClientJobTracker) DeleteJob(jobid string) error

DeleteJob removes a finished job from remote.

func (*ClientJobTracker) JobControl

func (c *ClientJobTracker) JobControl(jobid, action string) error

func (*ClientJobTracker) JobInfo

func (c *ClientJobTracker) JobInfo(jobid string) (drmaa2interface.JobInfo, error)

func (*ClientJobTracker) JobState

func (c *ClientJobTracker) JobState(jobid string) (drmaa2interface.JobState, string, error)

func (*ClientJobTracker) ListArrayJobs

func (c *ClientJobTracker) ListArrayJobs(arrayjobid string) ([]string, error)

func (*ClientJobTracker) ListJobCategories

func (c *ClientJobTracker) ListJobCategories() ([]string, error)

ListJobCategories returns all job categories from remote.

func (*ClientJobTracker) ListJobs

func (c *ClientJobTracker) ListJobs() ([]string, error)

func (*ClientJobTracker) Wait

func (p *ClientJobTracker) Wait(jobid string, timeout time.Duration, states ...drmaa2interface.JobState) error

Wait until the job has a certain DRMAA2 state or return an error if the state is unreachable.

type ClientTrackerParams

type ClientTrackerParams struct {
	// Server of the remote API like "http://localhost:8087"
	Server string
	// Path sets path at server of remote jobtracker API (like "/container")
	Path string
	// Opts are additional settings for the client, like for authentication
	Opts []genclient.ClientOption
}