restart

Documentation

Overview

The restart package implements common restart strategies for ifrit processes.

The API is still experimental and subject to change.

Index

• Variables
• func OnError(runner ifrit.Runner, err error, errors ...error) ifrit.Runner
• type Restarter
  • func (r Restarter) Run(signals <-chan os.Signal, ready chan<- struct{}) error

Variables

var ErrNoLoadCallback = errors.New("ErrNoLoadCallback")

ErrNoLoadCallback is returned by Restarter if it is Invoked without a Load function.

Functions

func OnError

func OnError(runner ifrit.Runner, err error, errors ...error) ifrit.Runner

OnError is a restart strategy for Safely Restartable Runners. It will restart the Runner only if it exits with a matching error.

Types

type Restarter

type Restarter struct {
	Runner ifrit.Runner
	Load   func(runner ifrit.Runner, err error) ifrit.Runner
}

Restarter takes an inital runner and a Load function. When the inital Runner exits, the load function is called. If the Load function retuns a Runner, the Restarter will invoke the Runner. This continues until the Load function returns nil, or the Restarter is signaled to stop. The Restarter returns the error of the final Runner it invoked.

func (Restarter) Run

func (r Restarter) Run(signals <-chan os.Signal, ready chan<- struct{}) error