summaryrefslogtreecommitdiff
path: root/pkg/pool/interface.go
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-02-24 00:12:05 +0300
committerValery Piashchynski <[email protected]>2021-02-24 00:12:05 +0300
commite684ac16035bed9a4c09677b0db3b33477955dc9 (patch)
tree0d226eb8ad9730ede1f7cd80b5f7b44d1fb23b0a /pkg/pool/interface.go
parent18a097292a567fccdd02304ff236bf78d769965d (diff)
Fix pool behavior, update tests
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)
}