daemon

Documentation

Index

• Constants
• Variables
• func Group(group int, args []string, cb ProcessCallback, config Config, ...)
• func Run(groupId int, args []string, cb ProcessCallback, config Config, ...) int
• type ArgOption
• type ArgOptionFunc
• type Cmd
  • func Background(id int, args []string, conf Config, opts ...ArgOptionFunc) (*Cmd, error)
  • func (c *Cmd) WithErr(err error) *Cmd
• type Config
• type ProcessCallback
• type Status

Constants

const (
	KStatusRunning = Status(1)
	KStatusClose   = Status(2)
	KStatusExit    = Status(3)
)

Variables

var (
	DefConfig = Config{Config: system.Config{EnableEnv: true, EnableStd: false}}

	CmdNilErr   = errors.New("cmd obj is nil")
	MaxCountErr = errors.New("max count")
	MaxErr      = errors.New("max error")
)

Functions

func Group

func Group(group int, args []string, cb ProcessCallback, config Config, opts ...ArgOptionFunc)

Group 守护进程启动一个N[1,2000]子进程, 并循环监视

func Run

func Run(groupId int, args []string, cb ProcessCallback, config Config, opts ...ArgOptionFunc) int

Run 守护进程启动一个子进程, 并循环监视

Types

type ArgOption

type ArgOption struct {
	Id   int
	Data interface{} //用户自己定义
	Args []string
	Env  []string
}

type ArgOptionFunc

type ArgOptionFunc func(arg *ArgOption)

type Cmd

type Cmd struct {
	Cmd  *exec.Cmd
	Err  error
	Data interface{}
}

func Background

func Background(id int, args []string, conf Config, opts ...ArgOptionFunc) (*Cmd, error)

func (*Cmd) WithErr

func (c *Cmd) WithErr(err error) *Cmd

type Config

type Config struct {
	system.Config
	MaxCount    int   `json:"maxCount" yaml:"maxCount" xml:"maxCount"`
	MaxError    int   `json:"maxError" yaml:"maxError" xml:"maxError"`
	MinExitTime int64 `json:"minExitTime" yaml:"minExitTime" xml:"minExitTime"`
}

type ProcessCallback

type ProcessCallback func(cmd *Cmd, status Status, time int64)

type Status

type Status int