check

Documentation

Index

• type Check
• type CheckConsumer
  • func NewCheckConsumer(client sarama.Client, l *zap.Logger, repo repository.PostRepository, ...) *CheckConsumer
  • func (r *CheckConsumer) Consume(sess sarama.ConsumerGroupSession, msg *sarama.ConsumerMessage) error
  • func (r *CheckConsumer) Start(ctx context.Context) error
• type Event

Types

type Check

type Check struct {
	ID        int64  `mapstructure:"id"`
	PostID    uint   `mapstructure:"post_id"`
	Title     string `mapstructure:"title"`
	Content   string `mapstructure:"content"`
	CreatedAt int64  `mapstructure:"created_at"`
	UpdatedAt int64  `mapstructure:"updated_at"`
	UserID    int64  `mapstructure:"author_id"`
	Status    uint8  `mapstructure:"status"`
	Remark    string `mapstructure:"remark"`
}

type CheckConsumer

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

func NewCheckConsumer

func NewCheckConsumer(client sarama.Client, l *zap.Logger, repo repository.PostRepository, checkCache cache.CheckCache) *CheckConsumer

func (*CheckConsumer) Consume

func (r *CheckConsumer) Consume(sess sarama.ConsumerGroupSession, msg *sarama.ConsumerMessage) error

func (*CheckConsumer) Start

func (r *CheckConsumer) Start(ctx context.Context) error

type Event

type Event struct {
	Type     string                   `json:"type"`
	Database string                   `json:"database"`
	Table    string                   `json:"table"`
	Data     []map[string]interface{} `json:"data"`
}