base

Sep 1, 2023

Changes in this version

+ var ErrAlphanumeric = NewBError(CodeInvalidArgument, "alphanumeric must be [a-zA-Z0-9] and not repeat")

+ var ErrAlphanumericLength = NewBError(CodeInvalidArgument, "alphanumeric length must be [50, 62]")

+ func Max6() int64

+ func Max8() int64

+ func NewIdCode(alphanumericSet []byte, salt6, salt8 int64) (*IdCode, *BError)

type BError

+ func Code2Id(code []byte) (id int64, err *BError)

+ func Code6(id int64) (code []byte, err *BError)

+ func Code6String(id int64) (code string, err *BError)

+ func Code6To8(code6 []byte) (code8 []byte, err *BError)

+ func Code8(id int64) (code []byte, err *BError)

+ func Code8String(id int64) (code string, err *BError)

+ func CodeString2Id(code string) (id int64, err *BError)

+ func CodeString6To8(code6 string) (code8 string, err *BError)

+ type IdCode struct

+ func (ic *IdCode) Code2Id(code []byte) (id int64, err *BError)

+ func (ic *IdCode) Code6(id int64) (code []byte, err *BError)

+ func (ic *IdCode) Code6String(id int64) (code string, err *BError)

+ func (ic *IdCode) Code6To8(code6 []byte) (code8 []byte, err *BError)

+ func (ic *IdCode) Code8(id int64) (code []byte, err *BError)

+ func (ic *IdCode) Code8String(id int64) (code string, err *BError)

+ func (ic *IdCode) CodeString2Id(code string) (id int64, err *BError)

+ func (ic *IdCode) CodeString6To8(code6 string) (code8 string, err *BError)

+ func (ic *IdCode) Max6() int64

+ func (ic *IdCode) Max8() int64

Sep 1, 2023

Changes in this version

+ func AbsInt(value int) int

+ func AbsInt16(value int16) int16

+ func AbsInt32(value int32) int32

+ func AbsInt64(value int64) int64

+ func AbsInt8(value int8) int8

+ func Code2Uint64(code string) (id uint64, err error)

+ func Id2Code6(id uint64) (code string, err error)

+ func Id2Code7(id uint64) (code string, err error)

+ func Id2Code8(id uint64) (code string, err error)

Aug 16, 2023

Changes in this version

type BError

+ func NewBError(code codes.Code, msg string) *BError

+ func (be *BError) Clone() *BError

+ func (be *BError) Equal(target error) bool

Aug 16, 2023

Changes in this version

+ type BError struct

+ func NewBaseError(code codes.Code, msg string) *BError

+ func (be *BError) Code() codes.Code

+ func (be *BError) Error() string

+ func (be *BError) Is(target error) bool

+ func (be *BError) JsonMarshal() []byte

+ func (be *BError) ToStatus() *Status

+ func (be *BError) WithFlag(flag uint8) *BError

type Status

+ Flag uint8

+ func (s *Status) WithFlag(flag uint8) *Status

Aug 15, 2023

Changes in this version

type Status

+ func StatusOk(data interface{}) *Status

+ func StatusWithCodeMsg(code codes.Code, msg string) *Status

Aug 15, 2023

Changes in this version

+ func Recover(eventName string, f func())

Aug 15, 2023

Changes in this version

+ const CodeAborted

+ const CodeAlreadyExists

+ const CodeCanceled

+ const CodeDataLoss

+ const CodeDeadlineExceeded

+ const CodeFailedPrecondition

+ const CodeInternal

+ const CodeInvalidArgument

+ const CodeNotFound

+ const CodeOutRange

+ const CodePermissionDenied

+ const CodeResourceExhausted

+ const CodeUnauthenticated

+ const CodeUnavailable

+ const CodeUnimplemented

+ const CodeUnknown

+ var ErrNotTcpListener = NewError(CodeInvalidArgument, "listener is not tcp listener")

+ func StopPprofWithTimeout(seconds int64) error

