server

Documentation

Overview

*********************************************************** ** @Description: server ** @Author: george hao ** @Date: 2018-11-29 11:13 ** @Last Modified by: george hao ** @Last Modified time: 2018-11-29 11:13 ************************************************************

*********************************************************** ** @Description: job ** @Author: george hao ** @Date: 2019-06-24 15:14 ** @Last Modified by: george hao ** @Last Modified time: 2019-06-24 15:14 ************************************************************

*********************************************************** ** @Description: log ** @Author: datang ** @Date: 2018-08-22 23:00 ** @Last Modified by: datang ** @Last Modified time: 2018-08-22 23:00 ************************************************************

*********************************************************** ** @Description: notify ** @Author: george hao ** @Date: 2019-06-26 15:17 ** @Last Modified by: george hao ** @Last Modified time: 2019-06-26 15:17 ************************************************************

*********************************************************** ** @Description: service ** @Author: george hao ** @Date: 2019-06-26 15:27 ** @Last Modified by: george hao ** @Last Modified time: 2019-06-26 15:27 ************************************************************

*********************************************************** ** @Description: server ** @Author: george hao ** @Date: 2018-11-29 11:24 ** @Last Modified by: george hao ** @Last Modified time: 2018-11-29 11:24 ************************************************************

*********************************************************** ** @Description: task ** @Author: george hao ** @Date: 2019-06-24 13:22 ** @Last Modified by: george hao ** @Last Modified time: 2019-06-24 13:22 ************************************************************

Index

• Variables
• func Close() error
• func GetCmdMap(key string) *exec.Cmd
• func Heartbeat() error
• func InitConfig(path string) error
• func ListenSignal()
• func NLog(level string, value ...interface{})
• func Register() error
• func ResetCommandJob(id int, serverId int, name string, command string) *Job
• func RestJobFromTask(task *models.Task, serverId int) (*Job, error)
• func RpcRun() error
• func Run(j *Job) *JobResult
• func SaveConfig(key string, value string) error
• func SetCmdMap(key string, cmd *exec.Cmd)
• func WriteLog(r *http.Request, t time.Time, match string, pattern string)
• type RpcResult
• type RpcTask
  • func (r *RpcTask) HeartBeat(ping string, reply *RpcResult) error
  • func (r *RpcTask) KillCommand(task models.Task, reply *RpcResult) error
  • func (r *RpcTask) RunTask(task *models.Task, Result *jobs.JobResult) error

Variables

var C = new(common.Conf)

var CmdMap sync.Map

执行句柄map

var ConfPath string

var Env string

Functions

func Close

func Close() error

程序异常退出的通知

func GetCmdMap

func GetCmdMap(key string) *exec.Cmd

func Heartbeat

func Heartbeat() error

心跳机制

func InitConfig

func InitConfig(path string) error

func ListenSignal

func ListenSignal()

监听关闭状态

func NLog

func NLog(level string, value ...interface{})

系统运行相关

func Register

func Register() error

启动时注册

func ResetCommandJob

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

func RestJobFromTask

func RestJobFromTask(task *models.Task, serverId int) (*Job, error)

func RpcRun

func RpcRun() error

func Run

func Run(j *Job) *JobResult

func SaveConfig

func SaveConfig(key string, value string) error

func SetCmdMap

func SetCmdMap(key string, cmd *exec.Cmd)

func WriteLog

func WriteLog(r *http.Request, t time.Time, match string, pattern string)

http相关

Types

type RpcResult

type RpcResult struct {
	Status  int
	Message string
}

type RpcTask

type RpcTask struct {
}

func (*RpcTask) HeartBeat

func (r *RpcTask) HeartBeat(ping string, reply *RpcResult) error

func (*RpcTask) KillCommand

func (r *RpcTask) KillCommand(task models.Task, reply *RpcResult) error

Kill execution

func (*RpcTask) RunTask

func (r *RpcTask) RunTask(task *models.Task, Result *jobs.JobResult) error

Execute once