service

package
v0.0.0-...-a9e7740 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 12, 2020 License: Artistic-2.0 Imports: 33 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	Counter sync.Map
)

调度计数器

View Source
var (
	CronParse = cron.NewParser(options)
)
View Source
var (
	NotifyTypeList = map[int8]NotifyTypeDetail{
		1: {Id: 1, NotifyName: "邮件"},
	}
)
View Source
var ServersGroupList = map[int]map[string]interface{}{
	1: {"id": 1, "group_name": "内网服务器"},
	2: {"id": 2, "group_name": "外网服务器"},
}
View Source
var TaskGroupList = map[int]map[string]interface{}{
	1: {"id": 1, "group_name": "服务器任务"},
	2: {"id": 2, "group_name": "业务层任务"},
}

Functions

func AddJob

func AddJob(spec string, job *Job) bool

func AddJobFunc

func AddJobFunc()

增加定时方法

func AdminCreateOrUpdate

func AdminCreateOrUpdate(adminJ *AdminRequest) error

创建或者新增

func BanList

func BanList() (interface{}, error)

func DelAdminLoginData

func DelAdminLoginData(userId int) bool

删除管理员登录信息

func EditBan

func EditBan(data []string, id string) error

func ExecuteTask

func ExecuteTask(taskId int) error

任务执行

func GetCounter

func GetCounter(key string) int

func GetEntryById

func GetEntryById(taskId int) bool

func GetRouteData

func GetRouteData() (map[int]*RouteCache, error)

获取路由组信息

func GetUserRouteById

func GetUserRouteById(userId int) []interface{}

根据用户id获取路由信息

func Init

func Init()

func InitJobs

func InitJobs()

初始化定时任务

func IsBan

func IsBan(order string) error

func NotifyCreateOrUpdate

func NotifyCreateOrUpdate(data *NotifyTplDetail, adminId int) error

创建或者新增

func NotifyDelete

func NotifyDelete(NotifyTplId int) error

func PushMessage

func PushMessage(message *MessageData) error

func PushTakRunLog

func PushTakRunLog(log *TaskRunLog) error

func RedisDataReload

func RedisDataReload(funcList ...string)

redis数据重新加载

func RefreshLogin

func RefreshLogin(userId int) error

刷新登陆信息

func RemoteAgent

func RemoteAgent(servers *models.TaskServers) error

func RemoteCommandByKey

func RemoteCommandByKey(servers *models.TaskServers) error

func RemoteCommandByPassword

func RemoteCommandByPassword(servers *models.TaskServers) error

func RemoteCommandByTelnetPassword

func RemoteCommandByTelnetPassword(servers *models.TaskServers) error

func RoleCreateOrUpdate

func RoleCreateOrUpdate(roleJ *RoleRequest) error

创建或者新增

func RoleDelete

func RoleDelete(roleId int) error

func RouteCreateOrUpdate

func RouteCreateOrUpdate(params *RouteDetail) error

创建或者新增

func RouteDelete

func RouteDelete(routeId int) int

func RouteEdit

func RouteEdit(routeParams *RouteEditParams) int

func RunServer

func RunServer(j *Job) bool

func ServersCreateOrUpdate

func ServersCreateOrUpdate(params *ServersDetail) error

创建或者新增

func ServersDelete

func ServersDelete(routeId int) error

func SetAdminLoginData

func SetAdminLoginData(data *models.Admin, Role string) bool

设置管理员登录信息

func SetCounter

func SetCounter(key string)

func SetRoleData

func SetRoleData() (map[int]*RoleCache, error)

设置角色组信息

func SetRouteData

func SetRouteData() (map[int]*RouteCache, error)

设置路由信息

func SetRouteSort

func SetRouteSort(routeId int, sort int16) error

设置排序顺序

func SetTaskState

func SetTaskState(taskId int, status int8) error

设置任务状态

func TaskAudit

func TaskAudit(taskId int, audit int8) error

任务审核

func TaskCreateOrUpdate

func TaskCreateOrUpdate(params *TaskDetail, userId int) error

创建或者新增

func TaskDelete

func TaskDelete(taskId int) error

任务删除

func TaskLogGather

func TaskLogGather()

定时任务日志收集

func TestServer

func TestServer(server *models.TaskServers) error

测试服务器

Types

type AdminBrief

type AdminBrief struct {
	Id       int    `json:"user_id"`
	RealName string `json:"real_name"` //用户名称
}

type AdminData

