producers

Documentation

Index

• type KafkaProducer
  • func CreateKafkaProducer(server server.Server) (*KafkaProducer, error)
  • func (p *KafkaProducer) FlushAndCloseKafkaProducer()
  • func (p *KafkaProducer) InitStreamStockMarketDataProducer(server server.Server)
  • func (p *KafkaProducer) UpdateTickersTimeSeries(server server.Server)

Types

type KafkaProducer

type KafkaProducer struct {
	// contains filtered or unexported fields
}

func CreateKafkaProducer

func CreateKafkaProducer(server server.Server) (*KafkaProducer, error)

func (*KafkaProducer) FlushAndCloseKafkaProducer

func (p *KafkaProducer) FlushAndCloseKafkaProducer()

func (*KafkaProducer) InitStreamStockMarketDataProducer

func (p *KafkaProducer) InitStreamStockMarketDataProducer(server server.Server)

func (*KafkaProducer) UpdateTickersTimeSeries

func (p *KafkaProducer) UpdateTickersTimeSeries(server server.Server)