conn

Documentation

Index

• func GetDB(ctx context.Context) (*gorm.DB, bool)
• func InitJaegerTracer(serviceName, url string) error
• func NewDiscovery(c IDiscoveryConfig, opts ...DiscoveryConfigBuilderOptions) (registry.Discovery, error)
• func NewGormDB(c GormDBConfig, logger ...log.Logger) (*gorm.DB, error)
• func NewGormLogger(logger log.Logger) logger.Interface
• func NewNutsDB(cfg NutsDbConfig) (*nutsdb.DB, error)
• func NewRedisClient(cfg RedisConfig) *redis.Client
• func NewRegister(c IDiscoveryConfig, opts ...DiscoveryConfigBuilderOptions) (registry.Registrar, error)
• type DiscoveryConfigBuilderOptions
  • func WithDiscoveryConfigEtcd(etcdConf IEtcdConfig) DiscoveryConfigBuilderOptions
• type GormDBConfig
• type GormLogger
  • func (l *GormLogger) Error(ctx context.Context, s string, i ...interface{})
  • func (l *GormLogger) Info(ctx context.Context, s string, i ...interface{})
  • func (l *GormLogger) LogMode(level logger.LogLevel) logger.Interface
  • func (l *GormLogger) Trace(ctx context.Context, begin time.Time, ...)
  • func (l *GormLogger) Warn(ctx context.Context, s string, i ...interface{})
• type IDiscoveryConfig
• type IEtcdConfig
• type NutsDbConfig
• type RedisConfig

Functions

func GetDB

func GetDB(ctx context.Context) (*gorm.DB, bool)

GetDB 获取数据库连接

func InitJaegerTracer

func InitJaegerTracer(serviceName, url string) error

InitJaegerTracer 设置全局trace

func NewDiscovery

func NewDiscovery(c IDiscoveryConfig, opts ...DiscoveryConfigBuilderOptions) (registry.Discovery, error)

NewDiscovery 创建一个服务发现实例

func NewGormDB

func NewGormDB(c GormDBConfig, logger ...log.Logger) (*gorm.DB, error)

NewGormDB 获取数据库连接

func NewGormLogger

func NewGormLogger(logger log.Logger) logger.Interface

NewGormLogger Gorm日志实现

func NewNutsDB

func NewNutsDB(cfg NutsDbConfig) (*nutsdb.DB, error)

NewNutsDB 创建一个 nuts db

func NewRedisClient

func NewRedisClient(cfg RedisConfig) *redis.Client

NewRedisClient 获取redis客户端

func NewRegister

func NewRegister(c IDiscoveryConfig, opts ...DiscoveryConfigBuilderOptions) (registry.Registrar, error)

NewRegister 创建一个服务注册实例

Types

type DiscoveryConfigBuilderOptions

type DiscoveryConfigBuilderOptions func(cfg *discoveryConfig)

DiscoveryConfigBuilderOptions 服务发现配置构建选项

func WithDiscoveryConfigEtcd

func WithDiscoveryConfigEtcd(etcdConf IEtcdConfig) DiscoveryConfigBuilderOptions

WithDiscoveryConfigEtcd 设置 etcd 配置

type GormDBConfig

type GormDBConfig interface {
	GetDriver() string
	GetDsn() string
	GetDebug() bool
}

GormDBConfig GORM数据库配置

type GormLogger

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

GormLogger gorm日志实现

func (*GormLogger) Error

func (l *GormLogger) Error(ctx context.Context, s string, i ...interface{})

Error log error

func (*GormLogger) Info

func (l *GormLogger) Info(ctx context.Context, s string, i ...interface{})

Info log info

func (*GormLogger) LogMode

func (l *GormLogger) LogMode(level logger.LogLevel) logger.Interface

LogMode 设置日志等级

func (*GormLogger) Trace

func (l *GormLogger) Trace(ctx context.Context, begin time.Time, fc func() (sql string, rowsAffected int64), err error)

Trace log trace

func (*GormLogger) Warn

func (l *GormLogger) Warn(ctx context.Context, s string, i ...interface{})

Warn log warn

type IDiscoveryConfig

type IDiscoveryConfig interface {
	GetDriver() string
}

IDiscoveryConfig 服务发现配置

type IEtcdConfig

type IEtcdConfig interface {
	GetEndpoints() []string
	GetPassword() string
	GetTimeout() *durationpb.Duration
	GetUsername() string
}

IEtcdConfig etcd配置

type NutsDbConfig

type NutsDbConfig interface {
	GetPath() string
	GetBucket() string
}

NutsDbConfig nuts db 配置

type RedisConfig

type RedisConfig interface {
	GetNetwork() string
	GetAddr() string
	GetPassword() string
	GetDb() uint32
	GetWriteTimeout() *durationpb.Duration
	GetReadTimeout() *durationpb.Duration
	GetDialTimeout() *durationpb.Duration
}

RedisConfig redis配置