hutils

README

hutils

不使用第三方库，不产生额外依赖

为了尽可能减少依赖，一些有用的代码贴在这里

import "golang.org/x/crypto/pbkdf2"

// 密码加密
func EncodePassword(password, salt string) string {
	dk := pbkdf2.Key([]byte(password), []byte(salt), 4096, 32, sha256.New)
	return hex.EncodeToString(dk)
}

Documentation

Index

• Variables
• func AESDecrypt(src []byte, key []byte) ([]byte, error)
• func AESEncrypt(src []byte, key []byte) ([]byte, error)
• func AppendBytes(fpath string, bs []byte) error
• func Clamp[T cmp.Ordered](v, min, max T) T
• func FormatTime(t time.Time) string
• func MD5(s string) string
• func MapToSlice[K comparable, V, T any](m map[K]V, transFunc func(K, V) (T, bool)) []T
• func MapToSliceK[K comparable, V any](m map[K]V) []K
• func MapToSliceV[K comparable, V any](m map[K]V) []V
• func Must(i interface{}, e error) interface{}
• func Now() time.Time
• func RandMapK[K comparable, V any](m map[K]V, n int) []K
• func RandMapV[K comparable, V any](m map[K]V, n int) []V
• func RandSlice[T any](slice []T, n int) []T
• func RandSliceWeightFunc[T any](slice []T, weightFunc func(T) int) T
• func RandSliceWeightFuncN[T any](slice []T, n int, weightFunc func(T) int) []T
• func RandString(n int) string
• func ReadJson(fpath string, i interface{}) error
• func Recover()
• func RecoverF(f func(r interface{}))
• func SliceToMap[K comparable, V, T any](a []V, transFunc func(V) (K, T, bool)) map[K]T
• func SliceToSlice[T, V any](a []T, transFunc func(T) (V, bool)) []V
• func TopMapN[K comparable, V any](m map[K]V, n int, less func(V, V) bool) []V
• func TopSliceN[T any](a []T, n int, less func(T, T) bool) []T
• func WaitExitSignal()
• func WaitTimeoutFunc(timeout time.Duration, f func()) bool
• func WaitUntil(timeout time.Duration, f func() bool) bool
• func WriteBytes(fpath string, data []byte) error
• func WriteJson(fpath string, i interface{}) error
• type Duration
  • func (d *Duration) MarshalJSON() ([]byte, error)
  • func (d *Duration) UnmarshalJSON(b []byte) (err error)
• type MysqlDSNCreator
  • func NewMysqlDSNCreator(user, password, host, port, dbName string) *MysqlDSNCreator
  • func (opts *MysqlDSNCreator) DataSourceName() string
  • func (opts *MysqlDSNCreator) SetCharset(charset string) *MysqlDSNCreator
  • func (opts *MysqlDSNCreator) SetLoc(loc string) *MysqlDSNCreator
  • func (opts *MysqlDSNCreator) SetParseTime(parseTime bool) *MysqlDSNCreator
  • func (opts *MysqlDSNCreator) SetReadTimeout(readTimeout time.Duration) *MysqlDSNCreator
  • func (opts *MysqlDSNCreator) SetTimeout(timeout time.Duration) *MysqlDSNCreator
  • func (opts *MysqlDSNCreator) SetWriteTimeout(writeTimeout time.Duration) *MysqlDSNCreator
• type TimeUtil
  • func NewTimeUtil() *TimeUtil
  • func (t *TimeUtil) Add(duration time.Duration)
  • func (t *TimeUtil) Now() time.Time
  • func (t *TimeUtil) SetDebug(isDebug bool)
  • func (t *TimeUtil) SetNow(now time.Time)
• type WaitTimeout
  • func NewWaitTimeout() *WaitTimeout
  • func (wt *WaitTimeout) Add(n int32) *WaitTimeout
  • func (wt *WaitTimeout) Done()
  • func (wt *WaitTimeout) Wait(timeout time.Duration) chan bool
• type Watcher
  • func NewWatcher() *Watcher
  • func (w *Watcher) Notify()
  • func (w *Watcher) Watch(timeout time.Duration) chan bool

Variables

var (
	DefTimeUtil = NewTimeUtil()
)

Functions

func AESDecrypt

func AESDecrypt(src []byte, key []byte) ([]byte, error)

func AESEncrypt

func AESEncrypt(src []byte, key []byte) ([]byte, error)

func AppendBytes

func AppendBytes(fpath string, bs []byte) error

func Clamp

func Clamp[T cmp.Ordered](v, min, max T) T

func FormatTime

func FormatTime(t time.Time) string

func MD5

func MD5(s string) string

func MapToSlice

func MapToSlice[K comparable, V, T any](m map[K]V, transFunc func(K, V) (T, bool)) []T

func MapToSliceK

func MapToSliceK[K comparable, V any](m map[K]V) []K

func MapToSliceV

func MapToSliceV[K comparable, V any](m map[K]V) []V

func Must

func Must(i interface{}, e error) interface{}

func Now

func Now() time.Time

func RandMapK

func RandMapK[K comparable, V any](m map[K]V, n int) []K

func RandMapV

