publish

Documentation

Index

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

Constants

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 PublishEvent

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

type PublishPostEventConsumer

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

func NewPublishPostEventConsumer

func NewPublishPostEventConsumer(repo repository.PostRepository, client sarama.Client, 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