gobase

package module

Go to main page

Versions in this module

v1

v1.2.24053

May 17, 2024

Changes in this version

+ var ErrUnsupported = fmt.Errorf("unsupported")

v1.2.24052

May 13, 2024

Changes in this version

+ type ICheckStart interface

+ CheckStart func() error

type ObjectInnerRef

+ func (this *ObjectInnerRef) CheckStart() error

+ func (this *ObjectInnerRef) ReleaseRef() int

type StrMap

+ func (this StrMap) DeleteByKeylst(keylst ...string) (r int)

+ func (this StrMap) URLFormEncodeKeylst(keylst ...string) string

v1.2.24051

Apr 30, 2024

Changes in this version

+ func LogPrintf(s string, args ...interface{})

+ func SetLogOutput(fn func(calldepth int, lvl int8, sender string, s string))

type CacheFile

+ func (this *CacheFile) GetFileSize() int

v1.2.24041

Apr 1, 2024

Changes in this version

+ type ConnString struct

+ Addr string

+ Pass string

+ Path string

+ Type string

+ User string

+ func ParseConnString(str string) (rval ConnString)

+ func (this *ConnString) Parse(str string)

+ func (this ConnString) String() string

+ type ConnectObjectRefStorage struct

+ func NewConnectObjectRefStorage(newfun func(connstr string) interface{}) *ConnectObjectRefStorage

+ func (this *ConnectObjectRefStorage) CheckGetRef(connstr string) *ObjectInnerRef

+ func (this *ConnectObjectRefStorage) GetStatus(args ...string) string

+ func (this *ConnectObjectRefStorage) Range(filter func(obj interface{}) bool, lessfn func(iobj, jobj interface{}) bool, ...)

+ func (this *ConnectObjectRefStorage) ReleaseRef(itm *ObjectInnerRef)

+ type IStatusGet interface

+ GetStatus func(args StrMap) string

+ type ObjectInnerRef struct

+ func (this *ObjectInnerRef) GetObject() interface{}

type StrMap

+ func NewStrMapFromURLStr(s string) StrMap

v1.2.24013

Jan 18, 2024

Changes in this version

type CacheFile

+ func (this *CacheFile) GetFileName() string

v1.2.24012

Jan 7, 2024

v1.2.2401

Jan 4, 2024

v1.1.2312

Dec 7, 2023

Changes in this version

+ const DURA_DAY

+ const EMPTY_STRING

+ const I64_1

+ const QUOTECHR

+ const U32_0

+ const U32_1

+ const U64_0

+ const U64_1

+ const U64_MAX

+ const U8_0

+ const U8_1

+ const U8_MAX

+ var GoFunCatchException bool = true

+ var OnCatchAllPanic func(err interface{}, args ...interface{})

+ var PathSeparator = "\\"

+ var RootPath = ""

+ var SIZE_GB = 1024 * SIZE_MB

+ var SIZE_KB uint64 = 1024

+ var SIZE_MB = 1024 * SIZE_KB

+ var SIZE_TB = 1024 * SIZE_GB

+ var SPACE_BYTES []byte = []byte(" ")

+ var START_Duration time.Duration = ParseDuration("0s")

+ var START_Time time.Time = StrToTimeDef("00", "04", time.UTC, ZeroTime)

+ var UnixZeroTime time.Time = time.Unix(0, 0).Local()

+ var ZeroTime time.Time

+ var ZeroTimeLocal = ZeroTime.Local()

+ func AbsDuration(t1 time.Duration) time.Duration

+ func AbsInt(x int) int

+ func AddLogger(id string, typestr string, onMsg func(rec *GoLogRecord) bool)

+ func AddPatrolTask(id interface{}, minInterval time.Duration, fn patrolcb, args ...interface{})

+ func AddPrefixForWidth(src string, width int, prefix string) string

+ func AddSuffixForWidth(src string, width int, suffix string) string

+ func AppendAllFile(srcFile string, dataFile string) error

+ func AppendFile(fileName string, fileData []byte) (int, error)

+ func AppendFileEx(fileName string, fileData []byte, forceDir bool) (int, error)

+ func BetweenTime(t1, t2 time.Time) time.Duration

+ func Binary2Hex(bt []byte) string

+ func BitTrimPrefix(v uint64, bitN byte) uint64

+ func Bool2Byte(v bool) byte

+ func Bool2Str(v bool) string

+ func BufStart(buf []byte, start, l int) []byte

+ func BufToHexStr(buf []byte, l int, spliterstr string) string

+ func BuildJSONBytes(kvPairs ...interface{}) []byte

+ func BuildJSONString(kvPairs ...interface{}) string

+ func BytesAppendUInt64_LE(buf []byte, v uint64) []byte

+ func BytesCheckGrow(buf []byte, n int) []byte

+ func BytesCheckSize(buf []byte, start, l int) []byte

+ func CRC24Q(buf []byte, len int) uint32

+ func CRC24QBuf(buf []byte) uint32

+ func Cfmod(x, y float64) float64

+ func CheckAddPrefix(s, prefix string) (added bool, rval string)

+ func CheckAddQuoteChr(s string, prefix, suffix rune) string

+ func CheckAddSuffix(s, suffix string) (added bool, rval string)

+ func CheckAllStrsIsNotEmpty(strs ...string) bool

+ func CheckByteIn(v byte, sets ...byte) bool

+ func CheckGetStrlist(strs []string, idx int, def string) string

+ func CheckGetValInlst(lst []interface{}, idx int, def interface{}) interface

+ func CheckInitialDefaultWorkers(minwork, maxwork int32, quemax int32) bool

+ func CheckRotateFile(filename string) error

+ func CheckRotateFileAfterCreateFile(filename string) (fn *os.File, err error)

+ func CheckTrimPrefix(s, prefix string) (bool, string)

+ func CheckTrimQuoteChr(s string, prefix, suffix byte) (bool, string)

+ func CheckTrimQuoteString(s string, prefix, suffix string) (bool, string)

+ func CheckTrimSuffix(s, suffix string) (bool, string)

+ func CloneBytes(src []byte, offset int, l int) []byte

+ func CloneBytesEx(src []byte, offset int, l int) []byte

+ func CmpAndSetBitValue(ival uint64, bitN byte, cmpbitVal, newbitVal byte) (changed bool, newval uint64)

+ func CombineFilePath(parts ...string) string

+ func CombineIfFirstNotEmpty(s1, s2 string) string

+ func CombineIfNotEmpty(s1, s2 string) string

+ func CompareIgnoreCase(s1, s2 string) int

+ func ConsoleLogMsg(rec *GoLogRecord) bool

