Versions in this module Expand all Collapse all v1 v1.5.5 May 18, 2020 Changes in this version + var JSONTool = jsoniter.Config{UseNumber: true}.Froze() + func BatchFullOrTimeout(runnerName string, stopped *int32, batchLen, batchSize int64, ...) bool + func CheckNotExistFile(runnerName string, expireMap map[string]int64) + func DeepCopyByGob(dst, src interface{}) + func DeepCopyByJSON(dst, src interface{}) + func GetFiles(runnerName, dirPath string) (map[string]string, error) + func GetParseTestData(line string, size int) []string + func IsDir(path string) bool + func IsExist(path string) bool + func IsGzipped(data []byte) bool + func MongoDail(host string, mode string, syncTimeoutInS int64) (session *mgo.Session, err error) + func SetMode(s *mgo.Session, modeFriendly string, refresh bool) + func UpdateExpireMap(runnerName string, fileMap map[string]string, expireMap map[string]int64) + func WriteZipToFile(zipf *zip.File, filename string) error + type Backoff struct + func NewBackoff(factor, threshold float64, min, max time.Duration) *Backoff + func (b *Backoff) Attempt() float64 + func (b *Backoff) Duration() time.Duration + func (b *Backoff) ForAttempt(attempt float64) time.Duration + func (b *Backoff) Reset() + type Collection struct + func (c Collection) CloseSession() (err error) + type MongoConfig struct + DB string + Direct bool + Host string + Mode string + SyncTimeoutInS int64 + type Stage struct + Duration time.Duration + Note string + type Tracker struct + Stages []Stage + Start time.Time + func NewTracker() *Tracker + func (t *Tracker) Print() string + func (t *Tracker) Reset() + func (t *Tracker) Track(stage string)
Go to main page