data

Documentation

Index

• func NewLogicRepo(c *conf.Config, data *Data, redisExpire time.Duration) biz.LogicRepo
• type Data
  • func NewData(kafkaCli *kafka.Client, redisCli redis.Cmdable, db *gorm.DB) *Data
• type OfflineMsg

Functions

func NewLogicRepo

func NewLogicRepo(c *conf.Config, data *Data, redisExpire time.Duration) biz.LogicRepo

Types

type Data

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

func NewData

func NewData(kafkaCli *kafka.Client, redisCli redis.Cmdable, db *gorm.DB) *Data

type OfflineMsg

type OfflineMsg struct {
	Operation int32
	Data      []byte
}