data

package

v0.0.0-...-7d1b39b Latest Latest Go to latest Published: Sep 21, 2023 License: Apache-2.0 Imports: 20 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/toomanysource/atreus

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func InitDB(db *gorm.DB)
func NewMessageRepo(data *Data, logger log.Logger) biz.MessageRepo
func NewMysqlConn(c *conf.Data, l log.Logger) *gorm.DB
func NewRedisConn(c *conf.Data, l log.Logger) (cacheClient *redis.Client)
type Data
- func NewData(db *gorm.DB, kfk *KafkaConn, cache *redis.Client, logger log.Logger) (*Data, func(), error)
type KafkaConn
- func NewKafkaConn(c *conf.Data, l log.Logger) *KafkaConn
type Message
- func (Message) TableName() string

Constants ¶

View Source

const (
	RandTimeBegin = 360
	RandTimeEnd   = 720
)

Variables ¶

View Source

var (
	ErrCopy             = errors.New("copy error")
	ErrJsonMarshal      = errors.New("json marshal error")
	ErrRedisSet         = errors.New("redis set error")
	ErrRedisQuery       = errors.New("redis query error")
	ErrMysqlInsert      = errors.New("mysql insert error")
	ErrMysqlQuery       = errors.New("mysql query error")
	ErrRedisDelete      = errors.New("redis delete error")
	ErrRedisTransaction = errors.New("redis transaction error")
)

View Source

var ErrMsgYourself = errors.New("can't send message to yourself")

View Source

var ProviderSet = wire.NewSet(NewData, NewMessageRepo, NewMysqlConn, NewKafkaConn, NewRedisConn)

Functions ¶

func InitDB ¶

func InitDB(db *gorm.DB)

InitDB 创建followers数据表，并自动迁移

func NewMessageRepo ¶

func NewMessageRepo(data *Data, logger log.Logger) biz.MessageRepo

func NewMysqlConn ¶

func NewMysqlConn(c *conf.Data, l log.Logger) *gorm.DB

NewMysqlConn mysql数据库连接

func NewRedisConn ¶

func NewRedisConn(c *conf.Data, l log.Logger) (cacheClient *redis.Client)

NewRedisConn Redis数据库连接

Types ¶

type Data ¶

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

func NewData ¶

func NewData(db *gorm.DB, kfk *KafkaConn, cache *redis.Client, logger log.Logger) (*Data, func(), error)

type KafkaConn ¶

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

func NewKafkaConn ¶

func NewKafkaConn(c *conf.Data, l log.Logger) *KafkaConn

type Message ¶

type Message struct {
	Id         uint32 `gorm:"column:id;primary_key;auto_increment"`
	FromUserId uint32 `gorm:"column:from_user_id;not null;index:idx_from_user_to_user"`
	ToUserId   uint32 `gorm:"column:to_user_id;not null;index:idx_from_user_to_user"`
	Content    string `gorm:"column:content;not null"`
	CreateTime int64  `gorm:"column:created_at"`
}

func (Message) TableName ¶

func (Message) TableName() string

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL