data

Documentation

Index

• Variables
• func InitTables(db *gorm.DB) error
• func NewDB(c *conf.Data) (*gorm.DB, error)
• func NewLogger() *zap.Logger
• func NewMongoDB(c *conf.Data) *mongo.Client
• func NewPostData(data *Data, l *zap.Logger) biz.PostData
• func NewRedis(c *conf.Data) redis.Cmdable
• func NewSaramaClient(c *conf.Data) (sarama.Client, error)
• func NewSyncProducer(c sarama.Client) sarama.SyncProducer
• type Data
  • func NewData(c *conf.Data, cs *conf.Service, db *gorm.DB, redis redis.Cmdable, ...) (*Data, func(), error)

Variables

var (
	ErrPostNotFound  = errors.New("post not found")
	ErrInvalidParams = errors.New("invalid parameters")
)

var ProviderSet = wire.NewSet(NewData, NewDB, NewRedis, NewLogger, NewMongoDB, NewPostData, NewSaramaClient, NewSyncProducer)

ProviderSet is data providers.

Functions

func InitTables

func InitTables(db *gorm.DB) error

func NewDB

func NewDB(c *conf.Data) (*gorm.DB, error)

NewDB initializes the database.

func NewLogger

func NewLogger() *zap.Logger

NewLogger 将日志输出到控制台

func NewMongoDB

func NewMongoDB(c *conf.Data) *mongo.Client

func NewPostData

func NewPostData(data *Data, l *zap.Logger) biz.PostData

func NewRedis

func NewRedis(c *conf.Data) redis.Cmdable

NewRedis initializes Redis.

func NewSaramaClient

func NewSaramaClient(c *conf.Data) (sarama.Client, error)

NewSaramaClient 初始化Sarama客户端，用于连接到Kafka集群

func NewSyncProducer

func NewSyncProducer(c sarama.Client) sarama.SyncProducer

NewSyncProducer 使用已有的Sarama客户端初始化同步生产者

Types

type Data

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

Data .

func NewData

func NewData(c *conf.Data, cs *conf.Service, db *gorm.DB, redis redis.Cmdable, logger log.Logger, mongo *mongo.Client) (*Data, func(), error)

NewData .