controller

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

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 CreateRDBMSKline

func CreateRDBMSKline(klineEvent *binance.WsKlineEvent)

AddKline

func CreateRedisKline

func CreateRedisKline(kline *binance.WsKlineEvent) error

func CreateRedisPriceDepth

func CreateRedisPriceDepth(priceDepth *binance.WsDepthEvent) error

func SubmitAggTradeQueue

func SubmitAggTradeQueue(queueName string, contentType string, aggTrade *binance.WsAggTradeEvent) error

func SubmitKlineQueue

func SubmitKlineQueue(queueName string, contentType string, kline *binance.WsKlineEvent) error

func SubmitPriceDepthQueue

func SubmitPriceDepthQueue(queueName string, contentType string, priceDepth *binance.WsDepthEvent) error