process

Documentation

Index

• Constants
• Variables
• func Cmd(name string, args []string) (*exec.Cmd, error)
• func Register(name string, processHandler func()) error
• func Run() bool
• func RunDebug(name string) bool
• type IConfigBuild
• type IProcessUpdate
• type IProcessUpdates
  • func (I IProcessUpdates) Update(cmd *exec.Cmd)
• type ProcessCmd
  • func NewProcessCmd(name string, cmd *exec.Cmd, reader io.Reader) *ProcessCmd
  • func (p *ProcessCmd) Close() error
  • func (p *ProcessCmd) Cmd() *exec.Cmd
  • func (p *ProcessCmd) Pid() int
  • func (p *ProcessCmd) Read()
  • func (p *ProcessCmd) Status() int
  • func (p *ProcessCmd) Wait() error
• type ProcessController
  • func NewProcessController(ctx context.Context, name string, logWriter io.Writer, ...) *ProcessController
  • func (pc *ProcessController) Shutdown()
  • func (pc *ProcessController) Start(configData []byte, extraFiles []*os.File) error
  • func (pc *ProcessController) Stop()
  • func (pc *ProcessController) TryRestart(configData []byte, extraFiles []*os.File)
• type StartArgs

Constants

const (
	StatusStart = iota
	StatusExit
	StatusRunning
	StatusError
)

const (
	EnvDaemonName = "EO_DAEMON_IDX"
	EnvDaemonPath = "EO_DAEMON_PATH"
)

Variables

var (
	ErrorProcessHandlerConflict = errors.New("process handler name conflict")
)

Functions

func Cmd

func Cmd(name string, args []string) (*exec.Cmd, error)

func Register

func Register(name string, processHandler func()) error

Register 注册程序到进程处理器中

func Run

func Run() bool

run process

func RunDebug

func RunDebug(name string) bool

Types

type IConfigBuild

type IConfigBuild interface {
	Config() StartArgs
}

type IProcessUpdate

type IProcessUpdate interface {
	Update(cmd *exec.Cmd)
}

type IProcessUpdates

type IProcessUpdates []IProcessUpdate

func (IProcessUpdates) Update

func (I IProcessUpdates) Update(cmd *exec.Cmd)

type ProcessCmd

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

func NewProcessCmd

func NewProcessCmd(name string, cmd *exec.Cmd, reader io.Reader) *ProcessCmd

func (*ProcessCmd) Close

func (p *ProcessCmd) Close() error

func (*ProcessCmd) Cmd

func (p *ProcessCmd) Cmd() *exec.Cmd

func (*ProcessCmd) Pid

func (p *ProcessCmd) Pid() int

func (*ProcessCmd) Read

func (p *ProcessCmd) Read()

func (*ProcessCmd) Status

func (p *ProcessCmd) Status() int

func (*ProcessCmd) Wait

func (p *ProcessCmd) Wait() error

type ProcessController

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

func NewProcessController

func NewProcessController(ctx context.Context, name string, logWriter io.Writer, callback ...IProcessUpdate) *ProcessController

func (*ProcessController) Shutdown

func (pc *ProcessController) Shutdown()

func (*ProcessController) Start

func (pc *ProcessController) Start(configData []byte, extraFiles []*os.File) error

func (*ProcessController) Stop

func (pc *ProcessController) Stop()

func (*ProcessController) TryRestart

func (pc *ProcessController) TryRestart(configData []byte, extraFiles []*os.File)

type StartArgs

type StartArgs struct {
	Data       []byte
	ExtraFiles []*os.File
}