lib

Documentation

Index

• Constants
• Variables
• func AddGetDataToUrl(urlString string, data url.Values) string
• func CloseDB() error
• func DBPoolLogQuery(trace *TraceContext, sqlDb *sql.DB, query string, args ...interface{}) (*sql.Rows, error)
• func Encode(data string) (string, error)
• func GetBoolConf(key string) bool
• func GetConf(key string) interface{}
• func GetConfEnv() string
• func GetConfEnvPath() string
• func GetConfFilePath(fileName string) string
• func GetConfPath(fileName string) string
• func GetDBPool(name string) (*sql.DB, error)
• func GetDurationConf(key string) time.Duration
• func GetFloat64Conf(key string) float64
• func GetGormPool(name string) (*gorm.DB, error)
• func GetIntConf(key string) int
• func GetLocalIPs() (ips []net.IP)
• func GetMd5Hash(text string) string
• func GetStringConf(key string) string
• func GetStringMapConf(key string) map[string]interface{}
• func GetStringMapStringConf(key string) map[string]string
• func GetStringSliceConf(key string) []string
• func GetTimeConf(key string) time.Time
• func GetTraceId() (traceId string)
• func InArrayString(s string, arr []string) bool
• func Init(configPath string) error
• func InitBaseConf(path string) error
• func InitDBPool(path string) error
• func InitModule(configPath string, modules []string) error
• func InitRedisConf(path string) error
• func InitViperConf() error
• func IsSetConf(key string) bool
• func NewSpanId() string
• func ParseConfPath(config string) (err error)
• func ParseConfig(path string, conf interface{}) (err error)
• func ParseServerAddr(serverAddr string) (host, port string)
• func RedisConfDo(trace *TraceContext, name string, commandName string, args ...interface{}) (interface{}, error)
• func RedisConnFactory(name string) (redis.Conn, error)
• func Substr(str string, start int64, end int64) string
• type BaseConf
  • func GetBaseConf() *BaseConf
• type LogConfConsoleWriter
• type LogConfFileWriter
• type LogConfig
• type Logger
  • func (l *Logger) Close()
  • func (l *Logger) TagDebug(trace *TraceContext, tag string, m map[string]interface{})
  • func (l *Logger) TagError(trace *TraceContext, tag string, m map[string]interface{})
  • func (l *Logger) TagInfo(trace *TraceContext, tag string, m map[string]interface{})
  • func (l *Logger) TagTrace(trace *TraceContext, tag string, m map[string]interface{})
  • func (l *Logger) TagWarning(trace *TraceContext, tag string, m map[string]interface{})
• type MySQLConf
• type MysqlMapConf
• type RedisConf
• type RedisMapConf
• type Trace
• type TraceContext
  • func NewTrace() *TraceContext

Constants

const (
	TagUndefined = "_undef"
)

Variables

var (
	ConfBase     *BaseConf
	ViperConfMap map[string]*viper.Viper

	DBMapPool       map[string]*sql.DB
	GORMMapPool     map[string]*gorm.DB
	DBDefaultPool   *sql.DB
	GORMDefaultPool *gorm.DB
	ConfRedis       *RedisConf
	ConfRedisMap    *RedisMapConf
)

var ConfEnv string //配置环境名 dev/debug/test/pro

var ConfEnvPath string //配置文件夹

var DateFormat = "2006-01-02"

var LocalIP = net.ParseIP("127.0.0.1")

var TimeFormat = "2006-01-02 15:04:05"

var TimeLocation *time.Location

Functions

func AddGetDataToUrl

func AddGetDataToUrl(urlString string, data url.Values) string

func CloseDB

func CloseDB() error

func DBPoolLogQuery

func DBPoolLogQuery(trace *TraceContext, sqlDb *sql.DB, query string, args ...interface{}) (*sql.Rows, error)

func Encode

func Encode(data string) (string, error)

func GetBoolConf

func GetBoolConf(key string) bool

获取get配置信息

func GetConf

func GetConf(key string) interface{}

获取get配置信息

func GetConfEnv

func GetConfEnv() string

func GetConfEnvPath

func GetConfEnvPath() string

func GetConfFilePath

func GetConfFilePath(fileName string) string

func GetConfPath

func GetConfPath(fileName string) string

func GetDBPool

func GetDBPool(name string) (*sql.DB, error)

func GetDurationConf

func GetDurationConf(key string) time.Duration

获取时间阶段长度

func GetFloat64Conf

func GetFloat64Conf(key string) float64

获取get配置信息

func GetGormPool

func GetGormPool(name string) (*gorm.DB, error)

func GetIntConf

func GetIntConf(key string) int

获取get配置信息

func GetLocalIPs

func GetLocalIPs() (ips []net.IP)

func GetMd5Hash

func GetMd5Hash(text string) string

func GetStringConf

func GetStringConf(key string) string

获取get配置信息

func GetStringMapConf

func GetStringMapConf(key string) map[string]interface{}

