Merge pull request #6 from spiral/develop

Develop

1 files changed, 6 insertions, 0 deletions

diff --git a/pool.go b/pool.go
index 1a134a6a..d22830a6 100644
--- a/pool.go
+++ b/pool.go
@@ -13,9 +13,15 @@ const (
 
 // Pool managed set of inner worker processes.
 type Pool interface {
+	// Report 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)
 
+	// Workers returns worker list associated with the pool.
+	Workers() (workers []*Worker)
+
 	// Destroy all underlying workers (but let them to complete the task).
 	Destroy()
 }