utils

Jan 19, 2023

Changes in this version

+ func GracefulCancel(cancel func())

+ func NewTmpFileForContent(content []byte) (path string, err error)

type AsyncTaskStatus

+ func (s AsyncTaskStatus) String() string

type AsyncTaskStore

+ Heartbeat func(ctx context.Context, taskID string) (alived bool, err error)

Mar 2, 2022

Changes in this version

+ var ErrAsyncTask = errors.New("async task error")

+ var SignMethodRS256 = jwt.SigningMethodRS256

+ func CloseQuietly(v interface{})

+ func HasField(st interface{}, fieldName string) bool

+ func HasMethod(st interface{}, methodName string) bool

+ func Race(gs ...func())

+ func RaceWithCtx(ctx context.Context, gs ...func())

+ func RunWithTimeout(timeout time.Duration, f func())

+ func SleepWithContext(ctx context.Context, duration time.Duration)

+ type AsyncTask struct

+ func NewAsyncTask(ctx context.Context, store AsyncTaskStore) (*AsyncTask, error)

+ func (t *AsyncTask) ID() string

+ func (t *AsyncTask) SetDone(ctx context.Context, data string) (err error)

+ func (t *AsyncTask) SetError(ctx context.Context, errMsg string) (err error)

+ func (t *AsyncTask) Status() AsyncTaskStatus

+ type AsyncTaskResult struct

+ Data string

+ Err string

+ Exp time.Time

+ Status AsyncTaskStatus

+ TaskID string

+ type AsyncTaskStatus string

+ const AsyncTaskStatusDone

+ const AsyncTaskStatusFailed

+ const AsyncTaskStatusPending

+ type AsyncTaskStore interface

+ New func(ctx context.Context) (result *AsyncTaskResult, err error)

+ Set func(ctx context.Context, taskID string, result *AsyncTaskResult) (err error)

+ type Deque interface

+ Back func() interface{}

+ Front func() interface{}

+ Len func() int

+ PopBack func() interface{}

+ PopFront func() interface{}

+ PushBack func(interface{})

+ PushFront func(interface{})

+ func NewDeque(optfs ...DequeOptFunc) (Deque, error)

+ type DequeOptFunc func(*dequeOpt) error

+ func WithDequeCurrentCapacity(size int) DequeOptFunc

+ func WithDequeMinimalCapacity(size int) DequeOptFunc

+ type EmailDialer interface

+ DialAndSend func(m ...*gomail.Message) error

+ type FLock interface

+ Lock func() error

+ Unlock func() error

+ func NewFlock(lockFilePath string) FLock

type JWT

+ func (e *JWT) ParseClaimsByRS256(token string, claimsPtr jwt.Claims, opts ...JWTDiviceOptFunc) error

+ type LoggerItf interface

+ ChangeLevel func(level string) (err error)

+ Clone func() LoggerItf

+ DebugSample func(sample int, msg string, fields ...zapcore.Field)

+ InfoSample func(sample int, msg string, fields ...zapcore.Field)

+ Level func() zapcore.Level

+ Named func(s string) LoggerItf

+ WarnSample func(sample int, msg string, fields ...zapcore.Field)

+ With func(fields ...zapcore.Field) LoggerItf

+ WithOptions func(opts ...zap.Option) LoggerItf

+ type LoggerOptFunc func(l *loggerOption) error

+ type MailSendOptFunc func(*mailSendOpt)

+ func WithMailSendDialer(dialerFact func(host string, port int, username, passwd string) EmailDialer) MailSendOptFunc

Dec 23, 2021

Changes in this version

+ var TimeZoneShanghai *time.Location

+ var TimeZoneUTC = time.UTC

+ func AESEncryptFilesInDir2(dir string, secret []byte, opts ...SettingsEncryptOptf) (err error)

+ func Dedent(v string, optfs ...DedentOptFunc) string

+ func DeepClone(src interface{}) (dst interface{})

+ func MD5JSON(data interface{}) (string, error)

+ func NilInterface(data interface{}) bool

+ func PanicIfErr(err error)

+ type AtomicFieldBool struct

+ func (a *AtomicFieldBool) SetFalse()

+ func (a *AtomicFieldBool) SetTrue()

+ func (a *AtomicFieldBool) True() bool

+ type DedentOptFunc func(opt *dedentOpt)

+ func WithReplaceTabBySpaces(spaces int) DedentOptFunc

type SettingsEncryptOptf

+ func AESEncryptFilesInDirFileSuffix(suffix string) SettingsEncryptOptf

type SettingsOptFunc

+ func WithSettingsEnableInclude() SettingsOptFunc

+ func WithSettingsEncryptedFileSuffix(suffix string) SettingsOptFunc

type SettingsType

+ func NewSettings() *SettingsType

type SortItemItf

+ GetData func() interface{}

Sep 16, 2021

Changes in this version

+ const LoggerEncodingConsole

+ const LoggerEncodingJSON

+ const LoggerLevelFatal

+ const LoggerLevelPanic

+ func JumpHash(key uint64, numBuckets int) (int32, error)

+ func NewRand() *rand.Rand

+ func NewSkiplist() *skiplist.SkipList

+ func ParseLoggerLevel(level string) (zapcore.Level, error)

+ func SetInternalClock(interval time.Duration)

type ClockItf

+ Interval func() time.Duration

type ClockType

+ func (c *ClockType) Interval() time.Duration

type ExpCache

+ func (c *ExpCache) Delete(key interface{})

+ type FIFO struct

+ func NewFIFO() *FIFO

+ func (f *FIFO) Get() interface{}

