diff options
author | Valery Piashchynski <[email protected]> | 2021-02-24 13:46:37 +0300 |
---|---|---|
committer | GitHub <[email protected]> | 2021-02-24 13:46:37 +0300 |
commit | caea9cb452fda97a9496bc33190c95fbc27e54c3 (patch) | |
tree | 0d226eb8ad9730ede1f7cd80b5f7b44d1fb23b0a /pkg/pool/interface.go | |
parent | 18a097292a567fccdd02304ff236bf78d769965d (diff) | |
parent | e684ac16035bed9a4c09677b0db3b33477955dc9 (diff) |
Merge pull request #562 from spiral/supervisor_update
🐛 fix(supervisor): supervisor behavior update
Diffstat (limited to 'pkg/pool/interface.go')
-rw-r--r-- | pkg/pool/interface.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/pkg/pool/interface.go b/pkg/pool/interface.go index bfc56c3f..4ef2f2e7 100644 --- a/pkg/pool/interface.go +++ b/pkg/pool/interface.go @@ -15,9 +15,6 @@ type Pool interface { // Exec executes task with payload Exec(rqs payload.Payload) (payload.Payload, error) - // ExecWithContext executes task with context which is used with timeout - ExecWithContext(ctx context.Context, rqs payload.Payload) (payload.Payload, error) - // Workers returns worker list associated with the pool. Workers() (workers []worker.BaseProcess) @@ -26,4 +23,7 @@ type Pool interface { // Destroy all underlying stack (but let them to complete the task). Destroy(ctx context.Context) + + // ExecWithContext executes task with context which is used with timeout + execWithTTL(ctx context.Context, rqs payload.Payload) (payload.Payload, error) } |