algorithms

package

v1.6.3 Latest Latest Go to latest Published: Sep 24, 2021 License: MIT Imports: 14 Imported by: 0

Details

This section is empty.

This section is empty.

func BuyDecisionTree(
	configData *types.Config,
	marketData *types.Market,
	sessionData *types.Session) (bool, float64)

BuyDecisionTree BUY decision routine

func SellDecisionTree(
	configData *types.Config,
	marketData *types.Market,
	sessionData *types.Session) (bool, types.Order)

SellDecisionTree SELL decision routine

func UpdatePendingOrders(
	configData *types.Config,
	sessionData *types.Session)

UpdatePendingOrders Routine to fill rogue and not up-to-date orders in the db and update

func WsBookTicker(
	configData *types.Config,
	marketData *types.Market,
	sessionData *types.Session,
	wg *sync.WaitGroup)

WsBookTicker Pushes any update to the best bid or asks price or quantity in real-time for a specified symbol

func WsKline(
	configData *types.Config,
	marketData *types.Market,
	sessionData *types.Session,
	wg *sync.WaitGroup)

WsKline The Kline/Candlestick Stream push updates to the current klines/candlestick every second.

func WsUserDataServe(
	configData *types.Config,
	sessionData *types.Session,
	wg *sync.WaitGroup)

WsUserDataServe Websocket routine to retrieve realtime user data

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

Channel control goroutine channel operations

func (c Channel) SetTrue(sessionData *types.Session)

SetTrue set all goroutines to stop

func (c Channel) Stop(
	channel chan struct{},
	wg *sync.WaitGroup,
	configData *types.Config,
	sessionData *types.Session)

Stop a websocket channel and decrease waiting group