summaryrefslogtreecommitdiff
path: root/pkg/worker_watcher/interface.go
diff options
context:
space:
mode:
Diffstat (limited to 'pkg/worker_watcher/interface.go')
-rw-r--r--pkg/worker_watcher/interface.go10
1 files changed, 5 insertions, 5 deletions
diff --git a/pkg/worker_watcher/interface.go b/pkg/worker_watcher/interface.go
index ce5011c0..a3552e7e 100644
--- a/pkg/worker_watcher/interface.go
+++ b/pkg/worker_watcher/interface.go
@@ -9,13 +9,13 @@ import (
// Watcher is an interface for the Sync workers lifecycle
type Watcher interface {
// Watch used to add workers to the stack
- Watch(workers []worker.SyncWorker) error
+ Watch(workers []worker.BaseProcess) error
// Get provide first free worker
- Get(ctx context.Context) (worker.SyncWorker, error)
+ Get(ctx context.Context) (worker.BaseProcess, error)
// Push enqueues worker back
- Push(w worker.SyncWorker)
+ Push(w worker.BaseProcess)
// Allocate - allocates new worker and put it into the WorkerWatcher
Allocate() error
@@ -24,8 +24,8 @@ type Watcher interface {
Destroy(ctx context.Context)
// WorkersList return all stack w/o removing it from internal storage
- List() []worker.SyncWorker
+ List() []worker.BaseProcess
// RemoveWorker remove worker from the stack
- Remove(wb worker.SyncWorker) error
+ Remove(wb worker.BaseProcess) error
}