获取get配置信息

func GetStringMapStringConf

func GetStringMapStringConf(key string) map[string]string

获取get配置信息

func GetStringSliceConf

func GetStringSliceConf(key string) []string

获取get配置信息

func GetTimeConf

func GetTimeConf(key string) time.Time

获取get配置信息

func GetTraceId

func GetTraceId() (traceId string)

func InArrayString

func InArrayString(s string, arr []string) bool

func Init

func Init(configPath string) error

公共初始化函数：支持两种方式设置配置文件

函数传入配置文件 Init("./conf/dev/") 如果配置文件为空，会从命令行中读取 -config conf/dev/

func InitBaseConf

func InitBaseConf(path string) error

func InitDBPool

func InitDBPool(path string) error

func InitModule

func InitModule(configPath string, modules []string) error

模块初始化

func InitRedisConf

func InitRedisConf(path string) error

func InitViperConf

func InitViperConf() error

func IsSetConf

func IsSetConf(key string) bool

是否设置了key

func NewSpanId

func NewSpanId() string

func ParseConfPath

func ParseConfPath(config string) (err error)

func ParseConfig

func ParseConfig(path string, conf interface{}) (err error)

func ParseServerAddr

func ParseServerAddr(serverAddr string) (host, port string)

func RedisConfDo

func RedisConfDo(trace *TraceContext, name string, commandName string, args ...interface{}) (interface{}, error)

func RedisConnFactory

func RedisConnFactory(name string) (redis.Conn, error)

func Substr

func Substr(str string, start int64, end int64) string

Substr 字符串的截取

Types

type BaseConf

type BaseConf struct {
	DebugMode    string    `mapstructure:"debug_mode"`
	TimeLocation string    `mapstructure:"time_location"`
	Log          LogConfig `mapstruacture:"log"`
	Base         struct {
		DebugMode    string `mapstructure:"debug_mode"`
		TimeLocation string `mapstructure:"time_location"`
	} `mapstructure:"base"`
}

func GetBaseConf

func GetBaseConf() *BaseConf

get base config

type LogConfConsoleWriter

type LogConfConsoleWriter struct {
	On    bool `mapstructure:"on"`
	Color bool `mapstructure:"color"`
}

type LogConfFileWriter

type LogConfFileWriter struct {
	On              bool   `mapstructure:"on"`
	LogPath         string `mapstructure:"log_path"`
	RotateLogPath   string `mapstructure:"rotate_log_path"`
	WfLogPath       string `mapstructure:"wf_log_path"`
	RotateWfLogPath string `mapstructure:"rotate_wf_log_path"`
}

type LogConfig

type LogConfig struct {
	Level string               `mapstructure:"log_level"`
	FW    LogConfFileWriter    `mapstructure:"file_writer"`
	CW    LogConfConsoleWriter `mapstructure:"console_writer"`
}

type Logger

type Logger struct {
}

var Log *Logger

func (*Logger) Close

func (l *Logger) Close()

func (*Logger) TagDebug

func (l *Logger) TagDebug(trace *TraceContext, tag string, m map[string]interface{})

func (*Logger) TagError

func (l *Logger) TagError(trace *TraceContext, tag string, m map[string]interface{})

func (*Logger) TagInfo

func (l *Logger) TagInfo(trace *TraceContext, tag string, m map[string]interface{})

func (*Logger) TagTrace

func (l *Logger) TagTrace(trace *TraceContext, tag string, m map[string]interface{})

func (*Logger) TagWarning

func (l *Logger) TagWarning(trace *TraceContext, tag string, m map[string]interface{})

type MySQLConf

type MySQLConf struct {
	DriverName      string `mapstructure:"driver_name"`
	DataSourceName  string `mapstructure:"data_source_name"`
	MaxOpenConn     int    `mapstructure:"max_open_conn"`
	MaxIdleConn     int    `mapstructure:"max_idle_conn"`
	MaxConnLifeTime int    `mapstructure:"max_conn_life_time"`
}

type MysqlMapConf

type MysqlMapConf struct {
	Map map[string]*MySQLConf `mapstructure:"list"`
}

type RedisConf

type RedisConf struct {
	ProxyList    []string `mapstructure:"proxy_list"`
	Password     string   `mapstructure:"password"`
	Db           int      `mapstructure:"db"`
	ConnTimeout  int      `mapstructure:"conn_timeout"`
	ReadTimeout  int      `mapstructure:"read_timeout"`
	WriteTimeout int      `mapstructure:"write_timeout"`
}

type RedisMapConf

type RedisMapConf struct {
	Map map[string]*RedisConf `mapstructure:"map"`
}

type Trace

type Trace struct {
	TraceId     string
	SpanId      string
	Caller      string
	SrcMethod   string
	HintCode    int64
	HintContent string
}

type TraceContext

type TraceContext struct {
	Trace
	CSpanId string
}

func NewTrace

func NewTrace() *TraceContext