summaryrefslogtreecommitdiff
path: root/pkg/pool/interface.go
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-02-24 14:16:59 +0300
committerGitHub <[email protected]>2021-02-24 14:16:59 +0300
commitb3cb0cd2428f1bfdd959ea8f3461e2992b6acdb2 (patch)
tree0d226eb8ad9730ede1f7cd80b5f7b44d1fb23b0a /pkg/pool/interface.go
parent3c5a85bf8a0d1c8b8f8f71c215f75b338c4e7510 (diff)
parentcaea9cb452fda97a9496bc33190c95fbc27e54c3 (diff)
Merge pull request #551 from spiral/rc.4-releasev2.0.0-RC.4
âš¡ release(RC.4): Release RC.4
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)
}