model

Documentation

Index

• type JobInfo
• type Service
  • func NewService(taskName string, config *viper.Viper) Service
• type ServiceEntity
  • func (g *ServiceEntity) Do(job *work.Job) error
  • func (g *ServiceEntity) GetConfig() *viper.Viper
  • func (g *ServiceEntity) GetRegisterInfo() *JobInfo
  • func (g *ServiceEntity) GetTaskName() string

Types

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
}

func NewService

func NewService(taskName string, config *viper.Viper) Service

type ServiceEntity

type ServiceEntity struct {
	// contains filtered or unexported fields
}

func (*ServiceEntity) Do

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

func (*ServiceEntity) GetConfig

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

func (*ServiceEntity) GetRegisterInfo

func (g *ServiceEntity) GetRegisterInfo() *JobInfo

func (*ServiceEntity) GetTaskName

func (g *ServiceEntity) GetTaskName() string