conn

Documentation

Index

• Variables
• func Enforcer() *casbin.SyncedEnforcer
• func GetDiscovery() registry.Discovery
• func GetNodeGrpcClient(ctx context.Context, s INodeServer, d registry.Discovery) (*gGrpc.ClientConn, error)
• func GetNodeHttpClient(ctx context.Context, s INodeServer, d registry.Discovery) (*http.Client, error)
• func GetRegistrar() *etcd.Registry
• func InitCasbinModel(db *gorm.DB) (*casbin.SyncedEnforcer, error)
• func NewCasbinModel(db *gorm.DB) (*casbin.SyncedEnforcer, error)
• func NewDB(cfg DBConfig, logger ...log.Logger) (*gorm.DB, error)
• func NewETCDClient(conf IEtcdConfig) *clientV3.Client
• func NewETCDRegistrar(etcdClient *clientV3.Client) *etcd.Registry
• func NewGormLogger(logger log.Logger) logger.Interface
• func NewKafkaConsumer(kafkaEndpoints []string, kafkaGroupID string) (*kafka.Consumer, error)
• func NewKafkaProducer(endpoints []string) (*kafka.Producer, error)
• func NewRedisClient(cfg RedisConfig) *redis.Client
• func NewTracerProvider(conf ITraceConfig, traceEnv ITraceEnv) *traceSdk.TracerProvider
• type DBConfig
• 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 IEtcdConfig
• type INodeServer
• type ITraceConfig
• type ITraceEnv
• type Network
• type RedisConfig

Variables

var NetworkError = errors.New("invalid network")

Functions

func Enforcer

func Enforcer() *casbin.SyncedEnforcer

Enforcer casbin enforcer

func GetDiscovery

func GetDiscovery() registry.Discovery

func GetNodeGrpcClient

func GetNodeGrpcClient(ctx context.Context, s INodeServer, d registry.Discovery) (*gGrpc.ClientConn, error)

func GetNodeHttpClient

func GetNodeHttpClient(ctx context.Context, s INodeServer, d registry.Discovery) (*http.Client, error)

func GetRegistrar

func GetRegistrar() *etcd.Registry

func InitCasbinModel

func InitCasbinModel(db *gorm.DB) (*casbin.SyncedEnforcer, error)

func NewCasbinModel

func NewCasbinModel(db *gorm.DB) (*casbin.SyncedEnforcer, error)

NewCasbinModel new casbin model

func NewDB

func NewDB(cfg DBConfig, logger ...log.Logger) (*gorm.DB, error)

NewDB 获取数据库连接

func NewETCDClient

func NewETCDClient(conf IEtcdConfig) *clientV3.Client

NewETCDClient new etcd client

@param cfg IEtcdConfig

func NewETCDRegistrar

func NewETCDRegistrar(etcdClient *clientV3.Client) *etcd.Registry

NewETCDRegistrar new etcd registrar

@param etcdClient *clientV3.Client

func NewGormLogger

func NewGormLogger(logger log.Logger) logger.Interface

func NewKafkaConsumer

func NewKafkaConsumer(kafkaEndpoints []string, kafkaGroupID string) (*kafka.Consumer, error)

NewKafkaConsumer 创建kafka消费对象

func NewKafkaProducer

func NewKafkaProducer(endpoints []string) (*kafka.Producer, error)

NewKafkaProducer 创建kafka生产对象

func NewRedisClient

func NewRedisClient(cfg RedisConfig) *redis.Client

NewRedisClient 获取redis客户端

func NewTracerProvider

func NewTracerProvider(conf ITraceConfig, traceEnv ITraceEnv) *traceSdk.TracerProvider

NewTracerProvider new tracer provider

@param conf ITraceConfig

Types

type DBConfig

type DBConfig interface {
	GetDriver() string
	GetSource() string
	GetDebug() bool
}

type GormLogger

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

func (*GormLogger) Error

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

func (*GormLogger) Info

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

func (*GormLogger) LogMode

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

func (*GormLogger) Trace

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

func (*GormLogger) Warn

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

type IEtcdConfig

type IEtcdConfig interface {
	GetEndpoints() []string
	GetKeyFile() string
	GetCertFile() string
	GetTrustedCaFile() string
}

type INodeServer

type INodeServer interface {
	GetServerName() string
	GetNetwork() string
	GetTimeout() *durationpb.Duration
}

type ITraceConfig

type ITraceConfig interface {
	GetEndpoint() string
	GetEnable() bool
}

type ITraceEnv

type ITraceEnv interface {
	GetName() string
	GetVersion() string
	GetNamespace() string
}

type Network

type Network = string

const (
	NetworkGrpc  Network = "grpc"
	NetworkHttp  Network = "http"
	NetworkHttps Network = "https"
)

type RedisConfig

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