README
¶
Mori's Goforever Fork
See the original at https://github.com/gwoo/goforever
Config based process manager. Goforever could be used in place of supervisor, runit, node-forever, etc. Goforever will start an http server on the specified port.
Usage of ./goforever:
-conf="goforever.toml": Path to config file.
功能描述
- 主进程退出不影响子进程，当主进程恢复服务后继续根据pid文件进行监控进程状态
- 进程被外部程序结束后自动启动（respawn > 0）
- 有延迟启动功能（delay）
- 心跳时间可配置（ping）
配置文件模板
ip = "127.0.0.1" # API 监听地址
port = "2224" # API 监听端口
username = "go" # API 用户名
password = "forever" # API 密码
pidfile = "goforever.pid"
logfile = "goforever.log"
errfile = "goforever.log"
[[process]]
name = "example-panic"
command = "./example/example-panic"
pidfile = "example/example-panic.pid"
logfile = "example/logs/example-panic.debug.log"
errfile = "example/logs/example-panic.errors.log"
respawn = 1 # 进程被结束时自动重启
delay = "1m" # 延迟一分钟启动
ping = "30s" # 30s检测一次进状态
[[process]]
name = "example"
dir = "/tmp/" # 切换到此目录下运行 command
env = ["aaa=aaa","bbb=bbb"] # 程序指定的环境变量
command = "./example/example"
args = ["-name=foo"] # 命令行参数
pidfile = "example/example.pid"
logfile = "example/logs/example.debug.log"
errfile = "example/logs/example.errors.log"
respawn = 1
Running
Help.
./goforever -h
Daemonize main process.
./goforever start
Run main process and output to current session.
./goforever
CLI
list List processes.
show [process] Show a main proccess or named process.
start [process] Start a main proccess or named process.
stop [process] Stop a main proccess or named process.
restart [process] Restart a main proccess or named process.
HTTP API
Return a list of managed processes
GET host:port/
Start the process
POST host:port/:name
Restart the process
PUT host:port/:name
Stop the process
DELETE host:port/:name
Documentation
¶
Index ¶
- Constants
- Variables
- func ChildKeys() []string
- func IsRunning(name string) bool
- func NewLog(path string) *os.File
- func NewSysProcAttr() *syscall.SysProcAttr
- func Pid() int
- func RotateLog(logfile string, keepNum int) error
- func Run()
- func RunProcess(name string, p *Process) chan *Process
- func SetOption(options map[string]interface{}, name string, value interface{}) map[string]interface{}
- func Status() string
- func StopChild(name string) error
- type Children
- type Pidfile
- type Process
- func (p *Process) Add(name string, procs *Process, run ...bool) *Process
- func (p *Process) AddHook(status string, hooks ...func(procs *Process)) *Process
- func (p *Process) Child(name string) *Process
- func (p *Process) ChildKeys() []string
- func (p *Process) DailyRotate(keepNum int)
- func (p *Process) Error() error
- func (p *Process) Find() (*os.Process, string, error)
- func (p *Process) Init() *Process
- func (p *Process) IsRunning(name string) bool
- func (p *Process) LogKeepNum() int
- func (p *Process) Pid() int
- func (p *Process) Reset() error
- func (p *Process) Restart() (*Process, string)
- func (p *Process) RestartChild(name string) (*Process, error)
- func (p *Process) Rotate(keepNum int)
- func (p *Process) Run()
- func (p *Process) RunHook(status string)
- func (p *Process) SetAndTriggerStatus(status string)
- func (p *Process) SetChildKV(name string, proc *Process)
- func (p *Process) SetChildren(children map[string]*Process)
- func (p *Process) SetError(err error)
- func (p *Process) SetHook(status string, hooks ...func(procs *Process)) *Process
- func (p *Process) SetLogKeepNum(keepNum int)
- func (p *Process) SetStatus(status string, dontTriggerEvent ...bool)
- func (p *Process) SetX(x Processer)
- func (p *Process) Start(name string) string
- func (p *Process) StartChild(name string) (*Process, error)
- func (p *Process) StartProcess(name string, argv []string, attr *os.ProcAttr) (Processer, error)
- func (p *Process) Status() string
- func (p *Process) Stop() string
- func (p *Process) StopChild(name string) error
- func (p *Process) String() string
- func (p *Process) X() Processer
- type Processer
Constants ¶
View Source
const ( StatusStarted = `started` StatusRunning = `running` StatusStopped = `stopped` StatusRestarted = `restarted` StatusExited = `exited` StatusKilled = `killed` )
Variables ¶
View Source
var Default = New()
View Source
var ErrCouldNotFindProcess = errors.New("could not find process")
View Source
var ErrPidfileEmpty = errors.New("Pidfile is empty")
Functions ¶
func NewSysProcAttr ¶ added in v0.3.0
func NewSysProcAttr() *syscall.SysProcAttr
Types ¶
type Children ¶ added in v0.1.1
type Children struct {
// contains filtered or unexported fields
}
Children Child processes.
func NewChildren ¶ added in v0.3.0
type Process ¶
type Process struct {
Name string
Command string
Env []string
Dir string
Args []string
User string
Pidfile Pidfile
Logfile string
Errfile string
Respawn int
Delay string
Ping string
Debug bool
// Options
// HideWindow bool // for windows
Options map[string]interface{} `json:",omitempty" xml:",omitempty"`
// contains filtered or unexported fields
}
func NewProcess ¶ added in v0.1.1
func RestartChild ¶ added in v0.1.1
func StartChild ¶ added in v0.1.1
func (*Process) DailyRotate ¶ added in v0.3.1
func (*Process) LogKeepNum ¶ added in v0.3.1
func (*Process) RestartChild ¶ added in v0.1.1
func (*Process) SetAndTriggerStatus ¶ added in v0.2.5
func (*Process) SetChildKV ¶ added in v0.2.0
func (*Process) SetChildren ¶ added in v0.2.0
func (*Process) SetLogKeepNum ¶ added in v0.3.1
func (*Process) StartChild ¶ added in v0.1.1
func (*Process) StartProcess ¶ added in v0.2.5
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.