Aug 8, 2023

Changes in this version

+ func WorkWithAffinity(id int) (uint64, error)

Jul 21, 2023

Changes in this version

+ type GracefulHttp struct

+ func NewGracefulHttp(server *http.Server) *GracefulHttp

+ func (hs *GracefulHttp) HandlerSig(pprofAddr string, timeoutSecond int64)

+ func (hs *GracefulHttp) Listen() (err error)

+ func (hs *GracefulHttp) Reload() (pid int, err error)

+ func (hs *GracefulHttp) Shutdown(ctx context.Context) error

+ func (hs *GracefulHttp) ShutdownWithTimeout(timeoutSecond int64) error

Jul 13, 2023

Changes in this version

+ type Mysql struct

+ Options MysqlOption

+ func NewMysql(opt MysqlOption) (mysql *Mysql, err error)

+ type MysqlOption struct

+ CharSet string

+ ConnMaxIdleTimeSecond int64

+ ConnMaxLifetimeSecond int64

+ DbName string

+ Host string

+ MaxIdleConns int

+ MaxOpenConns int

+ Password string

+ Port uint32

+ UserName string

+ func DefaultMysqlOption() MysqlOption

+ func MysqlOptionWithJson(conf string) (opt MysqlOption, err error)

+ func MysqlOptionWithYaml(conf string) (opt MysqlOption, err error)

+ func (mo *MysqlOption) Dsn() string

Jul 7, 2023

Changes in this version

+ func JoinInt(sep string, elems ...int) string

+ func JoinInt16(sep string, elems ...int16) string

+ func JoinInt32(sep string, elems ...int32) string

+ func JoinInt64(sep string, elems ...int64) string

+ func JoinInt8(sep string, elems ...int8) string

+ func JoinUint(sep string, elems ...uint) string

+ func JoinUint16(sep string, elems ...uint16) string

+ func JoinUint32(sep string, elems ...uint32) string

+ func JoinUint64(sep string, elems ...uint64) string

+ func JoinUint8(sep string, elems ...uint8) string

Jun 2, 2023

Changes in this version

type Rsa

+ func NewRsaBytes(public, private []byte) (r *Rsa, err error)

+ func NewRsaWithPkcs1Bytes(public, private []byte) (r *Rsa, err error)

+ func NewRsaWithPkcs8Bytes(public, private []byte) (r *Rsa, err error)

Apr 19, 2023

Changes in this version

+ func NewError(code codes.Code, msg string) error

+ type MyError struct

+ func (me *MyError) Code() codes.Code

+ func (me *MyError) Error() string

+ func (me *MyError) Is(target error) bool

+ func (me *MyError) ToStatus() *Status

type Status

+ func (s *Status) ToError() error

Apr 18, 2023

Changes in this version

+ func Bytes2Uint64(data []byte) uint64

+ func LcFirst(str string) string

+ func UcFirst(str string) string

Nov 25, 2022

Changes in this version

+ const StateIndexMax

+ var ErrState = errors.New("state index must lte 30")

+ type State int32

+ func StateFromSlice(list []uint8) (State, error)

+ func StatusFromValueSlice(list []int32) State

+ func (s *State) Add(indexList ...uint8) error

+ func (s *State) Has(index uint8) bool

+ func (s *State) Intersection(val State) []uint8

+ func (s *State) Merge(val State)

+ func (s *State) Remove(index uint8)

+ func (s *State) RemoveAll()

+ func (s *State) Slice() []uint8

+ func (s *State) UnionSet(val State) []uint8

+ func (s *State) ValueSlice() []int32

Nov 10, 2022

Changes in this version

+ const EventClose

+ const EventConnectSuccess

+ const EventError

+ const EventLogin

+ const EventLoginFailed

+ const EventLoginSuccess

+ const EventTick

Nov 8, 2022

Changes in this version

+ func PackIn32(value int32) []byte

+ func PackUin32(value uint32) []byte

+ func UnpackInt32(data []byte) (value int32, err error)

