job

type ApiJob struct {
	SimpleJob
}

type DisJob func(jid string, k, v interface{}) (interface{}, error)

type DoJob func(jid string, args interface{}) (interface{}, error)

type DoRlt func(jid string, res interface{}) (interface{}, error)

type FinishSyncInfo struct {
	Id string `json:"id"`
}

type Job interface {
	GetId() string
	Run(chan bool)
	Distribute(jid string, k, v interface{}) error
	Retry()
	RltCallback(jid string, v interface{}) (interface{}, error)
	Finish()
	Stop()
}

type JobArgs struct {
	Name    string      `json:"name"`
	Host    string      `json:"host"`
	Path    string      `json:"path"`
	Args    interface{} `json:"args"`
	Scheme  string      `json:"scheme"`
	Method  string      `json:"method"`
	Timeout int         `json:"timeout"`
}

type JobResWithArgs struct {
	Args     *JobArgs
	Response *grequests.Response
	Result   string
}

type NewSyncInfo struct {
	Id      string `json:"id"`
	Name    string `json:"name"`
	ConNum  int    `json:"con_num"`
	Timeout int    `json:"timeout"`
	NeedRes bool   `json:"need_res"`
}

type SimpleJob struct {
	Id      string
	Name    string
	Mode    int
	Meta    map[string]interface{}
	Workers []string
	ConNum  int
	Timeout int
	NeedRes bool //whether save the result to redis
	//stop job channel
	Done chan bool
	//
	Dis DisJob
	Do  DoJob
	Rlt DoRlt

	Rds redis.UniversalClient
}

type StopSyncInfo struct {
	Id string `json:"id"`
}

type TransInfo struct {
	Action string `json:"action"`
	Data   string `json:"data"`
}