distribute

Mar 14, 2018

Changes in this version

+ func MasterApi(n Distributer) teleport.API

+ func SlaveApi(n Distributer) teleport.API

+ type Distributer interface

+ CountNodes func() int

+ Receive func(task *Task)

+ Send func(clientNum int) Task

+ type Task struct

+ DockerCap int

+ DockerQueueCap int

+ FailureInherit bool

+ Id int

+ Keyins string

+ Limit int64

+ OutType string

+ Pausetime int64

+ ProxyMinute int64

+ Spiders []map[string]string

+ SuccessInherit bool

+ ThreadNum int

+ type TaskJar struct

+ Tasks chan *Task

+ func NewTaskJar() *TaskJar

+ func (self *TaskJar) Len() int

+ func (self *TaskJar) Pull() *Task

+ func (self *TaskJar) Push(task *Task)

+ func (self *TaskJar) Receive(task *Task)

+ func (self *TaskJar) Send(clientNum int) Task