runner

Documentation

Index

• type CmdInfo
• type Runner
  • func NewRunner(project *config.Project, taskNames []string, statusInterval time.Duration) (runner *Runner)
  • func (r *Runner) Run() (err error)
  • func (r *Runner) Terminate()
• type TaskStatus
  • func NewTaskStatus() (ts *TaskStatus)
  • func (ts *TaskStatus) Finish(err error)

Types

type CmdInfo

type CmdInfo struct {
	Cmd       *exec.Cmd
	IsProcess bool
	StdInPipe io.WriteCloser
	TaskName  string
}

CmdInfo represent information of Cmd

type Runner

type Runner struct {
	TaskNames       []string
	Conf            *config.Project
	TaskStatus      map[string]*TaskStatus
	TaskStatusMutex *sync.RWMutex
	CmdInfo         map[string]*CmdInfo
	CmdInfoMutex    *sync.RWMutex
	Killed          bool
	KilledMutex     *sync.RWMutex
	Done            bool
	DoneMutex       *sync.RWMutex
	StatusInterval  time.Duration
	StartTimeMutex  *sync.RWMutex
	StartTime       time.Time
	Spaces          string
}

Runner is used to run tasks

func NewRunner

func NewRunner(project *config.Project, taskNames []string, statusInterval time.Duration) (runner *Runner)

NewRunner create new runner

func (*Runner) Run

func (r *Runner) Run() (err error)

Run Tasks

func (*Runner) Terminate

func (r *Runner) Terminate()

Terminate all processes

type TaskStatus

type TaskStatus struct {
	Finished bool
	Error    error
}

TaskStatus represent task status

func NewTaskStatus

func NewTaskStatus() (ts *TaskStatus)

NewTaskStatus create new task status

func (*TaskStatus) Finish

func (ts *TaskStatus) Finish(err error)

Finish task status