diff options
author | Valery Piashchynski <[email protected]> | 2021-02-10 20:00:22 +0300 |
---|---|---|
committer | Valery Piashchynski <[email protected]> | 2021-02-10 20:00:22 +0300 |
commit | ae3dd0c3672217be0b3fb4042ef650477fba108b (patch) | |
tree | da5b08308e5aff50a102f41e254ee3620d41550e /pkg/worker_watcher/interface.go | |
parent | da64d9fbab7d73e203e7dbbb9503f4d422feaab0 (diff) |
Rewrite container for the workers
Update tests
Diffstat (limited to 'pkg/worker_watcher/interface.go')
-rw-r--r-- | pkg/worker_watcher/interface.go | 10 |
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) } |