model

Documentation

Index

• func Callback(g Service, namespace string, identity string, costTime *CostTime, err error) error
• func EnableExecute(g Service, namespace, identity string) bool
• type BaseJobData
• type CostTime
  • func NewCostTime() *CostTime
  • func (c *CostTime) GetMillionSecond() int64
• type ExecHistory
• type JobInfo
• type Service
• type ServiceEntity
  • func NewService(TaskName string, Config *viper.Viper) *ServiceEntity
  • func (g *ServiceEntity) Do(job *work.Job) error
  • func (g *ServiceEntity) GetConfig() *viper.Viper
  • func (g *ServiceEntity) GetMongoClient() *mongo.Client
  • func (g *ServiceEntity) GetRegisterInfo() *JobInfo
  • func (g *ServiceEntity) GetTaskName() string
• type Status
  • func (p Status) String() string

Functions

func Callback

func Callback(g Service, namespace string, identity string, costTime *CostTime, err error) error

func EnableExecute

func EnableExecute(g Service, namespace, identity string) bool

Types

type BaseJobData

type BaseJobData struct {
	Identity string `json:"identity"`
}

type CostTime

type CostTime struct {
	Start time.Time
	Since time.Duration
}

func NewCostTime

func NewCostTime() *CostTime

func (*CostTime) GetMillionSecond

func (c *CostTime) GetMillionSecond() int64

type ExecHistory

type ExecHistory struct {
	Status     string    `json:"history"`
	Message    string    `json:"message"`
	CostTime   int64     `json:"costTime"`
	CompleteAt time.Time `json:"completeAt"`
}

type JobInfo

type JobInfo struct {
	Name   string
	Job    go_worker.Job
	Option *work.JobOptions
}

type Service

type Service interface {
	GetRegisterInfo() *JobInfo
	Do(job *work.Job) error
	GetTaskName() string
	GetConfig() *viper.Viper
	GetMongoClient() *mongo.Client
}

type ServiceEntity

type ServiceEntity struct {
	TaskName    string
	Config      *viper.Viper
	MongoClient *mongo.Client
}

func NewService

func NewService(TaskName string, Config *viper.Viper) *ServiceEntity

func (*ServiceEntity) Do

func (g *ServiceEntity) Do(job *work.Job) error

func (*ServiceEntity) GetConfig

func (g *ServiceEntity) GetConfig() *viper.Viper

func (*ServiceEntity) GetMongoClient

func (g *ServiceEntity) GetMongoClient() *mongo.Client

func (*ServiceEntity) GetRegisterInfo

func (g *ServiceEntity) GetRegisterInfo() *JobInfo

func (*ServiceEntity) GetTaskName

func (g *ServiceEntity) GetTaskName() string

type Status

type Status int

const (
	Pending Status = iota
	Running
	Failed
	Succeeded
)

func (Status) String

func (p Status) String() string