data

Documentation

Index

• Variables
• func InitTables(db *gorm.DB) error
• func NewDB(c *conf.Data) (*gorm.DB, error)
• func NewLogger() *zap.Logger
• func NewRedis(c *conf.Data) redis.Cmdable
• func NewSaramaClient(c *conf.Service) (sarama.Client, error)
• func NewSyncProducer(client sarama.Client) (sarama.SyncProducer, error)
• type Data
  • func NewData(cs *conf.Service, db *gorm.DB, redis redis.Cmdable, logger log.Logger) (*Data, func(), error)

Variables

var ProviderSet = wire.NewSet(NewData, NewDB, NewLogger, NewRedis)

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 NewRedis

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

NewRedis initializes Redis.

func NewSaramaClient

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

NewSaramaClient 初始化一个新的 Sarama 客户端

func NewSyncProducer

func NewSyncProducer(client sarama.Client) (sarama.SyncProducer, error)

NewSyncProducer 初始化一个新的 Sarama 同步生产者

Types

type Data

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

Data .

func NewData

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

NewData .