grouper

Documentation

Index

• type Member
• type MemberChan
• type ProcessGroup
  • func EnvokeGroup(rGroup RunGroup) ProcessGroup
• type RunGroup
  • func (r RunGroup) Run(sig <-chan os.Signal, ready chan<- struct{}) error

Types

type Member

type Member struct {
	Name    string
	Process ifrit.Process
	Error   error
}

type MemberChan

type MemberChan chan Member

type ProcessGroup

type ProcessGroup interface {
	ifrit.Process
	Exits() <-chan Member
}

func EnvokeGroup

func EnvokeGroup(rGroup RunGroup) ProcessGroup

type RunGroup

type RunGroup map[string]ifrit.Runner

func (RunGroup) Run

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