job

package
v1.12.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 10, 2023 License: GPL-3.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrJobRunning      = errors.New("job already running")
	ErrJobIsNotRunning = errors.New("job is not running")
	ErrJobFinished     = errors.New("job already finished")
)

Functions

This section is empty.

Types

type Job

type Job struct {
	DAG           *dag.DAG
	Command       string
	WorkDir       string
	Next          time.Time
	EngineFactory engine.Factory
}

TODO: write tests

func (*Job) GetDAG

func (j *Job) GetDAG() *dag.DAG

func (*Job) Restart

func (j *Job) Restart() error

func (*Job) Start

func (j *Job) Start() error

func (*Job) Stop

func (j *Job) Stop() error

func (*Job) String

func (j *Job) String() string

Jump to

Keyboard shortcuts

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