worker_watcher

Documentation

Index

• func NewSyncWorkerWatcher(allocator worker.Allocator, log *zap.Logger, numWorkers uint64, ...) *workerWatcher
• type Vector

Functions

func NewSyncWorkerWatcher

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

NewSyncWorkerWatcher is a constructor for the Watcher

Types

type Vector

type Vector interface {
	// Push used to put worker to the vector
	Push(worker.BaseProcess)
	// Pop used to get worker from the vector
	Pop(ctx context.Context) (worker.BaseProcess, error)
	// Remove worker with provided pid
	Remove(pid int64)
	// Destroy used to stop releasing the workers
	Destroy()
}

Vector interface represents vector container