+ func ContainElement(s string, ele string, sep rune) (rval bool)

+ func CopyFile(src, dst string) (w int64, err error)

+ func CreateIfExistsThenRename(name string) (*os.File, string, error)

+ func CreateRewrite(fileName string) (*os.File, error)

+ func CutIfMore(s string, n int, moreflagstr string) string

+ func CutLeft(s string, n int) (cut string, remain string)

+ func CutNPrefixFunc(s string, idx int, cutflag byte, CheckCutBreakFunc func(c rune) bool) (cut string, remain string)

+ func CutNSuffixFunc(s string, idx int, cutflag byte, CheckCutBreakFunc func(c rune) bool) (cut string, remain string)

+ func CutPrefixByRune(s string, idx int, cutflag byte, c rune) (cut string, remain string)

+ func CutPrefixFunc(s string, cutflag byte, CheckCutBreakFunc func(c rune) bool) (cut string, remain string)

+ func CutSuffixByRune(s string, idx int, cutflag byte, c rune) (cut string, remain string)

+ func CutSuffixFunc(s string, cutflag byte, CheckCutBreakFunc func(c rune) bool) (cut string, remain string)

+ func DateString(val time.Time) string

+ func DateTimeIDString(val time.Time) string

+ func DateTimeString(val time.Time) string

+ func DateTimeString2(val time.Time) string

+ func DateTimeString3(val time.Time) string

+ func DateTimeStringForShortShow(val time.Time) string

+ func DateTimeStringForShow(val time.Time) string

+ func DateYYMM(val time.Time) string

+ func DateYYYYMM(val time.Time) string

+ func DateYYYYMMDD(val time.Time) string

+ func DayOfYear(atime time.Time) string

+ func DecimalToAny(num, n, count int) string

+ func DecodeCRCBuf(src []byte) []byte

+ func DeferCatchPanic(args ...interface{})

+ func DelLogger(id string, typestr string)

+ func DelNonAsciiChar(s []byte) string

+ func DelNonAsciiCharEx(s []byte, splitchar byte) string

+ func DelNonChineseChar(s string) string

+ func DelNonChineseCharEx(s string, splitchar rune) string

+ func DelNonPrintChar(s string) string

+ func DeleteBuf(buf []byte, startidx, n int) (newBuf []byte)

+ func DeleteFileNameExt(fileName string) string

+ func DeleteFileOrDir(strPath string) error

+ func DeleteStrlstEle(strs []string, fn func(s string) bool) []string

+ func DetectBOMType(data []byte) int

+ func DurationStr(d time.Duration) string

+ func EnablePanicRecordFile(logpath string)

+ func EncodeCRCBuf(src []byte) []byte

+ func EndOfADay(day time.Time) time.Time

+ func EscapeJsonStr(str string) string

+ func EscapeJsonStrSimple(str string) string

+ func EscapeSQLStr(str string) string

+ func EscapeStr4Line(str string) string

+ func ExecCmdLine(cmdLine string, arg_spliter string) error

+ func ExecCmdNoWait(cmdLine string) (*exec.Cmd, error)

+ func ExecCmdNoWaitNoSettingIO(cmdLine string) (*exec.Cmd, error)

+ func ExecShell(cmdLine string) error

+ func ExecShellAndNoWait(cmdLine string) error

+ func ExecShellOutput(cmd string) (err error, str string)

+ func ExecShellWithIO(cmdLine string, rd io.Reader, outstd, outerr io.Writer) error

+ func ExecShellWithStdIO(cmdLine string) error

+ func ExecWithStdIO(cmdLine string) error

+ func ExtractFileName(fileName string) string

+ func ExtractFileNameWithOutPathAndExt(fileName string) string

+ func ExtractFilePath(fileName string) string

+ func FastByte2String(bt []byte) string

+ func FileIs(fileName string) int

+ func FileIsExists(fileName string) bool

+ func FileMTime(fp string) (time.Time, error)

+ func FileNameAddfix(fileName, prefix, suffix string) string

+ func FileSize(fp string) (int64, error)

+ func FindNonElement(s1, s2 string, sep rune) string

+ func FixintervalLastTime(t time.Time, fixinterval time.Duration) time.Time

+ func FixintervalNextTime(t time.Time, fixinterval time.Duration) time.Time

+ func FixintervalOffsetTime(t time.Time, fixinterval time.Duration, offsetN int) time.Time

+ func Float32ToStr(val float64) string

+ func Float64ToStr(val float64) string

+ func ForceAllPath(strPath string) error

+ func ForceCreateFilePath(fileName string) error

+ func ForceCreatePath(strPath string) bool

+ func FormatFloatVlst(fmtstr string, singalw int, totalwidth int, args ...float64) string

+ func FormatLogRecord(format string, rec *GoLogRecord) []byte

+ func GetAbsPath(basePath, relaPath string) (string, error)

+ func GetAreaBK(s string, start, end string, idx int) string

+ func GetBetween(str string, start, end string, idx int) string

+ func GetBetweenEx(str string, start, end string, idx int) (ok bool, val string)

+ func GetBitG(buf []byte, startBitN int, l int) float64

+ func GetBitI16(buf []byte, startBitN int, l int) int16

+ func GetBitI32(buf []byte, startBitN int, l int) int32

+ func GetBitI64(buf []byte, startBitN int, l int) int64

+ func GetBitI8(buf []byte, startBitN int, l int) int8

+ func GetBitOnU32(v uint32) (n byte)

+ func GetBitOnU64(v uint64) (n byte)

+ func GetBitU(buf []byte, startBitN int, l int) uint32

+ func GetBitU16(buf []byte, startBitN int, l int) uint16

+ func GetBitU64(buf []byte, startBitN int, l int) uint64

+ func GetBitU8(buf []byte, startBitN int, l int) byte

+ func GetBitV_U32(v uint32, bitN byte) byte

+ func GetBitV_U64(v uint64, bitN byte) byte

+ func GetBitValue(ival uint64, bitN byte) byte

+ func GetBitValue0(ival uint64, bitN byte) byte

+ func GetBoolValue(val interface{}, def bool) bool

+ func GetCurrentDirectory() (path string, err error)

+ func GetCurrentGoRoutineID() uint64

+ func GetCurrentWorkingPath() (path string)

+ func GetDateTimeValue(val interface{}, def time.Time) time.Time

+ func GetDayOfWeek(val time.Time) byte

+ func GetDecimalBitN(v int64, n int64) int

+ func GetDecimalBitNEx(v int64, n int64) int

+ func GetExecShellCmd(cmdLine string) *exec.Cmd

