wfl

package module

Go to main page

Versions in this module

v1

v1.0.1

Jan 26, 2019

Changes in this version

type CloudFoundryConfig

+ DefaultTemplate drmaa2interface.JobTemplate

type Context

+ func NewSingularityContext() *Context

+ func NewSingularityContextByCfg(cfg SingularityConfig) *Context

type DockerConfig

+ DefaultTemplate drmaa2interface.JobTemplate

type Job

+ func (j *Job) Errored() bool

type KubernetesConfig

+ DefaultTemplate drmaa2interface.JobTemplate

type ProcessConfig

+ DefaultTemplate drmaa2interface.JobTemplate

+ type SingularityConfig struct

+ DBFile string

+ DefaultImage string

+ DefaultTemplate drmaa2interface.JobTemplate

type Workflow

+ func (w *Workflow) Logger() log.Logger

+ func (w *Workflow) SetLogger(log log.Logger) *Workflow

v1.0.0

Aug 25, 2018

Changes in this version

+ func TmpFile() string

+ type CloudFoundryConfig struct

+ APIAddr string

+ DBFile string

+ Password string

+ User string

+ type Context struct

+ func DRMAA2SessionManagerContext(sm drmaa2interface.SessionManager) *Context

+ func ErrorTestContext() *Context

+ func NewCloudFoundryContext() *Context

+ func NewCloudFoundryContextByCfg(cfg CloudFoundryConfig) *Context

+ func NewDockerContext() *Context

+ func NewDockerContextByCfg(cfg DockerConfig) *Context

+ func NewKubernetesContext() *Context

+ func NewKubernetesContextByCfg(cfg KubernetesConfig) *Context

+ func NewProcessContext() *Context

+ func NewProcessContextByCfg(cfg ProcessConfig) *Context

+ func (c *Context) Error() error

+ func (c *Context) HasError() bool

+ func (c *Context) OnError(f func(e error)) *Context

+ type DockerConfig struct

+ DBFile string

+ DefaultDockerImage string

+ type Iterator func(drmaa2interface.JobTemplate) drmaa2interface.JobTemplate

+ func NewEnvSequenceIterator(env string, start, incr int) Iterator

+ func NewTimeIterator(d time.Duration) Iterator

+ type Job struct

+ func EmptyJob() *Job

+ func NewJob(wfl *Workflow) *Job

+ func (j *Job) After(d time.Duration) *Job

+ func (j *Job) AnyFailed() bool

+ func (j *Job) Do(f func(job drmaa2interface.Job)) *Job

+ func (j *Job) ExitStatus() int

+ func (j *Job) Failed() bool

+ func (j *Job) HasAnyFailed() bool

+ func (j *Job) JobID() string

+ func (j *Job) JobInfo() drmaa2interface.JobInfo

+ func (j *Job) JobInfos() []drmaa2interface.JobInfo

+ func (j *Job) Kill() *Job

+ func (j *Job) LastError() error

+ func (j *Job) ListAllFailed() []drmaa2interface.Job

+ func (j *Job) Notify(n *Notifier) *Job

+ func (j *Job) Observe(o Observer) *Job

+ func (j *Job) OnError(f func(err error)) *Job

+ func (j *Job) OnFailure(f func(job drmaa2interface.Job)) *Job

+ func (j *Job) OnFailureRun(cmd string, args ...string) *Job

+ func (j *Job) OnFailureRunT(jt drmaa2interface.JobTemplate) *Job

+ func (j *Job) OnSuccess(f func(job drmaa2interface.Job)) *Job

+ func (j *Job) OnSuccessRun(cmd string, args ...string) *Job

+ func (j *Job) OnSuccessRunT(jt drmaa2interface.JobTemplate) *Job

+ func (j *Job) Resubmit(r int) *Job

+ func (j *Job) Resume() *Job

+ func (j *Job) Retry(r int) *Job

+ func (j *Job) RetryAnyFailed(amount int) *Job

+ func (j *Job) Run(cmd string, args ...string) *Job

+ func (j *Job) RunEvery(d time.Duration, end time.Time, cmd string, args ...string) error

+ func (j *Job) RunEveryT(d time.Duration, end time.Time, jt drmaa2interface.JobTemplate) error

+ func (j *Job) RunT(jt drmaa2interface.JobTemplate) *Job

+ func (j *Job) State() drmaa2interface.JobState

+ func (j *Job) Success() bool

+ func (j *Job) Suspend() *Job

+ func (j *Job) Synchronize() *Job

+ func (j *Job) Tag() string

+ func (j *Job) TagWith(tag string) *Job

+ func (j *Job) Template() *drmaa2interface.JobTemplate

+ func (j *Job) Then(f func(job drmaa2interface.Job)) *Job

+ func (j *Job) ThenRun(cmd string, args ...string) *Job

+ func (j *Job) ThenRunT(jt drmaa2interface.JobTemplate) *Job

+ func (j *Job) Wait() *Job

+ type KubernetesConfig struct

+ DBFile string

+ DefaultImage string

+ type Notifier struct

+ func NewNotifier() *Notifier

+ func (n *Notifier) Destroy()

+ func (n *Notifier) ReceiveJob() *Job

+ func (n *Notifier) SendJob(job *Job)

+ type Observer struct

+ ErrorHandler func(error)

+ FailedHandler func(drmaa2interface.Job)

+ SuccessHandler func(drmaa2interface.Job)

+ func NewDefaultObserver() Observer

+ type ProcessConfig struct

+ DBFile string

+ type Template struct

+ Jt drmaa2interface.JobTemplate

+ func NewTemplate(jt drmaa2interface.JobTemplate) *Template

+ func (t *Template) AddIterator(name string, itr Iterator) *Template

+ func (t *Template) AddMap(name string, f Iterator) *Template

+ func (t *Template) MapTo(system string) drmaa2interface.JobTemplate

+ func (t *Template) Next() drmaa2interface.JobTemplate

+ func (t *Template) NextMap(name string) drmaa2interface.JobTemplate

+ type Workflow struct

+ func NewWorkflow(context *Context) *Workflow

+ func (w *Workflow) Error() error

+ func (w *Workflow) HasError() bool

+ func (w *Workflow) OnError(f func(e error)) *Workflow

+ func (w *Workflow) Run(cmd string, args ...string) *Job

+ func (w *Workflow) RunT(jt drmaa2interface.JobTemplate) *Job

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL