actions

Documentation

Index

• func NewEval(store ostore.IObjectStore) *eval
• func ReadScenario(source string) (*spec.ScenarioDoc, error)
• type ActionHandler
• type Engine
  • func NewEngine(store ostore.IObjectStore) *Engine
  • func (e *Engine) GetInterface(ifaceId string) *spec.InterfaceEntry
  • func (e *Engine) GetProperties(symbol string) (map[string]any, error)
  • func (e *Engine) HasInterface(ifaceId string) bool
  • func (e *Engine) HasSequence(name string) bool
  • func (e *Engine) InvokeOperation(ifaceId string, opName string, args []any) (any, error)
  • func (e *Engine) LoadScenario(source string, doc *spec.ScenarioDoc) error
  • func (e *Engine) PlayAllSequences(ctx context.Context) error
  • func (e *Engine) PlaySequence(ctx context.Context, name string) error
  • func (e *Engine) SetProperties(symbol string, props map[string]any) error
  • func (e *Engine) StopAllSequences()
  • func (e *Engine) StopSequence(name string)
  • func (a *Engine) UnloadScenario(source string) error
• type PlayFrame
• type Player
  • func NewPlayer(iface *spec.InterfaceEntry, seq *spec.SequenceEntry) *Player
  • func (p *Player) Play(ctx context.Context) error
  • func (p *Player) SequenceName() string
  • func (p *Player) Stop() error

Functions

func NewEval

func NewEval(store ostore.IObjectStore) *eval

func ReadScenario

func ReadScenario(source string) (*spec.ScenarioDoc, error)

ReadScenario reads a scenario from file.

Types

type ActionHandler

type ActionHandler func(symbol string, args map[string]any) (any, error)

type Engine

type Engine struct {
	core.EventNotifier
	// contains filtered or unexported fields
}

func NewEngine

func NewEngine(store ostore.IObjectStore) *Engine

func (*Engine) GetInterface

func (e *Engine) GetInterface(ifaceId string) *spec.InterfaceEntry

func (*Engine) GetProperties

func (e *Engine) GetProperties(symbol string) (map[string]any, error)

FetchProperties returns a copy of the properties of the interface.

func (*Engine) HasInterface

func (e *Engine) HasInterface(ifaceId string) bool

func (*Engine) HasSequence

func (e *Engine) HasSequence(name string) bool

func (*Engine) InvokeOperation

func (e *Engine) InvokeOperation(ifaceId string, opName string, args []any) (any, error)

InvokeOperation invokes a operation of the interface.

func (*Engine) LoadScenario

func (e *Engine) LoadScenario(source string, doc *spec.ScenarioDoc) error

func (*Engine) PlayAllSequences

func (e *Engine) PlayAllSequences(ctx context.Context) error

func (*Engine) PlaySequence

func (e *Engine) PlaySequence(ctx context.Context, name string) error

func (*Engine) SetProperties

func (e *Engine) SetProperties(symbol string, props map[string]any) error

SetProperties sets the properties of the interface.

func (*Engine) StopAllSequences

func (e *Engine) StopAllSequences()

func (*Engine) StopSequence

func (e *Engine) StopSequence(name string)

func (*Engine) UnloadScenario

func (a *Engine) UnloadScenario(source string) error

type PlayFrame

type PlayFrame struct {
	Action    spec.ActionEntry
	Interface *spec.InterfaceEntry
}

type Player

type Player struct {
	sync.RWMutex

	StepC   chan *spec.ActionListEntry
	FramesC chan PlayFrame
	// contains filtered or unexported fields
}

Player is a player for one sequence It plays the sequence and sends the actions to the stream The stream is closed when the sequence is finished Actions are evaluated in the context of an interface

func NewPlayer

func NewPlayer(iface *spec.InterfaceEntry, seq *spec.SequenceEntry) *Player

func (*Player) Play

func (p *Player) Play(ctx context.Context) error

func (*Player) SequenceName

func (p *Player) SequenceName() string

func (*Player) Stop

func (p *Player) Stop() error