+ func GetExecuteFileDirectory() (path string)

+ func GetExecuteFileName() (name string)

+ func GetFirstFromVars(arg interface{}) interface

+ func GetFloat64Value(val interface{}, def float64) float64

+ func GetIdxFloat64ValFromVars(arg interface{}, idx int, def float64) float64

+ func GetIdxIntValFromVars(arg interface{}, idx int, def int) int

+ func GetIdxStrValFromVarsDef(arg interface{}, idx int, def string) string

+ func GetIdxValFromVars(arg interface{}, idx int) interface

+ func GetIdxValFromVarsDef(arg interface{}, idx int, def interface{}) interface

+ func GetInt32Value(val interface{}, def int32) int32

+ func GetInt64Value(val interface{}, def int64) int64

+ func GetLastNumStr(str string, maxl int) string

+ func GetMonthDayN(year, month int) int

+ func GetNewFileUseIncSN(fileName string) string

+ func GetRelativePath(basePath, path2 string) (string, error)

+ func GetStrValue(val interface{}, def string) string

+ func GetU64BitsU(v uint64, startBit, endBit int) uint64

+ func GetU64BitsU_L(v uint64, startBit, l int) uint64

+ func GetU8BitValue0(ival byte, bitN byte) byte

+ func HEX2BCD(val int) (int, error)

+ func HEX2BCDDef(val, def int) int

+ func HashStr(str string) int64

+ func HaveAnyGBK(data []byte) bool

+ func HexStrToBuf(hexstr string) []byte

+ func HexToDateTime(hex string, def time.Time) time.Time

+ func HexToInt(hex string) int

+ func HexValue(chr rune) int

+ func HumanDuration(dura time.Duration) string

+ func HumanFilesize(sizebytes int64) string

+ func HumanFilesizeU(sizebytes uint64) string

+ func HumanSizeStrToSize(str string) int64

+ func HumanTimeStr(secs int64) string

+ func HumanTimeStrFromMinutes(minutes int64, spliter string) string

+ func HumanTimeStrFromMinutesInt(minutes int, spliter string) string

+ func IncDay(atime time.Time, num int) time.Time

+ func IncMonth(atime time.Time, num int) time.Time

+ func IncYear(atime time.Time, num int) time.Time

+ func InsertBeforeLineFile(fileName string, idx_before_line int64, fileData []byte) error

+ func InsertBuf(buf []byte, startidx int, val []byte) (newBuf []byte)

+ func Int64_BEBytes(val int64) []byte

+ func Int64_FromBEBytes(val []byte) int64

+ func Int8ListToStrs(lst []int8, sep string) string

+ func IntFromU(v uint64, bitN byte) int64

+ func IsAsciiPrintByte(c byte) bool

+ func IsAsciiPrintChar(chr rune) bool

+ func IsAsciiPrintStr(src string) bool

+ func IsChineseChar(c rune) bool

+ func IsHexChar(chr rune) bool

+ func IsHexStr(src string) bool

+ func IsInMultiSection(exp, s string) string

+ func IsInSection(exp, s string) bool

+ func IsLeapYear(year int) bool

+ func IsLinux() bool

+ func IsPrintStr(src string) bool

+ func IsSameDay(time1, time2 time.Time) bool

+ func IsSameMonth(time1, time2 time.Time) bool

+ func IsWindows() bool

+ func JoinDateAndTime(dateT, timeT time.Time) time.Time

+ func JoinDateAndTimeStr(dateT time.Time, timestr string) time.Time

+ func JoinDateAndTimeStrFormat(dateT time.Time, timestr, timestr_format string) time.Time

+ func JoinIfNoEmpty(chk string, sep string, args ...string) string

+ func LastChrCnt(s string, c byte) int

+ func LeftStr(s string, n int) string

+ func LocationCopy(t1, loctime time.Time) time.Time

+ func Log3Msgf(callskip int, s string, args ...interface{})

+ func LogMsg(typestr string, lvl int8, callskip int, msg interface{})

+ func LogMsgf(typestr string, lvl int8, callskip int, s string, args ...interface{})

+ func MD5(str string) string

+ func MD5Buf(data []byte) string

+ func MD5SumFile(filePath string) string

+ func MSecOfDuration(time time.Duration) int64

+ func MakeVars(arg ...interface{}) interface

+ func MapEncode(strMap map[string]string, kvsep, itmsep string, escapeflag bool, bb io.Writer)

+ func MaxTime(t0 time.Time, t1 time.Time) time.Time

+ func MillisecondOf(start, end time.Time) int64

+ func MinInt(a, b int) int

+ func MinTime(t0 time.Time, t1 time.Time) time.Time

+ func MinuteOfDuration(time time.Duration) int64

+ func NewFileData(fileName string, fileData []byte) (int, error)

+ func NewFileFromReader(fileName string, reader io.Reader) (int, error)

+ func NewFileNameIfExistsThenIncSN(fileName string) string

+ func NextMonthV(month int) int

+ func NextMonthYM(y, m int) (y1, m1 int)

+ func NowIDString() string

+ func NowString() string

+ func NowStringEx() string

+ func ObjectHexAddr(v interface{}) string

+ func PanicRecordFile(err interface{}, args ...interface{})

+ func ParseDuraStr(s string) time.Duration

+ func ParseDuration(timeExp string) time.Duration

+ func ParseTimeFmt(strPattern string, _t time.Time) string

+ func ParserJsonEscapeStr(escapedstr string) string

+ func PathBase(path string) string

+ func PathEscape(s string) string

+ func PathExists(path string) (bool, error)

+ func PathUnescape(s string) (string, error)

+ func QueryEscape(s string) string

+ func QueryUnescape(s string) (string, error)

+ func RandBuf(len int) []byte

+ func RandFloat64(f float64) float64

+ func RandHexString(len int) string

+ func RandKeyString(len int) string

+ func RandNumString(len int) string

+ func RandNumStringWithout4(len int) string

+ func RandPass0String(len int) string

+ func RangeByteFromHexStr(hexstr string, cb func(v byte) bool) int

+ func RangeFiles(path string, maxlevel int, fn func(path string, file os.FileInfo) bool, ...) error

+ func RangeStringSep(s string, sep rune, cb func(idx int, s1 string) bool) int

+ func RangeStringSep2(s string, cb func(idx int, s1 string) bool, sep0, sep1 rune) int

+ func RangeStringSplit(s string, sep string, cb func(idx int, s string) bool) int

+ func ReadDir(dirname string) ([]os.FileInfo, error)

+ func ReadFile(fileName string) ([]byte, error)