type AdminData struct {
	Id       int    `json:"user_id"`
	RealName string `json:"real_name"` //用户名称
	Sex      int8   `json:"sex"`       //性別
	Status   int8   `json:"status"`    //状态
	Birthday int    `json:"birthday"`  //生日
	Phone    string `json:"phone"`     //手机
	RoleId   int    `json:"role_id"`   //角色id
	RoleName string `json:"role_name"` //角色名称
}

type AdminDataValid

type AdminDataValid struct {
	UserName string `valid:"Required;MinSize(5);MaxSize(32)"`
	Password string `valid:"Required;Length(32)"`
	RealName string `valid:"Required;MinSize(2);MaxSize(10)"`
	Birthday string `valid:"Required"`
	Phone    string `valid:"Required;Phone"`
	Email    string `valid:"Required;Email"`
	Sex      int8   `valid:"Required;Range(0,2)"`
	Status   int8   `valid:"Required;Range(0,2)"`
	RoleId   int    `valid:"Required"`
	RouteIds string `valid:"MaxSize(200)"`
}

Admin 用户数据校验--注册

type AdminDetail

type AdminDetail struct {
	UserId       int    `json:"user_id"`
	Username     string `json:"username"`
	RealName     string `json:"real_name"`
	Status       int8   `json:"status"`
	Birthday     string `json:"birthday"`
	Phone        string `json:"phone"`
	Email        string `json:"email"`
	Sex          int8   `json:"sex"`
	RoleId       int    `json:"role_id"`
	RouteIds     string `json:"route_ids"`
	Introduction string `json:"introduction"`
}

func AdminDetailById

func AdminDetailById(userId int) (AdminDetail, error)

查询用户数据

type AdminListData

type AdminListData struct {
	Total int64        `json:"total"` //用户数量
	List  []*AdminData `json:"list"`  // 用户列表
}

func AdminList

func AdminList(adminJ *AdminParams) (error, *AdminListData)

查询管理员列表

type AdminLoginData

type AdminLoginData struct {
	UserId       int    `json:"user_id"`      //用户id
	RealName     string `json:"real_name"`    //用户名称
	Sex          int8   `json:"sex"`          //性別
	Token        string `json:"token"`        //秘钥
	Introduction string `json:"introduction"` //描述
	Menu         *Menu  `json:"menu"`         // 菜单
}

Admin 用户登录返回值

func AdminLogin

func AdminLogin(params *AdminRequest) (*AdminLoginData, int, error)

管理员登录

func AdminReLogin

func AdminReLogin(userId int, ip string, token string) (*AdminLoginData, int, error)

重新登录

type AdminLoginRedisData

type AdminLoginRedisData struct {
	UserId       int    `json:"user_id"`      //用户id
	RealName     string `json:"real_name"`    //姓名
	Birthday     int    `json:"birthday"`     //出生日期时间戳
	Phone        string `json:"phone"`        //手机号码
	Sex          int8   `json:"sex"`          //性别
	RoleId       int    `json:"role_id"`      //角色id
	Role         string `json:"role"`         //角色
	RouteIds     string `json:"route_ids"`    //路由id
	Introduction string `json:"introduction"` //介绍
}

Admin 管理员-登录redis缓存数据

func GetAdminLoginData

func GetAdminLoginData(UserId int) AdminLoginRedisData

获取用户登录信息

type AdminLoginValid

type AdminLoginValid struct {
	UserName string `valid:"Required;MinSize(5);MaxSize(32)"`
	Password string `valid:"Required;Length(32)"`
}

Admin 用户登录校验

type AdminParams

type AdminParams struct {
	UserId   int
	Page     int
	Limit    int
	RealName string
	RoleId   int
	Sort     string
}

type AdminRequest

type AdminRequest struct {
	UserId       int    `json:"user_id"`      //用户id
	UserName     string `json:"username"`     //用户名
	PassWord     string `json:"password"`     //密码
	RealName     string `json:"real_name"`    //姓名
	Birthday     string `json:"birthday"`     //出生日期
	Status       int8   `json:"status"`       //状态
	IsDelete     int8   `json:"is_delete"`    //是否删除
	Phone        string `json:"phone"`        //手机号码
	Email        string `json:"email"`        //邮箱
	Sex          int8   `json:"sex"`          //性别
	RoleId       int    `json:"role_id"`      //角色id
	Ip           string `json:"ip"`           //ip地址
	Introduction string `json:"introduction"` //描述
	RouteIds     string `json:"route_ids"`    //路由id
}