+ func (f *FIFO) Len() int

+ func (f *FIFO) Put(d interface{})

+ type HeapItemItf interface

+ GetKey func() interface{}

+ GetPriority func() int

+ func GetLargestNItems(inputChan <-chan HeapItemItf, topN int) ([]HeapItemItf, error)

+ func GetSmallestNItems(inputChan <-chan HeapItemItf, topN int) ([]HeapItemItf, error)

+ func GetTopKItems(inputChan <-chan HeapItemItf, topN int, isHighest bool) ([]HeapItemItf, error)

+ type HeapSlice []HeapItemItf

+ type LRUExpiredMap struct

+ func NewLRUExpiredMap(ctx context.Context, ttl time.Duration, new func() interface{}) (el *LRUExpiredMap, err error)

+ func (e *LRUExpiredMap) Get(key string) interface{}

+ type LimitSizeHeap struct

+ func NewLimitSizeHeap(size int, isHighest bool) (h *LimitSizeHeap, err error)

+ func (h *LimitSizeHeap) Pop() HeapItemItf

+ func (h *LimitSizeHeap) Push(item HeapItemItf) HeapItemItf

+ type LoggerConfig struct

+ Name string

+ type LoggerEncoding string

+ type LoggerOption func(l *LoggerConfig) error

+ func WithLoggerEncoding(format LoggerEncoding) LoggerOption

+ func WithLoggerErrorOutputPaths(paths []string) LoggerOption

+ func WithLoggerLevel(level string) LoggerOption

+ func WithLoggerName(name string) LoggerOption

+ func WithLoggerOutputPaths(paths []string) LoggerOption

+ func WithLoggerZapOptions(opts ...zap.Option) LoggerOption

+ type PriorityQ struct

+ func NewPriorityQ(isMaxTop bool) *PriorityQ

+ func (p *PriorityQ) Len() int

+ func (p *PriorityQ) Less(i, j int) bool

+ func (p *PriorityQ) Pop() (popped interface{})

+ func (p *PriorityQ) Push(x interface{})

+ func (p *PriorityQ) Remove(v HeapItemItf) (ok bool)

+ func (p *PriorityQ) Swap(i, j int)

+ type SingleItemExpCache struct

+ func NewSingleItemExpCache(ttl time.Duration) *SingleItemExpCache

+ func (c *SingleItemExpCache) Get() (data interface{}, ok bool)

+ func (c *SingleItemExpCache) GetString() (data string, ok bool)

+ func (c *SingleItemExpCache) GetUintSlice() (data []uint, ok bool)

+ func (c *SingleItemExpCache) Set(data interface{})

Jul 30, 2021

Changes in this version

+ func StopSignal(optfs ...StopSignalOptFunc) (stopCh <-chan struct{})

+ type StopSignalOptFunc func(*stopSignalOpt)

+ func WithStopSignalCloseSignals(signals ...os.Signal) StopSignalOptFunc

Jul 8, 2021

Changes in this version

+ func AbsInt32(v int32) int32

+ func AbsInt64(v int64) int64

+ func ConvertMap2StringKey(inputMap interface{}) map[string]interface

+ func GetFuncAddress(v interface{}) string

+ func HumanReadableByteCount(bytes int64, si bool) (ret string)

+ func IsPanic(f func()) (isPanic bool)

type EventEngine

+ func (e *EventEngine) RegisterWithHandler(topic EventTopic, handler EventHandler)

+ func (e *EventEngine) SetEventEngineChanBuffer(msgBufferSize int) *EventEngine

+ func (e *EventEngine) SetEventEngineLogger(logger *LoggerType) *EventEngine

+ func (e *EventEngine) SetEventEngineNFork(nfork int) *EventEngine

+ func (e *EventEngine) SetEventEngineSuppressPanic(suppressPanic bool) *EventEngine

+ func (e *EventEngine) UnRegisterWithHandler(topic EventTopic, handler EventHandler)

type HandlerID

+ func GetHandlerID(handler EventHandler) HandlerID

Jun 21, 2021

Changes in this version

+ func Convert2Map(inputMap interface{}) map[string]interface

type SettingsType

+ func (s *SettingsType) Unmarshal(obj interface{}) error

+ func (s *SettingsType) UnmarshalKey(key string, obj interface{}) error

Jun 11, 2021

Changes in this version

+ func Bytes2Str(b []byte) string

+ func Str2Bytes(s string) []byte

May 26, 2021

Changes in this version

type Event

+ Stack string

May 25, 2021

Changes in this version

+ func GetStructFieldByName(st interface{}, fieldName string) interface

+ func IsRemoteUDPPortOpen(addr string) error

+ func SecRandInt(n int) (int, error)

+ func SecRandomStringWithLength(n int) (string, error)

type ClockType

+ func (c *ClockType) SetInterval(interval time.Duration)

+ type EventMeta map[MetaKey]interface

+ type EventTopic string

+ func (h EventTopic) String() string

+ type HandlerID string

+ func (h HandlerID) String() string

+ type MetaKey string

+ func (h MetaKey) String() string

+ type SimpleExpCache struct

+ func NewSimpleExpCache(ttl time.Duration) *SimpleExpCache

+ func (c *SimpleExpCache) Get() (data interface{}, ok bool)

+ func (c *SimpleExpCache) GetString() (data string, ok bool)

+ func (c *SimpleExpCache) GetUintSlice() (data []uint, ok bool)

+ func (c *SimpleExpCache) Set(data interface{})

Jan 7, 2021

Changes in this version

+ type Event struct

