post

Documentation

Index

• Constants
• type EventConsumer
  • func NewEventConsumer(repo repository.InteractiveRepository, hisRepo repository.HistoryRepository, ...) *EventConsumer
  • func (i *EventConsumer) Start(ctx context.Context) error
• type PostDeadLetterConsumer
  • func NewPostDeadLetterConsumer(repo repository.InteractiveRepository, hisRepo repository.HistoryRepository, ...) *PostDeadLetterConsumer
  • func (i *PostDeadLetterConsumer) Start(ctx context.Context) error
• type Producer
  • func NewSaramaSyncProducer(producer sarama.SyncProducer) Producer
• type ReadEvent
• type SaramaSyncProducer
  • func (s *SaramaSyncProducer) ProduceReadEvent(evt ReadEvent) error

Constants

const (
	TopicDeadLetter = "post_events_dlq" // 死信队列主题
	MaxRetries      = 3                 // 最大重试次数
)

const (
	TopicReadEvent = "read_events"
)

Types

type EventConsumer

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

func NewEventConsumer

func NewEventConsumer(
	repo repository.InteractiveRepository,
	hisRepo repository.HistoryRepository,
	client sarama.Client,
	dlqProd sarama.SyncProducer,
	l *zap.Logger,
) *EventConsumer

func (*EventConsumer) Start

func (i *EventConsumer) Start(ctx context.Context) error

type PostDeadLetterConsumer

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

func NewPostDeadLetterConsumer

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

func (*PostDeadLetterConsumer) Start

func (i *PostDeadLetterConsumer) Start(ctx context.Context) error

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 SaramaSyncProducer

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

func (*SaramaSyncProducer) ProduceReadEvent

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