data

package
v1.0.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 26, 2025 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var CasbinModule = fx.Module("casbin",
	fx.Provide(NewCasbinEnforcer),
)

CasbinModule Casbin模块

View Source 
var Model = fx.Options(
	fx.Provide(
		db.NewDataSource,
		NewDB,
		NewQuery,
		NewDataManager,
	),
)

Functions

func NewCasbinEnforcer added in v1.0.2 

func NewCasbinEnforcer(db *gorm.DB, cfg configs.Config) (*casbin.Enforcer, error)

NewCasbinEnforcer 创建Casbin权限控制器

func NewDB added in v1.0.2 

func NewDB(ds *db.DataSource) *gorm.DB

NewDB exposes the primary Gorm DB from the unified DataSource for DI consumers.

func NewQuery added in v1.0.2 

func NewQuery(db *gorm.DB) *query.Query

Types

type DataManager added in v1.0.2 

type DataManager struct {

	// 查询接口
	Query *query.Query

	// 配置
	Config *configs.Config
	// contains filtered or unexported fields
}

DataManager 统一的数据管理器，提供所有数据库组件的操作接口

func NewDataManager added in v1.0.2 

func NewDataManager(
	ds *db.DataSource,
	query *query.Query,
	cfg configs.Config,
) *DataManager

NewDataManager 创建统一的数据管理器

func (*DataManager) Close added in v1.0.2 

func (dm *DataManager) Close() error

Close 关闭所有数据库连接

func (*DataManager) Health added in v1.0.2 

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

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

func (*DataManager) IsComponentEnabled added in v1.0.2 

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

IsComponentEnabled 检查组件是否启用

func (*DataManager) Kafka added in v1.0.2 

func (dm *DataManager) Kafka() sarama.SyncProducer

Kafka 获取Kafka生产者

func (*DataManager) MongoDB added in v1.0.2 

func (dm *DataManager) MongoDB() *mongo.Database

MongoDB 获取MongoDB数据库

func (*DataManager) MySQL added in v1.0.2 

func (dm *DataManager) MySQL() *gorm.DB

MySQL 获取MySQL数据库连接

func (*DataManager) MySQLWithContext added in v1.0.2 

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

MySQLWithContext 获取带上下文的MySQL连接

func (*DataManager) Redis added in v1.0.2 

func (dm *DataManager) Redis() *redis.Client

Redis 获取Redis客户端

func (*DataManager) RedisWithContext added in v1.0.2 

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

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

func (*DataManager) SendKafkaMessage added in v1.0.2 

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

SendKafkaMessage 发送Kafka消息

type JwtCustomClaims 

type JwtCustomClaims struct {
	Name  string `json:"name"`
	ID    int64  `json:"id" `
	Admin bool   `json:"admin"`
	jwt.RegisteredClaims
}

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.