core

Documentation

Index

• func MakeSymbol(typ, member string) string
• func SplitSymbol(symbol string) (string, string)
• type EventNotifier
  • func (n *EventNotifier) EmitCall(ifaceId string, opName string, args []any)
  • func (n *EventNotifier) EmitCallError(symbol string, name string, err error)
  • func (n *EventNotifier) EmitError(err error)
  • func (n *EventNotifier) EmitEvent(e *SimuEvent)
  • func (n *EventNotifier) EmitPropertyChanged(ifaceId string, propName string, value any)
  • func (n *EventNotifier) EmitPropertySet(ifaceId string, kwargs map[string]any)
  • func (n *EventNotifier) EmitReply(ifaceId string, opName string, value any)
  • func (n *EventNotifier) EmitSignal(ifaceId string, signName string, args []any)
  • func (n *EventNotifier) EmitSimuStart(name string)
  • func (n *EventNotifier) EmitSimuStop(name string)
  • func (n *EventNotifier) OnEvent(f OnEventFunc)
• type IEngine
• type INotifier
• type MultiEngine
  • func NewMultiEngine(entries ...IEngine) *MultiEngine
  • func (e *MultiEngine) GetProperties(ifaceId string) (map[string]any, error)
  • func (e *MultiEngine) HasInterface(ifaceId string) bool
  • func (e *MultiEngine) HasSequence(sequencerId string) bool
  • func (e *MultiEngine) InvokeOperation(ifaceId string, name string, args []any) (any, error)
  • func (e *MultiEngine) PlayAllSequences(ctx context.Context) error
  • func (e *MultiEngine) PlaySequence(ctx context.Context, sequenceId string) error
  • func (e *MultiEngine) SetProperties(ifaceId string, props map[string]any) error
  • func (e *MultiEngine) StopAllSequences()
  • func (e *MultiEngine) StopSequence(sequenceId string) error
• type OnEventFunc
• type SimuEvent
• type SimuEventType

Functions

func MakeSymbol

func MakeSymbol(typ, member string) string

func SplitSymbol

func SplitSymbol(symbol string) (string, string)

Types

type EventNotifier

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

func (*EventNotifier) EmitCall

func (n *EventNotifier) EmitCall(ifaceId string, opName string, args []any)

func (*EventNotifier) EmitCallError

func (n *EventNotifier) EmitCallError(symbol string, name string, err error)

func (*EventNotifier) EmitError

func (n *EventNotifier) EmitError(err error)

func (*EventNotifier) EmitEvent

func (n *EventNotifier) EmitEvent(e *SimuEvent)

func (*EventNotifier) EmitPropertyChanged

func (n *EventNotifier) EmitPropertyChanged(ifaceId string, propName string, value any)

func (*EventNotifier) EmitPropertySet

func (n *EventNotifier) EmitPropertySet(ifaceId string, kwargs map[string]any)

func (*EventNotifier) EmitReply

func (n *EventNotifier) EmitReply(ifaceId string, opName string, value any)

func (*EventNotifier) EmitSignal

func (n *EventNotifier) EmitSignal(ifaceId string, signName string, args []any)

func (*EventNotifier) EmitSimuStart

func (n *EventNotifier) EmitSimuStart(name string)

func (*EventNotifier) EmitSimuStop

func (n *EventNotifier) EmitSimuStop(name string)

func (*EventNotifier) OnEvent

func (n *EventNotifier) OnEvent(f OnEventFunc)

type IEngine

type IEngine interface {
	INotifier
	HasInterface(symbol string) bool
	InvokeOperation(symbol string, name string, args []any) (any, error)
	SetProperties(symbol string, params map[string]any) error
	GetProperties(symbol string) (map[string]any, error)
	HasSequence(name string) bool
	PlaySequence(ctx context.Context, name string) error
	StopSequence(name string) error
	PlayAllSequences(ctx context.Context) error
	StopAllSequences()
}

IEngine is the interface for the simulation engine.

type INotifier

type INotifier interface {
	OnEvent(f OnEventFunc)
	EmitEvent(e *SimuEvent)
}

type MultiEngine

type MultiEngine struct {
	EventNotifier
	// contains filtered or unexported fields
}

func NewMultiEngine

func NewMultiEngine(entries ...IEngine) *MultiEngine

func (*MultiEngine) GetProperties

func (e *MultiEngine) GetProperties(ifaceId string) (map[string]any, error)

FetchProperties fetches the properties of the interface.

func (*MultiEngine) HasInterface

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

HasInterface returns true if the interface is served by the simulation.

func (*MultiEngine) HasSequence

func (e *MultiEngine) HasSequence(sequencerId string) bool

func (*MultiEngine) InvokeOperation

func (e *MultiEngine) InvokeOperation(ifaceId string, name string, args []any) (any, error)

InvokeOperation invokes the operation of the interface.

func (*MultiEngine) PlayAllSequences

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

func (*MultiEngine) PlaySequence

func (e *MultiEngine) PlaySequence(ctx context.Context, sequenceId string) error

func (*MultiEngine) SetProperties

func (e *MultiEngine) SetProperties(ifaceId string, props map[string]any) error

SetProperties sets the properties of the interface.

func (*MultiEngine) StopAllSequences

func (e *MultiEngine) StopAllSequences()

func (*MultiEngine) StopSequence

func (e *MultiEngine) StopSequence(sequenceId string) error

type OnEventFunc

type OnEventFunc func(event *SimuEvent)

type SimuEvent

type SimuEvent struct {
	Type      SimuEventType  `json:"type"`
	Timestamp time.Time      `json:"timestamp"`
	Symbol    string         `json:"symbol"`
	Name      string         `json:"name"`
	Args      []any          `json:"args"`
	KWArgs    map[string]any `json:"kwargs"`
	Error     string         `json:"error"`
}

type SimuEventType

type SimuEventType string

const (
	EventSimuStart       SimuEventType = "start"
	EventSimuStop        SimuEventType = "stop"
	EventCall            SimuEventType = "call"
	EventReply           SimuEventType = "response"
	EventSignal          SimuEventType = "signal"
	EventPropertySet     SimuEventType = "set"
	EventPropertyChanged SimuEventType = "changed"
	EventError           SimuEventType = "error"
)