Documentation
¶
Index ¶
- func ConsumeAggTradeQueue(conn *amqp.Connection, queueName string)
- func ConsumeKlineQueue(conn *amqp.Connection, queueName string)
- func ConsumePriceDepthQueue(conn *amqp.Connection, queueName string)
- func CreateElasticAggTrade(aggTrade *binance.WsAggTradeEvent) *error
- func CreateMongoAggTrade(aggTrade *binance.WsAggTradeEvent) error
- func CreateMongoKline(kline *binance.WsKlineEvent)
- func CreateRDBMSAggTrade(aggTradEvent *binance.WsAggTradeEvent)
- func CreateRDBMSKline(klineEvent *binance.WsKlineEvent)
- func CreateRedisKline(kline *binance.WsKlineEvent) error
- func CreateRedisPriceDepth(priceDepth *binance.WsDepthEvent) error
- func SubmitAggTradeQueue(queueName string, contentType string, aggTrade *binance.WsAggTradeEvent) error
- func SubmitKlineQueue(queueName string, contentType string, kline *binance.WsKlineEvent) error
- func SubmitPriceDepthQueue(queueName string, contentType string, priceDepth *binance.WsDepthEvent) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConsumeAggTradeQueue ¶
func ConsumeAggTradeQueue(conn *amqp.Connection, queueName string)
func ConsumeKlineQueue ¶
func ConsumeKlineQueue(conn *amqp.Connection, queueName string)
func ConsumePriceDepthQueue ¶
func ConsumePriceDepthQueue(conn *amqp.Connection, queueName string)
func CreateElasticAggTrade ¶
func CreateElasticAggTrade(aggTrade *binance.WsAggTradeEvent) *error
func CreateMongoAggTrade ¶
func CreateMongoAggTrade(aggTrade *binance.WsAggTradeEvent) error
func CreateMongoKline ¶
func CreateMongoKline(kline *binance.WsKlineEvent)
func CreateRDBMSAggTrade ¶
func CreateRDBMSAggTrade(aggTradEvent *binance.WsAggTradeEvent)
AddAggTrade
func CreateRedisKline ¶
func CreateRedisKline(kline *binance.WsKlineEvent) error
func CreateRedisPriceDepth ¶
func CreateRedisPriceDepth(priceDepth *binance.WsDepthEvent) error
func SubmitAggTradeQueue ¶
func SubmitKlineQueue ¶
func SubmitPriceDepthQueue ¶
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.