Versions in this module Expand all Collapse all v0 v0.11.1 Mar 16, 2021 v0.10.1 Mar 16, 2021 Changes in this version + type KafkaProducer struct + func NewKafkaProducer(url string, cfg *appcfg.StreamConfig) *KafkaProducer + func (kp *KafkaProducer) RefreshMarketIDMap(data *kline.KlineData, logger log.Logger) error + func (kp *KafkaProducer) SendAllMsg(data *kline.KlineData, logger log.Logger) (map[string]int, error)
Go to main page