publish

Documentation

Index

• Constants
• type Producer
  • func NewSaramaSyncProducer(producer sarama.SyncProducer, l *zap.Logger) Producer
• type PublishDeadLetterConsumer
  • func NewPublishDeadLetterConsumer(repo repository.PostRepository, client sarama.Client, l *zap.Logger) *PublishDeadLetterConsumer
  • func (p *PublishDeadLetterConsumer) Start(ctx context.Context) error
• type PublishEvent
• type PublishPostEventConsumer
  • func NewPublishPostEventConsumer(repo repository.PostRepository, client sarama.Client, ...) *PublishPostEventConsumer
  • func (p *PublishPostEventConsumer) Start(ctx context.Context) error
• type SaramaSyncProducer
  • func (s *SaramaSyncProducer) ProducePublishEvent(evt PublishEvent) error

Constants

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

const TopicPublishEvent = "publish_events"

Types

type Producer

type Producer interface {
	ProducePublishEvent(evt PublishEvent) error
}

func NewSaramaSyncProducer

func NewSaramaSyncProducer(producer sarama.SyncProducer, l *zap.Logger) Producer

type PublishDeadLetterConsumer

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

func NewPublishDeadLetterConsumer

func NewPublishDeadLetterConsumer(
	repo repository.PostRepository,
	client sarama.Client,
	l *zap.Logger,
) *PublishDeadLetterConsumer

func (*PublishDeadLetterConsumer) Start

func (p *PublishDeadLetterConsumer) Start(ctx context.Context) error

type PublishEvent

type PublishEvent struct {
	PostId uint  `json:"post_id"`
	Uid    int64 `json:"uid"`
	Status uint8 `json:"status"`
}

type PublishPostEventConsumer

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

func NewPublishPostEventConsumer

func NewPublishPostEventConsumer(repo repository.PostRepository, client sarama.Client, dlqProd sarama.SyncProducer, l *zap.Logger) *PublishPostEventConsumer

func (*PublishPostEventConsumer) Start

func (p *PublishPostEventConsumer) Start(ctx context.Context) error

Start 启动消费者，并开始消费 Kafka 中的消息

type SaramaSyncProducer

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

func (*SaramaSyncProducer) ProducePublishEvent

func (s *SaramaSyncProducer) ProducePublishEvent(evt PublishEvent) error