utee

Jan 18, 2024

Changes in this version

+ func TimeBetween(check, start, end time.Time) bool

Oct 18, 2023

Changes in this version

+ func FinishWithGen(concurrent int, gen func(source chan<- func() error)) error

Oct 18, 2023

Changes in this version

+ func Finish(concurrent int, fn ...func() error) error

Jul 6, 2023

Changes in this version

+ func SplitSliceIntoN(a []T, n int) [][]T

Jun 28, 2023

Changes in this version

+ func Zip(pathToZip string, dest io.Writer) error

May 20, 2023

Changes in this version

+ func PasswdHash(password string, cost ...int) (string, error)

+ func VerifyPasswd(password, hash string) bool

Nov 28, 2022

Changes in this version

type Throttle

+ func (p *Throttle) Wait()

Jul 7, 2022

Changes in this version

+ type SyncMap2 struct

+ func (p *SyncMap2[K, V]) Clear()

+ func (p *SyncMap2[K, V]) Get(key K) (V, bool)

+ func (p *SyncMap2[K, V]) Keys() []K

+ func (p *SyncMap2[K, V]) Len() int

+ func (p *SyncMap2[K, V]) Put(key K, val V)

+ func (p *SyncMap2[K, V]) Remove(key K)

+ type TimerCache2 struct

+ func NewTimerCache2(ttl int, expireCb ...func(key K, value V)) *TimerCache2[K, V]

+ func (p *TimerCache2[K, V]) Get(key K) (V, bool)

+ func (p *TimerCache2[K, V]) Keys() []K

+ func (p *TimerCache2[K, V]) Len() int

+ func (p *TimerCache2[K, V]) Put(key K, val V) bool

+ func (p *TimerCache2[K, V]) Remove(key K) (V, bool)

+ func (p *TimerCache2[K, V]) TTL(key K) (int64, bool)

Jun 15, 2022

Changes in this version

+ func Filter(collection []T, fn func(T) bool) []T

+ func FilterMap(collection []T, fn func(T) (R, bool)) []R

+ func FlatMap(collection []T, fn func(T) []R) []R

+ func Map(collection []T, fn func(T) R) []R

+ func OrderBy(l []T, fn func(T) R) []T

+ func OrderByDescending(l []T, fn func(T) R) []T

+ func Reject(collection []T, fn func(T) bool) []T

+ func Sum(l []T) T

Jun 30, 2021

Changes in this version

+ func Max(n ...int) int

+ func Min(n ...int) int

May 31, 2021

Changes in this version

type Tick

+ func (p Tick) Value() int64

Apr 10, 2021

Changes in this version

+ func SplitIntSlice(src []int, chunkSize int) [][]int

+ func SplitStringSlice(src []string, chunkSize int) [][]string

+ func SplitStringSliceIntoN(a []string, n int) [][]string

Dec 26, 2020

Changes in this version

+ func SetHttpClient(hc *http.Client)

Dec 23, 2020

Changes in this version

type TimerCache

+ func (p *TimerCache) TTL(key interface{}) int64

Dec 16, 2020

Changes in this version

type J

+ func (p J) ToReader() io.Reader

+ func (p J) ToString() string

Dec 16, 2020

Changes in this version

type Tick

+ func (p Tick) CompareTo(b Tick) int

Dec 16, 2020

Changes in this version

+ func MultiDeleteFromMap(m map[string]interface{}, ks ...string)

type Tick

+ func NewTick(t ...time.Time) Tick

+ func (p Tick) ToTime() time.Time

Aug 18, 2020

Changes in this version

+ func TickToTime(tick int64) time.Time

Dec 2, 2019

Changes in this version

+ func Unique(data []interface{}) []interface

+ func UniqueInt(data []int) []int

+ func UniqueStr(data []string) []string

Dec 2, 2019

Changes in this version

+ const ContentTypeForm

+ const ContentTypeJson

+ const MAX_HTTP_CLIENT_CONCURRENT

+ var ErrEmptyHeaderName = errors.New("header name must not be empty")

+ var ErrFull = errors.New("queue is full")

+ var PlainMd5 = Md5Str("")

+ var PlainSha1 = Sha1Str("")

