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 DecryptAES(src string) (res string, err error)
- func DefaultWait()
- func DenormalizeBsonMObjectId(m bson.M) (res bson.M)
- func EncryptAES(src string) (res string, err error)
- func EncryptMd5(str string) string
- func EnvIsTrue(key string, defaultOk bool) bool
- 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 GetApiAddress() (res string)
- 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 GetLocalTime(t time.Time) time.Time
- func GetLocalTimeString(t time.Time) string
- func GetMongoOpts(opts *generic.ListOptions) (res *mongo.FindOptions)
- func GetMongoQuery(query generic.ListQuery) (res bson.M)
- func GetNodeType() string
- func GetRpcParam(key string, params map[string]string) string
- func GetSecretKey() string
- func GetSecretKeyBytes() []byte
- func GetSpiderCol(col string, name string) string
- func GetSpiderMd5Str(file string) string
- func GetTimeString(t time.Time) string
- func GetUserFromArgs(args ...interface{}) (u interfaces.User)
- func ImportDemo() (err error)
- func InitModule(id interfaces.ModuleId, fn func() error) (err error)
- func IsCancellable(status string) bool
- func IsDebug() bool
- func IsDemo() (ok bool)
- func IsDir(path string) bool
- func IsDocker() (ok bool)
- func IsFile(path string) bool
- func IsMaster() 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 ReimportDemo() (err error)
- func RemoveFiles(path string)
- func ResultToJson()
- 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
Constants ¶
This section is empty.
Variables ¶
View Source
var CronUtils = cronUtils{ // contains filtered or unexported fields }
View Source
var TaskExecChanMap = NewChanMap()
Functions ¶
func BackoffErrorNotify ¶ added in v0.6.0
func BackoffErrorNotify(prefix string) backoff.Notify
func BsonMEqual ¶ added in v0.6.0
func BytesToString ¶
func ComputeHmacSha256 ¶
func DeCompressByPath ¶
func DecryptAES ¶ added in v0.6.0
func DefaultWait ¶ added in v0.6.0
func DefaultWait()
func DenormalizeBsonMObjectId ¶ added in v0.6.0
func EncryptAES ¶ added in v0.6.0
func EncryptMd5 ¶ added in v0.6.0
func FillEmptyFileData ¶ added in v0.6.0
func ForceInitModule ¶ added in v0.6.0
func GetApiAddress ¶ added in v0.6.1
func GetApiAddress() (res string)
func GetArrayItems ¶ added in v0.6.0
func GetArrayItems(array interface{}) (res []interface{}, err error)
func GetFromDbCache ¶ added in v0.6.0
func GetLocalTimeString ¶
func GetMongoOpts ¶ added in v0.6.0
func GetMongoOpts(opts *generic.ListOptions) (res *mongo.FindOptions)
func GetNodeType ¶ added in v0.6.1
func GetNodeType() string
func GetSecretKey ¶ added in v0.6.0
func GetSecretKey() string
func GetSecretKeyBytes ¶ added in v0.6.0
func GetSecretKeyBytes() []byte
func GetSpiderCol ¶
func GetSpiderMd5Str ¶
func GetTimeString ¶
func GetUserFromArgs ¶ added in v0.6.0
func GetUserFromArgs(args ...interface{}) (u interfaces.User)
func ImportDemo ¶ added in v0.6.1
func ImportDemo() (err error)
func InitModule ¶ added in v0.6.0
func InitModule(id interfaces.ModuleId, fn func() error) (err error)
func IsCancellable ¶ added in v0.6.0
func JsonToBytes ¶ added in v0.6.0
func NewUUIDString ¶ added in v0.6.0
func NewUUIDString() (res string)
func ReadFileOneLine ¶
func ReimportDemo ¶ added in v0.6.1
func ReimportDemo() (err error)
func RemoveFiles ¶
func RemoveFiles(path string)
func ResultToJson ¶ added in v0.6.0
func ResultToJson()
func SetFileVariable ¶
设置文件变量值 可以理解为将文件中的变量占位符替换为想要设置的值
func ShuffleArray ¶ added in v0.6.0
func ShuffleArray(slice []interface{}) (err error)
func StringArrayContains ¶
func TrimFileData ¶ added in v0.6.0
func VisualizeContainer ¶ added in v0.6.0
Types ¶
type ChanMap ¶
type ChanMap struct {
// contains filtered or unexported fields
}
func NewChanMap ¶
func NewChanMap() *ChanMap
func (*ChanMap) ChanBlocked ¶
func (*ChanMap) HasChanKey ¶
Source Files ¶
Click to show internal directories.
Click to hide internal directories.