utils

Documentation

Index

• Variables
• func BackoffErrorNotify(prefix string) backoff.Notify
• func BsonMEqual(v1, v2 bson.M) (ok bool)
• func BytesToString(b []byte) string
• func Close(c io.Closer)
• func Compress(files []*os.File, dest string) error
• func ComputeHmacSha256(message string, secret string) string
• func Contains(array interface{}, val interface{}) (fla bool)
• func CopyDir(src string, dst string) error
• func CopyFile(src, dst string) error
• func CreateDirPath(filePath string)
• func DeCompress(srcFile *os.File, dstPath string) error
• func DeCompressByPath(tarFile, dest string) error
• func DefaultWait()
• func EncryptPassword(str string) string
• func Exists(path string) bool
• func FillEmptyFileData(data []byte) (res []byte)
• func ForceInitModule(fn func() error) (err error)
• func GetAllFilesFromDir(dirPath string) ([]*os.File, error)
• func GetArrayItems(array interface{}) (res []interface{}, err error)
• func GetFilesFromDir(dirPath string) ([]*os.File, error)
• func GetFromDbCache(key string, getFn func() (string, error)) (res string, err error)
• func GetJson(message entity.NodeMessage) string
• func GetLangFromLangNamePlain(name string) entity.Lang
• func GetLangList() []entity.Lang
• func GetLangListPlain() []entity.Lang
• func GetLocalTime(t time.Time) time.Time
• func GetLocalTimeString(t time.Time) string
• func GetMessage(message redis.Message) *entity.NodeMessage
• func GetPackageJsonDeps(filepath string) (deps []string, err error)
• func GetRpcParam(key string, params map[string]string) string
• func GetSpiderCol(col string, name string) string
• func GetSpiderMd5Str(file string) string
• func GetSystemScriptPath(scriptName string) string
• func GetSystemScripts() (res []string)
• func GetTimeString(t time.Time) string
• func GetUserFromArgs(args ...interface{}) (u interfaces.User)
• func InitModule(id interfaces.ModuleId, fn func() error) (err error)
• func IsCancellable(status string) bool
• func IsDebug() bool
• func IsDir(path string) bool
• func IsFile(path string) bool
• func JsonToBytes(d interface{}) (bytes []byte, err error)
• func ListDir(path string) []os.FileInfo
• func LogDebug(msg string)
• func NewUUIDString() (res string)
• func NormalizeBsonMObjectId(m bson.M) (res bson.M)
• func ObjectToString(params interface{}) string
• func OpenFile(fileName string) *os.File
• func ReadFileOneLine(fileName string) string
• func RemoveFiles(path string)
• func SetFileVariable(filePath string, key string, value string) error
• func ShuffleArray(slice []interface{}) (err error)
• func StringArrayContains(arr []string, str string) bool
• func TrimFileData(data []byte) (res []byte)
• func VisualizeContainer(c *dig.Container) (err error)
• type ChanMap
  • func NewChanMap() *ChanMap
  • func (cm *ChanMap) Chan(key string) chan string
  • func (cm *ChanMap) ChanBlocked(key string) chan string
  • func (cm *ChanMap) HasChanKey(key string) bool

Variables

var CronUtils = cronUtils{
	// contains filtered or unexported fields
}

var TaskExecChanMap = NewChanMap()

Functions

func BackoffErrorNotify

func BackoffErrorNotify(prefix string) backoff.Notify

func BsonMEqual

func BsonMEqual(v1, v2 bson.M) (ok bool)

func BytesToString

func BytesToString(b []byte) string

func Close

func Close(c io.Closer)

func Compress

func Compress(files []*os.File, dest string) error

压缩文件 files 文件数组，可以是不同dir下的文件或者文件夹 dest 压缩文件存放地址

func ComputeHmacSha256

func ComputeHmacSha256(message string, secret string) string

func Contains

func Contains(array interface{}, val interface{}) (fla bool)

func CopyDir

func CopyDir(src string, dst string) error

Dir copies a whole directory recursively

func CopyFile