+ Meta map[string]interface{}

+ Time time.Time

+ Topic string

+ type EventEngine struct

+ func NewEventEngine(ctx context.Context, opts ...EventEngineOptFunc) (e *EventEngine, err error)

+ func (e *EventEngine) Publish(evt *Event)

+ func (e *EventEngine) Register(topic, handlerName string, handler EventHandler)

+ func (e *EventEngine) UnRegister(topic, handlerName string)

+ type EventEngineOptFunc func(*eventStoreManagerOpt) error

+ func WithEventEngineChanBuffer(msgBufferSize int) EventEngineOptFunc

+ func WithEventEngineLogger(logger *LoggerType) EventEngineOptFunc

+ func WithEventEngineNFork(nfork int) EventEngineOptFunc

+ func WithEventEngineSuppressPanic(suppressPanic bool) EventEngineOptFunc

+ type EventHandler func(*Event)

+ type ExpiredMap struct

+ func NewExpiredMap(ctx context.Context, exp time.Duration, new func() interface{}) (el *ExpiredMap, err error)

+ func (e *ExpiredMap) Get(key string) interface{}

+ type ExpiredRLock struct

+ func NewExpiredRLock(ctx context.Context, exp time.Duration) (el *ExpiredRLock, err error)

+ func (e *ExpiredRLock) GetLock(key string) *sync.RWMutex

Dec 9, 2020

Changes in this version

+ type ExpCache struct

+ func NewExpCache(exp time.Duration) *ExpCache

+ func (c *ExpCache) Load(key interface{}) (data interface{}, ok bool)

+ func (c *ExpCache) Store(key, val interface{})

type LoggerType

+ func (l *LoggerType) Level() string

Oct 9, 2020

Changes in this version

+ func InArray(collection interface{}, ele interface{}) bool

+ func RemoveEmpty(vs []string) (r []string)

+ func TrimEleSpaceAndRemoveEmpty(vs []string) (r []string)

Sep 11, 2020

Changes in this version

+ const HTTPHeaderContentType

+ const HTTPHeaderContentTypeValJSON

+ const HTTPHeaderHost

+ const HTTPHeaderReferer

+ func IsDirWritable(dir string) (err error)

Jul 30, 2020

Changes in this version

+ const BaseHex

+ const BitSize64

+ const Nano2Sec

+ const TimeFormatDate

type ClockType

+ func (c *ClockType) GetDate() (time.Time, error)

Jul 22, 2020

Changes in this version

+ func AESEncryptFilesInDir(dir string, secret []byte, opts ...SettingsEncryptOptf) (err error)

+ func ListFilesInDir(dir string) ([]string, error)

+ type SettingsEncryptOptf func(*settingsAESEncryptOpt) error

+ func AESEncryptFilesInDirFileAppend(append string) SettingsEncryptOptf

+ func AESEncryptFilesInDirFileExt(ext string) SettingsEncryptOptf

type SettingsOptFunc

+ func WithSettingsEncryptedFileContain(mark string) SettingsOptFunc

Jul 21, 2020

Changes in this version

+ func CopyFile(src, dst string) (err error)

+ func EncryptByAes(secret []byte, cnt []byte) ([]byte, error)

+ func IsDir(path string) (bool, error)

+ func IsFile(path string) (bool, error)

+ func MoveFile(src, dst string) (err error)

+ type AesReaderWrapper struct

+ func NewAesReaderWrapper(in io.Reader, key []byte) (*AesReaderWrapper, error)

+ func (w *AesReaderWrapper) Read(p []byte) (n int, err error)

+ type GormLogger struct

+ func NewGormLogger(formatter func(...interface{}) []interface{}, logger gormLoggerItf) *GormLogger

+ func (l *GormLogger) Print(vs ...interface{})

type SettingsOptFunc

+ func WithSettingsAesEncrypt(key []byte) SettingsOptFunc

Jul 9, 2020

Changes in this version

+ type SettingsOptFunc func(*settingsOpt) error

+ func WithSettingsInclude(enableInclude bool) SettingsOptFunc

type SettingsType

+ func (s *SettingsType) LoadFromConfigServer(url, app, profile, label string) (err error)

+ func (s *SettingsType) LoadFromConfigServerWithRawYaml(url, app, profile, label, key string) (err error)

+ func (s *SettingsType) LoadFromDir(dirPath string) error

+ func (s *SettingsType) LoadFromFile(filePath string, opts ...SettingsOptFunc) (err error)

Jun 14, 2020

Changes in this version

+ func Base64Decode(encoded string) ([]byte, error)

+ func Base64Encode(raw []byte) string

+ func DecodeRSAPrivateKey(pemEncoded []byte) (*rsa.PrivateKey, error)

+ func DecodeRSAPublicKey(pemEncodedPub []byte) (*rsa.PublicKey, error)

+ func EncodeRSAPrivateKey(privateKey *rsa.PrivateKey) ([]byte, error)

+ func EncodeRSAPublicKey(publicKey *rsa.PublicKey) ([]byte, error)

+ func SignByRSAWithSHA256(priKey *rsa.PrivateKey, content []byte) ([]byte, error)

+ func SignReaderByRSAWithSHA256(priKey *rsa.PrivateKey, reader io.Reader) (sig []byte, err error)

+ func VerifyByRSAWithSHA256(pubKey *rsa.PublicKey, content []byte, sig []byte) error

+ func VerifyReaderByRSAWithSHA256(pubKey *rsa.PublicKey, reader io.Reader, sig []byte) error

+ type HTTPClientOptFunc func(*httpClientOption) error

