strategy

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

const BacktestStartedTopic = "strategy.BacktestStarted"

const NewBacktestTopic = "strategy.NewBacktest"

const StopBacktestTopic = "strategy.StopBacktest"

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"`
}