- update jobs

master
李光春 2 years ago
parent d3b49e7d93
commit 51f164e4d8

@ -62,16 +62,11 @@ func NewJobsGorm(attrs ...*OperationAttr) (*JobsGorm, error) {
if attr.lockPrefix != "" {
c.config.lockPrefix = attr.lockPrefix
}
if attr.outsideIp != "" {
c.config.outsideIp = attr.outsideIp
}
}
c.config.runVersion = go_library.Version()
c.config.os = runtime.GOOS
c.config.arch = runtime.GOARCH
c.config.maxProCs = runtime.GOMAXPROCS(0)
c.config.version = runtime.Version()
c.config.macAddrS = goarray.TurnString(goip.GetMacAddr())
c.config.insideIp = goip.GetInsideIp()
if c.config.outsideIp == "" {
return nil, errors.New("需要配置当前的IP")
}
@ -80,6 +75,14 @@ func NewJobsGorm(attrs ...*OperationAttr) (*JobsGorm, error) {
return nil, errors.New("需要配置数据库驱动")
}
c.config.runVersion = go_library.Version()
c.config.os = runtime.GOOS
c.config.arch = runtime.GOARCH
c.config.maxProCs = runtime.GOMAXPROCS(0)
c.config.version = runtime.Version()
c.config.macAddrS = goarray.TurnString(goip.GetMacAddr())
c.config.insideIp = goip.GetInsideIp()
switch c.config.lockType {
case lockTypeRedis:
if c.db.redisClient == nil {

@ -20,6 +20,7 @@ type OperationAttr struct {
lockPrefix string // 锁Key前缀
ipService *goip.Client // ip服务
lockType string // 锁驱动类型
outsideIp string // 外网ip
}
// WithGormClient 设置数据库驱动
@ -44,6 +45,11 @@ func WithLockPrefix(lockPrefix string) *OperationAttr {
return &OperationAttr{lockPrefix: lockPrefix}
}
// WithOutsideIp 设置外网ip
func WithOutsideIp(outsideIp string) *OperationAttr {
return &OperationAttr{outsideIp: outsideIp}
}
// WithIpService 设置ip服务
func WithIpService(ipService *goip.Client) *OperationAttr {
return &OperationAttr{ipService: ipService}

Loading…
Cancel
Save