+ func UnpackUint32(data []byte) (value uint32, err error)

Nov 4, 2022

Changes in this version

type Protocol

+ func NewV2ForClient(aes *Aes, key, secretData []byte) (protocol Protocol, err error)

Nov 3, 2022

Changes in this version

+ const ConnectSuccess

+ const LevelJson

+ const LevelV1

+ const LevelV2

+ const Login

+ const LoginFailed

+ const LoginSuccess

+ const Tick

+ var ErrForbidden = errors.New("forbidden")

+ func Hex2Uint64(value string) uint64

+ func RandBytes(length int) []byte

+ func Uint64ToHex(value uint64) string

+ type Accept struct

+ func NewAccept(aes *Aes, level uint8) *Accept

+ func (a *Accept) Accept(level uint8, secretData []byte) (protocol Protocol, err error)

+ func (a *Accept) AcceptBase64Url(level uint8, base64Data []byte, urlSafe bool) (protocol Protocol, err error)

+ func (a *Accept) AcceptHex(level uint8, hexData []byte) (protocol Protocol, err error)

+ type Protocol interface

+ Pack func(pkg *Package) []byte

+ ResponseKey func() []byte

+ Unpack func(data []byte) (pkg *Package, err error)

+ func NewV0() (protocol Protocol, err error)

+ func NewV2(aes *Aes, secretData []byte) (protocol Protocol, err error)

Nov 2, 2022

Changes in this version

+ var ErrDataEmpty = errors.New("data is empty")

+ var ErrDataFormat = errors.New("invalid data format")

+ var ErrDataSign = errors.New("invalid data sign")

+ var ErrKeyFormat = errors.New("invalid key format")

+ func Hex2Int64(value string) int64

+ func Int64ToHex(value int64) string

+ func Int64ToHexWithPad(value int64, padLength int) string

+ func PprofIsRun() bool

+ func StartPprof(addr string, handler http.Handler) error

+ func StopPprof(ctx context.Context) error

type Config

+ PprofAddr string

+ type Package struct

+ Id uint16

+ Name string

+ Param JsonParam

+ func (p *Package) Pack() []byte

+ func (p *Package) Unpack(data []byte) error

+ type V1 struct

+ func NewV1(key string, secretData []byte) (protocol *V1, err error)

+ func (v1 *V1) Pack(pkg *Package) []byte

+ func (v1 *V1) Unpack(data []byte) (pkg *Package, err error)

Nov 2, 2022

Changes in this version

+ const EnvDev

+ const EnvPro

+ const EnvTest

+ var DefaultContainer = &Container

+ func Bytes2Uint32(data []byte) uint32

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

+ func InitZapWithOption(conf zaplogger.Option, zapOpts ...zap.Option) error

+ func IsLevel(level zapcore.Level) bool

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

+ type Config struct

+ Addr string

+ Env string

+ Logger zaplogger.Option

+ Name string

+ Params JsonParam

+ Ver string

+ func (c *Config) IsEnv(env string) bool

+ type Container struct

+ func (c *Container) Config() *Config

+ func (c *Container) Get(key string) (value interface{}, exists bool)

+ func (c *Container) Set(key string, value interface{})

+ func (c *Container) SetConfig(value *Config)

Oct 31, 2022

Changes in this version

+ const ErrAborted

+ const ErrAlreadyExists

+ const ErrCanceled

+ const ErrDataLoss

+ const ErrDeadlineExceeded

+ const ErrFailedPrecondition

+ const ErrInternal

+ const ErrInvalidArgument

+ const ErrNotFound

+ const ErrOutRange

+ const ErrPermissionDenied

+ const ErrResourceExhausted

+ const ErrUnauthenticated

+ const ErrUnavailable

+ const ErrUnimplemented

+ const ErrUnknown

+ const OK

+ type Status struct

+ Code codes.Code

+ Data interface{}

+ Msg string

+ func StatusWithCode(code codes.Code) *Status

