publish

Documentation

Index

• Constants
• type Check
• type Producer
  • func NewSaramaSyncProducer(producer sarama.SyncProducer, logger *zap.Logger) Producer
• type PublishEvent
• type PublishPostEventConsumer
  • func NewPublishPostEventConsumer(checkClient checkClient.CheckClient, 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 = "linkme_microservices_publish_events"

Types

type Check

type Check struct {
	ID        int64     // 审核ID
	PostID    int64     // 帖子ID
	Content   string    // 审核内容
	Title     string    // 审核标签
	UserID    int64     // 提交审核的用户ID
	Status    uint8     // 审核状态
	Remark    string    // 审核备注
	CreatedAt time.Time // 创建时间
	UpdatedAt time.Time // 更新时间
}

type Producer

type Producer interface {
	ProducePublishEvent(evt PublishEvent) error
}

func NewSaramaSyncProducer

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

type PublishEvent

type PublishEvent struct {
	PostId  int64  `json:"post_id"`
	UserID  int64  `json:"user_id"`
	Title   string `json:"title"`
	Content string `json:"content"`
}

type PublishPostEventConsumer

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

func NewPublishPostEventConsumer

func NewPublishPostEventConsumer(checkClient checkClient.CheckClient, client sarama.Client, l *zap.Logger) *PublishPostEventConsumer

NewPublishPostEventConsumer 创建一个新的 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