components

Jul 23, 2025

Changes in this version

+ var DefaultSF = NewSFByIp(ModeWait, defaultSFBegin.Unix())

type SnowFlake

+ TimeBegin func() time.Time

Jul 16, 2025

Changes in this version

type Event

+ func NewEvent(name string, data any) *Event

+ func (e *Event) ParamData() kind.JsonParam

Jul 16, 2025

Changes in this version

type EventManager

+ func (em *EventManager) TriggerWithCtx(name string, ctx *Context)

Jul 15, 2025

Changes in this version

+ var DefaultBase62 = NewBase62(DefaultBase62Charset)

+ var DefaultBase62Charset = []byte("M01EK4aFzPcHNwZeUgAfXi3SjTkYmnGpqrJsuR8VohW2LvQ9xy7bB5CtD6dI")

+ type Base62 interface

+ Decode func(data []byte) (uint64, error)

+ Encode func(value uint64, length int) []byte

+ func NewBase62(charset []byte) (Base62, error)

type IdCode

+ func NewIdCodeWithCharset(charset []byte, salt int64) (*IdCode, error)

+ func (ic *IdCode) Id2Code32(id uint32) (code []byte, err error)

+ func (ic *IdCode) Id2Code64(id uint64) (code []byte, err error)

Jul 7, 2025

Changes in this version

type Rsa

+ func (r *Rsa) DecryptOAEP(secretData []byte, hash hash.Hash, label []byte) ([]byte, error)

+ func (r *Rsa) EncryptOAEP(data []byte, hash hash.Hash, label []byte) ([]byte, error)

Jun 27, 2025

Changes in this version

+ const En

+ var DefaultLang = ZhCn

type I18n

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

Jun 27, 2025

Changes in this version

+ var DefaultAlphanumeric = []byte("M0Q1EK4aFzPcZeUgAfXi3SjTkYmnGpqrJstD6uLv9xy7bB5CHNR8VhW2wdI")

+ var DefaultIdCode = NewIdCode(DefaultAlphanumeric, defaultSalt6, defaultSalt8)

Jun 26, 2025

Changes in this version

+ const ModeError

+ const ModeMaxTime

+ const ModeWait

+ const ZhCn

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

+ var ErrAlphanumeric = errors.New("alphanumeric must be [a-zA-Z0-9] and not repeat")

+ var ErrAlphanumericLength = errors.New("alphanumeric length must be [50, 62]")

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

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

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

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

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

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

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

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

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

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

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

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

+ func Code6String(id int64) (code string, err error)

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

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

+ func Code8String(id int64) (code string, err error)

+ func CodeString2Id(code string) (id int64, err error)

+ func CodeString6To8(code6 string) (code8 string, err error)

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

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

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

+ func Max6() int64

+ func Max8() int64

+ type Aes struct

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

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

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

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

+ type Chain struct

+ func NewChain(handlers ...Handler) *Chain

+ func (c *Chain) Run()

+ func (c *Chain) RunWithCtx(ctx *Context)

+ func (c *Chain) Use(handlers ...Handler)

+ type Context struct

+ func AcquireCtx(handlers []Handler) *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) Event() *Event

+ func (c *Context) Get(key string, defaultVal any) (value any)

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

+ func (c *Context) GetInt(key string, defaultVal int64) (value int64)

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

+ func (c *Context) GetUint(key string, defaultVal uint64) (value uint64)

+ func (c *Context) IsAborted() bool

+ func (c *Context) Next()

+ func (c *Context) Set(key string, value any)

+ func (c *Context) SetEvent(event *Event)

+ func (c *Context) Value(key any) any

+ type Event struct

+ func (e *Event) Data() any

+ func (e *Event) Name() string

+ type EventManager struct

+ func (em *EventManager) Has(name string) bool

+ func (em *EventManager) On(name string, handlers ...Handler)

+ func (em *EventManager) Trigger(name string, data any)

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

+ func GetMachineIdByEnv(key string) GetMachineId

+ func GetMachineIdByIp() GetMachineId

+ type Handler func(ctx *Context)

+ type HashRing interface

+ Add func(server kind.CanHash)

+ Get func(key any) (server kind.CanHash, err error)

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

+ Length func() int

+ Range func(handler func(index int, server kind.CanHash, hitCount uint64) (handled bool))

+ Remove func(server kind.CanHash)

+ Store func(servers ...kind.CanHash)

+ func NewHashRing(servers ...kind.CanHash) HashRing

+ 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 IdCode struct

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

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

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

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

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

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

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

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

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

+ func (ic *IdCode) Max6() int64

+ func (ic *IdCode) Max8() int64

+ 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)

+ type Package struct

+ Id uint16

+ Name string

+ Param kind.JsonParam

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

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

+ type Rsa struct

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

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

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

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

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

+ func NewRsaWithPkcs8Bytes(public, private []byte) (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

+ type SnowFlake interface

+ Id func() (int64, error)

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

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

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

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