kafkaclient

Documentation

Index

• type KafkaProducer
  • 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)

Types

type KafkaProducer

type KafkaProducer struct {
	kline.MarketConfig
	*kafka.Writer
}

func NewKafkaProducer

func NewKafkaProducer(url string, cfg *appcfg.StreamConfig) *KafkaProducer

func (*KafkaProducer) RefreshMarketIDMap

func (kp *KafkaProducer) RefreshMarketIDMap(data *kline.KlineData, logger log.Logger) error

func (*KafkaProducer) SendAllMsg

func (kp *KafkaProducer) SendAllMsg(data *kline.KlineData, logger log.Logger) (map[string]int, error)