worknodes

Documentation

Index

• type WorkerNodes
  • func New(workerNum int) *WorkerNodes
  • func (w *WorkerNodes) AddJob(job worker.Job)
  • func (w *WorkerNodes) Close()

Types

type WorkerNodes

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

WorkerNodes a worker list

func New

func New(workerNum int) *WorkerNodes

New return a container of workers

func (*WorkerNodes) AddJob

func (w *WorkerNodes) AddJob(job worker.Job)

AddJob add a job to one of workers basis of key

func (*WorkerNodes) Close

func (w *WorkerNodes) Close()

Close close all worker