Versions in this module Expand all Collapse all v1 v1.0.0 Jun 16, 2026 Changes in this version + type Config struct + Bus *bus.Bus + Node *platform.Node + Strategies []strategy.Strategy + type Health struct + LastError string + Platform platform.Health + State kernel.ComponentState + Strategies []StrategyHealth + type Node struct + func NewNode(cfg NodeConfig) (*Node, error) + func (n *Node) Bus() *bus.Bus + func (n *Node) Cache() *cache.Cache + func (n *Node) Health() Health + func (n *Node) Platform() *platform.Node + func (n *Node) Portfolio() *portfolio.Portfolio + func (n *Node) Risk() *risk.Engine + func (n *Node) Start(ctx context.Context) error + func (n *Node) Stop(ctx context.Context) error + type NodeBuilder struct + func NewNodeBuilder() *NodeBuilder + func (b *NodeBuilder) AddDataClient(client venue.DataClient) *NodeBuilder + func (b *NodeBuilder) AddExecutionClient(client venue.ExecutionClient) *NodeBuilder + func (b *NodeBuilder) AddStrategy(strategy strategy.Strategy) *NodeBuilder + func (b *NodeBuilder) Build() (*Node, error) + func (b *NodeBuilder) WithBus(bus *bus.Bus) *NodeBuilder + func (b *NodeBuilder) WithCache(cache *cache.Cache) *NodeBuilder + func (b *NodeBuilder) WithPortfolio(portfolio *portfolio.Portfolio) *NodeBuilder + func (b *NodeBuilder) WithReconnectPolicy(policy RetryPolicy) *NodeBuilder + func (b *NodeBuilder) WithRisk(risk *risk.Engine) *NodeBuilder + func (b *NodeBuilder) WithRiskConfig(cfg risk.Config) *NodeBuilder + type NodeConfig struct + Bus *bus.Bus + Cache *cache.Cache + DataClients []venue.DataClient + ExecutionClients []venue.ExecutionClient + Logger *slog.Logger + Portfolio *portfolio.Portfolio + ReconnectPolicy RetryPolicy + Risk *risk.Engine + RiskConfig risk.Config + Strategies []strategy.Strategy + func (cfg NodeConfig) Validate() error + type RetryPolicy = platform.RetryPolicy + type Runner struct + func NewRunner(cfg Config) *Runner + func (r *Runner) Health() Health + func (r *Runner) Start(ctx context.Context) (err error) + func (r *Runner) Stop(ctx context.Context) error + type StrategyHealth struct + ID string + State kernel.ComponentState + type TradingNode = Node + func NewTradingNode(cfg NodeConfig) (*TradingNode, error)
Go to main page