+ func ReadFileBlockBuf(fileName string, cb func(block []byte) bool, makebuffunc func() []byte) (int64, error)

+ func ReadFileBlockBufOffset(fileName string, offset int64, cb func(block []byte) bool, ...) (int64, error)

+ func ReadFileLine(fileName string, cb func(idx int64, line []byte) bool) (int64, error)

+ func ReadLBytes(r io.Reader, buf []byte, l int) error

+ func ReadPerLine(reader io.Reader, cb func(idx int64, line []byte) bool) (int64, error)

+ func ReadPerLineEx(reader io.Reader, cb func(idx int64, line []byte) bool) (int64, error)

+ func ReadPerLineFile(filename string, offset int64, cb func(idx int64, line []byte) bool) (int64, error)

+ func RenameFile(afile string, newFileName string) error

+ func RenameLogFile(filename string) (newfile string, err error)

+ func ReplaceAll(s string, old, new string) string

+ func ReplaceArea(s string, start, end string, new string) string

+ func ReplaceMultiAny2One(s string, any, new string) string

+ func ReplaceMultiSpace2One(s string, new string) string

+ func ReplaceNonAsciiChar(s []byte, newchr byte) string

+ func ReplaceNonChineseChar(s string, newchr rune) string

+ func ReplaceNonPrintChar(s string, newchr rune) string

+ func ReplaceReg(s string, regP string, new string) (string, error)

+ func ReverseBytes(buf []byte)

+ func RewriteFile(fileName string, fileData []byte) error

+ func RewriteFileFunc(fileName string, fn func(w *os.File) error) error

+ func Round32(f float32, n int) float32

+ func Round64(f float64, n int) float64

+ func RoundTime_Second(t time.Time) time.Time

+ func SOD(atime time.Time) float64

+ func SearchAFile(path string, currlevel, maxlevel int, ...) (string, error)

+ func SearchAFileEx(path string, currlevel, maxlevel int, ...) (string, os.FileInfo)

+ func SearchFiles(path string, currlevel, maxlevel int, ...) (string, error)

+ func SecondBetween(t1, t2 time.Time) float64

+ func SecondOf(start time.Time, end time.Time) int64

+ func SecondSub(start, end time.Time) float64

+ func SetBitI32(buf []byte, startBitN int, l int, val int32)

+ func SetBitI64(buf []byte, startBitN int, l int, val int64)

+ func SetBitI8(buf []byte, startBitN int, l int, val int8)

+ func SetBitU16(buf []byte, startBitN int, l int, val uint16)

+ func SetBitU32(buf []byte, startBitN int, l int, val uint32)

+ func SetBitU64(buf []byte, startBitN int, l int, val uint64)

+ func SetBitU8(buf []byte, startBitN int, l int, val uint8)

+ func SetBitValue(ival uint64, bitN byte, bitVal bool) uint64

+ func SetBitValue0(ival uint64, bitN byte, bitVal bool) uint64

+ func SetU8BitValue0(ival byte, bitN byte, bitVal bool) byte

+ func Size2GB(sizebytes uint64) float64

+ func SizeStrToSize(str string) int64

+ func Split2PathAndFileName(fileName string) (dir string, name string)

+ func Split2Str(s, sep string) (s1, s2 string)

+ func Split2StrV1(s string, sep byte) (s1, s2 string)

+ func Split3Str(s, sep string) (s1, s2, s3 string)

+ func SplitNumericAndRemain(str string) (numstr, remain string)

+ func SplitQuantifiersUnits(s string) (qua string, unit string)

+ func SplitStrWidth(s string, width int) (rval []string)

+ func StartOfADay(day time.Time) time.Time

+ func StartOfAMonth(day time.Time) time.Time

+ func Str2lst(s string, sep string, itmprefix, itmsuffix rune, tolower, emptyignore bool) []string

+ func StrIndex(s string, strlst ...string) int

+ func StrIndexIgnoreCase(s string, strlst ...string) int

+ func StrNextSerialNo(str string, maxl int, inc int) string

+ func StrTo3Float64(str string, sep string) (f1, f2, f3 float64)

+ func StrToFloat32Def(s string, defval float32) float32

+ func StrToFloat64Def(s string, defval float64) float64

+ func StrToInt64Def(s string, defval int64) int64

+ func StrToInt8Def(s string, defval int8) int8

+ func StrToInt8List(str string, sep string) (rval []int8)

+ func StrToIntDef(s string, defval int) int

+ func StrToInts(str string, sep string) (rval []int)

+ func StrToNumSuffix(str string, mult int64) int64

+ func StrToTimeDef(str, format string, location *time.Location, def time.Time) time.Time

+ func StrToUInt8List(str string, sep string) (rval []byte)

+ func StringsRangeFunc(strs []string, cb func(idx int64, elestr string) bool) (int64, error)

+ func SwapBytes(buf []byte) []byte

+ func SyncMapLength(amap *sync.Map) int

+ func TimeBetween(t0 time.Time, start time.Time, end time.Time) bool

+ func TimeInLocalToday(val time.Time) time.Duration

+ func TimeInUtcToday(val time.Time) time.Duration

+ func TimeIsUnixZero(t time.Time) bool

+ func TimeString3(val time.Time) string

+ func ToHourChr(atime time.Time) string

+ func ToHourChrUpcase(atime time.Time) string

+ func ToJSONValString(val interface{}) string

+ func ToUTCTime(src time.Time) time.Time

+ func TodayIDString() string

+ func TodayStr() string

+ func Trim(s string) string

+ func TrimPrefixBuf(buf []byte, prefix []byte) (rval []byte, changed bool)

+ func TrimPrefixBytes(buf []byte, byteset ...byte) []byte

+ func TrimRightByte(buf []byte, rightByte byte) []byte

+ func TrimRightBytes(buf []byte, rightByte ...byte) []byte

+ func TryCreateFileAndRenameIfFileExists(fileName string) (newfile *os.File, ret_err error)

+ func TryStrToBool(str string, def bool) bool

+ func TryStrToTime(str string, location *time.Location, def time.Time) time.Time

+ func TryStrToTimeDefZero(str string, location *time.Location) (rval time.Time)

+ func UInt16_BEBytes(val uint16) []byte

+ func UInt16_FromBEBytes(buf []byte) uint16

+ func UInt16_FromLEBytes(buf []byte) uint16

+ func UInt16_LEBytes(val uint16) []byte

+ func UInt32_BEBytes(val uint32) []byte

+ func UInt32_FromBEBytes(buf []byte) uint32

+ func UInt32_LEBytes(val uint32) []byte

+ func UInt64_BEBytes(val uint64) []byte

