Documentation
¶
Index ¶
- Constants
- func NewExecutionModule(log *zap.Logger, config *config.Config, stream stream.Stream, ...) error
- func NewStorage(conn *pgxpool.Pool) (storage.BacktestStorage, storage.PeriodStorage, storage.StrategyStorage, error)
- func Routes(route *gin.RouterGroup, log *zap.Logger, ...) (*gin.RouterGroup, error)
- type BacktestStartedPayload
- type NewBacktestPayload
Constants ¶
View Source
const BacktestStartedTopic = "strategy.BacktestStarted"
View Source
const NewBacktestTopic = "strategy.NewBacktest"
View Source
const StopBacktestTopic = "strategy.StopBacktest"
Variables ¶
This section is empty.
Functions ¶
func NewExecutionModule ¶
func NewExecutionModule(log *zap.Logger, config *config.Config, stream stream.Stream, periods storage.PeriodStorage, orders financeStorage.OrderStorage, positions financeStorage.PositionStorage, instances serviceStorage.InstanceStorage, services serviceStorage.ServiceStorage, strategies storage.StrategyStorage, backtests storage.BacktestStorage, scheduler backtest.Scheduler, lc fx.Lifecycle) error
func NewStorage ¶
func NewStorage(conn *pgxpool.Pool) (storage.BacktestStorage, storage.PeriodStorage, storage.StrategyStorage, error)
func Routes ¶
func Routes(route *gin.RouterGroup, log *zap.Logger, services serviceStorage.ServiceStorage, instances serviceStorage.InstanceStorage, strategies storage.StrategyStorage, backtests storage.BacktestStorage, periods storage.PeriodStorage, orders financeStorage.OrderStorage, positions financeStorage.PositionStorage, trading finance.Trading, stream stream.Stream) (*gin.RouterGroup, error)
Types ¶
type BacktestStartedPayload ¶
type BacktestStartedPayload struct {
Execution backtest.AutomatedBacktest `json:"backtest"`
}
type NewBacktestPayload ¶
type NewBacktestPayload struct {
ID string `json:"id"`
Backtest serviceStorage.Service `json:"backtest"`
Worker serviceStorage.Service `json:"worker"`
}
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.