execution

package

v0.1.0 Latest Latest Go to latest Published: Jul 22, 2026 License: Apache-2.0 Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

func Register(typeName string, factory Factory)

Register registers an execution actor factory under the given type name. Typically called from init() in each execution actor package.

type Config struct {
	Actor []actor.Entry `yaml:"actor"`
}

Config contains execution engine configuration.

type Engine struct {
	engine.EngineBase
	// contains filtered or unexported fields
}

Engine manages order execution and maintains open order state. It constructs actors from config via the factory registry.

func NewEngine(router *adapter.ExecutionRouter, msgBus *msgbus.MsgBus, cache *cache.Cache) *Engine

NewEngine creates a new execution engine

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

Connect establishes WebSocket connections to all execution clients. Subscriptions are already prepared during Init().

func (e *Engine) Disconnect()

Disconnect disconnects the execution router

func (e *Engine) Execute(cmd msgbus.Command, bus *msgbus.MsgBus)

Execute routes commands to the appropriate handler.

func (e *Engine) Init(config Config)

Init constructs actors from config, registers them and command processors.

func (e *Engine) Start()

Start starts the execution engine

func (e *Engine) Stop()

Stop stops the execution engine

type Factory func(bus *msgbus.MsgBus, c *cache.Cache) actor.Actor

Factory is a constructor function that creates an execution actor.

Path	Synopsis
actor
oms