+ func StatusWithJsonUnmarshal(data []byte) (*Status, error)

+ func (s *Status) Close()

+ func (s *Status) ConvertGrpcStatus(details ...proto.Message) (*status.Status, error)

+ func (s *Status) Error() error

+ func (s *Status) Is(code codes.Code) bool

+ func (s *Status) IsOK() bool

+ func (s *Status) JsonMarshal() []byte

+ func (s *Status) WithData(data interface{}) *Status

+ func (s *Status) WithMsg(msg string) *Status

Oct 29, 2022

Changes in this version

+ type JsonParam map[string]interface

+ func (jp JsonParam) Exists(key string) bool

+ func (jp JsonParam) Float64(key string) float64

+ func (jp JsonParam) Int(key string) int

+ func (jp JsonParam) Int64(key string) int64

+ func (jp JsonParam) Int64Slice(key string) []int64

+ func (jp JsonParam) IntSlice(key string) []int

+ func (jp JsonParam) JsonMarshal() []byte

+ func (jp JsonParam) String(key string) string

+ func (jp JsonParam) StringSlice(key string) []string

+ func (jp JsonParam) Uint32Slice(key string) []uint32

+ func UnmarshalJsonParam(data []byte) (JsonParam, error)

Aug 11, 2022

Changes in this version

+ var JsonMarshal = jsoniter.Marshal

+ var JsonUnmarshal = jsoniter.Unmarshal

+ var YamlMarshal = yaml.Marshal

+ var YamlUnmarshal = yaml.Unmarshal

+ func BinPath() string

+ func NewGoPool(size int, opts ...gopool.Option) (*gopool.Pool, error)

+ func ToString(val interface{}) string

Apr 19, 2022

Changes in this version

type Aes

+ func NewAesWithBytes(key, iv []byte) (a *Aes, err error)

Apr 15, 2022

Changes in this version

+ type Context struct

+ func AcquireCtx(handlers []func(ctx *Context)) *Context

+ func (c *Context) Abort()

+ func (c *Context) Close()

+ func (c *Context) Deadline() (deadline time.Time, ok bool)

+ func (c *Context) Done() <-chan struct{}

+ func (c *Context) Err() error

+ func (c *Context) Get(key string) (value interface{}, exists bool)

+ func (c *Context) GetBool(key string) (value bool, exists bool)

+ func (c *Context) GetInt(key string) (value int, exists bool)

+ func (c *Context) GetInt64(key string) (value int64, exists bool)

+ func (c *Context) GetInt8(key string) (value int8, exists bool)

+ func (c *Context) GetString(key string) (value string, exists bool)

+ func (c *Context) IsAborted() bool

+ func (c *Context) Next()

+ func (c *Context) Set(key string, value interface{})

+ func (c *Context) Value(key interface{}) interface{}

Feb 8, 2022

Changes in this version

type SnowFlake

+ IdTime func(current time.Time, logicId uint8) (int64, error)

Jan 30, 2022

Changes in this version

type ShardMap

+ func NewSharMapWithChannel(size int) (sm ShardMap, ch <-chan shardmap.ChangeEvent)

Jan 27, 2022

Changes in this version

+ func FileExists(fileName string) bool

Jan 18, 2022

Changes in this version

+ func Debug(args ...interface{})

+ func Debugf(template string, args ...interface{})

+ func Error(args ...interface{})

+ func Errorf(template string, args ...interface{})

+ func Fatal(args ...interface{})

+ func Fatalf(template string, args ...interface{})

+ func Info(args ...interface{})

+ func Infof(template string, args ...interface{})

+ func InitLogger(l Logger)

+ func InitZap(l *zap.Logger)

+ func InitZapWithConfig(conf zap.Config, opts ...zap.Option) error

+ func InitZapWithCore(core zapcore.Core, opts ...zap.Option)

+ func InitZapWithProduction(opts ...zap.Option) error

+ func Panic(args ...interface{})

+ func Panicf(template string, args ...interface{})

+ func Warn(args ...interface{})

