g0

Documentation

Index

• Variables
• func NewGo(errorReceiver func(err error), add func(delta int), done func(err error), ...) (g0 parl.Go)
• func NewGoCreator(ctx context.Context) (goCreator parl.GoCreator)
• func NewGoError(err error, source parl.GoErrorSource, goer parl.Goer) (goError parl.GoError)
• func NewGoer(conduit parl.ErrorConduit, exitAction parl.ExitAction, index parl.GoIndex, ...) (goer parl.Goer)
• type GoCreatorDo
  • func (gc *GoCreatorDo) Add(conduit parl.ErrorConduit, exitAction parl.ExitAction) (goer parl.Goer)
  • func (gc *GoCreatorDo) IsExit() (isExit bool)
  • func (gc *GoCreatorDo) List() (s string)
  • func (gc *GoCreatorDo) Wait()
  • func (gc *GoCreatorDo) WaitPeriod(duration ...time.Duration)
  • func (gc *GoCreatorDo) Warnings() (ch <-chan parl.GoError)
• 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(err error)
  • func (g0 *GoDo) Register()
• type GoErrorDo
  • func (ge *GoErrorDo) GetError() (err error)
  • func (ge *GoErrorDo) Goer() (goer parl.Goer)
  • func (ge *GoErrorDo) Source() (source parl.GoErrorSource)
• type GoerDo
  • func (gr *GoerDo) Chan() (ch <-chan error)
  • func (gr *GoerDo) Go() (g0 parl.Go)
  • func (gr *GoerDo) String() (s string)
  • func (gr *GoerDo) Wait()
• type GoerRuntime

Variables

var GoCreatorFy = &goCreatorFactory{}

Functions

func NewGo

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

func NewGoCreator

func NewGoCreator(ctx context.Context) (goCreator parl.GoCreator)

func NewGoError

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

func NewGoer

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

Types

type GoCreatorDo

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

func (*GoCreatorDo) Add

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

func (*GoCreatorDo) IsExit

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

func (*GoCreatorDo) List

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

func (*GoCreatorDo) Wait

func (gc *GoCreatorDo) Wait()

func (*GoCreatorDo) WaitPeriod

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

func (*GoCreatorDo) Warnings

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

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(err error)

func (*GoDo) Register

func (g0 *GoDo) Register()

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)

type GoerDo

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

func (*GoerDo) Chan

func (gr *GoerDo) Chan() (ch <-chan error)

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 GoerRuntime

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