+ func UInt64_FromBEBytes(val []byte) uint64

+ func UInt8ListToStrs(lst []byte, sep string) string

+ func UnEscapeJSONStr(bvalue []byte) []byte

+ func UnEscapeStr4Line(str string) string

+ func WriteBuf_BE_Float64(val float64, outBuf []byte)

+ func WriteBuf_LE_Float64(val float64, outBuf []byte)

+ func WriteMsgPackBin(w io.Writer, s []byte) (int, error)

+ func WriteMsgPackLen(w io.Writer, typ byte, l int, byteN int) (int, error)

+ func WriteMsgPackStr(w io.Writer, s string) (int, error)

+ func XorBytes(buf []byte) byte

+ type ByPassGroup struct

+ func NewByPassGroup() *ByPassGroup

+ func (this *ByPassGroup) BeginUpdate()

+ func (this *ByPassGroup) ConfigStrategy(v int8)

+ func (this *ByPassGroup) DeleteByPassItem(id string) (isChanged bool)

+ func (this *ByPassGroup) EndUpdate(removeflag bool) (upcnt int)

+ func (this *ByPassGroup) GetByPassNode() (node *ByPassItem)

+ func (this *ByPassGroup) ReleaseByPassNode(node *ByPassItem, fail bool, block time.Duration, failmsg string)

+ func (this *ByPassGroup) Status() string

+ func (this *ByPassGroup) UpdateByPassNode(id string, sn int16, max int, data interface{}) (isChanged bool)

+ type ByPassItem struct

+ func (this *ByPassItem) GetData() interface{}

+ type ByPassMananger struct

+ func NewByPassManager() *ByPassMananger

+ func (this *ByPassMananger) CheckGetByPassGroup(id string, newflag bool) *ByPassGroup

+ func (this *ByPassMananger) GetByPassNode(groupid string) (rval *ByPassItem)

+ func (this *ByPassMananger) GetStatusText(lvl int) string

+ func (this *ByPassMananger) ReleaseByPassNode(itm *ByPassItem, fail bool, block time.Duration, failmsg string)

+ func (this *ByPassMananger) TrySetDefault(id string) bool

+ type BytesBuilder struct

+ func NewBytesBuilder() *BytesBuilder

+ func (b *BytesBuilder) AppendBufFromBase64Str(base64str string) (int, error)

+ func (b *BytesBuilder) AppendBuilder(b0 *BytesBuilder)

+ func (b *BytesBuilder) AppendIfNotEmpty(s string) *BytesBuilder

+ func (b *BytesBuilder) AppendLine(s string) *BytesBuilder

+ func (b *BytesBuilder) AppendRinexV(fv float64, digitN int, width int, zeroEmptyflag bool) *BytesBuilder

+ func (b *BytesBuilder) AppendStr(s string) *BytesBuilder

+ func (b *BytesBuilder) AppendStrPrefixForWidth(s string, width int, prefix string) *BytesBuilder

+ func (b *BytesBuilder) AppendStrSuffixForWidth(s string, width int, suffix string) *BytesBuilder

+ func (b *BytesBuilder) AppendStrs(strs ...string) *BytesBuilder

+ func (b *BytesBuilder) AppendStrsWithSpliter(spliter string, strs ...string) *BytesBuilder

+ func (b *BytesBuilder) Appendf(s string, args ...interface{}) *BytesBuilder

+ func (b *BytesBuilder) Appendf_PrefixFixed(w int, prefix string, s string, args ...interface{}) *BytesBuilder

+ func (b *BytesBuilder) Base64String() string

+ func (b *BytesBuilder) BufAsHexStr(start, l int, spliter string) string

+ func (b *BytesBuilder) Cap() int

+ func (b *BytesBuilder) CheckSize(startidx int, l int)

+ func (b *BytesBuilder) Cleanup()

+ func (b *BytesBuilder) GetBitI(startidx int, startBitN, l int) int

+ func (b *BytesBuilder) GetBitU(startidx int, startBitN, l int) uint32

+ func (b *BytesBuilder) GetBitU16(startidx int, startBitN, l int) uint16

+ func (b *BytesBuilder) GetBitU64(startidx int, startBitN, l int) uint64

+ func (b *BytesBuilder) GetBitUAsInt(startidx int, startBitN, l int) int

+ func (b *BytesBuilder) Grow(n int)

+ func (b *BytesBuilder) HexString(spliter string) string

+ func (b *BytesBuilder) Len() int

+ func (b *BytesBuilder) Reset()

+ func (b *BytesBuilder) SetBitI16(startidx int, startBitN int, l int, val int16)

+ func (b *BytesBuilder) SetBitI32(startidx int, startBitN int, l int, val int32)

+ func (b *BytesBuilder) SetBitI64(startidx int, startBitN int, l int, val int64)

+ func (b *BytesBuilder) SetBitU16(startidx int, startBitN, l int, v uint16)

+ func (b *BytesBuilder) SetBitU32(startidx int, startBitN, l int, v uint32)

+ func (b *BytesBuilder) SetBitU64(startidx int, startBitN, l int, v uint64)

+ func (b *BytesBuilder) SetBitU8(startidx int, startBitN, l int, v byte)

+ func (b *BytesBuilder) StatusString() string

+ func (b *BytesBuilder) String() string

+ func (b *BytesBuilder) Write(p []byte) (int, error)

+ func (b *BytesBuilder) WriteByte(c byte) error

+ func (b *BytesBuilder) WriteBytes(p ...byte)

+ func (b *BytesBuilder) WriteRune(r rune) (int, error)

+ func (b *BytesBuilder) WriteString(s string) (int, error)

+ func (b *BytesBuilder) WriteWithHexStr(hexStr string, maxl int) int

+ func (this *BytesBuilder) AppendFixedStr(s string, fixedw int, suffix string) *BytesBuilder

+ func (this *BytesBuilder) AppendFixedStrWithZeroByte(s string, fixedw int) *BytesBuilder

+ func (this *BytesBuilder) Buff(start, l int) []byte

+ func (this *BytesBuilder) BuffEx(start, endidx int) []byte

+ func (this *BytesBuilder) BuffTrimRight(start, l int, rightBytes ...byte) []byte

+ func (this *BytesBuilder) Byte(idx int) byte

+ func (this *BytesBuilder) ByteOr(idx int, v byte) byte

+ func (this *BytesBuilder) Bytes() []byte

+ func (this *BytesBuilder) Clone() *BytesBuilder

+ func (this *BytesBuilder) CloneBuf() []byte

+ func (this *BytesBuilder) CopyFrom(src *BytesBuilder) *BytesBuilder

