diff options
author | Wolfy-J <[email protected]> | 2020-10-25 16:50:49 +0300 |
---|---|---|
committer | Wolfy-J <[email protected]> | 2020-10-25 16:50:49 +0300 |
commit | 96c11f2b1830833c7e190f2476334380cf8697ce (patch) | |
tree | 3a343603db4c36eada47b4b62bdc50d08ddd8895 | |
parent | 6d0cea83e2a253c3baf4564a37eebaf54fc124c0 (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 |