Documentation
¶
Index ¶
- type Config
- type Health
- type Node
- 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
- 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
- type RetryPolicy
- type Runner
- type StrategyHealth
- type TradingNode
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
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)
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 StrategyHealth ¶
type StrategyHealth struct {
ID string
State kernel.ComponentState
}
type TradingNode ¶
type TradingNode = Node
func NewTradingNode ¶
func NewTradingNode(cfg NodeConfig) (*TradingNode, error)
Click to show internal directories.
Click to hide internal directories.