summaryrefslogtreecommitdiff
path: root/pool.go
diff options
context:
space:
mode:
authorWolfy-J <[email protected]>2018-03-31 18:31:09 +0300
committerWolfy-J <[email protected]>2018-03-31 18:31:09 +0300
commitf8ff7aeedc893969d02115d23b62503a75228446 (patch)
treeabe67a449cba8e00f23ad25b43d481d4b6fa1dee /pool.go
parent73240266eb12fbc763d9780ba66ffa8bc0f2c38b (diff)
worker destruction made public
Diffstat (limited to 'pool.go')
-rw-r--r--pool.go3
1 files changed, 3 insertions, 0 deletions
diff --git a/pool.go b/pool.go
index f491dfa5..e432ec25 100644
--- a/pool.go
+++ b/pool.go
@@ -13,6 +13,9 @@ const (
// Pool managed set of inner worker processes.
type Pool interface {
+ // Watch attaches pool event watcher.
+ Watch(o func(event int, w *Worker, ctx interface{}))
+
// Exec one task with given payload and context, returns result or error.
Exec(rqs *Payload) (rsp *Payload, err error)