Admin 管理员-请求数据

type AdminUpdateDataValid

type AdminUpdateDataValid struct {
	UserId   int    `valid:"Required"`
	RealName string `valid:"Required;MinSize(2);MaxSize(10)"`
	Birthday string `valid:"Required"`
	Phone    string `valid:"Required;Phone"`
	Email    string `valid:"Required;Email"`
	Sex      int8   `valid:"Required;Range(0,2)"`
	RoleId   int    `valid:"Required"`
	RouteIds string `valid:"MaxSize(200)"`
}

Admin 用户数据校验--修改

type BanListData

type BanListData struct {
	Id      string   `json:"_id"`
	BanList []string `json:"ban_list"`
	Ctime   int      `json:"ctime"`
	Utime   int      `json:"utime"`
}

type BanListFind

type BanListFind struct {
	Id      primitive.ObjectID `bson:"_id"`
	BanList []string           `bson:"ban_list"`
	Ctime   int                `bson:"ctime"`
	Utime   int                `bson:"utime"`
}

type DataCount

type DataCount struct {
	ActualData []int64  `json:"actual_data"`
	DateData   []string `json:"date_data"`
	Total      int64    `json:"total"`
}

总用户数

type IndexData

type IndexData struct {
	UserCount   DataCount `json:"user_count"`
	AuditTask   DataCount `json:"audit_task"`
	SuccessTask DataCount `json:"success_task"`
	FailTask    DataCount `json:"fail_task"`
}

首页统计数据

func GetIndexData

func GetIndexData() (IndexData, error)

type Job

type Job struct {
	Id         int                            // taskID
	LogId      interface{}                    // 日志记录ID
	ServerId   int                            // 执行器信息
	ServerName string                         // 执行器名称
	ServerType int8                           // 执行器类型, 0-ssh 1-telnet 2-agent
	Name       string                         // 任务名称
	Task       *models.Task                   // 任务对象
	RunFunc    func(time.Duration) *JobResult // 执行函数
	Status     int                            // 任务状态,大于0表示正在执行中
	Concurrent bool                           // 同一个任务是否允许并行执行
}

func NewCommandJob

func NewCommandJob(id int, serverId int, name string, command string) *Job

生成一个指定任务

func NewJobFromTask

func NewJobFromTask(task *models.Task) ([]*Job, error)

创建任务

func RemoteCommandJob

func RemoteCommandJob(id int, serverId int, name string, command string, servers *models.TaskServers) *Job

远程执行任务 密钥验证

func RemoteCommandJobByAgentPassword

func RemoteCommandJobByAgentPassword(id int, serverId int, name string, command string, servers *models.TaskServers) *Job

func RemoteCommandJobByPassword

func RemoteCommandJobByPassword(id int, serverId int, name string, command string, servers *models.TaskServers) *Job

func RemoteCommandJobByTelnetPassword

func RemoteCommandJobByTelnetPassword(id int, serverId int, name string, command string, servers *models.TaskServers) *Job

func (*Job) Run

func (j *Job) Run()

type JobResult

type JobResult struct {
	OutMsg    string
	ErrMsg    string
	IsOk      bool
	IsTimeout bool
}
type Menu struct {
	List []*MenuData `json:"list"` // 路由列表
}

前端菜单

func MenuList(adminId int) (*Menu, error)
type MenuData struct {
	Id        int         `json:"-"`
	ParentId  int         `json:"-"`                  //父id
	Path      string      `json:"path"`               //路径
	Redirect  string      `json:"redirect"`           //重定向
	Name      string      `json:"name"`               //唯一标识
	Meta      Meta        `json:"meta,omitempty"`     //meta信息
	Hidden    int8        `json:"hidden"`             //是否显示
	Component string      `json:"component"`          //view地址
	Child     []*MenuData `json:"children,omitempty"` //子节点
}

type MessageData

type MessageData struct {
	TplId       int               `json:"tpl_id"`       //模板id
	ToUser      []string          `json:"to_user"`      //接收人
	ExtraParams map[string]string `json:"extra_params"` //额外参数
}

type MessageRes

type MessageRes struct {
	Status bool
	Info   string
}

func SendMsg

func SendMsg(data *MessageData) (res *MessageRes, err error)

type Meta

type Meta struct {
	Title string `json:"title"`
	Icon  string `json:"icon"`
}

type NotifyData

