model

Documentation

Index

• func Callback(g Service, identity string, 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 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, identity string, 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 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