oversight

Nov 23, 2021

Changes in this version

+ var ErrMissingContext = errors.New("missing context")

+ func ChildProcessName(ctx context.Context) string

type Tree

+ func (t *Tree) GetErr() error

+ func (t *Tree) GracefulShutdown(ctx context.Context) error

Nov 23, 2021

Changes in this version

type TreeOption

+ func DefaultMaximumRestartIntensity() TreeOption

Jul 29, 2019

Changes in this version

type TreeOption

+ func WithMaximumRestartIntensity(maxR int, maxT time.Duration) TreeOption

Jan 15, 2019

Changes in this version

+ const DefaultChildProcessTimeout

+ const DefaultMaxR

+ const DefaultMaxT

+ var ErrInvalidChildProcessType = errors.New("invalid child process type")

+ var ErrInvalidConfiguration = errors.New("invalid tree configuration")

+ var ErrNoChildProcessLeft = errors.New("no child process left")

+ var ErrProcessNotRunning = errors.New("process not running")

+ var ErrTooManyFailures = errors.New("too many failures")

+ var ErrTreeNotRunning = errors.New("oversight tree is not running")

+ var ErrUnknownProcess = errors.New("unknown process")

+ type ChildProcess func(ctx context.Context) error

+ type ChildProcessSpecification struct

+ Name string

+ Restart Restart

+ Shutdown Shutdown

+ Start ChildProcess

+ type ChildProcessState string

+ const Done

+ const Failed

+ const Running

+ const Starting

+ type Logger interface

+ Printf func(format string, args ...interface{})

+ Println func(args ...interface{})

+ type Restart func(error) bool

+ func Permanent() Restart

+ func Temporary() Restart

+ func Transient() Restart

+ type Shutdown func() (context.Context, context.CancelFunc)

+ func Infinity() Shutdown

+ func Timeout(d time.Duration) Shutdown

+ type State struct

+ Name string

+ State ChildProcessState

+ Stop func()

+ type Strategy func(t *Tree, failedChildID int)

+ func OneForAll() Strategy

+ func OneForOne() Strategy

+ func RestForOne() Strategy

+ func SimpleOneForOne() Strategy

+ type Tree struct

+ func New(opts ...TreeOption) *Tree

+ func (t *Tree) Add(spec interface{}) error

+ func (t *Tree) Children() []State

+ func (t *Tree) Delete(name string) error

+ func (t *Tree) Start(rootCtx context.Context) error

+ func (t *Tree) Terminate(name string) error

+ type TreeOption func(*Tree)

+ func DefaultRestartIntensity() TreeOption

+ func DefaultRestartStrategy() TreeOption

+ func NeverHalt() TreeOption

+ func Process(specs ...ChildProcessSpecification) TreeOption

+ func Processes(processes ...ChildProcess) TreeOption

+ func WithLogger(logger Logger) TreeOption

+ func WithRestartIntensity(maxR int, maxT time.Duration) TreeOption

+ func WithRestartStrategy(strategy Strategy) TreeOption

+ func WithSpecification(maxR int, maxT time.Duration, strategy Strategy) TreeOption

+ func WithTree(subTree *Tree) TreeOption