May 23, 2020

Changes in this version

+ const LoggerLevelDebug

+ const LoggerLevelError

+ const LoggerLevelInfo

+ const LoggerLevelWarn

May 16, 2020

Changes in this version

+ const ANSIColorBgBlack

+ const ANSIColorBgBlue

+ const ANSIColorBgCyan

+ const ANSIColorBgGreen

+ const ANSIColorBgHiBlack

+ const ANSIColorBgHiBlue

+ const ANSIColorBgHiCyan

+ const ANSIColorBgHiGreen

+ const ANSIColorBgHiMagenta

+ const ANSIColorBgHiRed

+ const ANSIColorBgHiWhite

+ const ANSIColorBgHiYellow

+ const ANSIColorBgMagenta

+ const ANSIColorBgRed

+ const ANSIColorBgWhite

+ const ANSIColorBgYellow

+ const ANSIColorBlinkRapid

+ const ANSIColorBlinkSlow

+ const ANSIColorBold

+ const ANSIColorConcealed

+ const ANSIColorCrossedOut

+ const ANSIColorEscape

+ const ANSIColorFaint

+ const ANSIColorFgBlack

+ const ANSIColorFgBlue

+ const ANSIColorFgCyan

+ const ANSIColorFgGreen

+ const ANSIColorFgHiBlack

+ const ANSIColorFgHiBlue

+ const ANSIColorFgHiCyan

+ const ANSIColorFgHiGreen

+ const ANSIColorFgHiMagenta

+ const ANSIColorFgHiRed

+ const ANSIColorFgHiWhite

+ const ANSIColorFgHiYellow

+ const ANSIColorFgMagenta

+ const ANSIColorFgRed

+ const ANSIColorFgWhite

+ const ANSIColorFgYellow

+ const ANSIColorItalic

+ const ANSIColorReset

+ const ANSIColorReverseVideo

+ const ANSIColorUnderline

+ func Color(color int, s string) string

May 15, 2020

Changes in this version

+ func NewHTTPClient(opts ...HttpClientOptFunc) (c *http.Client, err error)

type LoggerType

+ func NewConsoleLoggerWithName(name, level string, opts ...zap.Option) (l *LoggerType, err error)

+ func NewLoggerWithNameAndFormat(name, format, level string, opts ...zap.Option) (l *LoggerType, err error)

May 8, 2020

Changes in this version

+ func Base64(raw []byte) string

+ func DecryptByAes(secret []byte, encrypted []byte) ([]byte, error)

+ func EncryptByAES(secret []byte, cnt []byte) ([]byte, error)

May 7, 2020

Changes in this version

+ func FormatBig2Base64(b *big.Int) string

+ func ParseBase642Big(raw string) (*big.Int, error)

Apr 29, 2020

Changes in this version

+ func RunCMD(app string, args ...string) (stdout []byte, err error)

Apr 23, 2020

Changes in this version

+ func DecodeES256SignByBase64(sign string) (a, b *big.Int, err error)

+ func DecodeES256SignByHex(sign string) (a, b *big.Int, err error)

+ func EncodeES256SignByBase64(a, b *big.Int) string

+ func EncodeES256SignByHex(a, b *big.Int) string

+ func GetHTTPClient(opts ...HttpClientOptFunc) (c *http.Client, err error)

+ type HttpClientOptFunc func(*httpClientOption) error

+ func WithHTTPClientInsecure(insecure bool) HttpClientOptFunc

+ func WithHTTPClientMaxConn(maxConn int) HttpClientOptFunc

+ func WithHTTPClientTimeout(timeout time.Duration) HttpClientOptFunc

Apr 13, 2020

Changes in this version

+ func IsHasField(st interface{}, fieldName string) bool

+ func IsHasMethod(st interface{}, methodName string) bool

Apr 13, 2020

Changes in this version

+ func ValidateFileHash(filepath string, hashed string) error

Apr 3, 2020

Changes in this version

+ var JSON = json

+ var SignMethodES256 = jwt.SigningMethodES256

+ var SignMethodHS256 = jwt.SigningMethodHS256

+ func IsPtr(t interface{}) bool

type JWT

+ func (e *JWT) ParseClaims(token string, claimsPtr jwt.Claims, opts ...JWTDiviceOptFunc) error

+ func (e *JWT) ParseClaimsByES256(token string, claimsPtr jwt.Claims, opts ...JWTDiviceOptFunc) error

+ func (e *JWT) ParseClaimsByHS256(token string, claimsPtr jwt.Claims, opts ...JWTDiviceOptFunc) error

+ func (e *JWT) Sign(claims jwt.Claims, opts ...JWTDiviceOptFunc) (string, error)

+ func (e *JWT) SignByES256(claims jwt.Claims, opts ...JWTDiviceOptFunc) (string, error)

+ func (e *JWT) SignByHS256(claims jwt.Claims, opts ...JWTDiviceOptFunc) (string, error)

+ type JWTDiviceOptFunc func(*jwtDivideOpt) error

+ func WithJWTDividePriKey(priKey []byte) JWTDiviceOptFunc

+ func WithJWTDividePubKey(pubKey []byte) JWTDiviceOptFunc

+ func WithJWTDivideSecret(secret []byte) JWTDiviceOptFunc

type JWTOptFunc

+ func WithJWTPriKeyByte(prikey []byte) JWTOptFunc

+ func WithJWTPubKeyByte(pubkey []byte) JWTOptFunc

+ func WithJWTSecretByte(secret []byte) JWTOptFunc

Mar 25, 2020

Changes in this version

