g0

Documentation

Overview

Package g0 facilitates launch, management and execution of goroutines

Index

• Variables
• func NewGo(errorReceiver func(err error), add func(delta int), done func(err *error), ...) (g0 parl.Go)
• func NewGoError(err error, source parl.GoErrorSource, goer parl.Goer) (goError parl.GoError)
• func NewGoGroup(ctx context.Context) (goCreator parl.GoGroup)
• func NewGoSub(g0 parl.Go) (subGo parl.SubGo)
• func NewGoer(conduit parl.ErrorConduit, exitAction parl.ExitAction, index parl.GoIndex, ...) (goer parl.Goer)
• func NewGoerGroup(ctx context.Context) (goer parl.Goer)
• type Go
  • func (g0 *Go) Add(delta int)
  • func (g0 *Go) AddError(err error)
  • func (g0 *Go) Cancel()
  • func (g0 *Go) Context() (ctx context.Context)
  • func (g0 *Go) Done(errp *error)
  • func (g0 *Go) Register()
  • func (g0 *Go) SubGo() (goCancel parl.SubGo)
• type GoErrorDo
  • func (ge *GoErrorDo) GetError() (err error)
  • func (ge *GoErrorDo) Goer() (goer parl.Goer)
  • func (ge *GoErrorDo) Source() (source parl.GoErrorSource)
  • func (ge *GoErrorDo) String() (s string)
• type GoGroup
  • func (gc *GoGroup) Add(conduit parl.ErrorConduit, exitAction parl.ExitAction) (goer parl.Goer)
  • func (we *GoGroup) Ch() (ch <-chan parl.GoError)
  • func (we *GoGroup) IsExit() (isExit bool)
  • func (gc *GoGroup) String() (s string)
  • func (we *GoGroup) Wait()
  • func (gc *GoGroup) WaitPeriod(duration ...time.Duration)
• type Goer
  • func (gr *Goer) AddError(err error)
  • func (we *Goer) Ch() (ch <-chan parl.GoError)
  • func (gr *Goer) Go() (g0 parl.Go)
  • func (we *Goer) IsExit() (isExit bool)
  • func (gr *Goer) String() (s string)
  • func (we *Goer) Wait()
• type GoerGroup
  • func (gr *GoerGroup) AddError(err error)
  • func (we *GoerGroup) Ch() (ch <-chan parl.GoError)
  • func (gr *GoerGroup) Go() (g0 parl.Go)
  • func (we *GoerGroup) IsExit() (isExit bool)
  • func (we *GoerGroup) String() (s string)
  • func (we *GoerGroup) Wait()
• type SubGo
  • func (gc *SubGo) Add(delta int)
  • func (gc *SubGo) Done(errp *error)
  • func (gc *SubGo) SubGo() (goCancel parl.SubGo)

Variables

var GoGroupFactory parl.GoGroupFactory = &goGroupFactory{}

var GoerFactory parl.GoerFactory = &goerFactory{}

var Index goerIndex

Functions

func NewGo

func NewGo(
	errorReceiver func(err error),
	add func(delta int),
	done func(err *error),
	context func() (ctx context.Context),
	cancel func()) (g0 parl.Go)

func NewGoError

func NewGoError(err error, source parl.GoErrorSource, goer parl.Goer) (goError parl.GoError)

func NewGoGroup

func NewGoGroup(ctx context.Context) (goCreator parl.GoGroup)

func NewGoSub

func NewGoSub(g0 parl.Go) (subGo parl.SubGo)

func NewGoer

func NewGoer(
	conduit parl.ErrorConduit,
	exitAction parl.ExitAction,
	index parl.GoIndex,
	gc *GoGroup,
	parentID parl.ThreadID,
	addLocation *pruntime.CodeLocation) (goer parl.Goer)

func NewGoerGroup

func NewGoerGroup(ctx context.Context) (goer parl.Goer)

Types

type Go

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

func (*Go) Add

func (g0 *Go) Add(delta int)

func (*Go) AddError

func (g0 *Go) AddError(err error)

func (*Go) Cancel

func (g0 *Go) Cancel()

func (*Go) Context

func (g0 *Go) Context() (ctx context.Context)

func (*Go) Done

func (g0 *Go) Done(errp *error)

func (*Go) Register

func (g0 *Go) Register()

func (*Go) SubGo

func (g0 *Go) SubGo() (goCancel parl.SubGo)

type GoErrorDo

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

func (*GoErrorDo) GetError

func (ge *GoErrorDo) GetError() (err error)

func (*GoErrorDo) Goer

func (ge *GoErrorDo) Goer() (goer parl.Goer)

func (*GoErrorDo) Source

func (ge *GoErrorDo) Source() (source parl.GoErrorSource)

func (*GoErrorDo) String

func (ge *GoErrorDo) String() (s string)

type GoGroup

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

func (*GoGroup) Add

func (gc *GoGroup) Add(conduit parl.ErrorConduit, exitAction parl.ExitAction) (goer parl.Goer)

func (*GoGroup) Ch

func (we *GoGroup) Ch() (ch <-chan parl.GoError)

func (*GoGroup) IsExit

func (we *GoGroup) IsExit() (isExit bool)

func (*GoGroup) String

func (gc *GoGroup) String() (s string)

func (*GoGroup) Wait

func (we *GoGroup) Wait()

func (*GoGroup) WaitPeriod

func (gc *GoGroup) WaitPeriod(duration ...time.Duration)

type Goer

type Goer struct {
	GoerGroup // Ch() IsExit() Wait() Cancel() Context()
	// contains filtered or unexported fields
}

func (*Goer) AddError

func (gr *Goer) AddError(err error)

func (*Goer) Ch

func (we *Goer) Ch() (ch <-chan parl.GoError)

func (*Goer) Go

func (gr *Goer) Go() (g0 parl.Go)

func (*Goer) IsExit

func (we *Goer) IsExit() (isExit bool)

func (*Goer) String

func (gr *Goer) String() (s string)

String outputs: #[index] [waitcount]([adds]): —lines: #[Goer-index] [waitcount]([adds]) ID: [thread-ID or parent-thread-ID] [create location].

index is a main-invocation-unique numeric identifier for the Goer. waitcount is the oustanding number of done invocations for the Goer. adds is the number of adds invoked for the Goer.

func (*Goer) Wait

func (we *Goer) Wait()

type GoerGroup

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

func (*GoerGroup) AddError

func (gr *GoerGroup) AddError(err error)

func (*GoerGroup) Ch

func (we *GoerGroup) Ch() (ch <-chan parl.GoError)

func (*GoerGroup) Go

func (gr *GoerGroup) Go() (g0 parl.Go)

func (*GoerGroup) IsExit

func (we *GoerGroup) IsExit() (isExit bool)

func (*GoerGroup) String

func (we *GoerGroup) String() (s string)

func (*GoerGroup) Wait

func (we *GoerGroup) Wait()

type SubGo

type SubGo struct {
	parl.Go // Register() AddError()
	// contains filtered or unexported fields
}

func (*SubGo) Add

func (gc *SubGo) Add(delta int)

func (*SubGo) Done

func (gc *SubGo) Done(errp *error)

func (*SubGo) SubGo

func (gc *SubGo) SubGo() (goCancel parl.SubGo)