utils

May 18, 2020

Changes in this version

+ func IsDir(path string) bool

+ 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()

Aug 20, 2019

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 IsGzipped(data []byte) bool

+ func UpdateExpireMap(runnerName string, fileMap map[string]string, expireMap map[string]int64)

+ func WriteZipToFile(zipf *zip.File, filename string) error

+ 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)

Sep 4, 2018

Changes in this version

+ func GetParseTestData(line string, size int) []string

Jul 30, 2018

Changes in this version

+ func IsExist(path string) bool

Mar 5, 2018

Changes in this version

+ func CheckFileMode(path string, fileMode os.FileMode) error

+ func Hash(s string) string

Jan 4, 2018

Changes in this version

+ func DecompressGzip(packPath, dstDir string) (packDir string, err error)

+ func DecompressZip(packFilePath, dstDir string) (packDir string, err error)

+ func IsJsonString(s string) bool

Dec 7, 2017

Changes in this version

+ const ErrClusterConfig

+ const ErrTransformTransform

+ const KeyCore

+ const KeyHostName

+ const KeyLocalIp

+ const KeyOsInfo

+ func DeleteMapValue(m map[string]interface{}, keys ...string) (interface{}, bool)

+ func GetKeys(keyStr string) []string

+ func GetMapValue(m map[string]interface{}, keys ...string) (interface{}, error)

+ func LogDirAndPattern(logpath string) (dir, pattern string, err error)

+ func SetMapValue(m map[string]interface{}, val interface{}, coercive bool, keys ...string) error

+ type SchemaErr struct

+ Last time.Time

+ Number int64

+ func (s *SchemaErr) Output(count int64, err error)

Nov 27, 2017

Changes in this version

+ const ErrClusterConfigs

+ const ErrClusterRegister

+ const ErrClusterRunnerAdd

+ const ErrClusterRunnerDelete

+ const ErrClusterRunnerReset

+ const ErrClusterRunnerStart

+ const ErrClusterRunnerStop

+ const ErrClusterRunnerUpdate

+ const ErrClusterSlaves

+ const ErrClusterSlavesDelete

+ const ErrClusterSlavesTag

+ const ErrClusterStatus

+ const ErrClusterTag

+ const ErrConfigName

+ const ErrNothing

+ const ErrParseParse

+ const ErrRunnerAdd

+ const ErrRunnerDelete

+ const ErrRunnerReset

+ const ErrRunnerStart

+ const ErrRunnerStop

+ const ErrRunnerUpdate

+ var ErrorCodeHumanize = map[string]string

+ func GetExtraInfo() map[string]string

+ type HashSet struct

+ func NewHashSet() *HashSet

+ func (s *HashSet) Add(ele interface{})

+ func (s *HashSet) AddStringArray(ele []string)

+ func (s *HashSet) Clear()

+ func (s *HashSet) Elements() []interface{}

+ func (s *HashSet) IsEmpty() bool

+ func (s *HashSet) IsIn(ele interface{}) bool

+ func (s *HashSet) Len() int

+ func (s *HashSet) Remove(ele interface{})

Nov 22, 2017

Changes in this version

+ func AddHttpProtocal(url string) string

+ func ExtractField(slice []string) (s []string, err error)

+ func GetLocalIP() (string, error)

+ func RemoveHttpProtocal(url string) (hostport, schema string)

Oct 10, 2017

Changes in this version

+ func IsJSON(str string) bool

Sep 27, 2017

Changes in this version

+ type OSInfo struct

+ Core string

+ Hostname string

+ Kernel string

+ OS string

+ Platform string

+ func GetOSInfo() *OSInfo

+ func (oi *OSInfo) String() string

type Option

+ Type string

Sep 13, 2017

Changes in this version

type StatsInfo

+ Speed float64

+ Trend string

Aug 29, 2017

Changes in this version

type Option

+ CheckRegex string

type StatsInfo

+ LastError error

Aug 16, 2017

Changes in this version

+ type ErrorResponse struct

+ Error error

+ func NewErrorResponse(err error) *ErrorResponse

+ type KeyValue struct

+ Key string

+ Value string

+ type Option struct

+ ChooseOnly bool

+ ChooseOptions []string

+ Default string

+ DefaultNoUse bool

+ Description string

+ KeyName string

Jun 27, 2017

Changes in this version

+ const GlobalKeyName

+ func CreateDirIfNotExist(dir string) (err error)

+ func GetEnv(env string) string

+ func GetIdentifyIDByFile(f *os.File) (uint64, error) — darwin/amd64, linux/amd64, windows/amd64

+ func GetIdentifyIDByPath(path string) (uint64, error) — darwin/amd64, linux/amd64, windows/amd64

+ func GetRealPath(path string) (newPath string, fi os.FileInfo, err error)

+ func MongoDail(host string, mode string, syncTimeoutInS int64) (session *mgo.Session, err error)

+ func ReadDirByTime(dir string) (files []os.FileInfo, err error)

+ func SetMode(s *mgo.Session, modeFriendly string, refresh bool)

+ func SortFilesByTime(files []os.FileInfo) (soredfiles []os.FileInfo)

+ func TrimeList(strs []string) (ret []string)

+ func TuoDecode(value []byte) (values [][]byte, err error)

+ func TuoEncode(values []sql.RawBytes) (ret []byte)

+ func WaitForInterrupt(interrupt func())

+ type Collection struct

+ func (c Collection) CloseSession() (err error)

+ type File struct

+ Info os.FileInfo

+ Path string

+ func GetLogFiles(doneFilePath string) (files []File)

+ type Int64Slice []int64

+ func (p Int64Slice) Len() int

+ func (p Int64Slice) Less(i, j int) bool

+ func (p Int64Slice) Sort()

+ func (p Int64Slice) Swap(i, j int)

+ type MongoConfig struct

+ DB string

+ Direct bool

+ Host string

+ Mode string

+ SyncTimeoutInS int64

+ type StatsError struct

+ ErrorDetail error

+ ErrorIndex []int

+ Ft bool

+ func (se *StatsError) AddErrors()

+ func (se *StatsError) AddSuccess()

+ func (se *StatsError) Error() string

+ func (se *StatsError) ErrorIndexIn(idx int) bool

+ type StatsInfo struct

+ Errors int64

+ Ftlag int64

+ Success int64