summaryrefslogtreecommitdiff
path: root/pkg/worker_watcher/interface.go
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-02-10 20:00:22 +0300
committerValery Piashchynski <[email protected]>2021-02-10 20:00:22 +0300
commitae3dd0c3672217be0b3fb4042ef650477fba108b (patch)
treeda5b08308e5aff50a102f41e254ee3620d41550e /pkg/worker_watcher/interface.go
parentda64d9fbab7d73e203e7dbbb9503f4d422feaab0 (diff)
Rewrite container for the workers
Update tests
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 a3552e7e..4625b7a7 100644
--- a/pkg/worker_watcher/interface.go
+++ b/pkg/worker_watcher/interface.go
@@ -8,7 +8,7 @@ import (
// Watcher is an interface for the Sync workers lifecycle
type Watcher interface {
- // Watch used to add workers to the stack
+ // Watch used to add workers to the container
Watch(workers []worker.BaseProcess) error
// Get provide first free worker
@@ -20,12 +20,12 @@ type Watcher interface {
// Allocate - allocates new worker and put it into the WorkerWatcher
Allocate() error
- // Destroy destroys the underlying stack
+ // Destroy destroys the underlying container
Destroy(ctx context.Context)
- // WorkersList return all stack w/o removing it from internal storage
+ // WorkersList return all container w/o removing it from internal storage
List() []worker.BaseProcess
- // RemoveWorker remove worker from the stack
- Remove(wb worker.BaseProcess) error
+ // RemoveWorker remove worker from the container
+ Remove(wb worker.BaseProcess)
}