type NotifyData struct {
	AdminList  []AdminBrief       `json:"admin_list,omitempty"`
	NotifyType []NotifyTypeDetail `json:"notify_type,omitempty"`
	NotifyTpl  []NotifyTplBrief   `json:"notify_tpl,omitempty"`
}

func GetNotifyData

func GetNotifyData(expand string) NotifyData

type NotifyTplBrief

type NotifyTplBrief struct {
	Id      int    `json:"id"`
	TplName string `json:"tpl_name"`
}

type NotifyTplDetail

type NotifyTplDetail struct {
	Id             int    `json:"id"`
	TplName        string `json:"tpl_name" valid:"Required;"`
	NotifyType     int8   `json:"notify_type" valid:"Required;"`
	NotifyTypeName string `json:"notify_type_name"`
	TplData        string `json:"tpl_data,omitempty" valid:"Required;MaxSize(500)" `
	Status         int8   `json:"status"`
	Ctime          int    `json:"ctime,omitempty"`
	Utime          int    `json:"utime,omitempty"`
}

func NotifyDetailById

func NotifyDetailById(id int) (NotifyTplDetail, error)

func (*NotifyTplDetail) Valid

func (tpl *NotifyTplDetail) Valid(v *validation.Validation)

type NotifyTplListData

type NotifyTplListData struct {
	Total int64             `json:"total"`
	List  []NotifyTplDetail `json:"list"`
}

查询返回数据

func NotifyTplList

func NotifyTplList(params *NotifyTplParams) (error, NotifyTplListData)

type NotifyTplOperation

type NotifyTplOperation struct {
	TplIds string `json:"tpl_ids"`
	Status int8   `json:"status"`
	Audit  int8   `json:"audit"`
}

type NotifyTplParams

type NotifyTplParams struct {
	Page  int
	Limit int
}

查询

type NotifyTypeDetail

type NotifyTypeDetail struct {
	Id         int8   `json:"id"`
	NotifyName string `json:"notify_name"`
}

type RoleCache

type RoleCache struct {
	Id        int    `json:"id"`
	Role      string `json:"role"`
	RoleName  string `json:"role_name"`
	ParentId  int    `json:"parent_id"`
	RoutesIds string `json:"routes_ids"`
}

type RoleData

type RoleData struct {
	Id       int    `json:"role_id"`
	ParentId int    `json:"parent_id"` //父id
	RoleName string `json:"role_name"` //角色名称
	Role     string `json:"role"`      //角色别名
	Status   int8   `json:"status"`    //状态
	Ctime    int    `json:"ctime"`     //创建时间
}

func RoleAll

func RoleAll() ([]*RoleData, error)

查询全部管理员角色

type RoleDataTree

type RoleDataTree struct {
	Id       int             `json:"role_id"`
	ParentId int             `json:"parent_id"` //父id
	RoleName string          `json:"role_name"` //角色名称
	Role     string          `json:"role"`      //角色别名
	Status   int8            `json:"status"`    //状态
	Ctime    int             `json:"ctime"`     //创建时间
	Child    []*RoleDataTree `json:"child"`     //子节点
}

type RoleDetail

type RoleDetail struct {
	Id       int    `json:"role_id"`
	RoleName string `json:"role_name"`
	Role     string `json:"role"`
	ParentId int    `json:"parent_id"`
	RouteIds string `json:"route_ids"`
	Status   int8   `json:"status"`
	IsDelete int8   `json:"is_delete"`
	Ctime    int    `json:"ctime,omitempty"`
	Utime    int    `json:"utime,omitempty"`
}

func RoleDetailById

func RoleDetailById(roleId int) (*RoleDetail, error)

type RoleListData

type RoleListData struct {
	Total int64           `json:"total"` //角色数量
	List  []*RoleDataTree `json:"list"`  // 角色列表
}

查询返回数据

func RoleList

func RoleList(roleJ *RoleParams) (*RoleListData, error)

查询管理员列表

type RoleParams

type RoleParams struct {
	Page  int
	Limit int
}

查询

type RoleRequest

type RoleRequest struct {
	RoleId   int    `json:"role_id"`                                //角色id
	Role     string `json:"role" valid:"Required;MaxSize(32)"`      //角色
	RoleName string `json:"role_name" valid:"Required;MaxSize(32)"` //角色名称
	ParentId int    `json:"parent_id"`                              //父级id
	Status   int8   `json:"status"`                                 //状态
	IsDelete int8   `json:"is_delete"`                              //删除状态
}

Role 角色-请求数据

type RouteCache

