job

Documentation

Index

• type Func
• type HandlerList
  • func GetAllHandlerList() *HandlerList
  • func GetRunningJobList() *HandlerList
  • func (t *HandlerList) Del(key string)
  • func (t *HandlerList) Get(key string) (Job, bool)
  • func (t *HandlerList) Set(key string, val Job)
• type Job
• type Resp

Types

type Func

type Func func(ctx *server.Context) Resp

type HandlerList

type HandlerList struct {
	sync.Map
}

var (
	RunningHandlerList *HandlerList
	AllHandlerList     *HandlerList
)

func GetAllHandlerList

func GetAllHandlerList() *HandlerList

func GetRunningJobList

func GetRunningJobList() *HandlerList

func (*HandlerList) Del

func (t *HandlerList) Del(key string)

func (*HandlerList) Get

func (t *HandlerList) Get(key string) (Job, bool)

func (*HandlerList) Set

func (t *HandlerList) Set(key string, val Job)

type Job

type Job struct {
	Id        int64
	Name      string
	Ext       context.Context
	Cancel    context.CancelFunc
	Fn        Func
	Param     *server.RunReq
	StartTime int64
	EndTime   int64
}

type Resp

type Resp struct {
	LogID       int64  `json:"logId"`
	LogDateTime int64  `json:"logDateTime"`
	HandleCode  int    `json:"handleCode"`
	HandleMsg   string `json:"handleMsg"`
}