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

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
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