diff options
| author | Valery Piashchynski <[email protected]> | 2021-07-19 09:49:16 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-07-19 09:49:16 +0300 |
| commit | 02fc3664f4ad97e03c8f3a641e7322362f78721c (patch) | |
| tree | c5cccffde3c9d087ac02846c593a63dfe38de98f /pkg/worker_watcher/container/queue/queue.go | |
| parent | 978451159855c155b2aecdca3c86f47e5c6dd1ff (diff) | |
Worker watcher interface update.
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'pkg/worker_watcher/container/queue/queue.go')
| -rw-r--r-- | pkg/worker_watcher/container/queue/queue.go | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/pkg/worker_watcher/container/queue/queue.go b/pkg/worker_watcher/container/queue/queue.go index 4f611bbe..edf81d60 100644 --- a/pkg/worker_watcher/container/queue/queue.go +++ b/pkg/worker_watcher/container/queue/queue.go @@ -91,7 +91,9 @@ func (q *Queue) Pop(ctx context.Context) (worker.BaseProcess, error) { return w, nil } -func (q *Queue) Remove(_ int64) {} +func (q *Queue) Replace(oldPid int64, newWorker worker.BaseProcess) { + +} func (q *Queue) Destroy() {} |