+ func Warnf(template string, args ...interface{})

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

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

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

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

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

+ func ZapSync() error

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

+ type Logger interface

+ Debug func(args ...interface{})

+ Debugf func(template string, args ...interface{})

+ Error func(args ...interface{})

+ Errorf func(template string, args ...interface{})

+ Fatal func(args ...interface{})

+ Fatalf func(template string, args ...interface{})

+ Info func(args ...interface{})

+ Infof func(template string, args ...interface{})

+ Panic func(args ...interface{})

+ Panicf func(template string, args ...interface{})

+ Warn func(args ...interface{})

+ Warnf func(template string, args ...interface{})

Jan 9, 2022

Changes in this version

+ func BigCamels(sep byte, data string) string

+ func SmallCamels(sep byte, data string) string

Nov 18, 2021

Changes in this version

+ func Bytes2Float64(data []byte) float64

Nov 15, 2021

Changes in this version

type Bitmap

+ Data func() (data []byte)

Nov 15, 2021

Changes in this version

type HashRing

+ Index func(index int) (server CanHash, err error)

Nov 14, 2021

Changes in this version

+ var ErrNoServer = errors.New("no server")

+ type HashRing interface

+ Add func(server CanHash)

+ Get func(key interface{}) (server CanHash, err error)

+ Length func() int

+ Range func(handler func(index int, server CanHash) (handled bool))

+ Remove func(server CanHash)

+ Store func(servers ...CanHash)

+ func NewHashRing(servers ...CanHash) HashRing

+ type Node struct

+ type NodeList []Node

+ func (n NodeList) Len() int

+ func (n NodeList) Less(i, j int) bool

+ func (n NodeList) Swap(i, j int)

Nov 7, 2021

Changes in this version

+ const ModeError

+ const ModeMaxTime

+ const ModeWait

+ var ErrLogicId = errors.New("illegal logic id")

+ var ErrMachineId = errors.New("illegal machine id")

+ var ErrNotFoundIp = errors.New("not found ip address")

+ var ErrOutOfRange = errors.New("out of range")

+ var ErrTimeBack = errors.New("time go back")

+ func LocalIp() (ip string, err error)

+ func RedFatal(format string, args ...interface{})

+ type GetMachineId func() (id int64, err error)

+ func GetMachineIdByEnv(key string) GetMachineId

+ func GetMachineIdByIp() GetMachineId

+ type SnowFlake interface

+ Id func(logicId uint8) (int64, error)

+ Info func(id int64) (timestamp int64, machineId uint8, logicId uint8, index int16)

+ func NewSF(mode uint8, id uint8, timeStampBegin int64) (sfl SnowFlake, err error)

+ func NewSFByIp(mode uint8, timeStampBegin int64) (sfl SnowFlake, err error)

+ func NewSFByMachineFunc(mode uint8, machindFunc GetMachineId, timeStampBegin int64) (sfl SnowFlake, err error)

Nov 6, 2021

Changes in this version

+ func Bytes2Int64(data []byte) int64

+ func Bytes2String(data []byte) string

Nov 6, 2021

Changes in this version

+ func CreatePkcs1Keys(keyLength int) (privateKey, publicKey string)

+ func MarshalPkcs8PrivateKey(key *rsa.PrivateKey) []byte

type Rsa

+ func NewRsaWithPkcs1(publicKey, privateKey string) (r *Rsa, err error)

+ func NewRsaWithPkcs8(publicKey, privateKey string) (r *Rsa, err error)

Nov 6, 2021

Changes in this version

+ const En

+ const ZhCn

+ const ZhTw

+ var ErrAesDecrypt = errors.New(`aes decrypt error`)

+ var ErrInvalidPaddingChar = errors.New(`invalid padding char`)

+ var ErrMsgMapEmpty = errors.New("msgMap can not empty")

+ var ErrNoJsonFiles = errors.New("there are no `.json` files in this directory")

+ var ErrNoYamlFiles = errors.New("there are no `.yml` or `.yaml` files in this directory")

