Versions in this module Expand all Collapse all v0 v0.1.0 Jul 22, 2026 Changes in this version + func Register(typeName string, factory Factory) + type Config struct + Actor []actor.Entry + type DataSubscription struct + AggTrade bool + Depth *adapter.DepthOptions + Endpoint string + Kline *adapter.KlineOptions + SymbolID int + Trade bool + type Engine struct + func NewEngine(cat *catalog.Catalog, msgBus *msgbus.MsgBus, c *cache.Cache) *Engine + func (e *Engine) Connect(ctx context.Context) + func (e *Engine) Disconnect() + func (e *Engine) Execute(cmd msgbus.Command, bus *msgbus.MsgBus) + func (e *Engine) Init(config Config, subscriptions []adapter.DataRouterEntry) + func (e *Engine) Start() + func (e *Engine) Stop() + type Factory func(cat *catalog.Catalog, bus *msgbus.MsgBus, c *cache.Cache) actor.Actor
Go to main page