summaryrefslogtreecommitdiff
path: root/pool.go
diff options
context:
space:
mode:
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)