dist

Jun 12, 2020

Changes in this version

+ func ConnectRedisCluster(addrs []string, password string, db int32) (*redis.ClusterClient, error)

Mar 27, 2020

Changes in this version

type AppInfo

+ func (self *AppInfo) RegisterSelf(parentPath string) error

Mar 5, 2020

Changes in this version

type HttpGinOptions

+ func EnableHTML(enable bool, ptn string) HttpGinOptions

Mar 4, 2020

Changes in this version

+ func GetGameIdByLogicId(logicId uint64) (uint64, error)

type LogicID

+ func (self *LogicID) GameId() uint64

Mar 3, 2020

Changes in this version

+ const LI_CATA_MULTI

+ const LI_FUNC_MULTI

+ const LI_INST_MULTI

+ const LI_MAX_ID

+ const LI_SUB_MULTI

+ func GetCataIdByLogicId(logicId uint64) (uint64, error)

+ func GetFuncIdByLogicId(logicId uint64) (uint64, error)

+ func GetSubIdByLogicId(logicId uint64) (uint64, error)

type LogicID

+ func (self *LogicID) HeaderCata() uint64

+ func (self *LogicID) HeaderSub() uint64

Feb 24, 2020

Changes in this version

+ type Mail struct

+ Attachments []string

+ Body string

+ Subject string

+ type MailReceiver struct

+ Addr string

+ Mail Mail

+ Name string

+ type Mailer struct

+ func NewMailer(smtp string, port int, username, password string) *Mailer

+ func (self *Mailer) Send(receivers ...MailReceiver) error

Feb 24, 2020

Changes in this version

+ var ErrHttpStatusCode = errors.New("http return bad status code.")

+ type HttpClient struct

+ func NewHttpClient() *HttpClient

+ func (self *HttpClient) LastStatusCode() int

+ func (self *HttpClient) PostJson(url string, json []byte) ([]byte, error)

type HttpGinOptions

+ func EnableBlacklist(b []string) HttpGinOptions

+ func EnableSession(enable bool, store sessions.Store) HttpGinOptions

+ func EnableWhitelist(b []string) HttpGinOptions

Feb 20, 2020

Changes in this version

type AppInfo

+ ChQuit chan struct{}

+ Offline int32

+ type MqSink struct

+ func NewMqSink(name string, mq *Mq) *MqSink

+ func (self *MqSink) Close() error

+ func (self *MqSink) Sync() error

+ func (self *MqSink) Write(p []byte) (int, error)

Feb 19, 2020

Changes in this version

+ var ACCESS_KEY_ID string = "LTAIDquqdpFdYVmW"

+ var ACCESS_KEY_SECRET string = "ozeRm4LWSqEnpPEw9spdOfylSNprY1"

+ var DOMAIN string = "dysmsapi.aliyuncs.com"

+ var ErrCannotConnectToMq = errors.New("Cannot connect to Mq server by NATS conn")

+ var ErrCannotConnectToNats = errors.New("Cannot connect to NATS server in Mq")

+ var ErrInvalidLogicId = errors.New("Invalid logic id")

+ var ErrInvalidParams = errors.New("invalid parameters")

+ var ErrNotImplemented = errors.New("Function not implemented")

+ var ErrReturnValue = errors.New("sms return message means failed.")

+ var LogLevelMap = map[int]zapcore.Level

+ var MESSAGE_SUCCESS string = "OK"

+ var PRODUCT string = "Dysmsapi"

+ var REGION string = "cn-hangzhou"

+ var SIGN_NAME string = "海拉科技"

+ var TEMPLATE_CODE string = "SMS_127790203"

+ var VERSION string = "2017-05-25"

+ func ConnectRedis(addrs []string, password string, db int32) (*redis.Client, error)

+ func Debug(msg string, fields ...zap.Field)

+ func Error(msg string, fields ...zap.Field)

+ func Fatal(msg string, fields ...zap.Field)

+ func GetMacInfoImmutablePart(mac *MachMeta)

+ func GetMachInfo(mac *MachMeta)

+ func GetMachInfoMutablePart(mac *MachMeta)

+ func Info(msg string, fields ...zap.Field)

+ func Panic(msg string, fields ...zap.Field)

+ func SendSmsTo(phone string, text string) error

+ func SetDefaultLogger(logger *SLogger)

+ func Sync()

+ func Warn(msg string, fields ...zap.Field)

+ type AppInfo struct

+ BootAt time.Time

+ ConfFile string

+ Debug bool

+ Ev *Eventbus

+ InstName string

+ Log *SLogger

+ Mode string

+ Mq *Mq

+ Name string

+ Rdb *redis.Client

+ Ver *Version

+ Zk *ZkClient