+ func (this *BytesBuilder) Delete(startidx, n int) *BytesBuilder

+ func (this *BytesBuilder) Delete2End(idx int) *BytesBuilder

+ func (this *BytesBuilder) HasSuffix(suffix []byte) bool

+ func (this *BytesBuilder) Index(startidx int, sub []byte) int

+ func (this *BytesBuilder) IndexByte(startidx int, v byte) int

+ func (this *BytesBuilder) IndexFunc(startidx int, fn func(v rune) bool) int

+ func (this *BytesBuilder) Insert(startidx int, val []byte) *BytesBuilder

+ func (this *BytesBuilder) InsertByte(startidx int, val byte) *BytesBuilder

+ func (this *BytesBuilder) Replace(startidx int, val []byte) *BytesBuilder

+ func (this *BytesBuilder) ReplaceUInt16_BE(startidx int, val uint16) *BytesBuilder

+ func (this *BytesBuilder) ReplaceUInt16_LE(startidx int, val uint16) *BytesBuilder

+ func (this *BytesBuilder) ReplaceUInt32_BE(startidx int, val uint32) *BytesBuilder

+ func (this *BytesBuilder) ReplaceUInt32_LE(startidx int, val uint32) *BytesBuilder

+ func (this *BytesBuilder) SaveToFile(fileName string) error

+ func (this *BytesBuilder) Str2FixedBytes(s string, fixedw int) []byte

+ func (this *BytesBuilder) UInt64_BE(val uint64) *BytesBuilder

+ func (this *BytesBuilder) Uint16_BE(startidx int) uint16

+ func (this *BytesBuilder) Uint16_LE(startidx int) uint16

+ func (this *BytesBuilder) Uint32_BE(startidx int) uint32

+ func (this *BytesBuilder) Uint32_LE(startidx int) uint32

+ func (this *BytesBuilder) Uint64_BE(startidx int) uint64

+ func (this *BytesBuilder) WriteUInt16_BE(val uint16) *BytesBuilder

+ func (this *BytesBuilder) WriteUInt16_LE(val uint16) *BytesBuilder

+ func (this *BytesBuilder) WriteUInt32_BE(val uint32) *BytesBuilder

+ func (this *BytesBuilder) WriteUInt32_LE(val uint32) *BytesBuilder

+ func (this *BytesBuilder) WriteUInt64_BE(val uint64) *BytesBuilder

+ type CacheFile struct

+ func NewCacheFile(filename string, cachesize int) *CacheFile

+ func (this *CacheFile) CheckOpen() error

+ func (this *CacheFile) Close() error

+ func (this *CacheFile) Flush()

+ func (this *CacheFile) Write(buf []byte) (int, error)

+ func (this *CacheFile) WriteString(s string) (int, error)

+ type CacheMultiFileWriter struct

+ MsgLvl int8

+ OnFileEof func(filename string)

+ func NewCacheMultiFileWriter(filename string) *CacheMultiFileWriter

+ func (this *CacheMultiFileWriter) Close() error

+ func (this *CacheMultiFileWriter) OnLogMsg(rec *GoLogRecord) bool

+ func (this *CacheMultiFileWriter) SetMaxSize(v int)

+ func (this *CacheMultiFileWriter) SetMsgFmt(s string)

+ func (this *CacheMultiFileWriter) WaitIdle()

+ type DElement struct

+ DList *DList

+ Value interface{}

+ func (e *DElement) Next() *DElement

+ func (e *DElement) Prev() *DElement

+ func (e *DElement) RemoveFromDList()

+ type DLinkNode struct

+ Value interface{}

+ func NewDlinknode() *DLinkNode

+ func NewDlinknodeFromPool() *DLinkNode

+ func (this *DLinkNode) Next() *DLinkNode

+ type DLinklist struct

+ func NewDlinklist() *DLinklist

+ func (this *DLinklist) Append(node *DLinkNode)

+ func (this *DLinklist) AppendValue(v interface{})

+ func (this *DLinklist) Count() int32

+ func (this *DLinklist) FetchNext() *DLinkNode

+ func (this *DLinklist) FetchPre() *DLinkNode

+ func (this *DLinklist) First() *DLinkNode

+ func (this *DLinklist) InsertToFirst(node *DLinkNode)

+ func (this *DLinklist) List() []interface{}

+ func (this *DLinklist) Nodes() []*DLinkNode

+ func (this *DLinklist) Range(cb func(val interface{}) bool) int

+ func (this *DLinklist) RangeEx(cb func(idx int, val interface{}, removeit *bool) bool, ...) int

+ func (this *DLinklist) Remove(node *DLinkNode) bool

+ func (this *DLinklist) RemoveFirst() *DLinkNode

+ func (this *DLinklist) RemoveLast() *DLinkNode

+ func (this *DLinklist) SeekFirst() *DLinkNode

+ func (this *DLinklist) SeekLast() *DLinkNode

+ type DList struct

+ func NewDList() *DList

+ func (l *DList) Back() *DElement

+ func (l *DList) Front() *DElement

+ func (l *DList) Init() *DList

+ func (l *DList) InsertAfter(v interface{}, mark *DElement) *DElement

+ func (l *DList) InsertBefore(v interface{}, mark *DElement) *DElement

+ func (l *DList) Len() int

+ func (l *DList) MoveAfter(e, mark *DElement)

+ func (l *DList) MoveBefore(e, mark *DElement)

+ func (l *DList) MoveToBack(e *DElement)

+ func (l *DList) MoveToFront(e *DElement)

+ func (l *DList) PushBack(v interface{}) *DElement

+ func (l *DList) PushBackDList(other *DList)

+ func (l *DList) PushFront(v interface{}) *DElement

+ func (l *DList) PushFrontDList(other *DList)

+ func (l *DList) Remove(e *DElement) interface{}

+ type DiskStatus struct

+ All uint64

+ Free uint64

+ Used uint64

+ func (this DiskStatus) FreePercent() float64

+ func (this DiskStatus) FreePercentStr(n int) string

+ type EscapeError string

+ func (e EscapeError) Error() string

+ type GoLog struct

+ func NewGoLog() *GoLog

+ func (this *GoLog) AddLogger(id string, typestr string, onMsg func(rec *GoLogRecord) bool)

+ func (this *GoLog) DelLogger(id string, typestr string)

+ func (this *GoLog) LogMsg(typestr string, lvl int8, callskip int, msg interface{})

+ func (this *GoLog) LogMsgf(typestr string, lvl int8, callskip int, s string, args ...interface{})

+ type GoLogRecord struct

+ CreatedTime time.Time

