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 GRun
  • func NewGroup() *GRun
  • func (g *GRun) Add(id int, it *Item) error
  • func (g *GRun) Exec(cb ProcessCallback, config Config, opts ...ArgOptionFunc)
  • func (g *GRun) Get(id int) (*Item, bool)
  • func (g *GRun) Wait()
• type Item
  • func NewItem(id int, args []string, data interface{}) *Item
  • func (it *Item) GetId() int
• type ProcessCallback
• type Status

Constants

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

const KMaxGroupCount = 3000

Variables

var (
	DefConfig       = Config{Config: system.Config{EnableEnv: true, EnableStd: false}}
	DefGRun   *GRun = nil

	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 GRun

type GRun struct {
	// contains filtered or unexported fields
}

func NewGroup

func NewGroup() *GRun

func (*GRun) Add

func (g *GRun) Add(id int, it *Item) error

func (*GRun) Exec

func (g *GRun) Exec(cb ProcessCallback, config Config, opts ...ArgOptionFunc)

func (*GRun) Get

func (g *GRun) Get(id int) (*Item, bool)

func (*GRun) Wait

func (g *GRun) Wait()

type Item

type Item struct {
	Data interface{}
	// contains filtered or unexported fields
}

func NewItem

func NewItem(id int, args []string, data interface{}) *Item

func (*Item) GetId

func (it *Item) GetId() int

type ProcessCallback

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

type Status

type Status int