worker_watcher

package

v2.0.0 Latest Latest Go to latest Published: Oct 8, 2026 License: MIT Imports: 11 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Allocator func() (*worker.Process, error)

Allocator is responsible for worker allocation in the pool

type WorkerWatcher struct {
	// contains filtered or unexported fields
}

func NewSyncWorkerWatcher(allocator Allocator, log *slog.Logger, numWorkers uint64, allocateTimeout time.Duration) *WorkerWatcher

NewSyncWorkerWatcher is a constructor for the Watcher

func (ww *WorkerWatcher) AddWorker() error

func (ww *WorkerWatcher) Allocate() error

func (ww *WorkerWatcher) Destroy(ctx context.Context)

Destroy all underlying containers (but let them complete the task)

func (ww *WorkerWatcher) FreeWorkers() int

FreeWorkers returns the number of workers currently idling in the container.

func (ww *WorkerWatcher) List() []*worker.Process

List - this is O(n) operation, and it will return copy of the actual workers

func (ww *WorkerWatcher) NumWorkers() uint64

NumWorkers returns the live number of workers tracked by the watcher.

func (ww *WorkerWatcher) Release(w *worker.Process)

Release O(1) operation

func (ww *WorkerWatcher) RemoveWorker(ctx context.Context) error

func (ww *WorkerWatcher) Reset(ctx context.Context) uint64

func (ww *WorkerWatcher) Take(ctx context.Context) (*worker.Process, error)

Take returns a worker in the Ready state from the container

func (ww *WorkerWatcher) Watch(workers []*worker.Process)

Path	Synopsis
container
channel