+ func AddFileToZip(zipWriter *zip.Writer, filename string) (err error)

+ func Unzip(src string, dest string) (filenames []string, err error)

+ func ZipFiles(filename string, files []string) (err error)

Mar 24, 2020

Changes in this version

+ func FormatBig2Hex(b *big.Int) string

+ func FormatECDSASign(a, b *big.Int) string

+ func ParseECDSASign(sign string) (a, b *big.Int, ok bool)

+ func ParseHex2Big(hex string) (b *big.Int, ok bool)

+ func SignReaderByECDSAWithSHA256(priKey *ecdsa.PrivateKey, reader io.Reader) (r, s *big.Int, err error)

+ func VerifyReaderByECDSAWithSHA256(pubKey *ecdsa.PublicKey, reader io.Reader, r, s *big.Int) (bool, error)

Mar 22, 2020

Changes in this version

+ func DecodeECDSAPrivateKey(pemEncoded []byte) (*ecdsa.PrivateKey, error)

+ func DecodeECDSAPublicKey(pemEncodedPub []byte) (*ecdsa.PublicKey, error)

+ func EncodeECDSAPrivateKey(privateKey *ecdsa.PrivateKey) ([]byte, error)

+ func EncodeECDSAPublicKey(publicKey *ecdsa.PublicKey) ([]byte, error)

+ func SignByECDSAWithSHA256(priKey *ecdsa.PrivateKey, content []byte) (r, s *big.Int, err error)

+ func VerifyByECDSAWithSHA256(pubKey *ecdsa.PublicKey, content []byte, r, s *big.Int) bool

Mar 11, 2020

Changes in this version

+ func UniqueStrings(vs []string) (r []string)

Feb 25, 2020

Changes in this version

+ func MaxInt(a, b int) int

+ func MinInt(a, b int) int

+ func SetStructFieldsBySlice(structs, vals interface{}) (err error)

Jan 22, 2020

Changes in this version

+ func AutoGC(ctx context.Context, opts ...GcOptFunc) (err error)

+ func HashSHA128String(val string) string

+ type GcOptFunc func(*gcOption) error

+ func WithGCMemLimitFilePath(path string) GcOptFunc

+ func WithGCMemRatio(ratio int) GcOptFunc

Jan 21, 2020

Changes in this version

+ func DirSize(path string) (size int64, err error)

+ func HashSHA256String(val string) string

+ func HashXxhashString(val string) string

type AlertPusher

+ func (a *AlertPusher) GetZapHook() func(zapcore.Entry, []zapcore.Field) (err error)

type LoggerType

+ func CreateNewDefaultLogger(name, level string, opts ...zap.Option) (l *LoggerType, err error)

+ func (l *LoggerType) Clone() *LoggerType

+ func (l *LoggerType) Named(s string) *LoggerType

+ type PateoAlertPusher struct

+ func NewPateoAlertPusher(ctx context.Context, api, token string, opts ...AlertHookOptFunc) (p *PateoAlertPusher, err error)

+ func (p *PateoAlertPusher) GetZapHook() func(zapcore.Entry, []zapcore.Field) (err error)

+ func (p *PateoAlertPusher) Send(title, content string, ts time.Time) (err error)

Dec 13, 2019

Changes in this version

+ func ParseJWTTokenWithoutValidate(token string) (payload jwt.MapClaims, err error)

+ type AcquireLockOptFunc func(*acquireLockOption)

+ func WithAcquireLockDuration(duration time.Duration) AcquireLockOptFunc

+ func WithAcquireLockIsRenewal(isRenewal bool) AcquireLockOptFunc

+ func WithAcquireLockMaxRetry(maxRetry int) AcquireLockOptFunc

+ func WithAcquireLockRenewalInterval(renewalInterval time.Duration) AcquireLockOptFunc

+ type AlertHookOptFunc func(*AlertHook)

+ type AlertPushOptFunc func(*AlertPusher)

+ type CompressOptFunc func(*compressOption)

+ func WithCompressBufSizeByte(n int) CompressOptFunc

+ func WithCompressLevel(n int) CompressOptFunc

+ func WithPGzipBlockSize(bytes int) CompressOptFunc

+ func WithPGzipNBlocks(nBlock int) CompressOptFunc

+ type CompressorItf interface

+ Flush func() error

+ Write func([]byte) (int, error)

+ WriteFooter func() error

+ WriteString func(string) (int, error)

type ConfigSrv

+ RemoteCfg *Config

type DivideJWT

+ func (j *DivideJWT) GetExpiresKey() string

+ func (j *DivideJWT) GetSignMethod() *jwt.SigningMethodHMAC

+ func (j *DivideJWT) GetUserIDKey() string

type JWT

+ func (j *JWT) GetExpiresKey() string

+ func (j *JWT) GetSignMethod() *jwt.SigningMethodHMAC

+ func (j *JWT) GetUserIDKey() string

+ type JWTOptFunc func(*jwtOption)

+ func WithJWTExpiresKey(expiresKey string) JWTOptFunc

+ func WithJWTSignMethod(method *jwt.SigningMethodHMAC) JWTOptFunc

+ func WithJWTUserIDKey(userIDKey string) JWTOptFunc

+ type JWTUserItf interface

+ GetSecret func() []byte

+ GetUID func() interface{}

+ type LaiskyRemoteLock struct

+ func NewLaiskyRemoteLock(api, token string, opts ...LaiskyRemoteLockOptFunc) (l *LaiskyRemoteLock, err error)