type RouteCache struct {
	Id        int    `json:"id"`
	Route     string `json:"route"`
	RouteName string `json:"route_name"`
	Request   string `json:"request"`
}

type RouteDataTree

type RouteDataTree struct {
	Id        int              `json:"route_id"`
	ParentId  int              `json:"parent_id"`          //父id
	RouteName string           `json:"route_name"`         //路由名称
	Route     string           `json:"route"`              //路由
	Request   string           `json:"request"`            //请求方式
	Status    int8             `json:"status"`             //状态
	Sort      int16            `json:"sort"`               //排序
	Child     []*RouteDataTree `json:"children,omitempty"` //子节点
}

type RouteDetail

type RouteDetail struct {
	Id        int    `json:"route_id"`
	RouteName string `json:"route_name" valid:"Required;MaxSize(32)"`
	Route     string `json:"route" valid:"Required;MaxSize(50)"`
	Request   string `json:"request" valid:"MaxSize(10)"`
	ParentId  int    `json:"parent_id,omitempty"`
	Component string `json:"component"`
	Title     string `json:"title"`
	Path      string `json:"path"`
	Name      string `json:"name"`
	Redirect  string `json:"redirect"`
	Hidden    int8   `json:"hidden"`
	Icon      string `json:"icon"`
	Extra     string `json:"extra"`
	Sort      int16  `json:"sort"`
	IsRoute   int8   `json:"is_route"`
	Status    int8   `json:"status"`
	Ctime     int    `json:"ctime,omitempty"`
	Utime     int    `json:"utime,omitempty"`
}

func RouteAll

func RouteAll() []*RouteDetail

func RouteDetailById

func RouteDetailById(routeId int) (*RouteDetail, error)

func (*RouteDetail) Valid

func (data *RouteDetail) Valid(v *validation.Validation)

type RouteEditParams

type RouteEditParams struct {
	RoleId   int
	RouteIds string
}

权限编辑

type RouteListData

type RouteListData struct {
	Total int64            `json:"total"` //路由总数
	List  []*RouteDataTree `json:"list"`  // 路由列表
}

查询返回数据

func RouteList

func RouteList(routeJ *RouteParams) (error, *RouteListData)

type RouteOperation

type RouteOperation struct {
	RouteId int   `json:"route_id"`
	Sort    int16 `json:"sort"`
}

type RouteParams

type RouteParams struct {
	Page  int
	Limit int
}

查询

type RpcResult

type RpcResult struct {
	Status  int
	Message string
}

type RunData

type RunData struct {
	RunData string `json:"run_date"`
}

type RunTimeList

type RunTimeList struct {
	List []RunData `json:"list"` //执行列表
}

执行时间列表

type ServersData

type ServersData struct {
	Id             int    `json:"server_id"`
	GroupName      string `json:"group_name"`      //分組名名称
	ServerName     string `json:"server_name"`     //服务器名称
	ConnectionType int8   `json:"connection_type"` //连接方式
	ServerIp       string `json:"server_ip"`       //连接ip
	Port           int    `json:"port"`            //端口
	Detail         string `json:"detail"`          //备注
	Status         int8   `json:"status"`          //状态
	Ctime          int    `json:"ctime"`           //创建时间
	Utime          int    `json:"utime"`           //修改时间
}

type ServersDetail

type ServersDetail struct {
	ServerId       int    `json:"server_id"`
	GroupId        int    `json:"group_id" valid:"Required;"`         //服务器id
	ConnectionType int8   `json:"connection_type" valid:"Range(0,1)"` //连接方式
	ServerName     string `json:"server_name" valid:"Required;"`      //服务器名称
	Port           int    `json:"port" valid:"Required;"`             //端口
	ServerIp       string `json:"server_ip" valid:"Required;IP"`      //服务器id
	ServerAccount  string `json:"server_account"`                     //服务器账号
	Password       string `json:"password"`                           //密码
	PrivateKeySrc  string `json:"private_key_src"`                    //私钥路径
	PublicKeySrc   string `json:"public_key_src"`                     //公钥路径
	Type           int8   `json:"type" valid:"Range(0,1)"`            //登录类型
	Detail         string `json:"detail" valid:"Required;"`           //备注
	Status         int8   `json:"status" valid:"Required;Range(0,1)"` //状态
	Ctime          int    `json:"ctime,omitempty"`
	Utime          int    `json:"utime,omitempty"`
}

func ServersDetailById

func ServersDetailById(serverId int) (*ServersDetail, error)

