utee

README

utee

utilities for golang

Documentation

Index

• Constants
• Variables
• func Chk(err error)
• 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 Md5(b []byte) []byte
• func Md5Str(salt string) func(string) string
• 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 TickToTime(tick int64) time.Time
• func Truncate(s string, n int) string
• func Unique(data []interface{}) []interface{}
• func UniqueInt(data []int) []int
• func UniqueStr(data []string) []string
• type BasicAuth
• type HttpOpt
• type J
• type MemQueue
  • func NewLeakMemQueue(cap, concurrent int, worker func(interface{})) MemQueue
  • func NewMemQueue(cap int) MemQueue
  • 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
• type PerfLog
  • func NewPerfLog(maxMs uint32, logger *logrus.Entry) *PerfLog
  • func (p *PerfLog) Done()
  • func (p *PerfLog) Tick(label interface{})
• type SyncMap
  • 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
  • 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
  • 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{}

Constants

const (
	MAX_HTTP_CLIENT_CONCURRENT = 1000

	ContentTypeForm = "application/x-www-form-urlencoded"
	ContentTypeJson = "application/json; charset=utf-8"
)

Variables

var (
	PlainMd5  = Md5Str("")
	PlainSha1 = Sha1Str("")
)

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

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

Functions

func Chk

func Chk(err error)

func DeleteMap

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

func HmacSha256

func HmacSha256(s string, key string) string

func HttpGet

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

func HttpGet2

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

func HttpPost

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

func HttpPost2

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

func IntToInf

func IntToInf(src []int) []interface{}

func IsPemExpire

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

func Md5

func Md5(b []byte) []byte

func Md5Str

func Md5Str(salt string) func(string) string

func ParseAddr

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

func PrintJson

func PrintJson(any ...interface{})

func SendMail

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

func Sha1Str

func Sha1Str(salt string) func(string) string

func Sha256Str

func Sha256Str(salt string) func(string) string

func Shuffle

func Shuffle(src []string) []string

func SplitSlice

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

split a into several parts, no more than n

func StrToInf

func StrToInf(src []string) []interface{}

func Tick

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

Tick unix timestamp in millisecond

func TickToTime

func TickToTime(tick int64) time.Time

TickToTime convert unix timestamp in millisecond to time at current location

func Truncate

func Truncate(s string, n int) string

Truncate truncate string

func Unique

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

func UniqueInt

func UniqueInt(data []int) []int

func UniqueStr

func UniqueStr(data []string) []string

Types

type BasicAuth

type BasicAuth struct {
	Username string
	Password string
}

type HttpOpt

type HttpOpt struct {
	Headers   map[string]string
	BasicAuth *BasicAuth
}

type J

type J map[string]interface{}

type MemQueue

type MemQueue chan interface{}

MemQueue memory queue

func NewLeakMemQueue

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

NewLeakMemQueue create memory queue, auto-leak element concurrently to worker

func NewMemQueue

func NewMemQueue(cap int) MemQueue

NewMemQueue create memory queue

func (MemQueue) Cap

func (p MemQueue) Cap() int

Cap queue capacity

func (MemQueue) Deq

func (p MemQueue) Deq() interface{}

Deq

func (MemQueue) DeqN

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

DeqN dequeue less than n in a batch

func (MemQueue) Enq

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

Enq enqueue, return error if queue is full

func (MemQueue) EnqBlocking

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

EnqBlocking enqueue, block if queue is full

func (MemQueue) Len

func (p MemQueue) Len() int

Len queue length

type PerfLog

type PerfLog struct {
	sync.Mutex
	// contains filtered or unexported fields
}

性能日志

func NewPerfLog

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

生成PerfLog， maxMs 输出阈值，单位为毫秒

func (*PerfLog) Done

func (p *PerfLog) Done()

func (*PerfLog) Tick

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

type SyncMap

type SyncMap struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*SyncMap) Clear

func (p *SyncMap) Clear()

func (*SyncMap) Get

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

func (*SyncMap) Keys

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

func (*SyncMap) Len

func (p *SyncMap) Len() int

func (*SyncMap) Put

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

func (*SyncMap) Remove

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

type Throttle

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

func NewThrottle

func NewThrottle(max int) *Throttle

func (*Throttle) Acquire

func (p *Throttle) Acquire()

func (*Throttle) Available

func (p *Throttle) Available() int

func (*Throttle) Current

func (p *Throttle) Current() int

func (*Throttle) Release

func (p *Throttle) Release()

type TimerCache

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

func NewTimerCache

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

ttl in second expireCb, expire callback

func (*TimerCache) Get

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

func (*TimerCache) Keys

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

func (*TimerCache) Len

func (p *TimerCache) Len() int

func (*TimerCache) Put

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

func (*TimerCache) Remove

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