utils

package module

Go to main page

Versions in this module

v2

v2.3.0

Jan 19, 2023

Changes in this version

+ func CostSecs(cost time.Duration) string

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

+ func IsEmpty(val any) bool

+ func NotEmpty(val any, name string) error

+ func OptionalVal(ptr *T, optionalVal T) T

+ func Pipeline(funcs []func(T) error, v T) (T, error)

+ func RenderTemplate(tplContent string, args any) ([]byte, error)

+ func RenderTemplateFile(tplFile string, args any) ([]byte, error)

+ func RunCMDWithEnv(ctx context.Context, app string, args []string, envs []string) (stdout []byte, err error)

+ type ClockT struct

+ func (c *ClockT) Close()

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

+ func (c *ClockT) GetNanoTimeInHex() string

+ func (c *ClockT) GetTimeInHex() string

+ func (c *ClockT) GetTimeInRFC3339Nano() string

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

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

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

+ type CopyFileOptionFunc func(o *copyFileOption) error

+ func Overwrite() CopyFileOptionFunc

+ func WithFileFlag(flag int) CopyFileOptionFunc

+ func WithFileMode(perm fs.FileMode) CopyFileOptionFunc

+ type GoroutineTest struct

+ func NewGoroutineTest(t testing.TB, cancel func()) *GoroutineTest

+ func (t *GoroutineTest) FailNow()

+ type ListFilesInDirOptionFunc func(*listFilesInDirOption) error

+ func Recursive() ListFilesInDirOptionFunc

v2.2.0

Nov 8, 2022

Changes in this version

+ func RaceErr(gs ...func() error) (err error)

+ func RaceErrWithCtx(ctx context.Context, gs ...func(context.Context) error) (err error)

+ func RandomBytesWithLength(n int) ([]byte, error)

+ func SecRandomBytesWithLength(n int) ([]byte, error)

+ func SilentClose(v interface{ ... })

+ func SilentFlush(v interface{ ... })

+ type RBACPermFullKey string

+ func (p RBACPermFullKey) Append(key RBACPermKey) RBACPermFullKey

+ func (p RBACPermFullKey) Contains(acquire RBACPermFullKey) bool

+ func (p RBACPermFullKey) Parent() RBACPermFullKey

+ func (p RBACPermFullKey) String() string

+ type RBACPermKey string

+ func (p RBACPermKey) String() string

+ type RBACPermissionElem struct

+ Children []*RBACPermissionElem

+ FullKey RBACPermFullKey

+ Key RBACPermKey

+ Title string

+ func NewPermissionTree() *RBACPermissionElem

+ func (p *RBACPermissionElem) Clone() *RBACPermissionElem

+ func (p *RBACPermissionElem) Cut(key RBACPermFullKey)

+ func (p *RBACPermissionElem) FillDefault(ancesterKey RBACPermFullKey) error

+ func (p *RBACPermissionElem) GetElemByKey(key RBACPermFullKey) *RBACPermissionElem

+ func (p *RBACPermissionElem) HasPerm(acquiredKey RBACPermFullKey) bool

+ func (p *RBACPermissionElem) Intersection(other *RBACPermissionElem)

+ func (p *RBACPermissionElem) OverwriteBy(another *RBACPermissionElem, intersection bool)

+ func (p *RBACPermissionElem) Scan(input interface{}) error

+ func (p *RBACPermissionElem) UnionAndOverwriteBy(other *RBACPermissionElem)

+ func (p *RBACPermissionElem) Valid() error

+ func (p RBACPermissionElem) Value() (driver.Value, error)

v2.1.2

Aug 31, 2022

Changes in this version

+ func FileSHA1(path string) (hashed string, err error)

+ func WatchFileChangingByMtime(ctx context.Context, files []string, callback func(fsnotify.Event)) error

v2.1.1

Aug 31, 2022

Changes in this version

+ func FileMD5(path string) (hashed string, err error)

+ func IsFileATimeChanged(path string, expectATime time.Time) (changed bool, newATime time.Time, err error)

+ func WatchFileChangingByNotify(ctx context.Context, files []string, callback func(fsnotify.Event)) error

v2.1.0

Aug 18, 2022

v2.0.4

Jul 18, 2022

Changes in this version

+ func PrettyBuildInfo() string

type ClockItf

+ GetDate func() (time.Time, error)

+ GetNanoTimeInHex func() string

+ GetTimeInHex func() string

+ SetInterval func(interval time.Duration)

v2.0.3

Jul 16, 2022

v2.0.2

Jul 16, 2022

Changes in this version

+ func EmptyAllChans(chans ...chan T)

+ func IntersectSortedChans(chans ...chan T) (result chan T, err error)

+ func Max(collection []T) T

+ func Min(collection []T) T

+ func WatchFileChanging(ctx context.Context, files []string, callback func(fsnotify.Event)) error

+ type Number interface

+ type Sortable interface

v2.0.1

Jun 29, 2022

Changes in this version

+ func Contains(collection []V, ele V) bool

v2.0.0

Mar 21, 2022

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

+ const BaseHex

+ const BitSize64