+ Level int8

+ Msg interface{}

+ Source string

+ Typestr string

+ type GroupTask struct

+ FixedWorker byte

+ Id string

+ OnFatalCallBack func(sender *GroupTask, rec *groupTaskRec, err error)

+ func DefaultGroupTask() *GroupTask

+ func NewGroupTask() *GroupTask

+ func (this *GroupTask) CheckAbnormal() (err error)

+ func (this *GroupTask) CheckCreateFixedGroupChannel(groupid interface{}) *groupTaskChannel

+ func (this *GroupTask) ConfigChannelMaxQueueSize(queue_size int32) *GroupTask

+ func (this *GroupTask) ConfigChannelMaxWorkNum(groupid interface{}, maxWorkNum int32) *GroupTask

+ func (this *GroupTask) ConfigGrowIfTaskPiled(num int32) *GroupTask

+ func (this *GroupTask) ConfigMaxWork(num int32) *GroupTask

+ func (this *GroupTask) ConfigMinWork(num int32) *GroupTask

+ func (this *GroupTask) Details(all bool) string

+ func (this *GroupTask) DetailsEx(all bool, max int) string

+ func (this *GroupTask) DetailsEx2(all bool, max int, searchval, exclusive string) string

+ func (this *GroupTask) GetChannelMaxQueueSize() int32

+ func (this *GroupTask) GroupSimpleStatus(groupid interface{}) string

+ func (this *GroupTask) GroupStatus(groupid interface{}) string

+ func (this *GroupTask) IsTerminated() bool

+ func (this *GroupTask) PostChannelTaskFunc(groupChanel interface{}, cb func(args ...interface{}), args ...interface{}) error

+ func (this *GroupTask) PostTaskArgs(groupid interface{}, cb func(sender *groupTaskRec), args ...interface{}) error

+ func (this *GroupTask) PostTaskArgsEx(groupid interface{}, cb func(args ...interface{}), args ...interface{}) error

+ func (this *GroupTask) PostTaskFunc(groupid interface{}, cb func()) error

+ func (this *GroupTask) PostTaskFuncAndWait(groupid interface{}, timeout time.Duration, cb func()) (ok bool, err error)

+ func (this *GroupTask) PostTaskFuncArgs(groupid interface{}, cb func(args ...interface{}), args ...interface{}) error

+ func (this *GroupTask) RemoveFixedGroupChannel(groupid interface{}) bool

+ func (this *GroupTask) Start()

+ func (this *GroupTask) StatusSimpleString() string

+ func (this *GroupTask) StatusString() string

+ func (this *GroupTask) Stop()

+ func (this *GroupTask) TaskCnt() int32

+ func (this *GroupTask) Terminate()

+ func (this *GroupTask) WaitExecFunc(sender *groupTaskRec)

+ type IPub interface

+ Pub func(topic string, max int, args ...interface{}) int

+ type ISub interface

+ Sub func(id, topic string, cb func(id, topic string, args ...interface{}) (ok bool))

+ type IUnsub interface

+ Unsub func(id, topic string) bool

+ type InvalidHostError string

+ func (e InvalidHostError) Error() string

+ type JSONBuilder struct

+ func NewJSONBuilder() *JSONBuilder

+ func (this *JSONBuilder) Add(key string, val interface{}) *JSONBuilder

+ func (this *JSONBuilder) AddAny(strs ...string) *JSONBuilder

+ func (this *JSONBuilder) AddEscapeStr(key string, val string) *JSONBuilder

+ func (this *JSONBuilder) AddKey(key string) *JSONBuilder

+ func (this *JSONBuilder) AddObject(kvPairs ...interface{}) *JSONBuilder

+ func (this *JSONBuilder) AddObjectEx(valfunc func(val interface{}) interface{}, kvPairs ...interface{}) *JSONBuilder

+ func (this *JSONBuilder) AddValues(kvPairs ...interface{}) *JSONBuilder

+ func (this *JSONBuilder) AddValuesEx(valfunc func(val interface{}) interface{}, kvPairs ...interface{}) *JSONBuilder

+ func (this *JSONBuilder) ArrayBegin() *JSONBuilder

+ func (this *JSONBuilder) ArrayEnd() *JSONBuilder

+ func (this *JSONBuilder) Bytes() []byte

+ func (this *JSONBuilder) EscapeSimpleVal(val interface{}) interface{}

+ func (this *JSONBuilder) EscapeVal(val interface{}) interface{}

+ func (this *JSONBuilder) Length() int

+ func (this *JSONBuilder) ObjectBegin() *JSONBuilder

+ func (this *JSONBuilder) ObjectEnd() *JSONBuilder

+ func (this *JSONBuilder) Reset() *JSONBuilder

+ func (this *JSONBuilder) Spliter() *JSONBuilder

+ func (this *JSONBuilder) String() string

+ type JSONDecode struct

+ func NewJSONDecode() *JSONDecode

+ func (this *JSONDecode) InputBuf(buf []byte, onjson func(jsonstr string))

+ func (this *JSONDecode) InputByte(val byte) (rval int)

+ func (this *JSONDecode) String() string

+ type MsgPackDecode struct

+ AssertType byte

+ func NewMsgPackDecode() *MsgPackDecode

+ func (this *MsgPackDecode) Bytes() []byte

+ func (this *MsgPackDecode) InputByte(v byte) int8

+ func (this *MsgPackDecode) Reset()

+ type PatrolTask struct

+ func DefaultPatrolTask() *PatrolTask

+ func NewPatrolTask() *PatrolTask

+ func (this *PatrolTask) AddTask(id interface{}, minInterval time.Duration, fn patrolcb, args ...interface{})

+ func (this *PatrolTask) AddTaskOnce(id interface{}, fn patrolcb, args ...interface{})

+ func (this *PatrolTask) AddTaskOnceA1(arg interface{}, fn func(arg interface{}))

+ func (this *PatrolTask) CheckAbnormal() error

+ func (this *PatrolTask) CheckStart()

+ func (this *PatrolTask) DelTask(id interface{})

+ func (this *PatrolTask) Status() string

+ type ReadFileSession struct

+ func NewReadFileSession(filename string) *ReadFileSession

+ func (this *ReadFileSession) Close() error

+ func (this *ReadFileSession) CloseFlag() int8

+ func (this *ReadFileSession) ErrFlag() int8

+ func (this *ReadFileSession) Read(b []byte) (n int, err error)

+ func (this *ReadFileSession) Reset()

+ type RunableProc func(worker *TaskWorker, args ...interface{})

+ type SingleCacheFileWriter struct

+ MsgLvl int8