+ func (l *LaiskyRemoteLock) AcquireLock(ctx context.Context, lockName string, opts ...AcquireLockOptFunc) (ok bool, err error)

+ type LaiskyRemoteLockOptFunc func(*LaiskyRemoteLock)

+ func WithLaiskyRemoteLockTimeout(timeout time.Duration) LaiskyRemoteLockOptFunc

+ type PGZCompressor struct

+ func NewPGZCompressor(writer io.Writer, opts ...CompressOptFunc) (c *PGZCompressor, err error)

+ func (c *PGZCompressor) Flush() (err error)

+ func (c *PGZCompressor) Write(d []byte) (int, error)

+ func (c *PGZCompressor) WriteFooter() (err error)

+ func (c *PGZCompressor) WriteString(d string) (int, error)

Dec 3, 2019

Changes in this version

type LoggerType

+ func (l *LoggerType) With(fields ...zapcore.Field) *LoggerType

+ func (l *LoggerType) WithOptions(opts ...zap.Option) *LoggerType

Nov 11, 2019

Changes in this version

+ func URLMasking(url, mask string) string

Nov 6, 2019

Changes in this version

+ type AlertHook struct

+ func NewAlertHook(pusher *AlertPusher, opts ...AlertHookOption) (a *AlertHook)

+ func (a *AlertHook) GetZapHook() func(zapcore.Entry) error

+ type AlertHookOption func(*AlertHook)

+ func WithAlertHookLevel(level zapcore.Level) AlertHookOption

+ type AlertPushOption func(*AlertPusher)

+ func WithAlertPushTimeout(timeout time.Duration) AlertPushOption

+ type AlertPusher struct

+ func NewAlertPusher(ctx context.Context, pushAPI string, opts ...AlertPushOption) (a *AlertPusher, err error)

+ func NewAlertPusherWithAlertType(ctx context.Context, pushAPI string, alertType, pushToken string, ...) (a *AlertPusher, err error)

+ func (a *AlertPusher) Close()

+ func (a *AlertPusher) Send(msg string) (err error)

+ func (a *AlertPusher) SendWithType(alertType, pushToken, msg string) (err error)

type LoggerType

+ func NewLoggerWithName(name, level string, opts ...zap.Option) (l *LoggerType, err error)

+ func SetDefaultLogger(name, level string, opts ...zap.Option) (l *LoggerType, err error)

type Throttle

+ func NewThrottleWithCtx(ctx context.Context, cfg *ThrottleCfg) (t *Throttle, err error)

+ func (t *Throttle) Close()

Oct 15, 2019

Changes in this version

+ var ParseTs2UTC = ParseUnix2UTC

+ func ParseHex2UTC(ts string) (t time.Time, err error)

+ func ParseHexNano2UTC(ts string) (t time.Time, err error)

+ func ParseUnix2String(ts int64, layout string) string

+ func ParseUnix2UTC(ts int64) time.Time

+ func ParseUnixNano2UTC(ts int64) time.Time

type ClockType

+ func (c *ClockType) GetNanoTimeInHex() string

+ func (c *ClockType) GetTimeInHex() string

type LoggerType

+ func NewLogger(level string) (l *LoggerType, err error)

+ func (l *LoggerType) ChangeLevel(level string) (err error)

Sep 30, 2019

Changes in this version

+ type Int64CounterItf interface

+ Count func() int64

+ CountN func(n int64) int64

type RotateCounter

+ func (c *RotateCounter) Get() int64

Sep 5, 2019

Changes in this version

type MonotonicRotateCounter

+ func NewMonotonicCounterFromNWithCtx(ctx context.Context, n, rotatePoint int64) (*MonotonicRotateCounter, error)

+ func NewMonotonicRotateCounterWithCtx(ctx context.Context, rotatePoint int64) (*MonotonicRotateCounter, error)

+ func (c *MonotonicRotateCounter) Close()

+ func (c *MonotonicRotateCounter) RunRotator(ctx context.Context)

type Mutex

+ func (m *Mutex) ForceRelease()

type RotateCounter

+ func NewRotateCounterFromNWithCtx(ctx context.Context, n, rotatePoint int64) (*RotateCounter, error)

+ func NewRotateCounterWithCtx(ctx context.Context, rotatePoint int64) (*RotateCounter, error)

+ func (c *RotateCounter) Close()

+ func (c *RotateCounter) RunRotator(ctx context.Context)

Sep 5, 2019

Changes in this version

+ var ForceGCBlocking = ForceGC

+ var ForceGCUnBlocking = TriggerGC

+ func UnixNano2UTC(ts int64) time.Time

type Throttle

+ func (t *Throttle) RunWithCtx(ctx context.Context)

Sep 3, 2019

Changes in this version

+ var Clock2 = NewClock2(context.Background(), defaultClockInterval)

+ type Clock2Type struct

+ func NewClock2(ctx context.Context, refreshInterval time.Duration) *Clock2Type

+ func (c *Clock2Type) Close()

+ func (c *Clock2Type) GetTimeInRFC3339Nano() string

+ func (c *Clock2Type) GetUTCNow() (t time.Time)

+ func (c *Clock2Type) SetupInterval(interval time.Duration)

+ type ClockItf interface

+ Close func()

+ GetTimeInRFC3339Nano func() string

+ GetUTCNow func() time.Time

+ SetupInterval func(time.Duration)

type ClockType

+ func (c *ClockType) Close()

Sep 2, 2019

Changes in this version

+ type CtxKeyT string

Aug 27, 2019

Changes in this version

+ type ChildParallelCounter struct

+ func (c *ChildParallelCounter) Count() (r int64)

