|
|
@ -4,6 +4,7 @@ import (
|
|
|
|
"errors"
|
|
|
|
"errors"
|
|
|
|
"fmt"
|
|
|
|
"fmt"
|
|
|
|
"go.dtapp.net/library/utils/gojobs/jobs_gorm_model"
|
|
|
|
"go.dtapp.net/library/utils/gojobs/jobs_gorm_model"
|
|
|
|
|
|
|
|
"log"
|
|
|
|
"math/rand"
|
|
|
|
"math/rand"
|
|
|
|
"time"
|
|
|
|
"time"
|
|
|
|
)
|
|
|
|
)
|
|
|
@ -20,6 +21,9 @@ func (j *JobsGorm) GetEtcdIssueAddress(server *Etcd, v jobs_gorm_model.Task) (ad
|
|
|
|
appointIpStatus = true
|
|
|
|
appointIpStatus = true
|
|
|
|
}
|
|
|
|
}
|
|
|
|
workers, err := server.ListWorkers()
|
|
|
|
workers, err := server.ListWorkers()
|
|
|
|
|
|
|
|
if j.config.Debug == true {
|
|
|
|
|
|
|
|
log.Printf("客户端列表:%+v\n", workers)
|
|
|
|
|
|
|
|
}
|
|
|
|
if err != nil {
|
|
|
|
if err != nil {
|
|
|
|
return address, errors.New(fmt.Sprintf("获取在线客户端列表失败:%s", err.Error()))
|
|
|
|
return address, errors.New(fmt.Sprintf("获取在线客户端列表失败:%s", err.Error()))
|
|
|
|
}
|
|
|
|
}
|
|
|
|