article

Documentation

Index

• Constants
• type Producer
  • func NewSaramaSyncProducer(producer sarama.SyncProducer) Producer
• type ReadEvent
• type SaramaSyncProducer
  • func (r *SaramaSyncProducer) ProduceReadEvent(event ReadEvent) error

Constants

const TopicReadEvent = "article_read"

Types

type Producer

type Producer interface {
	ProduceReadEvent(event ReadEvent) error
}

func NewSaramaSyncProducer

func NewSaramaSyncProducer(producer sarama.SyncProducer) Producer

type ReadEvent

type ReadEvent struct {
	Aid int64
	Uid int64
}

type SaramaSyncProducer

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

func (*SaramaSyncProducer) ProduceReadEvent

func (r *SaramaSyncProducer) ProduceReadEvent(event ReadEvent) error