func CopyFile(src, dst string) error

File copies a single file from src to dst

func CreateDirPath

func CreateDirPath(filePath string)

创建文件夹

func DeCompress

func DeCompress(srcFile *os.File, dstPath string) error

func DeCompressByPath

func DeCompressByPath(tarFile, dest string) error

func DefaultWait

func DefaultWait()

func EncryptPassword

func EncryptPassword(str string) string

func Exists

func Exists(path string) bool

func FillEmptyFileData

func FillEmptyFileData(data []byte) (res []byte)

func ForceInitModule

func ForceInitModule(fn func() error) (err error)

func GetAllFilesFromDir

func GetAllFilesFromDir(dirPath string) ([]*os.File, error)

func GetArrayItems

func GetArrayItems(array interface{}) (res []interface{}, err error)

func GetFilesFromDir

func GetFilesFromDir(dirPath string) ([]*os.File, error)

func GetFromDbCache

func GetFromDbCache(key string, getFn func() (string, error)) (res string, err error)

func GetJson

func GetJson(message entity.NodeMessage) string

func GetLangFromLangNamePlain

func GetLangFromLangNamePlain(name string) entity.Lang

根据语言名获取语言实例，不包含状态

func GetLangList

func GetLangList() []entity.Lang

func GetLangListPlain

func GetLangListPlain() []entity.Lang

获取语言列表

func GetLocalTime

func GetLocalTime(t time.Time) time.Time

func GetLocalTimeString

func GetLocalTimeString(t time.Time) string

func GetMessage

func GetMessage(message redis.Message) *entity.NodeMessage

func GetPackageJsonDeps

func GetPackageJsonDeps(filepath string) (deps []string, err error)

func GetRpcParam

func GetRpcParam(key string, params map[string]string) string

获取 RPC 参数

func GetSpiderCol

func GetSpiderCol(col string, name string) string

func GetSpiderMd5Str

func GetSpiderMd5Str(file string) string

func GetSystemScriptPath

func GetSystemScriptPath(scriptName string) string

func GetSystemScripts

func GetSystemScripts() (res []string)

获取系统脚本列表

func GetTimeString

func GetTimeString(t time.Time) string

func GetUserFromArgs

func GetUserFromArgs(args ...interface{}) (u interfaces.User)

func InitModule

func InitModule(id interfaces.ModuleId, fn func() error) (err error)

func IsCancellable

func IsCancellable(status string) bool

func IsDebug

func IsDebug() bool

func IsDir

func IsDir(path string) bool

func IsFile

func IsFile(path string) bool

func JsonToBytes

func JsonToBytes(d interface{}) (bytes []byte, err error)

func ListDir

func ListDir(path string) []os.FileInfo

func LogDebug

func LogDebug(msg string)

func NewUUIDString

func NewUUIDString() (res string)

func NormalizeBsonMObjectId

func NormalizeBsonMObjectId(m bson.M) (res bson.M)

func ObjectToString

func ObjectToString(params interface{}) string

Object 转化为 String

func OpenFile

func OpenFile(fileName string) *os.File

func ReadFileOneLine

func ReadFileOneLine(fileName string) string

func RemoveFiles

func RemoveFiles(path string)

func SetFileVariable

func SetFileVariable(filePath string, key string, value string) error

设置文件变量值 可以理解为将文件中的变量占位符替换为想要设置的值

func ShuffleArray

func ShuffleArray(slice []interface{}) (err error)

func StringArrayContains

func StringArrayContains(arr []string, str string) bool

func TrimFileData

func TrimFileData(data []byte) (res []byte)

func VisualizeContainer

func VisualizeContainer(c *dig.Container) (err error)

Types

type ChanMap

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

func NewChanMap

func NewChanMap() *ChanMap

func (*ChanMap) Chan

func (cm *ChanMap) Chan(key string) chan string

func (*ChanMap) ChanBlocked

func (cm *ChanMap) ChanBlocked(key string) chan string

func (*ChanMap) HasChanKey

func (cm *ChanMap) HasChanKey(key string) bool