+ func (c *ChildParallelCounter) CountN(n int64) (r int64)

+ func (c *ChildParallelCounter) Get() int64

type GZCompressorCfg

+ GzLevel int

+ type ParallelCounter struct

+ func NewParallelCounter(quoteStep, rotatePoint int64) (*ParallelCounter, error)

+ func NewParallelCounterFromN(n, quoteStep, rotatePoint int64) (*ParallelCounter, error)

+ func (c *ParallelCounter) GetChild() *ChildParallelCounter

+ func (c *ParallelCounter) GetQuote(step int64) (from, to int64)

Aug 21, 2019

Changes in this version

type GZCompressor

+ func (c *GZCompressor) WriteFooter() (err error)

Aug 19, 2019

Changes in this version

+ type GZCompressor struct

+ func NewGZCompressor(cfg *GZCompressorCfg) *GZCompressor

+ func (c *GZCompressor) Flush() (err error)

+ func (c *GZCompressor) Write(d []byte) (int, error)

+ func (c *GZCompressor) WriteString(d string) (int, error)

+ type GZCompressorCfg struct

+ BufSizeByte int

+ Writer io.Writer

Aug 15, 2019

Changes in this version

+ func TemplateWithMap(tpl string, data map[string]interface{}) string

+ func TemplateWithMapAndRegexp(tplReg *regexp.Regexp, tpl string, data map[string]interface{}) string

type SettingsType

+ func (s *SettingsType) GetStringMap(key string) map[string]interface{}

+ func (s *SettingsType) GetStringMapString(key string) map[string]string

+ func (s *SettingsType) IsSet(key string) bool

Jun 27, 2019

Changes in this version

type DivideJWT

+ func (j *DivideJWT) VerifyAndReplaceExp(payload jwt.MapClaims) (err error)

type JWT

+ func (j *JWT) VerifyAndReplaceExp(payload map[string]interface{}) (err error)

Jun 26, 2019

Changes in this version

+ const JWTExpiresAtKey

+ const JWTUserIDKey

+ type DivideJWT struct

+ func NewDivideJWT(cfg *DivideJWTCfg) (*DivideJWT, error)

+ func (j *DivideJWT) GenerateToken(user JWTUserModel, expiresAt time.Time, payload map[string]interface{}) (tokenStr string, err error)

+ func (j *DivideJWT) Validate(user JWTUserModel, tokenStr string) (payload jwt.MapClaims, err error)

+ type DivideJWTCfg struct

+ func NewDivideJWTCfg() *DivideJWTCfg

+ type JWTUserModel interface

+ GetUID func() interface{}

+ LoadSecretByUID func(uid interface{}) ([]byte, error)

May 31, 2019

Changes in this version

+ func TriggerGC()

May 31, 2019

Changes in this version

+ func ForceGC()

+ type Mutex struct

+ func NewMutex() *Mutex

+ func (m *Mutex) ForceRealse()

+ func (m *Mutex) IsLocked() bool

+ func (m *Mutex) SpinLock(step, timeout time.Duration)

+ func (m *Mutex) TryLock() bool

+ func (m *Mutex) TryRelease() bool

May 27, 2019

Changes in this version

type SettingsType

+ YamlExt string

May 24, 2019

Changes in this version

+ var JWTExpiresLayout = time.RFC3339

+ var JWTSigningMethod = jwt.SigningMethodHS512

type JWT

+ func NewJWT(cfg *JwtCfg) (*JWT, error)

+ type JwtCfg struct

+ ExpiresAtKey string

+ JWTSigningMethod *jwt.SigningMethodHMAC

+ Secret []byte

+ UserIDKey string

+ func NewJWTCfg(secret []byte) *JwtCfg

May 20, 2019

Changes in this version

+ var SigningMethod = jwt.SigningMethodHS512

May 20, 2019

Changes in this version

+ func GeneratePasswordHash(password []byte) ([]byte, error)

+ func ValidatePasswordHash(hashedPassword, password []byte) bool

type JWT

+ ExpiresAtKey string

+ UserIDKey string

+ func (j *JWT) GenerateToken(userId string, expiresAt time.Time, payload map[string]interface{}) (tokenStr string, err error)

Apr 17, 2019

Changes in this version

+ const CFG_FNAME

+ const HTTPJSONHeader

+ const HTTPJSONHeaderVal

+ const SampleRateDenominator

+ var Clock = NewClock(defaultClockInterval)

+ var Settings = &SettingsType

+ func CheckResp(resp *http.Response) error

+ func EnableCpuPprof()

+ func EnableMemPprof()

+ func EnableTracePprof()

+ func FallBack(orig func() interface{}, fallback interface{}) (ret interface{})

+ func FlattenMap(data map[string]interface{}, delimiter string)

+ func FloorDivision(val int, divisor int) int

+ func GetFuncName(f interface{}) string

+ func HTTPInvalidStatusError(statusCode int) error

+ func ParseTs2String(ts int64, layout string) string

+ func ParseTs2Time(ts int64) time.Time

+ func RandomStringWithLength(n int) string

+ func RegexNamedSubMatch(r *regexp.Regexp, str string, subMatchMap map[string]string) error

+ func RequestJSON(method, url string, request *RequestData, resp interface{}) (err error)

+ func RequestJSONWithClient(httpClient *http.Client, method, url string, request *RequestData, ...) (err error)

+ func Round(val float64, roundOn float64, places int) (newVal float64)

+ func SetupClock(refreshInterval time.Duration)

+ func SetupLogger(level string)

+ func UTCNow() time.Time

+ type ClockType struct