+ const HTTPHeaderContentType

+ const HTTPHeaderContentTypeValJSON

+ const HTTPHeaderHost

+ const HTTPHeaderReferer

+ const LoggerEncodingConsole

+ const LoggerEncodingJSON

+ const LoggerLevelDebug

+ const LoggerLevelError

+ const LoggerLevelFatal

+ const LoggerLevelInfo

+ const LoggerLevelPanic

+ const LoggerLevelWarn

+ const Nano2Sec

+ const SampleRateDenominator

+ const TimeFormatDate

+ var Clock = NewClock(context.Background(), defaultClockInterval)

+ var Clock2 = Clock

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

+ var ForceGC = ForceGCBlocking

+ var JSON = json

+ var NewClock2 = NewClock

+ var ParseTs2String = ParseUnix2String

+ var ParseTs2Time = ParseTs2UTC

+ var ParseTs2UTC = ParseUnix2UTC

+ var Settings = NewSettings()

+ var SignMethodES256 = jwt.SigningMethodES256

+ var SignMethodHS256 = jwt.SigningMethodHS256

+ var SignMethodRS256 = jwt.SigningMethodRS256

+ var TimeZoneShanghai *time.Location

+ var TimeZoneUTC = time.UTC

+ var TriggerGC = ForceGCUnBlocking

+ var UnixNano2UTC = ParseUnixNano2UTC

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

+ func AbsInt32(v int32) int32

+ func AbsInt64(v int64) int64

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

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

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

+ func Base64Encode(raw []byte) string

+ func Bytes2Str(b []byte) string

+ func CheckResp(resp *http.Response) error

+ func CloseQuietly(v io.Closer)

+ func Color(color int, s string) string

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func ForceGCBlocking()

+ func ForceGCUnBlocking()

+ func FormatBig2Base64(b *big.Int) string

+ func FormatBig2Hex(b *big.Int) string

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

+ func GetFuncName(f interface{}) string

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

+ func GracefulCancel(cancel func())

+ func HTTPInvalidStatusError(statusCode int) error

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

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

+ func HashSHA128String(val string) string

+ func HashSHA256String(val string) string

+ func HashXxhashString(val string) string

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

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

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

+ func IsDirWritable(dir string) (err error)

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

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

+ func IsPtr(t interface{}) bool

+ func IsRemoteUDPPortOpen(addr string) error

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

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

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

+ func MaxInt(a, b int) int

+ func MinInt(a, b int) int

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

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

+ func NewRand() *rand.Rand

+ func NewSkiplist() *skiplist.SkipList

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

+ func NilInterface(data interface{}) bool

+ func PanicIfErr(err error)

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

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

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

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

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

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

+ func ParseUnix2String(ts int64, layout string) string

+ func ParseUnix2UTC(ts int64) time.Time

+ func ParseUnixNano2UTC(ts int64) time.Time

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

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

+ func RandomStringWithLength(n int) string

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

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

+ 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, d int) float64

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

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

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

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

+ func SetInternalClock(interval time.Duration)

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

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

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

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

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

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

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

+ func Str2Bytes(s string) []byte

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

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

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

+ func URLMasking(url, mask string) string

+ func UTCNow() time.Time

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

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

+ func ValidateFileHash(filepath string, hashed string) error

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

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

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

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

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