func RandMapV[K comparable, V any](m map[K]V, n int) []V

func RandSlice

func RandSlice[T any](slice []T, n int) []T

func RandSliceWeightFunc

func RandSliceWeightFunc[T any](slice []T, weightFunc func(T) int) T

func RandSliceWeightFuncN

func RandSliceWeightFuncN[T any](slice []T, n int, weightFunc func(T) int) []T

RandSliceWeightFuncN 根据权重随机选择 n 个元素，权重由 weightFunc 提供，可以重复选择同一个元素

func RandString

func RandString(n int) string

func ReadJson

func ReadJson(fpath string, i interface{}) error

func Recover

func Recover()

func RecoverF

func RecoverF(f func(r interface{}))

func SliceToMap

func SliceToMap[K comparable, V, T any](a []V, transFunc func(V) (K, T, bool)) map[K]T

func SliceToSlice

func SliceToSlice[T, V any](a []T, transFunc func(T) (V, bool)) []V

func TopMapN

func TopMapN[K comparable, V any](m map[K]V, n int, less func(V, V) bool) []V

func TopSliceN

func TopSliceN[T any](a []T, n int, less func(T, T) bool) []T

func WaitExitSignal

func WaitExitSignal()

func WaitTimeoutFunc

func WaitTimeoutFunc(timeout time.Duration, f func()) bool

func WaitUntil

func WaitUntil(timeout time.Duration, f func() bool) bool

func WriteBytes

func WriteBytes(fpath string, data []byte) error

func WriteJson

func WriteJson(fpath string, i interface{}) error

Types

type Duration

type Duration struct {
	time.Duration
}

func (*Duration) MarshalJSON

func (d *Duration) MarshalJSON() ([]byte, error)

func (*Duration) UnmarshalJSON

func (d *Duration) UnmarshalJSON(b []byte) (err error)

type MysqlDSNCreator

type MysqlDSNCreator struct {
	// contains filtered or unexported fields
}

func NewMysqlDSNCreator

func NewMysqlDSNCreator(user, password, host, port, dbName string) *MysqlDSNCreator

func (*MysqlDSNCreator) DataSourceName

func (opts *MysqlDSNCreator) DataSourceName() string

func (*MysqlDSNCreator) SetCharset

func (opts *MysqlDSNCreator) SetCharset(charset string) *MysqlDSNCreator

func (*MysqlDSNCreator) SetLoc

func (opts *MysqlDSNCreator) SetLoc(loc string) *MysqlDSNCreator

func (*MysqlDSNCreator) SetParseTime

func (opts *MysqlDSNCreator) SetParseTime(parseTime bool) *MysqlDSNCreator

func (*MysqlDSNCreator) SetReadTimeout

func (opts *MysqlDSNCreator) SetReadTimeout(readTimeout time.Duration) *MysqlDSNCreator

func (*MysqlDSNCreator) SetTimeout

func (opts *MysqlDSNCreator) SetTimeout(timeout time.Duration) *MysqlDSNCreator

func (*MysqlDSNCreator) SetWriteTimeout

func (opts *MysqlDSNCreator) SetWriteTimeout(writeTimeout time.Duration) *MysqlDSNCreator

type TimeUtil

type TimeUtil struct {
	// contains filtered or unexported fields
}

时间工具，在测试中，很多时候需要控制 time.Now() 产生的时间 例如：设置当前时间为 3天 后，用正常时间的 1/10 行进时间

func NewTimeUtil

func NewTimeUtil() *TimeUtil

func (*TimeUtil) Add

func (t *TimeUtil) Add(duration time.Duration)

func (*TimeUtil) Now

func (t *TimeUtil) Now() time.Time

func (*TimeUtil) SetDebug

func (t *TimeUtil) SetDebug(isDebug bool)

func (*TimeUtil) SetNow

func (t *TimeUtil) SetNow(now time.Time)

type WaitTimeout

type WaitTimeout struct {
	// contains filtered or unexported fields
}

WaitTimeout 带有超时的 WaitGroup，避免了 wg.Wait() 可能引起的 blocked forever，协程永远无法被释放

func NewWaitTimeout

func NewWaitTimeout() *WaitTimeout

NewWaitTimeout 必须使用 NewWaitTimeout 实例化 WaitTimeout

func (*WaitTimeout) Add

func (wt *WaitTimeout) Add(n int32) *WaitTimeout

func (*WaitTimeout) Done

func (wt *WaitTimeout) Done()

func (*WaitTimeout) Wait

func (wt *WaitTimeout) Wait(timeout time.Duration) chan bool

Wait, 等待过程外置，外部使用时，可以先获取 chan, 在释放完可能存在的锁后，进入 <-chan 环节，避免等待时间内持有锁 一个 WaitTimeout 只能使用一次，wt.Done() 后会 close(wt.doneChan)，再次 wt.Done() 会触发 panic

type Watcher

type Watcher struct {
	// contains filtered or unexported fields
}

func NewWatcher

func NewWatcher() *Watcher

func (*Watcher) Notify

func (w *Watcher) Notify()

func (*Watcher) Watch

func (w *Watcher) Watch(timeout time.Duration) chan bool