+ func Black(format string, args ...interface{})

+ func Blue(format string, args ...interface{})

+ func CreateKeys(keyLength int) (privateKey, publicKey string)

+ func CreatePkcs8Keys(keyLength int) (privateKey, publicKey string)

+ func Fuchsia(format string, args ...interface{})

+ func Green(format string, args ...interface{})

+ func HMac(key []byte, data []byte, hash crypto.Hash) string

+ func Hash(data []byte, hash crypto.Hash) string

+ func MarshalPKCS8PrivateKey(key *rsa.PrivateKey) []byte

+ func Md5(data []byte) string

+ func Red(format string, args ...interface{})

+ func Sha1(data []byte) string

+ func Yellow(format string, args ...interface{})

+ type Aes struct

+ func NewAes(key string, iv string) (a *Aes, err error)

+ func (a *Aes) CbcDecrypt(secretData []byte) (data []byte, err error)

+ func (a *Aes) CbcEncrypt(plain []byte) (secretData []byte)

+ type I18n interface

+ T func(key, language string) (msg string)

+ func NewI18n(defaultLanguage string, msgMap map[string]map[string]string) (i I18n, err error)

+ func NewI18nFromJson(defaultLanguage string, dir string) (i I18n, err error)

+ func NewI18nFromYaml(defaultLanguage string, dir string) (i I18n, err error)

+ type Rsa struct

+ func NewRsa(publicKey, privateKey string) (r *Rsa, err error)

+ func (r *Rsa) Decrypt(secretData []byte) ([]byte, error)

+ func (r *Rsa) Encrypt(data []byte) ([]byte, error)

+ func (r *Rsa) Sign(data []byte, algorithmSign crypto.Hash) ([]byte, error)

+ func (r *Rsa) Verify(data []byte, sign []byte, algorithmSign crypto.Hash) bool

Nov 6, 2021

Changes in this version

+ var AcquireArgs = func() []interface{}

+ var ErrIpV4Address = errors.New(`invalid ip v4 address`)

+ var ReleaseArgs = func(args *[]interface{})

+ var SetValue = struct{}

+ func HashValue(key interface{}) uint32

+ func Index4Bit(key interface{}, bitCount uint8) uint32

+ func Index4Int16(key interface{}) int16

+ func Index4Int8(key interface{}) int8

+ func Index4Uint8(key interface{}) uint8

+ func Ip2Long(ip string) (ipVal uint32, err error)

+ func JsonDecode(data []byte, v interface{}) (err error)

+ func JsonDecodeFile(filePath string, v interface{}) (err error)

+ func JsonEncode(v interface{}) (data []byte, err error)

+ func Long2Ip(ipVal uint32) string

+ func YamlDecode(data []byte, v interface{}) (err error)

+ func YamlDecodeFile(filePath string, v interface{}) (err error)

+ func YamlEncode(v interface{}) (data []byte, err error)

+ type Bitmap interface

+ AddTag func(tag int) Bitmap

+ BitCount func() int

+ DelTag func(tag int) Bitmap

+ Exists func(tag int) (exists bool)

+ HasBit func() bool

+ SprinfBinary func() string

+ func NewBitmap(data []byte) Bitmap

+ type CanHash interface

+ HashCode func() (hashValue uint32)

+ type HashSet interface

+ Add func(items ...interface{}) (newNum int)

+ Delete func(items ...interface{}) (delNum int)

+ Exists func(item interface{}) (exists bool)

+ Length func() (length int)

+ func NewHashSet(size int) HashSet

+ type Msg struct

+ Code int

+ Data interface{}

+ Msg string

+ func (m *Msg) Json() (msg []byte)

+ type ShardMap interface

+ Delete func(keys ...interface{})

+ Exists func(key interface{}) (exists bool)

+ Get func(key interface{}) (value interface{}, exists bool)

+ Length func() int64

+ Set func(key interface{}, value interface{})

+ func NewShardMap() ShardMap