utils

package module

Go to main page

Versions in this module

v3

v3.5.0

Mar 1, 2023

Changes in this version

+ func UUID1() string

v3.4.0

Feb 8, 2023

Changes in this version

+ var DecodeByHex = hex.DecodeString

+ var EncodeByHex = hex.EncodeToString

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

+ func EncodeByBase64(raw []byte) string

+ func ReplaceFile(path string, content []byte, perm os.FileMode) error

+ func ReplaceFileStream(path string, in io.ReadCloser, perm os.FileMode) error

+ type AsyncTaskInterface 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

type AsyncTaskStatus

+ const AsyncTaskStatusUnspecified

+ type AsyncTaskStoreInterface interface

+ Delete func(ctx context.Context, taskID string) (err error)

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

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

+ func NewAsyncTaskStoreMemory() *AsyncTaskStoreMemory

+ func (s *AsyncTaskStoreMemory) Delete(ctx context.Context, taskID string) (err error)

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

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

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

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

v3.3.2

Jan 30, 2023

Changes in this version

+ func Wrap(err error, msg string) error

v3.3.1

Jan 29, 2023

v3.3.0

Jan 29, 2023

Changes in this version

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

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

type ExpCache

+ func (c *ExpCache[T]) LoadAndDelete(key string) (data T, ok bool)

+ type ExpCacheInterface interface

+ Delete func(key string)

+ Load func(key string) (data T, ok bool)

+ LoadAndDelete func(key string) (data T, ok bool)

+ Store func(key string, val T)

v3.2.0

Jan 17, 2023

Changes in this version

+ func CostSecs(cost time.Duration) string

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

v3.1.4

Jan 8, 2023

Changes in this version

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

v3.1.3

Jan 6, 2023

v3.1.2

Jan 6, 2023

Changes in this version

+ func IsEmpty(val any) bool

+ func NotEmpty(val any, name string) error

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

+ type CopyFileOptionFunc func(o *copyFileOption) error

+ func Overwrite() CopyFileOptionFunc

+ type ListFilesInDirOptionFunc func(*listFilesInDirOption) error

+ func Recursive() ListFilesInDirOptionFunc

v3.1.1

Dec 31, 2022

Changes in this version

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

+ type CopyFilOptionFunc func(o *copyFileOption) error

+ func WithFileFlag(flag int) CopyFilOptionFunc

+ func WithFileMode(perm fs.FileMode) CopyFilOptionFunc

v3.1.0

Nov 29, 2022

Changes in this version

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

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

+ func (t *GoroutineTest) FailNow()

v3.0.1

Nov 8, 2022

v3.0.0

Nov 8, 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 Nano2Sec

+ const TimeFormatDate

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

+ var CloseQuietly = SilentClose

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

+ var ForceGC = ForceGCBlocking

+ var JSON = json

+ var ParseTs2String = ParseUnix2String

+ var ParseTs2Time = ParseTs2UTC

+ var ParseTs2UTC = ParseUnix2UTC

+ var TimeZoneShanghai *time.Location

+ var TimeZoneUTC = time.UTC

+ var TriggerGC = ForceGCUnBlocking

+ var UnixNano2UTC = ParseUnixNano2UTC

+ func AbsInt32(v int32) int32

+ func AbsInt64(v int64) int64

+ 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 Color(color int, s string) string

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

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

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

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

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

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

+ func EmptyAllChans(chans ...chan T)

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

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

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

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

+ func ForceGCBlocking()

+ func ForceGCUnBlocking()

+ 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 HumanReadableByteCount(bytes int64, si bool) (ret string)

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

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

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

+ func IsDirWritable(dir string) (err error)

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

+ func IsFileATimeChanged(path string, expectATime time.Time) (changed bool, newATime time.Time, err 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 Max(vals ...T) T

+ func Min(vals ...T) T

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

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

+ func NewRand() *rand.Rand

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

+ func NilInterface(data interface{}) bool

+ func PanicIfErr(err error)

+ 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

+ func PrettyBuildInfo() string

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

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

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

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

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

+ 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 SecRandomBytesWithLength(n int) ([]byte, error)

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

+ func SetInternalClock(interval time.Duration)

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

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

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

+ 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 ValidateFileHash(filepath string, hashed string) error

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

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

+ func WatchFileChangingByNotify(ctx context.Context, files []string, callback func(fsnotify.Event)) 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 ClockItf interface

+ Close func()

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

+ GetNanoTimeInHex func() string

+ GetTimeInHex func() string

+ GetTimeInRFC3339Nano func() string

+ GetUTCNow func() time.Time

+ Interval func() time.Duration

+ SetInterval func(interval time.Duration)

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

+ type CtxKeyT struct

+ type DedentOptFunc func(opt *dedentOpt)

+ func WithReplaceTabBySpaces(spaces int) DedentOptFunc

+ 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 FLock interface — darwin/amd64, js/wasm, linux/amd64

+ Lock func() error

+ Unlock func() error

+ func NewFlock(lockFilePath string) FLock

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

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

+ type RequestData struct

+ Data interface{}

+ Headers map[string]string

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

+ 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

Other modules containing this package

github.com/Laisky/go-utils

github.com/Laisky/go-utils/v2

github.com/Laisky/go-utils/v4

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