g0

Documentation

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) (goCancel parl.SubGo)
• func NewGoer(conduit parl.ErrorConduit, exitAction parl.ExitAction, index parl.GoIndex, ...) (goer parl.Goer)
• func NewGoerGroup(ctx context.Context) (goer parl.GoerGroup)
• type GoDo
  • func (g0 *GoDo) Add(delta int)
  • func (g0 *GoDo) AddError(err error)
  • func (g0 *GoDo) Context() (ctx context.Context)
  • func (g0 *GoDo) Done(errp *error)
  • func (g0 *GoDo) Register()
  • func (g0 *GoDo) 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 (gc *GoGroup) IsExit() (isExit bool)
  • func (gc *GoGroup) List() (s string)
  • func (gc *GoGroup) Wait()
  • func (gc *GoGroup) WaitPeriod(duration ...time.Duration)
  • func (gc *GoGroup) Warnings() (ch <-chan parl.GoError)
• type GoSub
  • func (gc *GoSub) Add(delta int)
  • func (gc *GoSub) Cancel()
  • func (gc *GoSub) Done(errp *error)
  • func (gc *GoSub) String() (s string)
  • func (gc *GoSub) SubGo() (goCancel parl.SubGo)
  • func (gc *GoSub) Wait()
• type GoerDo
  • func (gr *GoerDo) Cancel()
  • func (gr *GoerDo) Ch() (ch <-chan parl.GoError)
  • func (gr *GoerDo) Context() (ctx context.Context)
  • func (gr *GoerDo) Go() (g0 parl.Go)
  • func (gr *GoerDo) String() (s string)
  • func (gr *GoerDo) Wait()
• type GoerGroup
  • func (gr *GoerGroup) AddError(err error)
  • func (gr *GoerGroup) Cancel()
  • func (gr *GoerGroup) Ch() (ch <-chan parl.GoError)
  • func (gr *GoerGroup) Context() (ctx context.Context)
  • func (gr *GoerGroup) Go() (g0 parl.Go)
  • func (gr *GoerGroup) IsExit() (isExit bool)
  • func (gr *GoerGroup) String() (s string)
  • func (gr *GoerGroup) Wait()
• type GoerRuntime

Variables

var GoGroupFactory parl.GoGroupFactory = &goCreatorFactory{}

var GoerGroupFactory parl.GoerGroupFactory = &goerFactory{}

Functions

func NewGo

func NewGo(
	errorReceiver func(err error),
	add func(delta int),
	done func(err error),
	ctxFn func() (ctx context.Context)) (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) (goCancel 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.GoerGroup)

Types

type GoDo

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

func (*GoDo) Add

func (g0 *GoDo) Add(delta int)

func (*GoDo) AddError

func (g0 *GoDo) AddError(err error)

func (*GoDo) Context

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

func (*GoDo) Done

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

func (*GoDo) Register

func (g0 *GoDo) Register()

func (*GoDo) SubGo

func (g0 *GoDo) 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) IsExit

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

func (*GoGroup) List

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

func (*GoGroup) Wait

func (gc *GoGroup) Wait()

func (*GoGroup) WaitPeriod

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

func (*GoGroup) Warnings

func (gc *GoGroup) Warnings() (ch <-chan parl.GoError)

type GoSub

type GoSub struct {
	parl.Go
	// contains filtered or unexported fields
}

func (*GoSub) Add

func (gc *GoSub) Add(delta int)

func (*GoSub) Cancel

func (gc *GoSub) Cancel()

func (*GoSub) Done

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

func (*GoSub) String

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

func (*GoSub) SubGo

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

func (*GoSub) Wait

func (gc *GoSub) Wait()

type GoerDo

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

func (*GoerDo) Cancel

func (gr *GoerDo) Cancel()

func (*GoerDo) Ch

func (gr *GoerDo) Ch() (ch <-chan parl.GoError)

func (*GoerDo) Context

func (gr *GoerDo) Context() (ctx context.Context)

func (*GoerDo) Go

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

func (*GoerDo) String

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

#[index] [waitcount] ([adds]) [thread-ID or parent-thread-ID] add: add-location # go-creator index

func (*GoerDo) Wait

func (gr *GoerDo) Wait()

type GoerGroup

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

func (*GoerGroup) AddError

func (gr *GoerGroup) AddError(err error)

func (*GoerGroup) Cancel

func (gr *GoerGroup) Cancel()

func (*GoerGroup) Ch

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

func (*GoerGroup) Context

func (gr *GoerGroup) Context() (ctx context.Context)

func (*GoerGroup) Go

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

func (*GoerGroup) IsExit

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

func (*GoerGroup) String

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

func (*GoerGroup) Wait

func (gr *GoerGroup) Wait()

type GoerRuntime

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