grouper

Documentation

Index

• Constants
• Variables
• type Loader
• type Member
• type Members
  • func (members Members) Load(err error) (ifrit.Runner, bool)
  • func (members Members) Run(sig <-chan os.Signal, ready chan<- struct{}) error
• type Restart
• type RestartPolicy
• type Signal
  • func (s Signal) Signal()
  • func (s Signal) String() string

Constants

const (
	NoTimeout           = time.Duration(0)
	DefaultStopTimeout  = 10 * time.Second
	DefaultGraceTimeout = 5 * time.Minute
)

const (
	Continue = Signal("continue")
)

Variables

var (
	RestartMePolicy = RestartPolicy(func() Restart {
		return Restart{true, Continue, NoTimeout}
	})

	StopMePolicy = RestartPolicy(func() Restart {
		return Restart{false, Continue, NoTimeout}
	})

	RestartGroupPolicy = RestartPolicy(func() Restart {
		return Restart{true, os.Interrupt, DefaultGraceTimeout}
	})

	StopGroupPolicy = RestartPolicy(func() Restart {
		return Restart{false, os.Interrupt, DefaultGraceTimeout}
	})
)

Types

type Loader

type Loader interface {
	Load(error) (ifrit.Runner, bool)
}

type Member

type Member struct {
	Name    string
	Runner  ifrit.Runner
	Restart Restart
}

type Members

type Members []Member

func (Members) Load

func (members Members) Load(err error) (ifrit.Runner, bool)

func (Members) Run

func (members Members) Run(sig <-chan os.Signal, ready chan<- struct{}) error

type Restart

type Restart struct {
	AttemptRestart bool
	Signal         os.Signal
	Timeout        time.Duration
}

type RestartPolicy

type RestartPolicy func() Restart

type Signal

type Signal string

func (Signal) Signal

func (s Signal) Signal()

func (Signal) String

func (s Signal) String() string