+ func NewClock(refreshInterval time.Duration) *ClockType

+ func (c *ClockType) GetTimeInRFC3339Nano() string

+ func (c *ClockType) GetUTCNow() time.Time

+ func (c *ClockType) Run()

+ func (c *ClockType) SetupInterval(interval time.Duration)

+ func (c *ClockType) Stop()

+ type Config struct

+ Label string

+ Name string

+ Profiles []string

+ Sources []*ConfigSource

+ Version string

+ type ConfigServerCfg struct

+ App string

+ Label string

+ Profile string

+ URL string

+ type ConfigSource struct

+ Name string

+ Source map[string]interface{}

+ type ConfigSrv struct

+ Cfg *Config

+ func NewConfigSrv(cfg *ConfigServerCfg) *ConfigSrv

+ func (c *ConfigSrv) Fetch() error

+ func (c *ConfigSrv) Get(name string) (interface{}, bool)

+ func (c *ConfigSrv) GetBool(name string) (bool, bool)

+ func (c *ConfigSrv) GetInt(name string) (int, bool)

+ func (c *ConfigSrv) GetString(name string) (string, bool)

+ func (c *ConfigSrv) Map(set func(string, interface{}))

+ type Counter struct

+ func NewCounter() *Counter

+ func NewCounterFromN(n int64) *Counter

+ func (c *Counter) Count() int64

+ func (c *Counter) CountN(n int64) int64

+ func (c *Counter) Get() int64

+ func (c *Counter) GetSpeed() (r float64)

+ func (c *Counter) Set(n int64)

+ type JWT struct

+ TKExpiresAt string

+ TKUsername string

+ func (j *JWT) CheckExpiresValid(now time.Time, expiresAtI interface{}) (ok bool, err error)

+ func (j *JWT) Generate(expiresAt int64, payload map[string]interface{}) (string, error)

+ func (j *JWT) Setup(secret string)

+ func (j *JWT) Validate(tokenStr string) (payload map[string]interface{}, err error)

+ type LoggerType struct

+ var Logger *LoggerType

+ func (l *LoggerType) DebugSample(sample int, msg string, fields ...zap.Field)

+ func (l *LoggerType) InfoSample(sample int, msg string, fields ...zap.Field)

+ func (l *LoggerType) WarnSample(sample int, msg string, fields ...zap.Field)

+ type Mail struct

+ func NewMail(host string, port int) *Mail

+ func (m *Mail) BuildMessage(msg string) string

+ func (m *Mail) Login(username, password string)

+ func (m *Mail) Send(fr, to, frName, toName, subject, content string) (err error)

+ type MonotonicRotateCounter struct

+ func NewMonotonicCounterFromN(n, rotatePoint int64) (*MonotonicRotateCounter, error)

+ func NewMonotonicRotateCounter(rotatePoint int64) (*MonotonicRotateCounter, error)

+ func (c *MonotonicRotateCounter) Count() (n int64)

+ func (c *MonotonicRotateCounter) CountN(n int64) (r int64)

+ type PairList []SortItemItf

+ func SortBiggest(items PairList) PairList

+ func SortSmallest(items PairList) PairList

+ func (p PairList) Len() int

+ func (p PairList) Less(i, j int) bool

+ func (p PairList) Swap(i, j int)

+ type RequestData struct

+ Data interface{}

+ Headers map[string]string

+ type RotateCounter struct

+ func NewRotateCounter(rotatePoint int64) (*RotateCounter, error)

+ func NewRotateCounterFromN(n, rotatePoint int64) (*RotateCounter, error)

+ func (c *RotateCounter) Count() int64

+ func (c *RotateCounter) CountN(n int64) (r int64)

+ type SettingsConst struct

+ YAML_TYPE string

+ type SettingsType struct

+ func (s *SettingsType) BindPFlags(p *pflag.FlagSet) error

+ func (s *SettingsType) Get(key string) interface{}

+ func (s *SettingsType) GetBool(key string) bool

+ func (s *SettingsType) GetDuration(key string) time.Duration

+ func (s *SettingsType) GetInt(key string) int

+ func (s *SettingsType) GetInt64(key string) int64

+ func (s *SettingsType) GetString(key string) string

+ func (s *SettingsType) GetStringSlice(key string) []string

+ func (s *SettingsType) LoadSettings()

+ func (s *SettingsType) Set(key string, val interface{})

+ func (s *SettingsType) Setup(configPath string) error

+ func (s *SettingsType) SetupFromConfigServer(cfg *ConfigServerCfg) (err error)

+ func (s *SettingsType) SetupFromConfigServerWithRawYaml(cfg *ConfigServerCfg, key string) (err error)

+ func (s *SettingsType) SetupFromDir(dirPath string) error

+ func (s *SettingsType) SetupFromFile(filePath string) error

+ type SortItemItf interface

+ GetKey func() interface{}

+ GetValue func() int

+ type Throttle struct

+ func NewThrottle(cfg *ThrottleCfg) *Throttle

+ func (t *Throttle) Allow() bool

+ func (t *Throttle) Run()

+ func (t *Throttle) Stop()

+ type ThrottleCfg struct

+ Max int

+ NPerSec int

+ type Uint32Counter struct

+ func NewUint32Counter() *Uint32Counter

+ func NewUint32CounterFromN(n uint32) *Uint32Counter

+ func (c *Uint32Counter) Count() uint32

+ func (c *Uint32Counter) CountN(n uint32) uint32

+ func (c *Uint32Counter) Get() uint32

+ func (c *Uint32Counter) Set(n uint32)