Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func InitializeAccountVersionCheckPointWorker ¶
func InitializeAccountVersionCheckPointWorker()
func InitializeKLineWorker ¶
func InitializeKLineWorker()
func InitializeRebuildKLineToRedisWorker ¶
func InitializeRebuildKLineToRedisWorker()
func InitializeTickerWorker ¶
func InitializeTickerWorker()
Types ¶
type AccountVersionCheckPointWorker ¶
func (*AccountVersionCheckPointWorker) Work ¶
func (worker *AccountVersionCheckPointWorker) Work(payloadJson *[]byte) (err error)
type KLineWorker ¶
func (*KLineWorker) Work ¶
func (worker *KLineWorker) Work(payloadJson *[]byte) (err error)
type RebuildKLineToRedisWorker ¶
func (*RebuildKLineToRedisWorker) Work ¶
func (worker *RebuildKLineToRedisWorker) Work(payloadJson *[]byte) (err error)
type TickerWorker ¶
func (*TickerWorker) Work ¶
func (worker *TickerWorker) Work(payloadJson *[]byte) (err error)
Click to show internal directories.
Click to hide internal directories.