+ func ZipFiles(output string, files []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 AlertHookOptFunc func(*alertHookOption)

+ func WithAlertHookLevel(level zapcore.Level) AlertHookOptFunc

+ func WithAlertPushTimeout(timeout time.Duration) AlertHookOptFunc

+ type AlertPusher struct

+ func NewAlertPusher(ctx context.Context, pushAPI string, opts ...AlertHookOptFunc) (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) GetZapHook() func(zapcore.Entry, []zapcore.Field) (err error)

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

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

+ type AsyncTask interface

+ ID func() string

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

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

+ Status func() AsyncTaskStatus

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

+ type AsyncTaskResult struct

+ Data string

+ Err string

+ Status AsyncTaskStatus

+ TaskID string

+ type AsyncTaskStatus string

+ const AsyncTaskStatusDone

+ const AsyncTaskStatusFailed

+ const AsyncTaskStatusPending

+ func (s AsyncTaskStatus) String() string

+ type AsyncTaskStore interface

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

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

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

+ type AtomicFieldBool struct

+ func (a *AtomicFieldBool) SetFalse()

+ func (a *AtomicFieldBool) SetTrue()

+ func (a *AtomicFieldBool) True() bool

+ type ChildParallelCounter struct

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

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

+ func (c *ChildParallelCounter) Get() int64

+ type Clock2Type ClockType

+ type ClockItf interface

+ Close func()

+ GetTimeInRFC3339Nano func() string

+ GetUTCNow func() time.Time

+ Interval func() time.Duration

+ SetupInterval func(time.Duration)

+ type ClockType struct

+ func NewClock(ctx context.Context, refreshInterval time.Duration) *ClockType

+ func (c *ClockType) Close()

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

+ func (c *ClockType) GetNanoTimeInHex() string

+ func (c *ClockType) GetTimeInHex() string

+ func (c *ClockType) GetTimeInRFC3339Nano() string

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

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

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

+ type CompressOptFunc func(*compressOption) error

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

+ Label string

+ Name string

+ Profiles []string

+ Sources []*ConfigSource

+ Version string

+ type ConfigSource struct

+ Name string

+ Source map[string]interface{}

+ type ConfigSrv struct

+ RemoteCfg *Config

+ func NewConfigSrv(url, app, profile, label string) *ConfigSrv

+ func (c *ConfigSrv) Fetch() error

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

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

+ func (c *ConfigSrv) GetInt(name string) (val int, ok 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 CtxKeyT struct

+ type DedentOptFunc func(opt *dedentOpt)

+ func WithReplaceTabBySpaces(spaces int) DedentOptFunc

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

+ func NewExpCache(ctx context.Context, ttl time.Duration) *ExpCache

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

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

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

+ type ExpiredRLock struct

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

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

+ type FIFO struct

+ func NewFIFO() *FIFO

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

+ func (f *FIFO) Len() int

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

+ type FLock interface — darwin/amd64, js/wasm, linux/amd64

+ Lock func() error

+ Unlock func() error

+ func NewFlock(lockFilePath string) FLock

+ type GZCompressor struct

+ func NewGZCompressor(writer io.Writer, opts ...CompressOptFunc) (c *GZCompressor, err error)

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

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

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

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

+ type GcOptFunc func(*gcOption) error

+ func WithGCMemLimitFilePath(path string) GcOptFunc

+ func WithGCMemRatio(ratio int) GcOptFunc

+ type HTTPClientOptFunc func(*httpClientOption) error

+ func WithHTTPClientInsecure() HTTPClientOptFunc

+ func WithHTTPClientMaxConn(maxConn int) HTTPClientOptFunc

+ func WithHTTPClientTimeout(timeout time.Duration) HTTPClientOptFunc

+ 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 Int64CounterItf interface

+ Count func() int64

+ CountN func(n int64) int64

+ type JWT struct

+ func NewJWT(opts ...JWTOptFunc) (e *JWT, err error)

+ 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) ParseClaimsByRS256(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(*JWT) error

+ func WithJWTPriKeyByte(prikey []byte) JWTOptFunc

+ func WithJWTPubKeyByte(pubkey []byte) JWTOptFunc

+ func WithJWTSecretByte(secret []byte) JWTOptFunc

+ func WithJWTSignMethod(method jwt.SigningMethod) JWTOptFunc

+ 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 LoggerEncoding string

+ 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

+ var Logger LoggerItf

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

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

+ func NewLogger(optfs ...LoggerOptFunc) (l LoggerItf, err error)

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

+ type LoggerOptFunc func(l *loggerOption) error

+ func WithLoggerEncoding(format LoggerEncoding) LoggerOptFunc

+ func WithLoggerErrorOutputPaths(paths []string) LoggerOptFunc

+ func WithLoggerLevel(level string) LoggerOptFunc

+ func WithLoggerName(name string) LoggerOptFunc

+ func WithLoggerOutputPaths(paths []string) LoggerOptFunc

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

+ type LoggerType struct

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

+ func (l *LoggerType) Clone() LoggerItf

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

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

+ func (l *LoggerType) Level() zapcore.Level

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

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

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

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

+ 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(frAddr, toAddr, frName, toName, subject, content string, ...) (err error)

+ type MailSendOptFunc func(*mailSendOpt)

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

+ type Mutex struct

+ func NewMutex() *Mutex

+ func (m *Mutex) ForceRelease()

+ func (m *Mutex) IsLocked() bool

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

+ func (m *Mutex) TryLock() bool

+ func (m *Mutex) TryRelease() bool

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

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

+ 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 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 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) Count() int64

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

+ func (c *RotateCounter) Get() int64

+ type SettingsEncryptOptf func(*settingsAESEncryptOpt) error

+ func AESEncryptFilesInDirFileExt(ext string) SettingsEncryptOptf

+ func AESEncryptFilesInDirFileSuffix(suffix string) SettingsEncryptOptf

+ type SettingsOptFunc func(*settingsOpt) error

+ func WithSettingsAesEncrypt(key []byte) SettingsOptFunc

+ func WithSettingsEnableInclude() SettingsOptFunc

+ func WithSettingsEncryptedFileSuffix(suffix string) SettingsOptFunc

+ type SettingsType struct

+ func NewSettings() *SettingsType

+ 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) GetStringMap(key string) map[string]interface{}

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

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

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

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

+ func (s *SettingsType) LoadSettings()

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

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

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

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

+ type SortItemItf interface

+ GetData func() interface{}

+ GetValue func() int

+ type StopSignalOptFunc func(*stopSignalOpt)

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

+ type Throttle struct

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

+ func (t *Throttle) Allow() bool

+ func (t *Throttle) Close()

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

Other modules containing this package

github.com/Laisky/go-utils

github.com/Laisky/go-utils/v3

github.com/Laisky/go-utils/v4

github.com/Laisky/go-utils/v5

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL