model

Documentation

Overview

Package model for list model

Index

• Constants
• type CreateTaskReq
• type CreateTaskResp
• type GetTaskCountByStatusReq
• type GetTaskCountByStatusResp
• type GetTaskListReq
• type GetTaskListResp
• type GetTaskReq
• type GetTaskResp
• type GetTaskScheduleCfgListReq
• type GetTaskScheduleCfgListResp
• type HoldTasksReq
• type HoldTasksResp
• type RespComm
• type SetTaskReq
• type SetTaskResp
• type SetTaskStatusReq
• type SetTaskStatusResp
• type TaskData
• type TaskScheduleCfg

Constants

const (
	GET_TASK_LIST_SUFFIX         = "/get_task_list"
	GET_TASK_SUFFIX              = "/get_task"
	HOLD_TASKS                   = "/hold_tasks"
	SET_TASK_SUFFIX              = "/set_task"
	CREATE_TASK_SUFFIX           = "/create_task"
	GET_TASK_SCHEDULE_CFG_SUFFIX = "/get_task_schedule_cfg_list"
)

const (
	SCHEDULE_TASK_LIMIT = 100
)

const (
	STATS_TASK_COUNT = "/stats_task_count"
)

Types

type CreateTaskReq

type CreateTaskReq struct {
	// 'json:"taskType"' 是一个标签，用于在序列化和反序列化时记录字段的名称。
	TaskData TaskData `json:"taskData"`
}

CreateTaskReq 请求消息

type CreateTaskResp

type CreateTaskResp struct {
	RespComm
	TaskId string `json:"taskId"`
}

CreateTaskResp 响应消息

type GetTaskCountByStatusReq

type GetTaskCountByStatusReq struct {
	TaskType string `json:"taskType" form:"taskType"`
	Status   int    `json:"status" form:"status"`
}

GetTaskCountByStatusReq 请求消息

type GetTaskCountByStatusResp

type GetTaskCountByStatusResp struct {
	RespComm
	Count int `json:"count"`
}

GetTaskCountByStatusResp 响应消息

type GetTaskListReq

type GetTaskListReq struct {
	TaskType string `json:"taskType" form:"taskType"`
	Status   int    `json:"status" form:"status"`
	Limit    int    `json:"limit" form:"limit"`
}

GetTaskListReq 请求消息

type GetTaskListResp

type GetTaskListResp struct {
	RespComm
	TaskList []*TaskData `json:"taskList"`
}

GetTaskListResp 响应消息

type GetTaskReq

type GetTaskReq struct {
	TaskId string `json:"taskId" form:"taskId"`
}

GetTaskReq 请求消息

type GetTaskResp

type GetTaskResp struct {
	RespComm
	TaskData *TaskData `json:"taskData"`
}

GetTaskResp 响应消息

type GetTaskScheduleCfgListReq

type GetTaskScheduleCfgListReq struct {
}

GetTaskScheduleCfgListReq 请求消息

type GetTaskScheduleCfgListResp

type GetTaskScheduleCfgListResp struct {
	RespComm
	ScheduleCfgList []*TaskScheduleCfg `json:"scheduleCfgList"`
}

GetTaskScheduleCfgListResp 响应消息

type HoldTasksReq

type HoldTasksReq struct {
	TaskType string `json:"taskType" form:"taskType"`
	Limit    int    `json:"limit" form:"limit"`
}

GetTaskListReq 请求消息

type HoldTasksResp

type HoldTasksResp struct {
	RespComm
	TaskList []*TaskData `json:"taskList"`
}

GetTaskListResp 响应消息

type RespComm

type RespComm struct {
	Code int    `json:"code"`
	Msg  string `json:"msg"`
}

RespComm 通用的响应消息

type SetTaskReq

type SetTaskReq struct {
	TaskId   string `json:"taskId"`
	TaskData `json:"TaskData"`
	Context  string `json:"context"`
}

SetTaskReq 请求消息

type SetTaskResp

type SetTaskResp struct {
	RespComm
}

SetTaskResp 响应消息

type SetTaskStatusReq

type SetTaskStatusReq struct {
	TaskId       string `json:"taskId"`
	Status       int    `json:"status"`
	NoModifyTime bool   `json:"noModifyTime"`
}

SetTaskStatusReq 请求消息

type SetTaskStatusResp

type SetTaskStatusResp struct {
	RespComm
}

SetTaskStatusResp 响应消息

type TaskData

type TaskData struct {
	UserId           string     `json:"userId"`
	TaskId           string     `json:"taskId"`
	TaskType         string     `json:"taskType"`
	TaskStage        string     `json:"taskStage"`
	Status           int        `json:"status"`
	Priority         *int       `json:"priority"`
	CrtRetryNum      int        `json:"crtRetryNum"`
	MaxRetryNum      int        `json:"maxRetryNum"`
	MaxRetryInterval int        `json:"maxRetryInterval"`
	ScheduleLog      string     `json:"scheduleLog"`
	TaskContext      string     `json:"context"`
	OrderTime        int64      `json:"orderTime"`
	CreateTime       *time.Time `json:"createTime"`
	ModifyTime       *time.Time `json:"modifyTime"`
}

TaskData 任务调度数据

type TaskScheduleCfg

type TaskScheduleCfg struct {
	TaskType          string
	ScheduleLimit     int
	ScheduleInterval  int
	MaxProcessingTime int64
	MaxRetryNum       int
	MaxRetryInterval  int
	CreateTime        *time.Time
	ModifyTime        *time.Time
}

TaskScheduleCfg 任务调度信息