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 AppendBytes(fpath string, bs []byte) error
• func FormatTime(t time.Time) string
• func InitRandSeed()
• func MD5(s string) string
• func Must(i interface{}, e error) interface{}
• func NewDataSourceName(user, password, host, port, dbName string) string
• func Now() time.Time
• func RandString(n int) string
• func ReadJson(fpath string, i interface{}) error
• func Recover()
• func WaitTimeoutFunc(timeout time.Duration, f func()) bool
• func WriteBytes(fpath string, data []byte) error
• func WriteJson(fpath string, i interface{}) error
• 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 AppendBytes

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

func FormatTime

func FormatTime(t time.Time) string

func InitRandSeed

func InitRandSeed()

func MD5

func MD5(s string) string

func Must

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

func NewDataSourceName

func NewDataSourceName(user, password, host, port, dbName string) string

func Now

func Now() time.Time

func RandString

func RandString(n int) string

func ReadJson

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

func Recover

func Recover()

func WaitTimeoutFunc

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

func WriteBytes

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

func WriteJson

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

Types

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