daemon

type CheckHealth struct {
	CheckAddress string    `json:"url"`
	CheckMode    CheckMode `json:"type"`
	CheckTtl     int       `json:"ttl"`
	//访问安全token定义，这里面是要定义key=value的，这样兼容性更高一些
	SecretToken string `json:"securityKey,omitempty"`
}

type CheckMode string

type Command struct {
	//程序运行体
	Command string `json:"command,omitempty"`

	//启动参数
	Args []string `json:"args,omitempty"`

	//监控检车接口
	CheckHealth *CheckHealth `json:"health,omitempty"`
}

type FSMState string

type FSMStatusEvent struct {
	Process    *Process `json:"process"`
	FromStatus FSMState `json:"fromStatus"`
	ToStatus   FSMState `json:"toStatus"`
}

type FSMStatusListener func(event FSMStatusEvent)

type Manager interface {
	Start() error
	Stop() error

	GetProcess(name string) (*Process, error)

	AddProgram(program *Program) error
	RemoveProgram(name string, skip bool) error
	ModifyProgram(program *Program) error

	ModifyTag(name string, add bool, tag string) error

	ListProgramNames() ([]string, error)
	ListProcess() ([]*Process, error)

	SetStatusListener(lis FSMStatusListener)

	StartProgram(name string, determinedResult chan *Process) error
	StopProgram(name string) error

	MustGetProcess(name string) *Process
	MustAddProgram(program *Program)
	MustRemoveProgram(name string, skip bool)
	MustModifyProgram(program *Program)
	MustModifyTag(name string, add bool, tag string)
	MustListProgramNames() []string
	MustListProcess() []*Process

	MustStartProgram(name string, determinedResult chan *Process)
	MustStopProgram(name string)

	SubscribeLogger(uid string, name string, tail TailLogger, firstLine int) error
	UnSubscribeLogger(uid, name string) error
}

type Process struct {
	Pid    int      `json:"pid"`
	Status FSMState `json:"status"`

	*Program

	Cpu float64 `json:"cpu"`
	Rss uint64  `json:"rss"`
	// contains filtered or unexported fields
}

type ProcessGroup []*Process

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

type Program struct {
	//程序唯一性ID，使用UUID方式
	Id uint64 `json:"id"`

	Node string `json:"node,omitempty"`

	Daemon string `json:"daemon"`

	//程序名称
	Name string `json:"name"`

	Description string `json:"description,omitempty"`

	//程序标签
	Tags Tags `json:"tags"`

	//工作目录
	WorkDir string `json:"workDir,omitempty"`

	//启动使用用户
	User string `json:"user,omitempty"`

	//环境参数变量
	Envs []string `json:"envs,omitempty"`

	//是不是守护程序，如果是需要提供启动和停止命令 前台程序
	Start *Command `json:"start"`

	//启动停止命令
	Stop *Command `json:"stop,omitempty"`

	//忽略,deamon类型的程序已经启动，也会直接加入管理
	IgnoreAlreadyStarted bool `json:"ignoreStarted,omitempty"`

	//是否自动启动
	AutoStart bool `json:"autoStart,omitempty"`

	//启动周期
	StartDuration int `json:"startDuration,omitempty"`

	//启动重试次数
	StartRetries int `json:"startRetries,omitempty"`

	StopSign syscall.Signal `json:"stopSign,omitempty"`

	//结束运行超时时间
	StopTimeout int `json:"stopTimeout,omitempty"`

	AddTime    time.Time `json:"addTime,omitempty"`
	UpdateTime time.Time `json:"updateTime,omitempty"`

	//日志文件位置
	Logger string `json:"logger,omitempty"`
}

type Tags []string

type TailLogger func(id, line string)