check

Documentation

Index

• Constants
• type CheckEvent
• type CheckEventConsumer
  • func NewCheckEventConsumer(checkRepo repository.CheckRepository, client sarama.Client, l *zap.Logger) *CheckEventConsumer
  • func (i *CheckEventConsumer) Start(ctx context.Context) error
• type Producer
  • func NewSaramaCheckProducer(producer sarama.SyncProducer) Producer
• type SaramaCheckProducer
  • func (s *SaramaCheckProducer) ProduceCheckEvent(evt CheckEvent) error

Constants

const TopicCheckEvent = "check_events"

Types

type CheckEvent

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

type CheckEventConsumer

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

func NewCheckEventConsumer

func NewCheckEventConsumer(
	checkRepo repository.CheckRepository,
	client sarama.Client,
	l *zap.Logger,
) *CheckEventConsumer

func (*CheckEventConsumer) Start

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

type Producer

type Producer interface {
	ProduceCheckEvent(evt CheckEvent) error
}

func NewSaramaCheckProducer

func NewSaramaCheckProducer(producer sarama.SyncProducer) Producer

type SaramaCheckProducer

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

func (*SaramaCheckProducer) ProduceCheckEvent

func (s *SaramaCheckProducer) ProduceCheckEvent(evt CheckEvent) error