post

Documentation

Index

• Constants
• type Producer
  • func NewSaramaSyncProducer(producer sarama.SyncProducer) Producer
• type ReadEvent
• type ReadEventConsumer
  • func NewReadEventConsumer(repo repository.InteractiveRepository, client sarama.Client, l *zap.Logger, ...) *ReadEventConsumer
  • func (i *ReadEventConsumer) BatchConsume(_ []*sarama.ConsumerMessage, events []ReadEvent) error
  • func (i *ReadEventConsumer) Start(_ context.Context) error
• type SaramaSyncProducer
  • func (s *SaramaSyncProducer) ProduceReadEvent(evt ReadEvent) error

Constants

const TopicReadEvent = "linkme_read_events"

Types

type Producer

type Producer interface {
	ProduceReadEvent(evt ReadEvent) error
}

func NewSaramaSyncProducer

func NewSaramaSyncProducer(producer sarama.SyncProducer) Producer

type ReadEvent

type ReadEvent struct {
	PostId  uint
	Uid     int64
	Title   string
	Content string
	PlateID int64
}

type ReadEventConsumer

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

func NewReadEventConsumer

func NewReadEventConsumer(repo repository.InteractiveRepository,
	client sarama.Client, l *zap.Logger, hisRepo repository.HistoryRepository) *ReadEventConsumer

func (*ReadEventConsumer) BatchConsume

func (i *ReadEventConsumer) BatchConsume(_ []*sarama.ConsumerMessage, events []ReadEvent) error

BatchConsume 处理函数，处理批次消息

func (*ReadEventConsumer) Start

func (i *ReadEventConsumer) Start(_ context.Context) error

type SaramaSyncProducer

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

func (*SaramaSyncProducer) ProduceReadEvent

func (s *SaramaSyncProducer) ProduceReadEvent(evt ReadEvent) error