diff options
Diffstat (limited to 'pkg/pool/interface.go')
| -rw-r--r-- | pkg/pool/interface.go | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/pkg/pool/interface.go b/pkg/pool/interface.go index bbf7653e..a040d27a 100644 --- a/pkg/pool/interface.go +++ b/pkg/pool/interface.go @@ -33,11 +33,11 @@ type Watcher interface { // Watch used to add workers to the container Watch(workers []worker.BaseProcess) error - // Get provide first free worker - Get(ctx context.Context) (worker.BaseProcess, error) + // Take takes the first free worker + Take(ctx context.Context) (worker.BaseProcess, error) - // Push enqueues worker back - Push(w worker.BaseProcess) + // Release releases the worker putting it back to the queue + Release(w worker.BaseProcess) // Allocate - allocates new worker and put it into the WorkerWatcher Allocate() error |