db

package

v1.0.6 Latest Latest Go to latest Published: Sep 28, 2025 License: Apache-2.0 Imports: 16 Imported by: 0

Details

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

Repository

github.com/NSObjects/go-template

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func AfterCreate(db *gorm.DB)
func MongoClient(cfg configs.Mongodb) *mongo.Database
func NewDB(dm *DataManager) *gorm.DB
func NewKafkaProducer(cfg configs.KafkaConfig) (sarama.SyncProducer, error)
func NewMysql(cfg configs.MysqlConfig) *gorm.DB
func NewQuery(dm *DataManager) *query.Query
func NewRedis(cfg configs.RedisConfig) *redis.Client
type DataManager
- func NewDataManager(lc fx.Lifecycle, cfg configs.Config) *DataManager

Constants ¶

This section is empty.

Variables ¶

View Source

var Model = fx.Options(
	fx.Provide(NewDataManager),
	fx.Provide(NewDB),
	fx.Provide(NewQuery),
)

Functions ¶

func AfterCreate ¶

func AfterCreate(db *gorm.DB)

func MongoClient ¶

func MongoClient(cfg configs.Mongodb) *mongo.Database

func NewDB ¶ added in v1.0.6

func NewDB(dm *DataManager) *gorm.DB

NewDB 为了向后兼容，提供获取MySQL连接的方法

func NewKafkaProducer ¶ added in v1.0.2

func NewKafkaProducer(cfg configs.KafkaConfig) (sarama.SyncProducer, error)

func NewMysql ¶

func NewMysql(cfg configs.MysqlConfig) *gorm.DB

func NewQuery ¶ added in v1.0.6

func NewQuery(dm *DataManager) *query.Query

NewQuery 为了向后兼容，提供获取Query的方法

func NewRedis ¶

func NewRedis(cfg configs.RedisConfig) *redis.Client

Types ¶

type DataManager ¶ added in v1.0.6

type DataManager struct {
	// 数据库组件
	Mysql   *gorm.DB
	Mongodb *mongo.Database
	Redis   *redis.Client
	Kafka   sarama.SyncProducer

	// 查询接口
	Query *query.Query

	// 配置
	Config *configs.Config
}

DataManager 统一的数据管理器，直接管理所有数据库组件

func NewDataManager ¶ added in v1.0.6

func NewDataManager(lc fx.Lifecycle, cfg configs.Config) *DataManager

NewDataManager 创建统一的数据管理器，直接初始化所有组件

func (*DataManager) Health ¶ added in v1.0.6

func (dm *DataManager) Health(ctx context.Context) map[string]error

Health 检查所有组件的健康状态

func (*DataManager) IsComponentEnabled ¶ added in v1.0.6

func (dm *DataManager) IsComponentEnabled(component string) bool

IsComponentEnabled 检查组件是否启用

func (*DataManager) MySQLWithContext ¶ added in v1.0.6

func (dm *DataManager) MySQLWithContext(ctx context.Context) *gorm.DB

MySQLWithContext 获取带上下文的MySQL连接

func (*DataManager) RedisWithContext ¶ added in v1.0.6

func (dm *DataManager) RedisWithContext(ctx context.Context) *redis.Client

RedisWithContext 获取带上下文的Redis客户端

func (*DataManager) SendKafkaMessage ¶ added in v1.0.6

func (dm *DataManager) SendKafkaMessage(topic string, key, value []byte) error

SendKafkaMessage 发送Kafka消息

func (*DataManager) Stop ¶ added in v1.0.6

func (dm *DataManager) Stop(ctx context.Context) error

Stop 停止所有组件

Source Files ¶

View all Source files

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