runtime

Documentation

Index

• Variables
• func NewDebugger(r *Runtime) *debugger
• type Runtime
  • func NewRuntime(irb *blueprint.IRBlueprint, serverMode bool) *Runtime
  • func (r *Runtime) DispatchCurrentActiveIdsEvent()
  • func (r *Runtime) Error() error
  • func (r *Runtime) Errors() []error
  • func (r *Runtime) ExitCode() int
  • func (r *Runtime) GetStack() []base.IActionContext
  • func (r *Runtime) GetThreads() map[*Thread]bool
  • func (r *Runtime) IsServerMode() bool
  • func (r *Runtime) NewAContext(parent base.IActionContext, action *base.Action) base.IActionContext
  • func (r *Runtime) NewAContextJoin(parent base.IActionContext, action *base.Action) base.IActionContext
  • func (r *Runtime) NewAContextThread(parent base.IActionContext, actions []*base.Action) base.IActionContext
  • func (r *Runtime) NewEventListener() *base.EventListener
  • func (r *Runtime) NewThread(actx base.IActionContext) bool
  • func (r *Runtime) Pause()
  • func (r *Runtime) Play()
  • func (r *Runtime) SavedActionOutputs() []*base.ActionOutput
  • func (r *Runtime) Stop()
• type Thread
  • func (t *Thread) EventListener() *base.EventListener
  • func (t *Thread) GetCurrent() base.IActionContext
  • func (t *Thread) GetDone() []base.IActionContext
  • func (t *Thread) GetLastRun() base.IActionContext
  • func (t *Thread) GetQueue() []base.IActionContext
  • func (t *Thread) GetState() base.RuntimeState
  • func (t *Thread) Init()
  • func (t *Thread) Pause()
  • func (t *Thread) Play()
  • func (t *Thread) StackUp() (<-chan struct{}, bool)
  • func (t *Thread) Step() (<-chan struct{}, bool)
  • func (t *Thread) Stop()
• type ThreadStep

Variables

var MAXREADSIZE = 1024

var MAXWRITESIZE = 1024

Functions

func NewDebugger

func NewDebugger(r *Runtime) *debugger

Newdebugger func

Types

type Runtime

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

func NewRuntime

func NewRuntime(irb *blueprint.IRBlueprint, serverMode bool) *Runtime

func (*Runtime) DispatchCurrentActiveIdsEvent

func (r *Runtime) DispatchCurrentActiveIdsEvent()

func (*Runtime) Error

func (r *Runtime) Error() error

func (*Runtime) Errors

func (r *Runtime) Errors() []error

func (*Runtime) ExitCode

func (r *Runtime) ExitCode() int

func (*Runtime) GetStack

func (r *Runtime) GetStack() []base.IActionContext

func (*Runtime) GetThreads

func (r *Runtime) GetThreads() map[*Thread]bool

func (*Runtime) IsServerMode

func (r *Runtime) IsServerMode() bool

func (*Runtime) NewAContext

func (r *Runtime) NewAContext(parent base.IActionContext, action *base.Action) base.IActionContext

NewActionContext func creates a new base.IActionContext (runtime.actionContext), push into the runtime action stack and return the newly created action context

func (*Runtime) NewAContextJoin

func (r *Runtime) NewAContextJoin(parent base.IActionContext, action *base.Action) base.IActionContext

func (*Runtime) NewAContextThread

func (r *Runtime) NewAContextThread(parent base.IActionContext, actions []*base.Action) base.IActionContext

func (*Runtime) NewEventListener

func (r *Runtime) NewEventListener() *base.EventListener

func (*Runtime) NewThread

func (r *Runtime) NewThread(actx base.IActionContext) bool

func (*Runtime) Pause

func (r *Runtime) Pause()

func (*Runtime) Play

func (r *Runtime) Play()

func (*Runtime) SavedActionOutputs

func (r *Runtime) SavedActionOutputs() []*base.ActionOutput

func (*Runtime) Stop

func (r *Runtime) Stop()

type Thread

type Thread struct {
	ThreadStep ThreadStep

	ExitCode int
	ExitErr  error // uncaught err
	// contains filtered or unexported fields
}

func (*Thread) EventListener

func (t *Thread) EventListener() *base.EventListener

func (*Thread) GetCurrent

func (t *Thread) GetCurrent() base.IActionContext

func (*Thread) GetDone

func (t *Thread) GetDone() []base.IActionContext

func (*Thread) GetLastRun

func (t *Thread) GetLastRun() base.IActionContext

func (*Thread) GetQueue

func (t *Thread) GetQueue() []base.IActionContext

func (*Thread) GetState

func (t *Thread) GetState() base.RuntimeState

func (*Thread) Init

func (t *Thread) Init()

commonly called by go Init()

func (*Thread) Pause

func (t *Thread) Pause()

func (*Thread) Play

func (t *Thread) Play()

func (*Thread) StackUp

func (t *Thread) StackUp() (<-chan struct{}, bool)

func (*Thread) Step

func (t *Thread) Step() (<-chan struct{}, bool)

func (*Thread) Stop

func (t *Thread) Stop()

type ThreadStep

type ThreadStep int

const (
	ThreadBeforeAction ThreadStep = iota
	ThreadIntoAction
	ThreadAfterAction
	ThreadClose
)