model

Documentation

Index

• func CalCostTime(c *CostTime) func()
• func Callback(g Service, namespace string, identity string, costTime *CostTime, err error) error
• type BaseJobData
• type CallbackReceiver
  • func (s *CallbackReceiver) InterfaceToObject(in interface{}) (*CallbackReceiver, error)
• type CallbackSender
  • func (s *CallbackSender) InterfaceToObject(in interface{}) (*CallbackSender, error)
• 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 CalCostTime

func CalCostTime(c *CostTime) func()

func Callback

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

Types

type BaseJobData

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

type CallbackReceiver

type CallbackReceiver struct {
	IdentityID string                 `json:"identityId"`
	Status     string                 `json:"status"`
	IsComplete bool                   `json:"isComplete"`
	Body       string                 `json:"body"`
	ErrMsg     string                 `json:"errMsg"`
	Args       map[string]interface{} `json:"args"`
}

func (*CallbackReceiver) InterfaceToObject

func (s *CallbackReceiver) InterfaceToObject(in interface{}) (*CallbackReceiver, error)

type CallbackSender

type CallbackSender struct {
	CallbackReceiver
	Namespace string `json:"namespace"`
	Identity  string `json:"identity"`
}

func (*CallbackSender) InterfaceToObject

func (s *CallbackSender) InterfaceToObject(in interface{}) (*CallbackSender, error)

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