func (*ServersDetail) Valid

func (s *ServersDetail) Valid(v *validation.Validation)

type ServersListData

type ServersListData struct {
	Total int64          `json:"total"` //資源服務器总数
	List  []*ServersData `json:"list"`  // 資源服務器列表
}

查询返回数据

func ServersList

func ServersList(params *ServersParams) (error, *ServersListData)

查询管理员列表

type ServersParams

type ServersParams struct {
	Page   int
	Limit  int
	Extend string
}

查询

type TaskData

type TaskData struct {
	Id           int    `json:"task_id"`
	GroupId      int    `json:"group_id"`
	GroupName    string `json:"group_name"`
	RunType      int8   `json:"run_type"`
	TaskName     string `json:"task_name"`
	CronSpec     string `json:"cron_spec"`
	Concurrent   int8   `json:"concurrent"`
	ExecuteTimes int    `json:"execute_times"`
	PrevTime     int    `json:"prev_time,omitempty"`
	NextTime     int    `json:"next_time,omitempty"`
	IsAudit      int8   `json:"is_audit"`
	Status       int8   `json:"status"`
	Ctime        int    `json:"ctime"`
	Utime        int    `json:"utime"`
}

type TaskDetail

type TaskDetail struct {
	TaskId        int    `json:"task_id"`
	GroupId       int    `json:"group_id" valid:"Required;"`
	ServerIds     string `json:"server_ids" valid:"Required;"`
	RunType       int8   `json:"run_type" valid:"Required;"`
	TaskName      string `json:"task_name" valid:"Required;"`
	Description   string `json:"description" valid:"Required;"`
	CronSpec      string `json:"cron_spec" valid:"Required;"`
	Concurrent    int8   `json:"concurrent"`
	Command       string `json:"command" valid:"Required;"`
	Timeout       int    `json:"timeout"`
	IsNotify      int8   `json:"is_notify"`
	NotifyType    int8   `json:"notify_type"`
	NotifyTplId   int    `json:"notify_tpl_id"`
	NotifyUserIds string `json:"notify_user_ids"`
	IsAudit       int8   `json:"is_audit"`
	UpdateId      int    `json:"update_id"`
	CreateId      int    `json:"create_id"`
	Status        int8   `json:"status"`
	Ctime         int    `json:"-"`
	Utime         int    `json:"-"`
}

Task

func TaskDetailById

func TaskDetailById(taskId int) (*TaskDetail, error)

func (*TaskDetail) Valid

func (task *TaskDetail) Valid(v *validation.Validation)

type TaskListData

type TaskListData struct {
	Total int64       `json:"total"`
	List  []*TaskData `json:"list"`
}

查询返回数据

func TaskList

func TaskList(params *TaskParams) (error, *TaskListData)

type TaskLogData

type TaskLogData struct {
	Id          string     `json:"id"`
	TaskId      int        `json:"task_id"`
	ServerId    int        `json:"server_id"`
	ServerName  string     `json:"server_name"`
	Output      string     `json:"output"`
	Error       string     `json:"error"`
	Status      int8       `json:"status"`
	ProcessTime int        `json:"process_time"`
	Ctime       int        `json:"ctime"`
	TaskInfo    TaskDetail `json:"task_info"`
}

func TaskLogDetailById

func TaskLogDetailById(LogId string) (*TaskLogData, error)

type TaskLogListData

type TaskLogListData struct {
	Total int64          `json:"total"`
	List  []*TaskLogData `json:"list"`
}

func TaskLogList

func TaskLogList(params *TaskLogParams) (error, *TaskLogListData)

type TaskLogParams

type TaskLogParams struct {
	Page   int
	Limit  int
	TaskId int
}

type TaskOperation

type TaskOperation struct {
	TaskIds string `json:"task_ids"`
	Status  int8   `json:"status"`
	Audit   int8   `json:"audit"`
}

type TaskParams

type TaskParams struct {
	Page  int
	Limit int
	Audit int8
}

查询

type TaskRunLog

type TaskRunLog struct {
	TaskId      int    `json:"task_id"`
	ServerId    int    `json:"server_id"`
	ServerName  string `json:"server_name"`
	Output      string `json:"output"`
	Error       string `json:"error"`
	Status      int8   `json:"status"`
	ProcessTime int    `json:"process_time"`
	Ctime       int    `json:"ctime"`
}

定时任务任务日志

func PullTaskRunLog

func PullTaskRunLog() TaskRunLog

拉取任务运行日志信息

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL