summaryrefslogtreecommitdiff
path: root/pkg/pool/interface.go
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-02-24 13:46:37 +0300
committerGitHub <[email protected]>2021-02-24 13:46:37 +0300
commitcaea9cb452fda97a9496bc33190c95fbc27e54c3 (patch)
tree0d226eb8ad9730ede1f7cd80b5f7b44d1fb23b0a /pkg/pool/interface.go
parent18a097292a567fccdd02304ff236bf78d769965d (diff)
parente684ac16035bed9a4c09677b0db3b33477955dc9 (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.go6
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)
}