diff options
author | Wolfy-J <[email protected]> | 2018-01-28 14:35:07 +0300 |
---|---|---|
committer | Wolfy-J <[email protected]> | 2018-01-28 14:35:07 +0300 |
commit | c57232ae2bc7253ded326226948dfc7f9b324753 (patch) | |
tree | a7710545a75f9ecf483618ff742f55ed8a0d5fae /worker.go | |
parent | e4e5cadce7deef4c36c038a4900d55ea30dd099c (diff) |
golint
Diffstat (limited to 'worker.go')
-rw-r--r-- | worker.go | 7 |
1 files changed, 5 insertions, 2 deletions
@@ -148,7 +148,7 @@ func (w *Worker) Wait() error { return &exec.ExitError{ProcessState: w.endState} } -// Destroy sends soft termination command to the worker to properly stop the process. +// Stop sends soft termination command to the worker and waits for process completion. func (w *Worker) Stop() error { select { case <-w.waitDone: @@ -166,7 +166,7 @@ func (w *Worker) Stop() error { } // Kill kills underlying process, make sure to call Wait() func to gather -// error log from the stderr +// error log from the stderr. Waits for process completion. func (w *Worker) Kill() error { select { case <-w.waitDone: @@ -183,6 +183,9 @@ func (w *Worker) Kill() error { } } +// Exec sends payload to worker, executes it and returns result or +// error. Make sure to handle worker.Wait() to gather worker level +// errors. Method might return JobError indicating issue with payload. func (w *Worker) Exec(rqs *Payload) (rsp *Payload, err error) { w.mu.Lock() defer w.mu.Unlock() |