summaryrefslogtreecommitdiff
path: root/pkg/pool/interface.go
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-02-08 23:21:54 +0300
committerValery Piashchynski <[email protected]>2021-02-08 23:21:54 +0300
commitda64d9fbab7d73e203e7dbbb9503f4d422feaab0 (patch)
tree3dc3d5dd4a8c4de7d4b57baf2eeb1089f831bc1c /pkg/pool/interface.go
parent3e92e3df723ca1c4f152d8526eebfd7184e6fcec (diff)
BaseProcess interface as a return type in the worker_watcher,pool and
worker interface
Diffstat (limited to 'pkg/pool/interface.go')
-rw-r--r--pkg/pool/interface.go4
1 files changed, 2 insertions, 2 deletions
diff --git a/pkg/pool/interface.go b/pkg/pool/interface.go
index 4f7ae595..bfc56c3f 100644
--- a/pkg/pool/interface.go
+++ b/pkg/pool/interface.go
@@ -19,10 +19,10 @@ type Pool interface {
ExecWithContext(ctx context.Context, rqs payload.Payload) (payload.Payload, error)
// Workers returns worker list associated with the pool.
- Workers() (workers []worker.SyncWorker)
+ Workers() (workers []worker.BaseProcess)
// Remove worker from the pool.
- RemoveWorker(worker worker.SyncWorker) error
+ RemoveWorker(worker worker.BaseProcess) error
// Destroy all underlying stack (but let them to complete the task).
Destroy(ctx context.Context)