+ OnFileEof func(filename string)

+ func NewSingleCacheFileWriter(filename string) *SingleCacheFileWriter

+ func (this *SingleCacheFileWriter) Close() error

+ func (this *SingleCacheFileWriter) GetTotleCount() int

+ func (this *SingleCacheFileWriter) OnLogMsg(rec *GoLogRecord) bool

+ func (this *SingleCacheFileWriter) SetMaxSize(v int)

+ func (this *SingleCacheFileWriter) SetMsgFmt(s string)

+ func (this *SingleCacheFileWriter) WaitIdle()

+ func (this *SingleCacheFileWriter) WriteMsgf(msglvl int8, s string, args ...interface{}) bool

+ type StrMap map[string]string

+ func NewStrMap() StrMap

+ func NewStrMapEx(s, kvsep, itmsep string) StrMap

+ func (this StrMap) CopyFrom(src StrMap)

+ func (this StrMap) Encode(kvspliter string, itmspliter string) string

+ func (this StrMap) ExecReplace(s string) string

+ func (this StrMap) Float64ByName(k string, def float64) float64

+ func (this StrMap) Int16ByName(k string, def int16) int16

+ func (this StrMap) Int8ByName(k string, def int8) int8

+ func (this StrMap) IntByName(k string, def int) int

+ func (this StrMap) ParseCmdArgs(args []string)

+ func (this StrMap) ParseKVPairs(s string, kvsep string, itmsep string)

+ func (this StrMap) ParseKVPairsEx(s string, kvsep string, itmsep string, keylower bool)

+ func (this StrMap) Reset()

+ func (this StrMap) SortRange(fn func(k, v string) bool)

+ func (this StrMap) SortRangeEncode(kvspliter string, itmspliter string, fn func(k, v string) bool) string

+ func (this StrMap) StringByName(k string, def string) string

+ func (this StrMap) U8ByName(k string, def byte) byte

+ func (this StrMap) URLFormDecode(s string)

+ func (this StrMap) URLFormEncode() string

+ func (this StrMap) UnixTimeByName(k string, def time.Time) time.Time

+ type SubFunc = func(id, topic string, args ...interface{}) (ok bool)

+ type SubTopicItem struct

+ type Subscribe struct

+ func NewSubscribe() *Subscribe

+ func NewSubscribeEx(routeParseFunc func(topic string) interface{}, ...) *Subscribe

+ func (this *Subscribe) Close() error

+ func (this *Subscribe) Count() int

+ func (this *Subscribe) GetTopicSubCount(topic string) int

+ func (this *Subscribe) Pub(topic string, max int, args ...interface{}) int

+ func (this *Subscribe) Status() string

+ func (this *Subscribe) StatusDetail() string

+ func (this *Subscribe) Sub(id, topic string, cb func(id, topic string, args ...interface{}) (ok bool))

+ func (this *Subscribe) TopicCount() int

+ func (this *Subscribe) Unsub(id, topic string) bool

+ type SyncMap struct

+ func (this *SyncMap) AsInt32(id interface{}, def int32) int32

+ func (this *SyncMap) AsString(id interface{}, def string) string

+ func (this *SyncMap) BatchSetFromStr(str string)

+ func (this *SyncMap) Clear()

+ func (this *SyncMap) Contain(id interface{}) bool

+ func (this *SyncMap) Count() int

+ func (this *SyncMap) CountFunc(fn func(k, v interface{}) bool) int

+ func (this *SyncMap) Get(id interface{}, def interface{}) interface{}

+ func (this *SyncMap) List() []interface{}

+ func (this *SyncMap) ListEx(filter func(key, value interface{}) bool, ...) []interface{}

+ func (this *SyncMap) ListRangeV2(filter func(key, value interface{}) bool, ...)

+ func (this *SyncMap) ListRangeV3(filterflag, sortflag int, filter func(key, value interface{}) bool, ...)

+ func (this *SyncMap) ListSorted(lessfunc func(iItm, jItm interface{}) bool) []interface{}

+ func (this *SyncMap) LoadOrStore(id interface{}, store interface{}) (actual interface{}, loaded bool)

+ func (this *SyncMap) LoadOrStoreFunc(id interface{}, newfunc func() interface{}, freefunc func(val interface{})) (actual interface{})

+ func (this *SyncMap) LoadOrStoreFunc2(id interface{}, newfunc func() interface{}, freefunc func(val interface{})) (actual interface{}, loaded bool)

+ func (this *SyncMap) PickFirst(filter func(key, value interface{}) bool, ...) interface{}

+ func (this *SyncMap) Range(f func(key, value interface{}) bool)

+ func (this *SyncMap) Remove(id interface{})

+ func (this *SyncMap) RemoveAndGet(id interface{}) (val interface{}, ok bool)

+ func (this *SyncMap) RemoveEx(id interface{}) bool

+ func (this *SyncMap) Set(id interface{}, val interface{})

+ func (this *SyncMap) Store(id interface{}, val interface{})

+ func (this *SyncMap) ValAsString(spliter string, filter func(key, value interface{}) bool, ...) string

+ func (this *SyncMap) ValAsString2(spliter string, filter func(key, value interface{}) bool, ordertype int) string

+ type SyncQueue struct

+ func NewSyncQueue() *SyncQueue

+ func (this *SyncQueue) Count() int32

+ func (this *SyncQueue) Peek() (bool, interface{})

+ func (this *SyncQueue) Pop() (bool, interface{})

+ func (this *SyncQueue) PopTaskArgMaxFunc(max int, cb func(args interface{}) bool) int

+ func (this *SyncQueue) Push(val interface{})

+ func (this *SyncQueue) Range(cb func(idx int, value interface{}, removeit *bool) bool)

+ func (this *SyncQueue) Reset()

+ type TaskPool struct

+ BusyCnt int32

+ TaskPop int64

+ TaskPush int64

+ Terminated int32

+ WorkMax int32

+ WorkMin int32

+ func NewTaskPool(maxCache int) *TaskPool

+ func (this *TaskPool) Close()

+ func (this *TaskPool) GetTaskNum() int

+ func (this *TaskPool) IsTerminated() bool

+ func (this *TaskPool) PostTask(fn RunableProc, args ...interface{}) bool

+ func (this *TaskPool) RunMinWorkers()

+ func (this *TaskPool) Status() string

+ func (this *TaskPool) WorkNum() int

+ type TaskWorker struct

+ Fixed int8

+ GoID uint64

+ Owner *TaskPool

+ func (this *TaskWorker) Run()

v1.1.2311

Nov 14, 2023

v1.0.2311

Nov 11, 2023

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL