cache

Documentation

Index

• type CacheConsumer
  • func NewCacheConsumer(client sarama.Client, l *zap.Logger, redis redis.Cmdable, ...) *CacheConsumer
  • func (r *CacheConsumer) Consume(sess sarama.ConsumerGroupSession, msg *sarama.ConsumerMessage)
  • func (r *CacheConsumer) DeleteKeysWithPattern(ctx context.Context, pattern string) error
  • func (r *CacheConsumer) Start(_ context.Context) error
• type Event
• type Post

Types

type CacheConsumer

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

func NewCacheConsumer

func NewCacheConsumer(client sarama.Client, l *zap.Logger, redis redis.Cmdable, local *local.CacheManager, hisCache cache.HistoryCache) *CacheConsumer

func (*CacheConsumer) Consume

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

func (*CacheConsumer) DeleteKeysWithPattern

func (r *CacheConsumer) DeleteKeysWithPattern(ctx context.Context, pattern string) error

func (*CacheConsumer) Start

func (r *CacheConsumer) Start(_ 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"`
}

type Post

type Post struct {
	ID           uint         `mapstructure:"id"`
	Title        string       `mapstructure:"title"`
	Content      string       `mapstructure:"content"`
	CreatedAt    time.Time    `mapstructure:"created_at"`
	UpdatedAt    time.Time    `mapstructure:"updated_at"`
	DeletedAt    sql.NullTime `mapstructure:"deleted_at"`
	AuthorID     int64        `mapstructure:"author_id"`
	Status       uint8        `mapstructure:"status"`
	PlateID      int64        `mapstructure:"plate_id"`
	Slug         string       `mapstructure:"slug"`
	CategoryID   int64        `mapstructure:"category_id"`
	Tags         string       `mapstructure:"tags"`
	CommentCount int64        `mapstructure:"comment_count"`
}