live

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 16, 2026 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config

type Config struct {
	Node       *platform.Node
	Bus        *bus.Bus
	Strategies []strategy.Strategy
}

type Health

type Health struct {
	State      kernel.ComponentState
	Platform   platform.Health
	Strategies []StrategyHealth
	LastError  string
}

type Node

type Node struct {
	// contains filtered or unexported fields
}

func NewNode

func NewNode(cfg NodeConfig) (*Node, error)

func (*Node) Bus

func (n *Node) Bus() *bus.Bus

func (*Node) Cache

func (n *Node) Cache() *cache.Cache

func (*Node) Health

func (n *Node) Health() Health

func (*Node) Platform

func (n *Node) Platform() *platform.Node

func (*Node) Portfolio

func (n *Node) Portfolio() *portfolio.Portfolio

func (*Node) Risk

func (n *Node) Risk() *risk.Engine

func (*Node) Start

func (n *Node) Start(ctx context.Context) error

func (*Node) Stop

func (n *Node) Stop(ctx context.Context) error

type NodeBuilder

type NodeBuilder struct {
	// contains filtered or unexported fields
}

func NewNodeBuilder

func NewNodeBuilder() *NodeBuilder

func (*NodeBuilder) AddDataClient

func (b *NodeBuilder) AddDataClient(client venue.DataClient) *NodeBuilder

func (*NodeBuilder) AddExecutionClient

func (b *NodeBuilder) AddExecutionClient(client venue.ExecutionClient) *NodeBuilder

func (*NodeBuilder) AddStrategy

func (b *NodeBuilder) AddStrategy(strategy strategy.Strategy) *NodeBuilder

func (*NodeBuilder) Build

func (b *NodeBuilder) Build() (*Node, error)

func (*NodeBuilder) WithBus

func (b *NodeBuilder) WithBus(bus *bus.Bus) *NodeBuilder

func (*NodeBuilder) WithCache

func (b *NodeBuilder) WithCache(cache *cache.Cache) *NodeBuilder

func (*NodeBuilder) WithPortfolio

func (b *NodeBuilder) WithPortfolio(portfolio *portfolio.Portfolio) *NodeBuilder

func (*NodeBuilder) WithReconnectPolicy

func (b *NodeBuilder) WithReconnectPolicy(policy RetryPolicy) *NodeBuilder

func (*NodeBuilder) WithRisk

func (b *NodeBuilder) WithRisk(risk *risk.Engine) *NodeBuilder

func (*NodeBuilder) WithRiskConfig

func (b *NodeBuilder) WithRiskConfig(cfg risk.Config) *NodeBuilder

type NodeConfig

type NodeConfig struct {
	Bus              *bus.Bus
	Cache            *cache.Cache
	Risk             *risk.Engine
	RiskConfig       risk.Config
	Portfolio        *portfolio.Portfolio
	ReconnectPolicy  RetryPolicy
	Logger           *slog.Logger
	DataClients      []venue.DataClient
	ExecutionClients []venue.ExecutionClient
	Strategies       []strategy.Strategy
}

func (NodeConfig) Validate

func (cfg NodeConfig) Validate() error

type RetryPolicy

type RetryPolicy = platform.RetryPolicy

type Runner

type Runner struct {
	// contains filtered or unexported fields
}

func NewRunner

func NewRunner(cfg Config) *Runner

func (*Runner) Health

func (r *Runner) Health() Health

func (*Runner) Start

func (r *Runner) Start(ctx context.Context) (err error)

func (*Runner) Stop

func (r *Runner) Stop(ctx context.Context) error

type StrategyHealth

type StrategyHealth struct {
	ID    string
	State kernel.ComponentState
}

type TradingNode

type TradingNode = Node

func NewTradingNode

func NewTradingNode(cfg NodeConfig) (*TradingNode, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL