worker

package

v0.0.0-...-39e769a Latest Latest Go to latest Published: Jun 27, 2022 License: Apache-2.0 Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

View Source

var ErrorJobNotFound = errors.New("job not found")

This section is empty.

type CancelFunc func()

type Command struct {
	Cmd  string
	Args []string
}

type Job struct {
	sync.Mutex
	ID     string
	Status JobStatus
	// contains filtered or unexported fields
}

func NewJob(command Command, logDir string) (*Job, error)

func (j *Job) FollowLogs() (<-chan string, CancelFunc, error)

func (j *Job) Start() error

func (j *Job) Wait()

type JobState int

const (
	JobStateUnspecified JobState = iota
	JobStatePending
	JobStateRunning
	JobStateCompleted
)

type JobStatus struct {
	State     JobState
	ExitCode  int
	ExitError error
}

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

func NewLogFile(filepath string) (*LogFile, error)

func (l *LogFile) Close() error

func (l *LogFile) Follow(stopCh <-chan bool) (<-chan string, error)

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

func NewWorker(logDir string) *Worker

func (w *Worker) FollowLogs(jobID string) (<-chan string, CancelFunc, error)

func (w *Worker) QueryJob(jobID string) (JobStatus, error)

func (w *Worker) StartJob(command Command) (*Job, error)

func (w *Worker) StopJob(jobID string) error