grouper

Documentation

Index

• type EntranceEvent
• type ErrorTrace
  • func NewErrorTrace(bufferSize int) ErrorTrace
  • func (trace ErrorTrace) Error() string
  • func (trace ErrorTrace) ToError() error
  • func (trace ErrorTrace) TraceExitEvents(exitEvents <-chan ExitEvent) ErrorTrace
• type ExitEvent
• type Member
• type Members
• type Pool
  • func NewPool(signal os.Signal, poolSize int, eventBufferSize int) *Pool
  • func (p *Pool) Client() PoolClient
  • func (p *Pool) Run(signals <-chan os.Signal, ready chan<- struct{}) error
• type PoolClient
• type StaticClient
• type StaticGroup
  • func NewOrdered(signal os.Signal, members []Member) StaticGroup
  • func NewParallel(signal os.Signal, members []Member) StaticGroup
  • func NewSerial(members []Member) StaticGroup

Types

type EntranceEvent

type EntranceEvent struct {
	Member  Member
	Process ifrit.Process
}

type ErrorTrace

type ErrorTrace []ExitEvent

func NewErrorTrace

func NewErrorTrace(bufferSize int) ErrorTrace

func (ErrorTrace) Error

func (trace ErrorTrace) Error() string

func (ErrorTrace) ToError

func (trace ErrorTrace) ToError() error

func (ErrorTrace) TraceExitEvents

func (trace ErrorTrace) TraceExitEvents(exitEvents <-chan ExitEvent) ErrorTrace

type ExitEvent

type ExitEvent struct {
	Member Member
	Err    error
}

type Member

type Member struct {
	Name string
	ifrit.Runner
}

type Members

type Members []Member

type Pool

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

func NewPool

func NewPool(signal os.Signal, poolSize int, eventBufferSize int) *Pool

func (*Pool) Client

func (p *Pool) Client() PoolClient

func (*Pool) Run

func (p *Pool) Run(signals <-chan os.Signal, ready chan<- struct{}) error

type PoolClient

type PoolClient interface {
	NewEntranceListener() <-chan EntranceEvent
	NewExitListener() <-chan ExitEvent
	Insert() chan<- Member
	CloseNotifier() <-chan struct{}
	Close()
}

type StaticClient

type StaticClient interface {
	NewEntranceListener() <-chan EntranceEvent
	NewExitListener() <-chan ExitEvent
}

type StaticGroup

type StaticGroup interface {
	ifrit.Runner
	Client() StaticClient
}

func NewOrdered

func NewOrdered(signal os.Signal, members []Member) StaticGroup

func NewParallel

func NewParallel(signal os.Signal, members []Member) StaticGroup

func NewSerial

func NewSerial(members []Member) StaticGroup