internal

Documentation

Index

• Variables
• func GetSiteMode() string
• func LoadEnv(siteMode string)
• type Error
  • func NewError(code int, message string) *Error
  • func (e *Error) Error() string
  • func (e *Error) GetCode() int
  • func (e *Error) String() string
• type Mysql
  • func NewMysql(host string, port int, username string, password string, database string, ...) *Mysql
  • func (m *Mysql) Close() error
  • func (m *Mysql) GetDb() (db *gorm.DB, err error)
  • func (m *Mysql) GetDns() string
  • func (m *Mysql) GetLevel() logger.LogLevel
  • func (m *Mysql) NewConnection() (*gorm.DB, error)
  • func (m *Mysql) SetLogger(logger *logrus.Logger)
• type Pub
• type Redis
  • func NewRedis(host string, port int, auth string, db int) *Redis
  • func (r *Redis) Client() *redis.Client
• type Server
  • func NewServer() (*Server, error)
  • func (s *Server) FillIp()
  • func (s *Server) GetClusterRedis(addrs []string) *redis.ClusterClient
  • func (s *Server) GetDb() (*gorm.DB, error)
  • func (s *Server) GetDbBySec(sectionDb string) (*gorm.DB, error)
  • func (s *Server) GetLog(section string) *logrus.Logger
  • func (s *Server) GetRandomEndPoint(serviceName string) (endpoint string, err error)
  • func (s *Server) GetRedis(sectionDb string) (*redis.Client, error)
  • func (s *Server) GrpcRequestRemote(ctx context.Context, serverName string, req interface{}, reqFactory sd.Factory) (response interface{}, err error)
  • func (s *Server) Log() *logrus.Logger
  • func (s *Server) Register()
  • func (s *Server) SetSiteMode(siteMode string)
  • func (s *Server) UnRegister()
• type ZLog
  • func NewLog(path, file string, age, rotation int64) *ZLog
  • func (l *ZLog) CheckOrCreateDIr(baseLogPaht string, where string) bool
  • func (l *ZLog) GetFilePath() string
  • func (l *ZLog) GetRotation() int64

Variables

var K = koanf.New(".")

Functions

func GetSiteMode

func GetSiteMode() string

func LoadEnv

func LoadEnv(siteMode string)

Types

type Error

type Error struct {
	Code    int
	Message string
}

func NewError

func NewError(code int, message string) *Error

func (*Error) Error

func (e *Error) Error() string

func (*Error) GetCode

func (e *Error) GetCode() int

func (*Error) String

func (e *Error) String() string

time="2021-09-24T20:52:10+08:00" level=info msg="初始化Etcd配置成功" init=etcd

type Mysql

type Mysql struct {
	Host            string
	Port            int
	Username        string
	Password        string
	Database        string
	Prefix          string
	Debug           bool
	Logger          *logrus.Logger
	Db              *gorm.DB
	MaxIdleConns    int //最大空闲连接数
	MaxOpenConns    int //最大连接数
	ConnMaxLifetime int //分钟
	SectionLog      string
}

func NewMysql

func NewMysql(
	host string,
	port int,
	username string,
	password string,
	database string,
	prefix string,
	debug bool,
	log *logrus.Logger,
	sectionLog string,
) *Mysql

func (*Mysql) Close

func (m *Mysql) Close() error

Close 关闭数据库

func (*Mysql) GetDb

func (m *Mysql) GetDb() (db *gorm.DB, err error)

GetDb 获取数据库

func (*Mysql) GetDns

func (m *Mysql) GetDns() string

func (*Mysql) GetLevel

func (m *Mysql) GetLevel() logger.LogLevel

func (*Mysql) NewConnection

func (m *Mysql) NewConnection() (*gorm.DB, error)

func (*Mysql) SetLogger

func (m *Mysql) SetLogger(logger *logrus.Logger)

type Pub

type Pub struct {
	Port    int
	Publish bool
}

type Redis

type Redis struct {
	Host string
	Port int
	Auth string
	Db   int
}

func NewRedis

func NewRedis(host string, port int, auth string, db int) *Redis

func (*Redis) Client

func (r *Redis) Client() *redis.Client

type Server

type Server struct {
	Cluster string
	Ip      string
	Name    string
	Loger   map[string]ZLog
	Etcd    zetcd.Etcd
	Retry   bool
	Listen  map[string]Pub
	Mysql   map[string]Mysql
	Redis   map[string]Redis
	EtcdDis *zetcd.EtcdDis
	Service map[string]string //service.key, service.value
	sync.RWMutex
}

func NewServer

func NewServer() (*Server, error)

func (*Server) FillIp

func (s *Server) FillIp()

func (*Server) GetClusterRedis

func (s *Server) GetClusterRedis(addrs []string) *redis.ClusterClient

GetClusterRedis 获取redis集群

func (*Server) GetDb

func (s *Server) GetDb() (*gorm.DB, error)

GetDb 指定DB

func (*Server) GetDbBySec

func (s *Server) GetDbBySec(sectionDb string) (*gorm.DB, error)

GetDbBySec 指定DB

func (*Server) GetLog

func (s *Server) GetLog(section string) *logrus.Logger

func (*Server) GetRandomEndPoint

func (s *Server) GetRandomEndPoint(serviceName string) (endpoint string, err error)

GetRandomEndPoint 获取随机的端点

func (*Server) GetRedis

func (s *Server) GetRedis(sectionDb string) (*redis.Client, error)

GetRedis 指定redis

func (*Server) GrpcRequestRemote

func (s *Server) GrpcRequestRemote(ctx context.Context, serverName string, req interface{}, reqFactory sd.Factory) (response interface{}, err error)

GrpcRequestRemote 外部服务

func (*Server) Log

func (s *Server) Log() *logrus.Logger

func (*Server) Register

func (s *Server) Register()

func (*Server) SetSiteMode

func (s *Server) SetSiteMode(siteMode string)

func (*Server) UnRegister

func (s *Server) UnRegister()

type ZLog

type ZLog struct {
	Path       string
	File       string
	Age        int64
	Rotation   int64
	Log        *logrus.Logger
	Initialize bool
}

func NewLog

func NewLog(path, file string, age, rotation int64) *ZLog

func (*ZLog) CheckOrCreateDIr

func (l *ZLog) CheckOrCreateDIr(baseLogPaht string, where string) bool

func (*ZLog) GetFilePath

func (l *ZLog) GetFilePath() string

func (*ZLog) GetRotation

func (l *ZLog) GetRotation() int64