summaryrefslogtreecommitdiff
path: root/worker.go
diff options
context:
space:
mode:
authorWolfy-J <[email protected]>2018-01-28 14:35:07 +0300
committerWolfy-J <[email protected]>2018-01-28 14:35:07 +0300
commitc57232ae2bc7253ded326226948dfc7f9b324753 (patch)
treea7710545a75f9ecf483618ff742f55ed8a0d5fae /worker.go
parente4e5cadce7deef4c36c038a4900d55ea30dd099c (diff)
golint
Diffstat (limited to 'worker.go')
-rw-r--r--worker.go7
1 files changed, 5 insertions, 2 deletions
diff --git a/worker.go b/worker.go
index 851239f9..d505c54b 100644
--- a/worker.go
+++ b/worker.go
@@ -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()