worker_watcher

Documentation

Index

• type WorkerWatcher
  • func NewSyncWorkerWatcher(allocator pool.Allocator, log *zap.Logger, numWorkers uint64, ...) *WorkerWatcher
  • func (ww *WorkerWatcher) Allocate() error
  • func (ww *WorkerWatcher) Destroy(ctx context.Context)
  • func (ww *WorkerWatcher) List() []*worker.Process
  • func (ww *WorkerWatcher) Release(w *worker.Process)
  • func (ww *WorkerWatcher) Remove(wb *worker.Process)
  • func (ww *WorkerWatcher) Reset(ctx context.Context)
  • func (ww *WorkerWatcher) Take(ctx context.Context) (*worker.Process, error)
  • func (ww *WorkerWatcher) Watch(workers []*worker.Process) error

Types

type WorkerWatcher

type WorkerWatcher struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewSyncWorkerWatcher

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

NewSyncWorkerWatcher is a constructor for the Watcher

func (*WorkerWatcher) Allocate

func (ww *WorkerWatcher) Allocate() error

func (*WorkerWatcher) Destroy

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

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

func (*WorkerWatcher) List

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

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

func (*WorkerWatcher) Release

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

Release O(1) operation

func (*WorkerWatcher) Remove

func (ww *WorkerWatcher) Remove(wb *worker.Process)

Remove worker

func (*WorkerWatcher) Reset

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

func (*WorkerWatcher) Take

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

Take is not a thread safe operation

func (*WorkerWatcher) Watch

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