summaryrefslogtreecommitdiff
path: root/worker.go
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2020-10-27 15:16:55 +0300
committerValery Piashchynski <[email protected]>2020-10-27 15:16:55 +0300
commitd199ef71b9644afbbba064c317cd0991be1c2443 (patch)
treef777eb90f10ca0e7dbc46227fc76c61f02111946 /worker.go
parent91cf918b30938129609323ded53e190385e019a6 (diff)
Supervised pool
Diffstat (limited to 'worker.go')
-rwxr-xr-xworker.go4
1 files changed, 2 insertions, 2 deletions
diff --git a/worker.go b/worker.go
index 2dda51cc..ef532f51 100755
--- a/worker.go
+++ b/worker.go
@@ -74,7 +74,7 @@ type WorkerBase interface {
// Kill kills underlying process, make sure to call Wait() func to gather
// error log from the stderr. Does not waits for process completion!
- Kill(ctx context.Context) error
+ Kill() error
// Relay returns attached to worker goridge relay
Relay() goridge.Relay
@@ -280,7 +280,7 @@ func (w *WorkerProcess) Stop(ctx context.Context) error {
// Kill kills underlying process, make sure to call Wait() func to gather
// error log from the stderr. Does not waits for process completion!
-func (w *WorkerProcess) Kill(ctx context.Context) error {
+func (w *WorkerProcess) Kill() error {
w.state.Set(StateKilling)
w.mu.Lock()
defer w.mu.Unlock()