+ func NewAppInfo(programeName string, major, minor, revision int, id uint64, confFile string, ...) *AppInfo

+ func (self *AppInfo) EnableLog(console bool, level int32, logPath string) error

+ type AppInfoOptions func(info *AppInfo)

+ func AppEnableLogger(enable bool, logLevel int32, logPath string, logStdout bool) AppInfoOptions

+ type CbQueueSubscribe func(subj string, q string, data []byte)

+ type CbSubscribe func(subj string, data []byte)

+ type Event struct

+ Err error

+ Path string

+ Type zk.EventType

+ type Eventbus struct

+ func NewEventbus(addrs []string, username, password string) (*Eventbus, error)

+ func (self *Eventbus) AsyncPub(subj string, content []byte, timeout time.Duration) error

+ func (self *Eventbus) Close()

+ func (self *Eventbus) GetOriginConn() *nats.Conn

+ func (self *Eventbus) QSub(subj, q string, cb CbQueueSubscribe) error

+ func (self *Eventbus) Sub(subj string, cb CbSubscribe) error

+ type HttpGin struct

+ func NewHttpGinServer(addr string, routes map[string]func(*gin.Context), options ...HttpGinOptions) *HttpGin

+ func (self *HttpGin) Start() error

+ func (self *HttpGin) Stop() error

+ type HttpGinOptions func(*HttpGin)

+ func EnableCors(enable bool) HttpGinOptions

+ func EnableDebug(enable bool) HttpGinOptions

+ func EnableFlowControl(enable bool) HttpGinOptions

+ func WithBlacklist(b []string) HttpGinOptions

+ type JwtTokener struct

+ func NewJwtTokener(key string) *JwtTokener

+ func (self *JwtTokener) Parse(token string) (interface{}, error)

+ func (self *JwtTokener) Token(m map[string]interface{}) (string, error)

+ type LogicID struct

+ func NewLogicIDByID(id uint64) (*LogicID, error)

+ func NewLogicIDByParts(funcId, cataId, subId, instId uint64) (*LogicID, error)

+ func (self *LogicID) CataId() uint64

+ func (self *LogicID) FuncId() uint64

+ func (self *LogicID) Id() uint64

+ func (self *LogicID) InstId() uint64

+ func (self *LogicID) SubId() uint64

+ type MachMeta struct

+ Arch string

+ BootTime uint64

+ CpuCoreNum int32

+ CpuModelName string

+ CpuNum int

+ CpuPercent []float64

+ Hostname string

+ KernelVer string

+ MemAvailable uint64

+ MemPercent float64

+ MemTotal uint64

+ MemUsed uint64

+ OS string

+ Platform string

+ UpTime uint64

+ type Mq struct

+ func NewMq(addrs []string, username, password string, cluster_id, client_id string) (*Mq, error)

+ func (self *Mq) AsyncPub(subj string, msg []byte) error

+ func (self *Mq) Close()

+ func (self *Mq) Pub(subj string, msg []byte) error

+ func (self *Mq) QSub(subj, qname, durable string, cb CbSubscribe) error

+ func (self *Mq) Sub(subj, durable string, cb CbSubscribe) error

+ type SLogger struct

+ func NewSLogger(console bool, path string, level zapcore.Level, sinks ...zap.Sink) *SLogger

+ func (self *SLogger) Debug(msg string, fields ...zap.Field)

+ func (self *SLogger) Error(msg string, fields ...zap.Field)

+ func (self *SLogger) Fatal(msg string, fields ...zap.Field)

+ func (self *SLogger) Info(msg string, fields ...zap.Field)

+ func (self *SLogger) Panic(msg string, fields ...zap.Field)

+ func (self *SLogger) Sync()

+ func (self *SLogger) Warn(msg string, fields ...zap.Field)

+ type Version struct

+ func NewVersion(major, minor, revision int) *Version

+ func (self *Version) Major() int

+ func (self *Version) Minor() int

+ func (self *Version) Revision() int

+ func (self *Version) String() string

+ type ZkCallback func(c *ZkClient, path string, ev zk.EventType)

+ type ZkClient struct

+ func NewZkClient(hosts []string, root string, user string, password string, timeout int, ...) (*ZkClient, error)

+ func (self *ZkClient) Close()

+ func (self *ZkClient) CreateEmpNode(name string, data []byte) error

+ func (self *ZkClient) Exists(name string) bool

+ func (self *ZkClient) GetChildren(name string) ([]string, error)

+ func (self *ZkClient) GetNodeData(name string) ([]byte, error)

+ func (self *ZkClient) SetNodeData(path string, data []byte) error

+ func (self *ZkClient) WatchChildren(name string) error

+ func (self *ZkClient) WatchNode(name string) error