supervisor

type Options struct {
	LogDir     string
	MinBackoff time.Duration
	MaxBackoff time.Duration
	// ControlSocket, when set, serves the restart/stop/start/status protocol
	// that internal/comps speaks (the supervisor's systemctl equivalent).
	ControlSocket string
	// OnStart is called after each successful start, with the pid.
	OnStart func(name string, pid int)
	// ReExec, when set, is the command line a "reexec" request replaces this
	// process with once every component has stopped; ReExec[0] is the binary.
	// Without it the request is refused.
	ReExec []string
}

type ProcSpec struct {
	Path string   `json:"path"`
	Args []string `json:"args"`
	Env  []string `json:"env,omitempty"`
}

type ProcStatus struct {
	Name    string `json:"name"`
	Pid     int    `json:"pid"`
	Running bool   `json:"running"`
	Wanted  bool   `json:"wanted"`
	// Foreign: the component's socket is served by a process the supervisor
	// does not own, so Running (if set) is not this component.
	Foreign bool `json:"foreign,omitempty"`
}

type Process struct {
	Name string
	Path string
	Args []string
	// ArgsFn, when set, is evaluated on every (re)start instead of Args — for
	// components whose flags must re-render after external surgery (etcd
	// membership after `stratum snapshot rejoin`).
	ArgsFn func() []string
	Env    []string
	// WaitFor gates each start. Without it, every apiserver client crash-loops
	// through the seconds before the apiserver has bootstrapped its RBAC — the
	// supervisor recovers, but a control plane that always logs a crash on boot
	// trains people to ignore crash logs.
	WaitFor func(context.Context) error
	// Socket, when set, is the unix socket this component serves. If the
	// component exits while that socket is still live, someone else owns it
	// (an orphan from an earlier run): the component is reported Foreign
	// instead of silently retrying forever.
	Socket string
	// ExecLabel, when set, is the SELinux context the component is exec'd in,
	// rather than the one it would inherit from this process.
	ExecLabel string
}

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