Versions in this module Expand all Collapse all v1 v1.0.0 Jun 16, 2026 Changes in this version + const TopicExecution + const TopicMarketData + type Config struct + Bus *bus.Bus + Cache *cache.Cache + DataCatalog data.Catalog + DataEngine *data.Engine + DataStaleAfter time.Duration + ExecutionEngine *execution.Engine + Logger *slog.Logger + Portfolio *portfolio.Portfolio + ReconnectPolicy RetryPolicy + Risk *risk.Engine + type DataClientHealth struct + ClientID string + Health venue.DataHealth + Venue model.Venue + type ExecutionClientHealth struct + AccountID model.AccountID + Health venue.ExecutionHealth + Venue model.Venue + type Health struct + Data []DataClientHealth + DataEngine data.Health + Execution []ExecutionClientHealth + LastError error + Ready bool + Risk risk.Health + State kernel.ComponentState + type Node struct + func NewNode(cfg Config) *Node + func (n *Node) AddDataClient(client venue.DataClient) error + func (n *Node) AddExecutionClient(client venue.ExecutionClient) error + func (n *Node) BatchCancelOrders(ctx context.Context, batch model.BatchCancelOrders) ([]model.OrderStatusReport, error) + func (n *Node) Bus() *bus.Bus + func (n *Node) Cache() *cache.Cache + func (n *Node) CancelAllOrders(ctx context.Context, cancelAll model.CancelAllOrders) ([]model.OrderStatusReport, error) + func (n *Node) CancelOrder(ctx context.Context, cancel model.CancelOrder) (model.OrderStatusReport, error) + func (n *Node) CancelTimer(_ context.Context, name string) error + func (n *Node) Clock() strategy.Clock + func (n *Node) DataEngine() *data.Engine + func (n *Node) ExecutionEngine() *execution.Engine + func (n *Node) Health() Health + func (n *Node) Logger() *slog.Logger + func (n *Node) ModifyOrder(ctx context.Context, modify model.ModifyOrder) (model.OrderStatusReport, error) + func (n *Node) OrderFactory(accountID model.AccountID) *model.OrderFactory + func (n *Node) Portfolio() *portfolio.Portfolio + func (n *Node) QueryAccount(ctx context.Context, query model.QueryAccount) (model.AccountSnapshot, error) + func (n *Node) QueryOrder(ctx context.Context, query model.QueryOrder) (model.OrderStatusReport, error) + func (n *Node) RequestData(ctx context.Context, request model.DataRequest) (model.DataResponse, error) + func (n *Node) SetTimer(_ context.Context, name string, interval time.Duration) error + func (n *Node) Start(ctx context.Context) (err error) + func (n *Node) Stop(ctx context.Context) error + func (n *Node) SubmitOrder(ctx context.Context, order model.SubmitOrder) (model.OrderStatusReport, error) + func (n *Node) SubmitOrderList(ctx context.Context, list model.OrderList) ([]model.OrderStatusReport, error) + func (n *Node) SubscribeBars(ctx context.Context, barType model.BarType) error + func (n *Node) SubscribeFundingRates(ctx context.Context, instrumentID model.InstrumentID) error + func (n *Node) SubscribeMarketData(ctx context.Context, sub model.SubscribeMarketData) error + func (n *Node) SubscribeOrderBookDepth(ctx context.Context, instrumentID model.InstrumentID, depth int) error + func (n *Node) SubscribeQuoteTicks(ctx context.Context, instrumentID model.InstrumentID) error + func (n *Node) SubscribeTicker(ctx context.Context, instrumentID model.InstrumentID) error + func (n *Node) SubscribeTradeTicks(ctx context.Context, instrumentID model.InstrumentID) error + func (n *Node) UnsubscribeBars(ctx context.Context, barType model.BarType) error + func (n *Node) UnsubscribeFundingRates(ctx context.Context, instrumentID model.InstrumentID) error + func (n *Node) UnsubscribeMarketData(ctx context.Context, sub model.SubscribeMarketData) error + func (n *Node) UnsubscribeOrderBookDepth(ctx context.Context, instrumentID model.InstrumentID, depth int) error + func (n *Node) UnsubscribeQuoteTicks(ctx context.Context, instrumentID model.InstrumentID) error + func (n *Node) UnsubscribeTicker(ctx context.Context, instrumentID model.InstrumentID) error + func (n *Node) UnsubscribeTradeTicks(ctx context.Context, instrumentID model.InstrumentID) error + type RetryPolicy struct + Backoff time.Duration + MaxAttempts int
Go to main page