grouper

package
v0.0.0-...-68efac8 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 17, 2014 License: MIT, Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL