worker_watcher

Documentation

Index

• func NewWorkerWatcher(allocator worker.Allocator, numWorkers int64, events events.Handler) worker.Watcher
• type Stack
  • func NewWorkersStack() *Stack
  • func (stack *Stack) Destroy(ctx context.Context)
  • func (stack *Stack) FindAndRemoveByPid(pid int64) bool
  • func (stack *Stack) IsEmpty() bool
  • func (stack *Stack) Pop() (worker.BaseProcess, bool)
  • func (stack *Stack) Push(w worker.BaseProcess)
  • func (stack *Stack) Reset()
  • func (stack *Stack) Workers() []worker.BaseProcess

Functions

func NewWorkerWatcher

func NewWorkerWatcher(allocator worker.Allocator, numWorkers int64, events events.Handler) worker.Watcher

workerCreateFunc can be nil, but in that case, dead stack will not be replaced

Types

type Stack

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

func NewWorkersStack

func NewWorkersStack() *Stack

func (*Stack) Destroy

func (stack *Stack) Destroy(ctx context.Context)

we also have to give a chance to pool to Push worker (return it)

func (*Stack) FindAndRemoveByPid

func (stack *Stack) FindAndRemoveByPid(pid int64) bool

func (*Stack) IsEmpty

func (stack *Stack) IsEmpty() bool

func (*Stack) Pop

func (stack *Stack) Pop() (worker.BaseProcess, bool)

func (*Stack) Push

func (stack *Stack) Push(w worker.BaseProcess)

Push worker back to the stack If stack in destroy state, Push will provide 100ms window to unlock the mutex

func (*Stack) Reset

func (stack *Stack) Reset()

func (*Stack) Workers

func (stack *Stack) Workers() []worker.BaseProcess

Workers return copy of the workers in the stack