summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorWolfy-J <[email protected]>2020-10-25 16:50:49 +0300
committerWolfy-J <[email protected]>2020-10-25 16:50:49 +0300
commit96c11f2b1830833c7e190f2476334380cf8697ce (patch)
tree3a343603db4c36eada47b4b62bdc50d08ddd8895
parent6d0cea83e2a253c3baf4564a37eebaf54fc124c0 (diff)
- massive update in roadrunner 2.0 abstractions
-rw-r--r--supervisor_pool.go (renamed from pool_watcher.go)8
1 files changed, 8 insertions, 0 deletions
diff --git a/pool_watcher.go b/supervisor_pool.go
index 6eb614dc..e63b4a59 100644
--- a/pool_watcher.go
+++ b/supervisor_pool.go
@@ -8,6 +8,14 @@ import (
const MB = 1024 * 1024
+type SupervisedPool interface {
+ Pool
+
+ // ExecWithContext provides the ability to execute with time deadline. Attention, worker will be destroyed if context
+ // deadline reached.
+ ExecWithContext(ctx context.Context, rqs Payload) (Payload, error)
+}
+
type supervisedPool struct {
cfg SupervisorConfig
events *util.EventHandler