core

Documentation

Index

• func MakeSymbol(typ, member string) string
• func SplitSymbol(symbol string) (string, string)
• type EventNotifier
  • func (n *EventNotifier) EmitCall(symbol string, name string, params map[string]any)
  • func (n *EventNotifier) EmitError(err error)
  • func (n *EventNotifier) EmitEvent(e *SimuEvent)
  • func (n *EventNotifier) EmitPropertyChanged(symbol string, name string, value any)
  • func (n *EventNotifier) EmitPropertySet(symbol string, kwargs map[string]any)
  • func (n *EventNotifier) EmitReply(symbol string, name string, value any, err error)
  • func (n *EventNotifier) EmitSignal(symbol string, name string, args map[string]any)
  • func (n *EventNotifier) EmitSimuStart()
  • func (n *EventNotifier) EmitSimuStop()
  • 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 map[string]any) (any, error)
  • func (e *MultiEngine) PlayAllSequences() error
  • func (e *MultiEngine) PlaySequence(sequenceId string) error
  • func (e *MultiEngine) SetProperties(ifaceId string, props map[string]any) error
  • func (e *MultiEngine) StopAllSequences()
  • func (e *MultiEngine) StopSequence(sequenceId string)
• 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(symbol string, name string, params map[string]any)

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(symbol string, name string, value any)

func (*EventNotifier) EmitPropertySet

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

func (*EventNotifier) EmitReply

func (n *EventNotifier) EmitReply(symbol string, name string, value any, err error)

func (*EventNotifier) EmitSignal

func (n *EventNotifier) EmitSignal(symbol string, name string, args map[string]any)

func (*EventNotifier) EmitSimuStart

func (n *EventNotifier) EmitSimuStart()

func (*EventNotifier) EmitSimuStop

func (n *EventNotifier) EmitSimuStop()

func (*EventNotifier) OnEvent

func (n *EventNotifier) OnEvent(f OnEventFunc)

type IEngine

type IEngine interface {
	INotifier
	HasInterface(symbol string) bool
	InvokeOperation(symbol string, name string, params map[string]any) (any, error)
	SetProperties(symbol string, params map[string]any) error
	GetProperties(symbol string) (map[string]any, error)
	HasSequence(name string) bool
	PlaySequence(name string) error
	StopSequence(name string)
	PlayAllSequences() 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 map[string]any) (any, error)

InvokeOperation invokes the operation of the interface.

func (*MultiEngine) PlayAllSequences

func (e *MultiEngine) PlayAllSequences() error

func (*MultiEngine) PlaySequence

func (e *MultiEngine) PlaySequence(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)

type OnEventFunc

type OnEventFunc func(event *SimuEvent)

type SimuEvent

type SimuEvent struct {
	Timestamp time.Time      `json:"timestamp"`
	Type      SimuEventType  `json:"type"`
	Symbol    string         `json:"service"`
	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"
)