+ func Chk(err error)

+ func CleanURI(s string) string

+ func DeleteMap(m map[string]interface{}, ks ...string)

+ func HmacSha256(s string, key string) string

+ func HttpGet(getUrl string, credential ...string) ([]byte, error)

+ func HttpGet2(getUrl string, contentType string, opt *HttpOpt) ([]byte, error)

+ func HttpPost(postUrl string, q url.Values, credential ...string) ([]byte, error)

+ func HttpPost2(postUrl string, contentType string, body io.Reader, opt *HttpOpt) ([]byte, error)

+ func IntToInf(src []int) []interface

+ func IsPemExpire(b []byte) (bool, error)

+ func Log(err error, prefix ...string)

+ func Md5(b []byte) []byte

+ func Md5Str(salt string) func(string) string

+ func Millis(fmt string, timeStr string) (int64, error)

+ func ParseAddr(s string) (string, int, error)

+ func PrintJson(any ...interface{})

+ func SendMail(user, password, host, to, subject, body, mailtype string) error

+ func Sha1Str(salt string) func(string) string

+ func Sha256Str(salt string) func(string) string

+ func Shuffle(src []string) []string

+ func SplitSlice(a []string, n int) [][]string

+ func StrToInf(src []string) []interface

+ func Tick(t ...time.Time) int64

+ func TickHour() int64

+ func TickSec() int64

+ func Truncate(s string, n int) string

+ type Ast struct

+ Path string

+ Result interface{}

+ Tp string

+ type BasicAuth struct

+ Password string

+ Username string

+ type HttpOpt struct

+ BasicAuth *BasicAuth

+ Headers map[string]string

+ type HttpTestCase struct

+ BasicAuthFunc func(*HttpTestCase) (string, string)

+ Body interface{}

+ ContentType string

+ EndPoint string

+ Method string

+ Name string

+ Res interface{}

+ Status int

+ func (p HttpTestCase) BuildRequest() *http.Request

+ func (p HttpTestCase) Exec(handler http.Handler, t *testing.T)

+ func (p HttpTestCase) GetBody() io.Reader

+ func (p HttpTestCase) GetContentType() string

+ func (p HttpTestCase) GetEndPoint() string

+ func (p HttpTestCase) GetMethod() string

+ type HttpTestSuite struct

+ CaseList []HttpTestCase

+ Name string

+ func (p HttpTestSuite) Exec(handler http.Handler, t *testing.T)

+ type J map[string]interface

+ type MemQueue chan interface

+ func (p MemQueue) Cap() int

+ func (p MemQueue) Deq() interface{}

+ func (p MemQueue) DeqN(n int) []interface{}

+ func (p MemQueue) Enq(data interface{}) error

+ func (p MemQueue) EnqBlocking(data interface{})

+ func (p MemQueue) Len() int

+ func NewLeakMemQueue(cap, concurrent int, worker func(interface{})) MemQueue

+ func NewMemQueue(cap int) MemQueue

+ type PerfLog struct

+ func NewPerfLog(maxMs uint32, logger *logrus.Entry) *PerfLog

+ func (p *PerfLog) Done()

+ func (p *PerfLog) Tick(label interface{})

+ type SyncMap struct

+ func (p *SyncMap) Clear()

+ func (p *SyncMap) Get(key interface{}) (interface{}, bool)

+ func (p *SyncMap) Keys() []interface{}

+ func (p *SyncMap) Len() int

+ func (p *SyncMap) Put(key, val interface{})

+ func (p *SyncMap) Remove(key interface{})

+ type Throttle struct

+ func NewThrottle(max int) *Throttle

+ func (p *Throttle) Acquire()

+ func (p *Throttle) Available() int

+ func (p *Throttle) Current() int

+ func (p *Throttle) Release()

+ type TimerCache struct

+ func NewTimerCache(ttl int, expireCb func(key, value interface{})) *TimerCache

+ func (p *TimerCache) Get(key interface{}) interface{}

+ func (p *TimerCache) Keys() []interface{}

+ func (p *TimerCache) Len() int

+ func (p *TimerCache) Put(key, val interface{}) bool

+ func (p *TimerCache) Remove(key interface{}) interface{}