supervisor

Documentation

Index

• type Cmd
• type Supervisor
  • func NewSupervisor(tag string, restartIntervalMS []int, maxRestartCount int) *Supervisor
  • func (s *Supervisor) Run(ctx context.Context, startup func(ctx context.Context) Cmd) error

Types

type Cmd

type Cmd interface {
	Start() error
	Wait() error
}

type Supervisor

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

func NewSupervisor

func NewSupervisor(tag string, restartIntervalMS []int, maxRestartCount int) *Supervisor

func (*Supervisor) Run

func (s *Supervisor) Run(ctx context.Context, startup func(ctx context.Context) Cmd) error

TODO: use ctx to stop process and stop restart