utils

package

v1.4.4-alpha1202-loadi... Latest Latest Go to latest Published: Dec 2, 2025 License: AGPL-3.0 Imports: 99 Imported by: 266

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/yaklang/yaklang

Links

Open Source Insights

Documentation ¶

Rendered for

Overview ¶

Package bytefmt contains helper methods and constants for converting to and from a human-readable byte format.

bytefmt.ByteSize(100.5*bytefmt.MEGABYTE) // "100.5M"
bytefmt.ByteSize(uint64(1024)) // "1K"

sshclient implements an ssh client

Index ¶

Constants
Variables
func AddressFamilyUint32ToString(i uint32) string
func AppendDefaultPort(raw string, port int) string
func AppendSliceItemWhenNotExists[T comparable](s []T, t T) []T
func AsDebugString(i interface{}, raws ...bool) string
func AsciiBytesToRegexpMatchedRunes(in []byte) []rune
func AsciiBytesToRegexpMatchedString(in []byte) string
func AsciiEqualFold(s, t string) bool
func AsciiToLower(s string) (lower string, ok bool)
func AttemptWithDelay(maxIteration int, delay time.Duration, f func() error) error
func AttemptWithDelayFast(f func() error) error
func BKDRHash(str []byte) uint32
func BufioReadLine(reader *bufio.Reader) ([]byte, error)
func BufioReadLineString(reader *bufio.Reader) (string, error)
func ByteCountBinary(b int64) string
func ByteCountDecimal(b int64) string
func ByteSize(bytes uint64) string
func BytesClone(raw []byte) (newBytes []byte)
func CacheFunc[T any](duration time.Duration, f func() (T, error)) func() (T, error)
func CalcMd5(items ...interface{}) string
func CalcSSDeepStability(req ...[]byte) (float64, error)
func CalcSha1(items ...interface{}) string
func CalcSha1WithSuffix(items []interface{}, suffix string) string
func CalcSha256(items ...interface{}) string
func CalcSimHashStability(req ...[]byte) (float64, error)
func CalcSimilarity(raw ...[]byte) float64
func CalcTextSubStringStability(raw ...[]byte) (float64, error)
func CallGeneralClose(closer any)
func CallWithCtx(ctx context.Context, cb func()) error
func CallWithTimeout(timeout float64, cb func()) error
func ChanStringToSlice(c chan string) (result []string)
func CloseConnSafe(conn net.Conn)
func CloseWrite(i any)
func ConcatPorts(ports []int) string
func ConcurrentCopyDirectory(source string, destination string, threads int, isMove bool) error
func ConnExpect(c net.Conn, timeout time.Duration, callback func([]byte) bool) (bool, error)
func ContainsAll[T comparable](s []T, vals ...T) bool
func ContainsAny[T comparable](s []T, vals ...T) bool
func ContainsJSON(raw string) (string, bool)
func ConvertTextFileToYakFuzztagByPath(file_bin_path string) (string, error)
func ConvertToStringSlice(raw ...interface{}) (r []string)
func CopyBytes(rsp []byte) []byte
func CopyDirectory(source string, destination string, isMove bool) error
func CopyDirectoryEx(source string, destination string, isMove bool, fs fi.FileSystem) error
func CopyFile(source, destination string) error
func CopyFileEx(source string, destination string, fs fi.FileSystem) error
func CopyMapInterface(i map[string]interface{}) map[string]interface{}
func CopyMapShallow[K comparable, V any](originalMap map[K]V) map[K]V
func CopySlice[T any](i []T) []T
func CreateTempTestDatabaseInMemory() (*gorm.DB, error)
func CreateUTF8StreamMirror(r io.Reader, cb ...func(reader io.Reader)) io.Reader
func CutBytesPrefixFunc(raw []byte, handle func(rune) bool) ([]byte, []byte, bool)
func DataVerbose(i interface{}) string
func DatePretty() string
func DatetimePretty() string
func DatetimePretty2() string
func Debug(f func())
func DebugMockEchoWs(point string) (string, int)
func DebugMockEchoWss(point string) (string, int)
func DebugMockGMHTTP(ctx context.Context, handler func(req []byte) []byte) (string, int)
func DebugMockHTTP(rsp []byte) (string, int)
func DebugMockHTTP2(ctx context.Context, handler func(req []byte) []byte) (string, int)
func DebugMockHTTP2HandlerFuncContext(ctx context.Context, handlerFunc http.HandlerFunc) (string, int)
func DebugMockHTTPEx(handle func(req []byte) []byte) (string, int)
func DebugMockHTTPExContext(ctx context.Context, handle func(req []byte) []byte) (string, int)
func DebugMockHTTPHandlerFunc(handlerFunc http.HandlerFunc) (string, int)
func DebugMockHTTPHandlerFuncContext(ctx context.Context, handlerFunc http.HandlerFunc) (string, int)
func DebugMockHTTPKeepAliveEx(handle func(req []byte) []byte) (string, int)
func DebugMockHTTPS(rsp []byte) (string, int)
func DebugMockHTTPSEx(handle func(req []byte) []byte) (string, int)
func DebugMockHTTPSKeepAliveEx(handle func(req []byte) []byte) (string, int)
func DebugMockHTTPServerWithContext(ctx context.Context, https, h2, gmtlsFlag, onlyGmtls, keepAlive bool, ...) (string, int)
func DebugMockHTTPServerWithContextWithAddress(ctx context.Context, addr string, ...) (string, int)
func DebugMockHTTPWithTimeout(du time.Duration, rsp []byte) (string, int)
func DebugMockOnlyGMHTTP(ctx context.Context, handler func(req []byte) []byte) (string, int)
func DebugMockTCP(rsp []byte) (string, int)
func DebugMockTCPEx(handleFunc handleTCPFunc) (string, int)
func DebugMockTCPHandlerFuncContext(ctx context.Context, handlerFunc handleTCPFunc) (string, int)
func DebugMockWs(handler func(conn *websocket.Conn)) (string, int)
func DomainToURLFilter(domain string) (*regexp.Regexp, error)
func DownloadFile(ctx context.Context, client *http.Client, u string, localFile string, ...) error
func DumpFileWithTextAndFiles(raw string, divider string, files ...string) (string, error)
func DumpHTTPRequest(req *http.Request, loadBody bool) ([]byte, error)
func DumpHTTPResponse(rsp *http.Response, loadBody bool, wr ...io.Writer) ([]byte, error)
func DumpHostFileWithTextAndFiles(raw string, divider string, files ...string) (string, error)
func EnableDebug()
func Error(i interface{}) error
func ErrorStack(origin any) (err error)
func Errorf(format string, args ...interface{}) error
func EscapeInvalidUTF8Byte(s []byte) string
func ExportAppConfigToMap(ins any) (map[string]string, error)
func ExtractFaviconURL(siteURL string, content []byte) (string, error)
func ExtractHost(raw string) string
func ExtractHostPort(raw string) string
func ExtractMapValueBool(m any, key string) bool
func ExtractMapValueGeneralMap(m any, key string) map[string]any
func ExtractMapValueInt(m any, key string) int
func ExtractMapValueRaw(m any, key string) any
func ExtractMapValueString(m any, key string) string
func ExtractRawPath(target string) string
func ExtractStrContextByKeyword(raw string, res []string) []string
func ExtractTitleFromHTMLTitle(s string, defaultValue string) string
func FileExists(filename string) bool
func FileLineReader(file string) (chan []byte, error)
func FileLineReaderWithContext(file string, ctx context.Context) (chan []byte, error)
func FilterInterface[T any](i []any) []T
func FindNearestAvailablePortWithTimeout(host string, originalPort int, timeout time.Duration) int
func FirstWriter(onFirstWrite func([]byte)) io.Writer
func FixForParseIP(host string) string
func FixHTTPRequestForGolangNativeHTTPClient(req *http.Request)
func FixHTTPRequestForHTTPDo(r *http.Request) (*http.Request, error)
func FixHTTPRequestForHTTPDoWithHttps(r *http.Request, isHttps bool) (*http.Request, error)
func FixHTTPResponseForGolangNativeHTTPClient(ins *http.Response)
func FixJsonRawBytes(rawBytes []byte) []byte
func FloatSecondDuration(f float64) time.Duration
func FlushWriter(writer io.Writer)
func Format(raw string, data map[string]string) string
func GetAllFiles(path string) (fileNames []string, err error)
func GetCClassByIPv4(s string) (network string, err error)
func GetCachedLog() (res []string)
func GetConnectedToHostPortFromHTTPRequest(t *http.Request) (string, error)
func GetContextKeyBool(ctx context.Context, key string) bool
func GetContextKeyString(ctx context.Context, key string) string
func GetCurrentDate() (time.Time, error)
func GetCurrentWeekMonday() (time.Time, error)
func GetDate(t time.Time) (time.Time, error)
func GetDefaultGMTLSConfig(i float64) *gmtls.Config
func GetDefaultOnlyGMTLSConfig(i float64) *gmtls.Config
func GetDefaultTLSConfig(i float64) *tls.Config
func GetExecutableFromEnv(cmd string) (string, error)
func GetFileAbsDir(filePath string) (string, error)
func GetFileAbsPath(filePath string) (string, error)
func GetFileMd5(filepath string) string
func GetFileModTime(path string) int64
func GetFileSha256(filepath string) string
func GetFirstExcludedHighPort(excluded ...string) int
func GetFirstExistedExecutablePath(paths ...string) string
func GetFirstExistedFile(paths ...string) string
func GetFirstExistedFileE(paths ...string) (string, error)
func GetFirstExistedPath(paths ...string) string
func GetFirstExistedPathE(paths ...string) (string, error)
func GetHTTPHeader(headers http.Header, key string) string
func GetHomeDir() (string, error)
func GetHomeDirDefault(d string) string
func GetLastElement[T any](list []T) T
func GetLatestFile(dir, suffix string) (filename string, err error)
func GetLocalIPAddress() string
func GetLocalIPAddressViaIface() string
func GetMachineCode() string
func GetNExcludeExcludeHighPort(n int, excluded ...string) []int
func GetRandomAvailableTCPPort() int
func GetRandomAvailableTCPPortWithCtx(ctx context.Context, host string) int
func GetRandomAvailableUDPPort() int
func GetRandomIPAddress() string
func GetRandomLocalAddr() string
func GetRangeAvailableTCPPort(startPort, endPort, maxRetries int) (int, error)
func GetSameSubStrings(raw ...string) []string
func GetSameSubStringsRunes(text1, text2 []rune) [][]rune
func GetSimpleUri(u *url.URL) string
func GetSortedMapKeys[K Ordered, V any](m map[K]V) []K
func GetSystemDnsServers() ([]string, error)
func GetSystemMachineCode() (_ string, err error)
func GetSystemNameServerList() ([]string, error)
func GetUnexportedField(field reflect.Value) interface{}
func GetWeekStartMonday(t time.Time) (time.Time, error)
func GetWeekStartSunday() (time.Time, error)
func GormTransaction(db *gorm.DB, callback func(tx *gorm.DB) error) (err error)
func GormTransactionReturnDb(db *gorm.DB, callback func(tx *gorm.DB)) (tx *gorm.DB)
func GzipCompress(i interface{}) ([]byte, error)
func GzipDeCompress(ret []byte) ([]byte, error)
func HTTPFrameParser(raw io.Reader) ([][2]string, [][2]string, io.Reader, error)
func HTTPPacketIsLargerThanMaxContentLength(res interface{}, maxLength int) bool
func HandleStdout(ctx context.Context, handle func(string)) error
func HandleStdoutBackgroundForTest(handle func(string)) (func(), func(), error)
func HostContains(rule string, target string) bool
func HostPort(host string, port interface{}) string
func HttpDumpWithBody(i interface{}, body bool) ([]byte, error)
func HttpShow(i interface{}) []byte
func IContains(s, sub string) bool
func IHasPrefix(s, sub string) bool
func IOCopy(dst io.Writer, src io.Reader, buf []byte) (written int64, err error)
func IPv4ToCClassNetwork(s string) (string, error)
func IPv4ToUint32(ip net.IP) (uint32, error)
func IPv4ToUint64(ip string) (int64, error)
func IStringContainsAnyOfSubString(s string, subs []string) bool
func ImportAppConfigToStruct(template any, data map[string]string) (err error)
func InDebugMode() bool
func InGithubActions() bool
func InTestcase() bool
func IncludeExcludeChecker(includes, excludes []string, target string) (passed bool)
func IndexAllSubstrings(s string, patterns ...string) (result [][2]int)
func InetAtoN(ip net.IP) int64
func InetNtoA(ip int64) net.IP
func InitialCapitalizationEachWords(str string) string
func InsertSliceItem[T comparable](slices []T, e T, index int) []T
func Int64SliceToIntSlice(i []int64) []int
func IntArrayContains(array []int, element int) bool
func IntLargerZeroOr(s ...int) int
func IntSliceToInt64Slice(i []int) []int64
func InterfaceToBoolean(i any) bool
func InterfaceToBytes(i interface{}) (result []byte)
func InterfaceToBytesSlice(i interface{}) [][]byte
func InterfaceToFloat64(i any) float64
func InterfaceToGeneralMap(params interface{}) (finalResult map[string]interface{})
func InterfaceToInt(i any) int
func InterfaceToJsonString(i interface{}) string
func InterfaceToMap(i interface{}) map[string][]string
func InterfaceToMapInterface(i interface{}) map[string]interface{}
func InterfaceToMapInterfaceE(i interface{}) (map[string]interface{}, error)
func InterfaceToQuotedString(i interface{}) string
func InterfaceToSliceInterface(i interface{}) []any
func InterfaceToSliceInterfaceE(i interface{}) ([]any, error)
func InterfaceToString(i interface{}) string
func InterfaceToStringSlice(i interface{}) (result []string)
func IsASCIIPrint(s string) bool
func IsAudio(filePath string) (bool, error)
func IsBase64(s string) bool
func IsCommonHTTPRequestMethod(i any) bool
func IsConnectResetError(err error) bool
func IsDir(path string) bool
func IsErrorNetOpTimeout(err error) bool
func IsFile(path string) bool
func IsFloat(v interface{}) bool
func IsGenericTextFile(filePath string) (bool, error)
func IsGenericTextType(fileType *mimetype.MIME) bool
func IsGzip(raw []byte) bool
func IsGzipBytes(i interface{}) bool
func IsHttpOrHttpsUrl(raw string) bool
func IsIPv4(raw string) bool
func IsIPv6(raw string) bool
func IsImage(i []byte) bool
func IsInt(v interface{}) bool
func IsJSON(raw string) (string, bool)
func IsLinux() bool
func IsLoopback(t string) bool
func IsMac() bool
func IsMap(input any) bool
func IsMedia(filePath string) (bool, error)
func IsNil(input any) bool
func IsPlainText(raw []byte) bool
func IsPortAvailable(host string, p int) bool
func IsPortAvailableWithTimeout(host string, port int, timeout time.Duration) bool
func IsPortAvailableWithUDP(host string, p int) bool
func IsPrivateIP(ip net.IP) bool
func IsProtobuf(raw []byte) bool
func IsStrongPassword(s string) bool
func IsSubPath(sub, parent string) bool
func IsTCPPortAvailable(p int) bool
func IsTCPPortAvailableWithLoopback(p int) bool
func IsTCPPortOpen(host string, p int) bool
func IsUDPPortAvailable(p int) bool
func IsUDPPortAvailableWithLoopback(p int) bool
func IsValidBool(raw string) bool
func IsValidCIDR(raw string) bool
func IsValidDomain(raw string) bool
func IsValidFloat(raw string) bool
func IsValidHost(raw string) bool
func IsValidHostsRange(raw string) bool
func IsValidInteger(raw string) bool
func IsValidPortsRange(ports string) bool
func IsVideo(filePath string) (bool, error)
func IsWebsocketUrl(raw string) bool
func IsWindows() bool
func JSONStringReader(reader io.Reader) io.Reader
func JavaTimeFormatter(t time.Time, formatter string) string
func JitterBackoff(min, max time.Duration, attempt int) time.Duration
func JoinErrors(errs ...error) error
func Jsonify(i interface{}) []byte
func LastLine(s []byte) []byte
func LoopEvery1sBreakUntil(until func() bool)
func MIMEGlobRuleCheck(target string, rule string) bool
func MapGet[T any](m map[string]any, key string) T
func MapGetBool(m map[string]interface{}, key string) bool
func MapGetBoolOr(m map[string]interface{}, key string, value bool) bool
func MapGetFirstRaw(m map[string]interface{}, key ...string) interface{}
func MapGetFloat32(m map[string]interface{}, key string) float32
func MapGetFloat32Or(m map[string]interface{}, key string, value float32) float32
func MapGetFloat64(m map[string]interface{}, key string) float64
func MapGetFloat64Or(m map[string]interface{}, key string, value float64) float64
func MapGetInt(m map[string]interface{}, key string) int
func MapGetInt64(m map[string]interface{}, key string) int64
func MapGetInt64Or(m map[string]interface{}, key string, value int64) int64
func MapGetInt64Slice(m map[string]interface{}, key string) []int64
func MapGetIntEx(m map[string]interface{}, key ...string) int
func MapGetIntOr(m map[string]interface{}, key string, value int) int
func MapGetMapRaw(m map[string]interface{}, key string) map[string]interface{}
func MapGetMapRawOr(m map[string]interface{}, key string, value map[string]interface{}) map[string]interface{}
func MapGetMapStringInt64(m map[string]interface{}, key string) map[string]int64
func MapGetOr[T any](m map[string]any, key string, value T) T
func MapGetRaw(m map[string]interface{}, key string) interface{}
func MapGetRawOr(m map[string]interface{}, key string, value interface{}) interface{}
func MapGetString(m map[string]interface{}, key string) string
func MapGetString2(m map[string]string, key string) string
func MapGetStringByManyFields(m map[string]interface{}, key ...string) string
func MapGetStringOr(m map[string]interface{}, key string, value string) string
func MapGetStringOr2(m map[string]string, key string, value string) string
func MapGetStringSlice(m map[string]interface{}, key string) []string
func MapQueryToString(values map[string][]string) string
func MapStringGet(m map[string]string, key string) string
func MapStringGetOr(m map[string]string, key string, value string) string
func MapToStruct(input map[string]interface{}, output interface{}) error
func MarshalHTTPRequest(req *http.Request) ([]byte, error)
func MarshalIdempotent(v interface{}) ([]byte, error)
func MatchAllOfGlob(i interface{}, re ...string) bool
func MatchAllOfRegexp(i interface{}, re ...string) bool
func MatchAllOfSubString(i interface{}, subStr ...string) bool
func MatchAnyOfGlob(i interface{}, re ...string) bool
func MatchAnyOfRegexp(i interface{}, re ...string) bool
func MatchAnyOfSubString(i interface{}, subStr ...string) bool
func Max(x, y int) int
func MaxByte(x, y byte) byte
func MaxInt64(x, y int64) int64
func MergeGeneralMap(ms ...map[string]any) map[string]any
func MergeStringMap(ms ...map[string]string) map[string]string
func MergeToMap[K comparable, V any](m map[K]V, ms ...map[K]V)
func Min(x, y int) int
func MinByte(x, y byte) byte
func MinInt64(x, y int64) int64
func Mmh3Hash32(raw []byte) string
func MustRenderTemplate(templateStr string, data any) string
func MustUnmarshalJson[T any](raw []byte) *T
func NeedsURLEncoding(s string) bool
func NestedSavepointTransaction(st *SavepointTransaction, callback func(*gorm.DB) error) error
func NetworkByteOrderBytesToUint16(r []byte) uint16
func NetworkByteOrderUint16ToBytes(i any) []byte
func NetworkByteOrderUint32ToBytes(i any) []byte
func NetworkByteOrderUint64ToBytes(i any) []byte
func NetworkByteOrderUint8ToBytes(i any) []byte
func NewBlockParser(reader io.Reader) *blockParser
func NewDebounce(wait float64) func(f func())
func NewDebounceEx(wait float64, lead bool, tail bool) func(f func())
func NewDefaultGMTLSConfig() *gmtls.Config
func NewDefaultHTTPClient() *http.Client
func NewDefaultHTTPClientWithProxy(proxy string) *http.Client
func NewDefaultTLSClient(conn net.Conn) *tls.Conn
func NewDefaultTLSConfig() *tls.Config
func NewDialer()
func NewFileLineWriter(file string, flag int, perm fs.FileMode) (*fileLineWriter, error)
func NewMirrorPipe(count int) ([]*bufpipe.PipeReader, *bufpipe.PipeWriter)
func NewNetConnFromReadWriter()
func NewSignalChannel(targetSignal ...os.Signal) chan os.Signal
func NewThrottle(wait float64) func(f func())
func NewThrottleEx(wait float64, lead bool, tail bool) func(f func())
func NotSpaceRune(r rune) bool
func OpenTempFile(s string) (*os.File, error)
func OrderedParallelProcess[I any, O any](ctx context.Context, inputCh <-chan I, processFunc func(I) (O, error), ...) <-chan Result[O]
func OrderedParallelProcessSkipError[I any, O any](ctx context.Context, inputCh <-chan I, processFunc func(I) (O, error), ...) <-chan O
func ParseAppTag(tag string) map[string]string
func ParseAppTagToOptions(template any, ext ...map[string]string) (configInfo []*ypb.ThirdPartyAppConfigItemTemplate, err error)
func ParseCStyleBinaryRawToBytes(raw []byte) []byte
func ParseHTTPRequestLine(line string) (method, requestURI, proto string, ok bool)
func ParseHTTPResponseLine(line string) (string, int, string, bool)
func ParseHostToAddrString(host string) string
func ParseIPNetToRange(n *net.IPNet) (int64, int64, error)
func ParseLines(raw string) chan string
func ParsePortToProtoPort(port int) (string, int)
func ParseStringToGeneralMap(i any) map[string]any
func ParseStringToHostPort(raw string) (host string, port int, err error)
func ParseStringToHosts(raw string) []string
func ParseStringToHostsWithCallback(raw string, callback func(string) bool)
func ParseStringToHttpsAndHostname(res string) (bool, string)
func ParseStringToLines(raw string) []string
func ParseStringToPorts(ports string) []int
func ParseStringToRawLines(raw string) []string
func ParseStringToUrl(s string) *url.URL
func ParseStringToUrlParams(i interface{}) string
func ParseStringToUrls(targets ...string) []string
func ParseStringToUrlsWith3W(sub ...string) []string
func ParseStringToVisible(raw interface{}) string
func ParseStringUrlToUrlInstance(s string) (*url.URL, error)
func ParseStringUrlToWebsiteRootPath(url string) (newURL string)
func PathExists(path string) (bool, error)
func PrefixLines(input interface{}, prefix string) string
func PrefixLinesReader(input io.Reader, prefix string) io.Reader
func PrefixLinesReaderSimple(input io.Reader, prefix string) io.Reader
func PrefixLinesWithLineNumbers(input interface{}) string
func PrefixLinesWithLineNumbersReader(input io.Reader) io.Reader
func PrettifyJoin(sep string, s ...string) string
func PrettifyListFromStringSplitEx(Raw string, sep ...string) (targets []string)
func PrettifyListFromStringSplited(Raw string, sep string) (targets []string)
func PrettifyShrinkJoin(sep string, s ...string) string
func PrintCurrentGoroutineRuntimeStack()
func ProtoHostPort(proto string, host string, port int) string
func QuoteCSV(s string) string
func RRFRank[T RRFScoredData](scoredDataList []T, k int) []T
func RRFRankWithDefaultK[T RRFScoredData](scoredDataList []T) []T
func RandAlphaNumStringBytes(n int) string
func RandBytes(n int) []byte
func RandChoice(a ...string) string
func RandFloat64() float64
func RandNumberStringBytes(n int) string
func RandSample(n int, material ...string) string
func RandSampleInRange(minLen, maxLen int, material ...string) string
func RandSecret(n int) string
func RandStringBytes(n int) string
func ReadConnUntil(conn net.Conn, timeout time.Duration, sep ...byte) ([]byte, error)
func ReadConnWithTimeout(r net.Conn, timeout time.Duration) ([]byte, error)
func ReadDirsRecursivelyCallback(p string, i func(info *FileInfo) bool) error
func ReadHTTPRequestFromBufioReader(reader *bufio.Reader) (*http.Request, error)
func ReadHTTPRequestFromBufioReaderOnFirstLine(reader *bufio.Reader, h func(string)) (*http.Request, error)
func ReadHTTPRequestFromBytes(raw []byte) (*http.Request, error)
func ReadHTTPResponseFromBufioReader(reader io.Reader, req *http.Request) (*http.Response, error)
func ReadHTTPResponseFromBufioReaderConn(reader io.Reader, conn net.Conn, req *http.Request) (*http.Response, error)
func ReadHTTPResponseFromBytes(raw []byte, req *http.Request) (*http.Response, error)
func ReadLine(reader io.Reader) ([]byte, error)
func ReadLineEx(reader io.Reader) (string, int64, error)
func ReadN(reader io.Reader, n int) ([]byte, error)
func ReadTimeout(r io.Reader, timeout time.Duration) ([]byte, error)
func ReadUntilStable(reader io.Reader, conn net.Conn, timeout time.Duration, ...) ([]byte, error)
func ReadUntilStableEx(reader io.Reader, noTimeout bool, conn net.Conn, timeout time.Duration, ...) ([]byte, error)
func ReadWithContextTickCallback(ctx context.Context, rc io.Reader, callback func([]byte) bool, ...)
func ReadWithLen(r io.Reader, length int) ([]byte, int)
func ReaderOnFirstByte(origin io.Reader, onFirstByte func()) io.Reader
func RealTimeCopy(dst io.Writer, src io.Reader) (int64, error)
func Regexp2Compile(rawRule string, opts ...int) (string, regexp2.RegexOptions, *regexp2.Regexp, error)
func RegisterDefaultTLSConfigGenerator(...)
func RegisterTempFileOpener(dialer FileOpenerType)
func RemoveBOM(raw []byte) []byte
func RemoveBOMForString(raw string) string
func RemoveRepeatIntSlice(slc []int) []int
func RemoveRepeatIntSliceByLoop(slc []int) []int
func RemoveRepeatIntSliceByMap(slc []int) []int
func RemoveRepeatStringSlice(slc []string) []string
func RemoveRepeatStringSliceByLoop(slc []string) []string
func RemoveRepeatStringSliceByMap(slc []string) []string
func RemoveRepeatUintSlice(slc []uint) []uint
func RemoveRepeatUintSliceByLoop(slc []uint) []uint
func RemoveRepeatUintSliceByMap(slc []uint) []uint
func RemoveRepeatedWithStringSlice(slice []string) []string
func RemoveSliceItem[T comparable](slice []T, s T) []T
func RemoveUnprintableChars(raw string) string
func RemoveUnprintableCharsWithReplace(raw string, handle func(i byte) string) string
func RemoveUnprintableCharsWithReplaceItem(raw string) string
func RenderTemplate(templateStr string, data any) (string, error)
func ReplaceLastSubString(s, sub, new string) string
func ReplaceSliceItem[T comparable](s []T, t T, to T) []T
func Retry(times int, f func() error) error
func Retry2(i int, handler func() bool)
func RetryWithExpBackOff(f func() error) error
func RetryWithExpBackOffEx(times int, begin int, f func() error) error
func RuneIndex(s, sub []rune) int
func RuneRead(r io.Reader, maxChars int) string
func SSDeepHash(raw []byte) string
func SafeReflectStructField(refV reflect.Value, field reflect.Value) reflect.Value
func SafeReflectValue(refV reflect.Value) reflect.Value
func SaveFile(raw interface{}, filePath string) error
func SaveTempFile(content interface{}, pattern string) (string, error)
func SavepointTransactionWithCallback(db *gorm.DB, callback func(st *SavepointTransaction) error) error
func ScanHTTPHeader(reader io.Reader, headerCallback func(rawHeader []byte), prefix []byte, ...) error
func ScanHTTPHeaderSimple(reader io.Reader, headerCallback func(rawHeader []byte), prefix []byte) error
func ScanHTTPHeaderWithHeaderFolding(reader io.Reader, headerCallback func(rawHeader []byte), prefix []byte) error
func SetContextKey(ctx context.Context, key string, value any) context.Context
func SetCurrentAbsPath(path ...string)
func SetSkipBottomFrameNum(skip int)
func SetSkipFrameNum(skip int)
func SetUnexportedField(field reflect.Value, value interface{})
func ShouldRemoveZeroContentLengthHeader(s string) bool
func ShuffleInt(slice []int)
func ShuffleString(slice []string)
func SimHash(raw []byte) uint64
func SimilarStr(str1 []rune, str2 []rune) (int, int, int)
func SimplifyUtf8(raw []byte) ([]byte, error)
func SliceGroup(origin []string, groupSize int) [][]string
func SnakeString(s string) string
func SocketTypeUint32ToString(i uint32) string
func Spinlock(t float64, h func() bool) error
func SplitHostsToPrivateAndPublic(hosts ...string) (privs, pub []string)
func StableReader(conn io.Reader, timeout time.Duration, maxSize int) []byte
func StableReaderEx(conn net.Conn, timeout time.Duration, maxSize int) []byte
func StandBase64(braw []byte) []byte
func StarAsWildcardToRegexp(prefix string, target string) (*regexp.Regexp, error)
func StartCacheLog(ctx context.Context, n int)
func StringAfter(value string, a string) string
func StringArrayContains(array []string, element string) bool
func StringArrayFilterEmpty(array []string) []string
func StringArrayIndex(array []string, element string) int
func StringArrayMerge(t ...[]string) []string
func StringAsFileParams(target interface{}) []byte
func StringBefore(value string, a string) string
func StringContainsAllOfSubString(s string, subs []string) bool
func StringContainsAnyOfSubString(s string, subs []string) bool
func StringGlobArrayContains(array []string, element string, seps ...rune) bool
func StringGlobContains(pattern string, element string, seps ...rune) bool
func StringHasPrefix(s string, prefix []string) bool
func StringLiteralToAny(s string) any
func StringLowerAndTrimSpace(raw string) string
func StringOr(s ...string) string
func StringReverse(s string) string
func StringSliceContain(s interface{}, raw string) (result bool)
func StringSliceContainsAll(s []string, elements ...string) bool
func StringSplitAndStrip(raw string, sep string) []string
func StringSubStringArrayContains(array []string, element string) bool
func StringToAsciiBytes(s string) []byte
func TCPNoDelay(i net.Conn)
func TLSConfigSetCheckServerName(tlsConfig *tls.Config, host string) *tls.Config
func Tick1sWithTimeout(timeout time.Duration, falseToBreak func() bool) (exitedByCondition bool)
func TickEvery1s(falseToBreak func() bool)
func TickWithTimeout(timeout, interval time.Duration, falseToBreak func() bool) (exitedByCondition bool)
func TickWithTimeoutContext(ctx context.Context, timeout, interval time.Duration, falseToBreak func() bool) (exitedByCondition bool)
func TimeoutContext(d time.Duration) context.Context
func TimeoutContextSeconds(d float64) context.Context
func TimestampMs() int64
func TimestampNano() int64
func TimestampSecond() int64
func ToBytes(s string) (uint64, error)
func ToLowerAndStrip(s string) string
func ToMapParams(params any) (map[string]any, error)
func ToMegabytes(s string) (uint64, error)
func ToNsServer(server string) string
func TrimFileNameExt(raw string) string
func TryCloseChannel(i any)
func TryWriteChannel[T any](c chan T, data T) (ret bool)
func UTF8Reader(r io.Reader) io.Reader
func Uint32ToIPv4(ip uint32) net.IP
func UnquoteANSIC(s string) (string, error)
func UnquoteANSICWithQuote(s string, quote rune) (string, error)
func UnquoteCSV(s string) string
func UnsafeBytesToString(b []byte) string
func UnsafeStringToBytes(s string) []byte
func Url2UnEscapeString(u *url.URL) string
func UrlJoin(origin string, paths ...string) (newURL string, err error)
func UrlJoinParams(i string, params ...interface{}) string
func Utf8EncodeBySpecificLength(str []byte, l int) []byte
func VersionClean(v string) string
func VersionCompare(v1, v2 string) (int, error)
func VersionEqual(v1, v2 string) bool
func VersionGreater(v1, v2 string) bool
func VersionGreaterEqual(v1, v2 string) bool
func VersionLess(v1, v2 string) bool
func VersionLessEqual(v1, v2 string) bool
func WaitConnect(addr string, timeout float64) error
func WaitRoutinesFromSlice[T any](arg []T, job func(T))
func WithCacheCapacity(capacity uint64) cacheExOption
func WithCacheTTL(ttl ...time.Duration) cacheExOption
func Wrap(err error, msg string) error
func Wrapf(err error, format string, args ...interface{}) error
func ZlibCompress(i interface{}) ([]byte, error)
func ZlibDeCompress(ret []byte) ([]byte, error)
type AssertTestingT
- func (a AssertTestingT) Errorf(format string, args ...interface{})
type AsyncFactory
- func NewAsyncFactory[T any](CTX context.Context, factor func() (T, error)) *AsyncFactory[T]
- func (af *AsyncFactory[T]) Close()
- func (af *AsyncFactory[T]) Get() (T, error)
type AtomicBool
- func NewAtomicBool() *AtomicBool
- func NewBool(ok bool) *AtomicBool
- func (ab *AtomicBool) IsSet() bool
- func (ab *AtomicBool) Set()
- func (ab *AtomicBool) SetTo(yes bool)
- func (ab *AtomicBool) SetToIf(old, new bool) (set bool)
- func (ab *AtomicBool) UnSet()
type AutoFlushWriter
- func WriterAutoFlush(writer io.Writer) *AutoFlushWriter
- func (w *AutoFlushWriter) Write(data []byte) (int, error)
type Barrier
- func (b *Barrier) Add(delta int)
- func (b *Barrier) Done()
type BatchProcessor
- func NewBatchProcessor[T any](ctx context.Context, dataChannel <-chan T, opts ...BatchProcessorOption[T]) *BatchProcessor[T]
- func (b *BatchProcessor[T]) Start()
- func (b *BatchProcessor[T]) Wait()
type BatchProcessorConfig
type BatchProcessorOption
- func WithBatchProcessorCallBack[T any](cb func([]T)) BatchProcessorOption[T]
- func WithBatchProcessorSize[T any](size int) BatchProcessorOption[T]
- func WithBatchProcessorTimeout[T any](timeout int) BatchProcessorOption[T]
type BruteDictParser
- func NewBruteDictParser(userDict, passDict string) (*BruteDictParser, error)
- func (b *BruteDictParser) Next() (*UserPassPair, error)
type BufferedPeekableConn
- func NewPeekableNetConn(r net.Conn) *BufferedPeekableConn
- func (b *BufferedPeekableConn) GetBuf() []byte
- func (b *BufferedPeekableConn) GetOriginConn() net.Conn
- func (b *BufferedPeekableConn) GetReader() io.Reader
- func (b *BufferedPeekableConn) Peek(i int) ([]byte, error)
- func (b *BufferedPeekableConn) PeekByte() (byte, error)
- func (b *BufferedPeekableConn) PeekUint16() uint16
- func (b *BufferedPeekableConn) Read(buf []byte) (int, error)
- func (b *BufferedPeekableConn) SetBuf(buf []byte)
type BufferedPeekableReader
- func NewPeekableReader(r io.Reader) *BufferedPeekableReader
- func (b *BufferedPeekableReader) GetBuf() []byte
- func (b *BufferedPeekableReader) GetReader() io.Reader
- func (b *BufferedPeekableReader) Peek(i int) ([]byte, error)
- func (b *BufferedPeekableReader) Read(buf []byte) (int, error)
- func (b *BufferedPeekableReader) SetBuf(buf []byte)
type BufferedPeekableReaderWriter
- func NewPeekableReaderWriter(r io.ReadWriter) *BufferedPeekableReaderWriter
- func (b *BufferedPeekableReaderWriter) GetBuf() []byte
- func (b *BufferedPeekableReaderWriter) GetReader() io.Reader
- func (b *BufferedPeekableReaderWriter) Peek(i int) ([]byte, error)
- func (b *BufferedPeekableReaderWriter) Read(buf []byte) (int, error)
- func (b *BufferedPeekableReaderWriter) SetBuf(buf []byte)
type CRLFtoLFReader
- func NewCRLFtoLFReader(source io.Reader) *CRLFtoLFReader
- func (r *CRLFtoLFReader) Read(p []byte) (n int, err error)
type Cache
- func NewLRUCache[T any](capacity uint64) *Cache[T]
- func NewTTLCache[T any](ttls ...time.Duration) *Cache[T]
type CacheEx
- func NewCacheEx[T any](opt ...cacheExOption) *CacheEx[T]
type CacheExWithKey
- func NewCacheExWithKey[U comparable, T any](opt ...cacheExOption) *CacheExWithKey[U, T]
- func (cache *CacheExWithKey[U, T]) Close()
- func (cache *CacheExWithKey[U, T]) Count() int
- func (cache *CacheExWithKey[U, T]) ForEach(handler func(U, T))
- func (cache *CacheExWithKey[U, T]) Get(key U) (value T, exists bool)
- func (cache *CacheExWithKey[U, T]) GetAll() map[U]T
- func (c *CacheExWithKey[U, T]) GetOrLoad(key U, dataLoader func() (T, error)) (T, error)
- func (cache *CacheExWithKey[U, T]) Purge()
- func (cache *CacheExWithKey[U, T]) Remove(key U) bool
- func (cache *CacheExWithKey[U, T]) Set(key U, value T)
- func (cache *CacheExWithKey[U, T]) SetExpirationCallback(callback expireCallback[U, T])
- func (cache *CacheExWithKey[U, T]) SetNewItemCallback(callback itemCallback[U, T])
- func (cache *CacheExWithKey[U, T]) SetTTL(ttl time.Duration)
- func (cache *CacheExWithKey[U, T]) SetWithTTL(key U, value T, ttl time.Duration)
- func (cache *CacheExWithKey[U, T]) SkipTtlExtensionOnHit(value bool)
type CacheWithKey
- func NewLRUCacheWithKey[U comparable, T any](capacity uint64) *CacheWithKey[U, T]
- func NewTTLCacheWithKey[U comparable, T any](ttls ...time.Duration) *CacheWithKey[U, T]
- func (cache *CacheWithKey[U, T]) GetOrLoad(key U, dataLoader func() (T, error)) (T, error)
- func (cache *CacheWithKey[U, T]) SetExpirationCallback(callback expireCallbackWithoutReason[U, T])
type CircularQueue
- func NewCircularQueue(capacity int) *CircularQueue
- func (q *CircularQueue) GetElements() []interface{}
- func (q *CircularQueue) Push(x interface{})
type Complex
type CondBarrier
- func NewCondBarrier() *CondBarrier
- func NewCondBarrierContext(ctx context.Context) *CondBarrier
- func (cb *CondBarrier) Cancel()
- func (cb *CondBarrier) CreateBarrier(name string) *Barrier
- func (cb *CondBarrier) Wait(names ...string) error
- func (cb *CondBarrier) WaitAll() error
type CoolDown
- func NewCoolDown(d time.Duration) *CoolDown
- func NewCoolDownContext(d time.Duration, ctx context.Context) *CoolDown
- func (c *CoolDown) Do(f func())
- func (c *CoolDown) DoOr(f func(), fallback func())
- func (c *CoolDown) Reset(d time.Duration)
type CoolDownFetcher
- func NewCoolDownFetcher(timeoutDuration time.Duration) *CoolDownFetcher
- func (c *CoolDownFetcher) Fetch(handler func() (any, error)) (any, error)
type CountingReadWriter
- func NewCountingReadWriter(w io.ReadWriter) *CountingReadWriter
- func (cw *CountingReadWriter) Count() int
- func (cr *CountingReadWriter) Read(p []byte) (n int, err error)
- func (cw *CountingReadWriter) Write(p []byte) (n int, err error)
type CountingReader
- func NewCountingReader(r io.Reader) *CountingReader
- func (cr *CountingReader) Count() int
- func (cr *CountingReader) Read(p []byte) (n int, err error)
type CountingWriter
- func NewCountingWriter(w io.Writer) *CountingWriter
- func (cw *CountingWriter) Count() int
- func (cw *CountingWriter) Write(p []byte) (n int, err error)
type CustomWriter
- func NewWriter(f func(p []byte) (n int, err error)) *CustomWriter
- func (c *CustomWriter) Write(p []byte) (n int, err error)
type DelayWaiter
- func NewDelayWaiter(min int32, max int32) (*DelayWaiter, error)
- func (d *DelayWaiter) Wait()
- func (d *DelayWaiter) WaitWithProbabilityPercent(raw float64)
type EventWatcherManager
- func NewEntityWatcher(ctx context.Context, triggerTime time.Duration, triggerCount int) *EventWatcherManager
- func (ew *EventWatcherManager) StopWatch(key string)
- func (ew *EventWatcherManager) Watch(key string, callback func(key string), firstWatch func(key string))
type EvictionReason
type FileInfo
- func ReadDir(p string) ([]*FileInfo, error)
- func ReadDirWithLimit(p string, limit int) ([]*FileInfo, error)
- func ReadDirsRecursively(p string) ([]*FileInfo, error)
- func ReadFilesRecursively(p string) ([]*FileInfo, error)
- func ReadFilesRecursivelyWithLimit(p string, limit int) ([]*FileInfo, error)
type FileOpenerType
type Float
type FloatSecondsDelayWaiter
- func NewFloatSecondsDelayWaiter(min, max float64) (*FloatSecondsDelayWaiter, error)
- func NewFloatSecondsDelayWaiterSingle(min float64) (*FloatSecondsDelayWaiter, error)
- func (d *FloatSecondsDelayWaiter) Wait()
- func (d *FloatSecondsDelayWaiter) WaitWithProbabilityPercent(raw float64)
type Frame
- func (f Frame) Format(s fmt.State, verb rune)
- func (f Frame) MarshalText() ([]byte, error)
type GlobFilter
- func NewGlobFilter(separator rune, exclude ...string) *GlobFilter
- func (f *GlobFilter) Add(block ...string)
- func (f *GlobFilter) Contains(target string) bool
type GoroutineLogBuffer
- func NewGoroutineLogBuffer(fallback io.Writer, opts ...GoroutineLogBufferOption) *GoroutineLogBuffer
- func (b *GoroutineLogBuffer) Attach() (*bytes.Buffer, func())
- func (b *GoroutineLogBuffer) Flush(label string, buf *bytes.Buffer, failed bool)
- func (b *GoroutineLogBuffer) FlushDefault()
- func (b *GoroutineLogBuffer) Write(p []byte) (int, error)
type GoroutineLogBufferOption
- func WithGoroutineLogFailedOnly(b bool) GoroutineLogBufferOption
type GoroutineLogCapture
- func StartGoroutineLogCapture(fallback io.Writer, opts ...GoroutineLogBufferOption) (*GoroutineLogCapture, error)
- func (c *GoroutineLogCapture) Stop()
type HTTPPacketFilter
- func NewHTTPPacketFilter() *HTTPPacketFilter
- func (j *HTTPPacketFilter) Conditions() []string
- func (h *HTTPPacketFilter) Hash() string
- func (h *HTTPPacketFilter) IsAllowed(req *http.Request, rsp *http.Response) bool
- func (i *HTTPPacketFilter) Remove(name string)
- func (j *HTTPPacketFilter) SetAllowForRequestHeader(header, regexp string)
- func (j *HTTPPacketFilter) SetAllowForRequestPath(regexp string)
- func (j *HTTPPacketFilter) SetAllowForRequestRaw(regexp string)
- func (j *HTTPPacketFilter) SetAllowForResponseHeader(header, regexp string)
- func (j *HTTPPacketFilter) SetAllowForResponseRaw(regexp string)
- func (j *HTTPPacketFilter) SetRejectForRequestHeader(header, regexp string)
- func (j *HTTPPacketFilter) SetRejectForRequestPath(regexp string)
- func (j *HTTPPacketFilter) SetRejectForRequestRaw(regexp string)
- func (j *HTTPPacketFilter) SetRejectForResponseHeader(header, regexp string)
- func (j *HTTPPacketFilter) SetRejectForResponseRaw(regexp string)
type HostPortClassifier
- func NewHostPortClassifier() *HostPortClassifier
- func (h *HostPortClassifier) AddHostPort(tag string, hosts []string, ports []string, ttl time.Duration) error
- func (h *HostPortClassifier) FilterTagByHostPort(host string, port int) []string
type HostsFilter
- func NewHostsFilter(excludeHosts ...string) *HostsFilter
- func (f *HostsFilter) Add(block ...string)
- func (f *HostsFilter) Contains(target string) bool
type IntHeap
- func NewIntHeap(init ...[]int) *IntHeap
- func (h *IntHeap) Index(i int) int
- func (h *IntHeap) Len() int
- func (h *IntHeap) Pop() interface{}
- func (h *IntHeap) Push(x interface{})
type Integer
type LimitRate
- func NewLimitRate(d time.Duration) *LimitRate
- func (l *LimitRate) WaitUntilNextAsync()
- func (l *LimitRate) WaitUntilNextAsyncWithFallback(f func())
- func (l *LimitRate) WaitUntilNextSync()
type MatchedRule
- func ParseNmapServiceMatchedRule(raw []byte) []*MatchedRule
type Once
- func NewOnce() *Once
- func (o *Once) Do(f func())
- func (o *Once) DoOr(f func(), fallback func())
- func (o *Once) Done() bool
- func (o *Once) Reset()
type Ordered
type ParallelProcessConfig
type ParallelProcessOption
- func WithParallelProcessConcurrency(concurrency int) ParallelProcessOption
- func WithParallelProcessDeferTask(h func()) ParallelProcessOption
- func WithParallelProcessFinishCallback(callback func()) ParallelProcessOption
- func WithParallelProcessStartCallback(callback func()) ParallelProcessOption
- func WithParallelProcessStartTask(h func()) ParallelProcessOption
type PathForest
- func GeneratePathTrees(l ...string) (*PathForest, error)
- func (p *PathForest) AddPath(path string, f any) error
- func (p *PathForest) Get(path string) (*PathNode, error)
- func (p *PathForest) Output() []*PathNode
- func (w *PathForest) ReadOnly()
- func (p *PathForest) Recursive(f func(node2 *PathNode))
type PathNode
- func (p *PathNode) AllChildren() []*PathNode
- func (p *PathNode) Existed(i string) bool
- func (n *PathNode) GetDepth() int
type PathNodes
type PortScanTarget
- func SplitHostsAndPorts(hosts, ports string, portGroupSize int, proto string) []PortScanTarget
- func (t *PortScanTarget) String() string
type PortsFilter
- func NewPortsFilter(blocks ...string) *PortsFilter
- func (f *PortsFilter) Add(block ...string)
- func (f *PortsFilter) Contains(port int) bool
type ProbeRule
- func ParseNmapServiceProbeRule(raw []byte) []*ProbeRule
type ProtoReader
- func NewProtoReader(reader io.Reader) *ProtoReader
- func (pr *ProtoReader) ReadBool() (bool, error)
- func (pr *ProtoReader) ReadBytes() ([]byte, error)
- func (pr *ProtoReader) ReadFloat32() (float32, error)
- func (pr *ProtoReader) ReadInt32() (int32, error)
- func (pr *ProtoReader) ReadInt64() (int64, error)
- func (pr *ProtoReader) ReadMagicHeader(expectedMagic string) error
- func (pr *ProtoReader) ReadString() (string, error)
- func (pr *ProtoReader) ReadUint32() (uint32, error)
- func (pr *ProtoReader) ReadVarint() (uint64, error)
type ProtoType
type ProtoWriter
- func NewProtoWriter(writer io.Writer) *ProtoWriter
- func (pw *ProtoWriter) WriteBool(value bool) error
- func (pw *ProtoWriter) WriteBytes(value []byte) error
- func (pw *ProtoWriter) WriteFloat32(value float32) error
- func (pw *ProtoWriter) WriteInt32(value int32) error
- func (pw *ProtoWriter) WriteInt64(value int64) error
- func (pw *ProtoWriter) WriteMagicHeader(magic string) error
- func (pw *ProtoWriter) WriteString(value string) error
- func (pw *ProtoWriter) WriteUint32(value uint32) error
- func (pw *ProtoWriter) WriteVarint(value uint64) error
type RRFScoredData
type RankScoredData
type RequireTestingT
- func NewRequireTestT(a AssertTestingT, f func()) *RequireTestingT
- func (r *RequireTestingT) FailNow()
type Result
type SSHClient
- func SSHDial(network, addr string, config *ssh.ClientConfig) (*SSHClient, error)
- func SSHDialWithKey(addr, user, keyfile string) (*SSHClient, error)
- func SSHDialWithKeyWithPassphrase(addr, user, keyfile string, passphrase string) (*SSHClient, error)
- func SSHDialWithPasswd(addr, user, passwd string) (*SSHClient, error)
- func (c *SSHClient) Close() error
- func (c *SSHClient) Cmd(cmd string) *SSHRemoteScript
- func (c *SSHClient) CopyLocalFileToRemote(srcFilePath string, dstFilePath string) error
- func (c *SSHClient) CopyRemoteFileToLocal(dstFilePath string, srcFilePath string) error
- func (c *SSHClient) Script(script string) *SSHRemoteScript
- func (c *SSHClient) ScriptFile(fname string) *SSHRemoteScript
- func (c *SSHClient) Shell() *SSHRemoteShell
- func (c *SSHClient) Terminal(config *TerminalConfig) *SSHRemoteShell
type SSHRemoteScript
- func (rs *SSHRemoteScript) Cmd(cmd string) *SSHRemoteScript
- func (rs *SSHRemoteScript) Output() ([]byte, error)
- func (rs *SSHRemoteScript) Run() error
- func (rs *SSHRemoteScript) SetStdio(stdout, stderr io.Writer) *SSHRemoteScript
- func (rs *SSHRemoteScript) SmartOutput() ([]byte, error)
type SSHRemoteScriptType
type SSHRemoteShell
- func (rs *SSHRemoteShell) SetStdio(stdin io.Reader, stdout, stderr io.Writer) *SSHRemoteShell
- func (rs *SSHRemoteShell) Start() error
type SSHRemoteShellType
type SafeMap
- func NewSafeMap[V any]() *SafeMap[V]
type SafeMapWithKey
- func NewSafeMapWithKey[K comparable, V any]() *SafeMapWithKey[K, V]
- func (sm *SafeMapWithKey[K, V]) Clear()
- func (sm *SafeMapWithKey[K, V]) Count() int
- func (sm *SafeMapWithKey[K, V]) Delete(key K)
- func (sm *SafeMapWithKey[K, V]) ForEach(f func(key K, value V) bool)
- func (sm *SafeMapWithKey[K, V]) Get(key K) (V, bool)
- func (sm *SafeMapWithKey[K, V]) GetAll() map[K]V
- func (sm *SafeMapWithKey[K, V]) GetOrLoad(key K, f func() V) V
- func (sm *SafeMapWithKey[K, V]) Have(key K) bool
- func (sm *SafeMapWithKey[K, V]) Set(key K, value V)
- func (sm *SafeMapWithKey[K, V]) Values() []V
type SavepointTransaction
- func NewSavepointTransaction(db *gorm.DB) *SavepointTransaction
- func (st *SavepointTransaction) Begin() (*gorm.DB, error)
- func (st *SavepointTransaction) Commit() error
- func (st *SavepointTransaction) GetDB() *gorm.DB
- func (st *SavepointTransaction) GetLevel() int
- func (st *SavepointTransaction) IsInTransaction() bool
- func (st *SavepointTransaction) Rollback() error
type Set
- func NewSet[T comparable](list ...[]T) *Set[T]
- func (s *Set[T]) Add(item T)
- func (s *Set[T]) AddList(items []T)
- func (s *Set[T]) And(other *Set[T]) *Set[T]
- func (s *Set[T]) Clear()
- func (s *Set[T]) Diff(other *Set[T]) *Set[T]
- func (s *Set[T]) ForEach(h func(T))
- func (s *Set[T]) Has(item T) bool
- func (s *Set[T]) IsEmpty() bool
- func (s *Set[T]) Len() int
- func (s *Set[T]) List() []T
- func (s *Set[T]) Or(other *Set[T]) *Set[T]
- func (s *Set[T]) Remove(item T)
type Signed
type SizedWaitGroup
- func NewSizedWaitGroup(limit int, ctxs ...context.Context) *SizedWaitGroup
- func (s *SizedWaitGroup) Add(delta ...int)
- func (s *SizedWaitGroup) AddWithContext(ctx context.Context, delta ...int) error
- func (s *SizedWaitGroup) Done()
- func (s *SizedWaitGroup) SetContext(ctx context.Context)
- func (s *SizedWaitGroup) SetZero()
- func (s *SizedWaitGroup) Wait()
type Stack
- func NewStack[T any]() *Stack[T]
- func (this *Stack[T]) CreateShadowStack() func()
- func (this *Stack[T]) ForeachStack(f func(T) bool)
- func (this *Stack[T]) Free()
- func (this *Stack[T]) HaveLastStackValue() bool
- func (this *Stack[T]) IsEmpty() bool
- func (this *Stack[T]) LastStackValue() T
- func (this *Stack[T]) Len() int
- func (this *Stack[T]) Peek() T
- func (this *Stack[T]) PeekN(n int) T
- func (this *Stack[T]) Pop() T
- func (this *Stack[T]) PopN(n int) []T
- func (this *Stack[T]) Push(value T)
- func (this *Stack[T]) Size() int
- func (this *Stack[T]) Values(sizes ...int) []T
type StackTrace
- func (st StackTrace) Format(s fmt.State, verb rune)
type StringRoundRobinSelector
- func NewStringRoundRobinSelector(l ...string) *StringRoundRobinSelector
- func (s *StringRoundRobinSelector) Add(raw ...string)
- func (s *StringRoundRobinSelector) Len() int
- func (s *StringRoundRobinSelector) List() []string
- func (s *StringRoundRobinSelector) Next() string
type Switch
- func NewSwitch(b ...bool) *Switch
- func (c *Switch) Condition() bool
- func (c *Switch) Switch()
- func (c *Switch) SwitchTo(b bool)
- func (c *Switch) WaitUntilOpen()
type TerminalConfig
type TextSplitter
- func NewTextSplitter() *TextSplitter
- func (ts *TextSplitter) Split(ctx context.Context, text string) []string
- func (ts *TextSplitter) SplitReader(ctx context.Context, reader io.Reader) chan string
type TriggerWriter
- func NewTriggerWriter(trigger uint64, h func(buffer io.ReadCloser, triggerEvent string)) *TriggerWriter
- func NewTriggerWriterEx(sizeTrigger uint64, timeTrigger time.Duration, ...) *TriggerWriter
- func (f *TriggerWriter) Close() error
- func (f *TriggerWriter) GetCount() int64
- func (f *TriggerWriter) Write(p []byte) (n int, err error)
type TrimLeftReader
- func NewTrimLeftReader(r io.Reader) *TrimLeftReader
- func (t *TrimLeftReader) Read(p []byte) (int, error)
type Unsigned
type UserPassPair
type WebHookServer
- func NewWebHookServer(port int, cb func(data interface{})) *WebHookServer
- func (w *WebHookServer) Addr() string
- func (w *WebHookServer) Shutdown()
- func (w *WebHookServer) Start()
type YakError
- func (err *YakError) Cause() []error
- func (err *YakError) Error() string
- func (e *YakError) ErrorWithStack() string
- func (err *YakError) Format(s fmt.State, verb rune)
- func (e *YakError) Is(rerr error) bool
- func (s YakError) StackTrace() StackTrace
- func (err *YakError) Unwrap() []error

Constants ¶

View Source

const (
	BYTE = 1 << (10 * iota)
	KILOBYTE
	MEGABYTE
	GIGABYTE
	TERABYTE
	PETABYTE
	EXABYTE
)

View Source

const (
	CommonHeaderStat string = "common-header"
	HeaderCheckStat         = "header-Check"
)

View Source

const (
	AllSepcialChars = ",./<>?;':\"[]{}`~!@#$%^&*()_+-=\\|"
	LittleChar      = "abcdefghijklmnopqrstuvwxyz"
	BigChar         = "ABCDEFGHIJKLMNOPQRSTUVWXYZ"
	NumberChar      = "1234567890"
	LetterChar      = LittleChar + BigChar
	AlphaNumChar    = LittleChar + BigChar + NumberChar
	PasswordChar    = passwordSepcialChars + LittleChar + BigChar + NumberChar
)

View Source

const CRLF = "\r\n"

View Source

const DefaultDateFormat = "2006-01-02"

View Source

const DefaultTimeFormat = "2006_01_02-15_04_05"

View Source

const DefaultTimeFormat2 = "20060102_15_04_05"

View Source

const DefaultTimeFormat3 = "2006/01/02 15:04:05"

Variables ¶

View Source

var (
	GbkToUtf8 = codec.GbkToUtf8
	Utf8ToGbk = codec.Utf8ToGbk
)

View Source

var BashCompleteScriptTpl = `` /* 1147-byte string literal not displayed */

View Source

var DefaultTextSplitter = NewTextSplitter()

View Source

var ErrCoolDownSkipCache = Error("Skip cache")

View Source

var GBKSafeString = codec.GBKSafeString

View Source

var NewBufPipe = bufpipe.NewBufPipe

View Source

var NewPipe = bufpipe.NewPipe

View Source

var ParseStringToInts = ParseStringToPorts

View Source

var ShrinkString = codec.ShrinkString

View Source

var ShrinkTextBlock = codec.ShrinkTextBlock

View Source

var (
	TargetIsLoopback = Errorf("loopback")
)

View Source

var WaitBySignal = func(fn func(), sigs ...os.Signal) {
	sigC := NewSignalChannel(sigs...)
	defer signal.Stop(sigC)

	for {
		select {
		case <-sigC:
			log.Warn("recv signal abort")
			fn()
			return
		}
	}
}

View Source

var WaitReleaseBySignal = func(fn func()) {
	sigC := NewSignalChannel(os.Interrupt, syscall.SIGTERM, syscall.SIGINT, syscall.SIGKILL)
	defer signal.Stop(sigC)

	for {
		select {
		case <-sigC:
			log.Warn("recv signal abort")
			fn()
			return
		}
	}
}

View Source

var ZshCompleteScriptTpl = `` /* 1072-byte string literal not displayed */

Functions ¶

func AddressFamilyUint32ToString ¶

func AddressFamilyUint32ToString(i uint32) string

func AppendDefaultPort ¶ added in v1.2.3

func AppendDefaultPort(raw string, port int) string

AppendDefaultPort returns host:port format. If the port is already specified in the host, it will be returned directly. wss -> 443 ws -> 80 http -> 80 https -> 443

func AppendSliceItemWhenNotExists ¶

func AppendSliceItemWhenNotExists[T comparable](s []T, t T) []T

func AsDebugString ¶ added in v1.2.9

func AsDebugString(i interface{}, raws ...bool) string

func AsciiBytesToRegexpMatchedRunes ¶

func AsciiBytesToRegexpMatchedRunes(in []byte) []rune

func AsciiBytesToRegexpMatchedString ¶

func AsciiBytesToRegexpMatchedString(in []byte) string

func AsciiEqualFold ¶

func AsciiEqualFold(s, t string) bool

AsciiEqualFold is strings.EqualFold, ASCII only. It reports whether s and t are equal, ASCII-case-insensitively.

func AsciiToLower ¶

func AsciiToLower(s string) (lower string, ok bool)

asciiToLower returns the lowercase version of s if s is ASCII and printable, and whether or not it was.

func AttemptWithDelay ¶

func AttemptWithDelay(maxIteration int, delay time.Duration, f func() error) error

func AttemptWithDelayFast ¶

func AttemptWithDelayFast(f func() error) error

func BufioReadLine ¶

func BufioReadLine(reader *bufio.Reader) ([]byte, error)

func BufioReadLineString ¶ added in v1.3.0

func BufioReadLineString(reader *bufio.Reader) (string, error)

func ByteCountBinary ¶

func ByteCountBinary(b int64) string

func ByteCountDecimal ¶

func ByteCountDecimal(b int64) string

func ByteSize ¶

func ByteSize(bytes uint64) string

ByteSize returns a human-readable byte string of the form 10M, 12.5K, and so forth. The following units are available:

E: Exabyte
P: Petabyte
T: Terabyte
G: Gigabyte
M: Megabyte
K: Kilobyte
B: Byte

The unit that results in the smallest number greater than or equal to 1 is always chosen.

func BytesClone ¶

func BytesClone(raw []byte) (newBytes []byte)

func CacheFunc ¶ added in v1.2.7

func CacheFunc[T any](duration time.Duration, f func() (T, error)) func() (T, error)

func CalcMd5 ¶

func CalcMd5(items ...interface{}) string

func CalcSSDeepStability ¶

func CalcSSDeepStability(req ...[]byte) (float64, error)

CalcSSDeepStability 使用模糊哈希算法计算多段文本之间的相似度，返回相似度与错误。传入的文本应该为大文本，即长度大于 30 kb。 Example: ``` p, err = str.CalcSSDeepStability(str.RandStr(100000), str.RandStr(100000)) ```

func CalcSha1 ¶

func CalcSha1(items ...interface{}) string

func CalcSha1WithSuffix ¶

func CalcSha1WithSuffix(items []interface{}, suffix string) string

func CalcSha256 ¶ added in v1.2.8

func CalcSha256(items ...interface{}) string

func CalcSimHashStability ¶

func CalcSimHashStability(req ...[]byte) (float64, error)

CalcSimHashStability 使用 SimHash 算法计算多段文本之间的相似度，返回相似度与错误。 Example: ``` p, err = str.CalcSimHashStability("hello", "hello world") // p = 0.96484375 ```

func CalcSimilarity ¶

func CalcSimilarity(raw ...[]byte) float64

CalcSimilarity 计算多段文本之间的相似度，根据最长的文本长度选择不同的算法如果最长的文本长度小于等于 2000，使用文本子串匹配算法如果最短的文本长度大于等于 30000，使用模糊哈希算法如果上述算法出现错误，则使用 SimHash 算法 Example: ``` str.CalcSimilarity("hello", "hello world") // 0.625 ```

func CalcTextSubStringStability ¶

func CalcTextSubStringStability(raw ...[]byte) (float64, error)

CalcTextMaxSubStrStability 使用文本子串匹配算法计算多段文本之间的相似度，返回相似度与错误 Example: ``` p, err = str.CalcTextMaxSubStrStability("hello", "hello world") // p = 0.625 ```

func CallGeneralClose ¶

func CallGeneralClose(closer any)

func CallWithCtx ¶ added in v1.2.9

func CallWithCtx(ctx context.Context, cb func()) error

func CallWithTimeout ¶ added in v1.2.9

func CallWithTimeout(timeout float64, cb func()) error

func ChanStringToSlice ¶

func ChanStringToSlice(c chan string) (result []string)

func CloseConnSafe ¶

func CloseConnSafe(conn net.Conn)

func CloseWrite ¶

func CloseWrite(i any)

func ConcatPorts ¶

func ConcatPorts(ports []int) string

func ConcurrentCopyDirectory ¶ added in v1.2.9

func ConcurrentCopyDirectory(source string, destination string, threads int, isMove bool) error

func ConnExpect ¶

func ConnExpect(c net.Conn, timeout time.Duration, callback func([]byte) bool) (bool, error)

func ContainsAll ¶ added in v1.3.3

func ContainsAll[T comparable](s []T, vals ...T) bool

func ContainsAny ¶ added in v1.3.3

func ContainsAny[T comparable](s []T, vals ...T) bool

func ContainsJSON ¶ added in v1.3.3

func ContainsJSON(raw string) (string, bool)

func ConvertTextFileToYakFuzztagByPath ¶

func ConvertTextFileToYakFuzztagByPath(file_bin_path string) (string, error)

func ConvertToStringSlice ¶

func ConvertToStringSlice(raw ...interface{}) (r []string)

func CopyBytes ¶

func CopyBytes(rsp []byte) []byte

func CopyDirectory ¶ added in v1.2.9

func CopyDirectory(source string, destination string, isMove bool) error

func CopyDirectoryEx ¶

func CopyDirectoryEx(source string,
	destination string,
	isMove bool,
	fs fi.FileSystem,
) error

func CopyFile ¶ added in v1.2.8

func CopyFile(source, destination string) error

func CopyFileEx ¶

func CopyFileEx(
	source string,
	destination string,
	fs fi.FileSystem,
) error

func CopyMapInterface ¶

func CopyMapInterface(i map[string]interface{}) map[string]interface{}

func CopyMapShallow ¶

func CopyMapShallow[K comparable, V any](originalMap map[K]V) map[K]V

func CopySlice ¶

func CopySlice[T any](i []T) []T

func CreateTempTestDatabaseInMemory ¶

func CreateTempTestDatabaseInMemory() (*gorm.DB, error)

func CreateUTF8StreamMirror ¶

func CreateUTF8StreamMirror(r io.Reader, cb ...func(reader io.Reader)) io.Reader

func CutBytesPrefixFunc ¶

func CutBytesPrefixFunc(raw []byte, handle func(rune) bool) ([]byte, []byte, bool)

func DataVerbose ¶

func DataVerbose(i interface{}) string

func DatePretty ¶ added in v1.3.3

func DatePretty() string

func DatetimePretty ¶

func DatetimePretty() string

func DatetimePretty2 ¶

func DatetimePretty2() string

func Debug ¶

func Debug(f func())

func DebugMockEchoWs ¶ added in v1.3.1

func DebugMockEchoWs(point string) (string, int)

func DebugMockEchoWss ¶

func DebugMockEchoWss(point string) (string, int)

func DebugMockGMHTTP ¶ added in v1.2.3

func DebugMockGMHTTP(ctx context.Context, handler func(req []byte) []byte) (string, int)

func DebugMockHTTP ¶

func DebugMockHTTP(rsp []byte) (string, int)

func DebugMockHTTP2 ¶ added in v1.2.3

func DebugMockHTTP2(ctx context.Context, handler func(req []byte) []byte) (string, int)

func DebugMockHTTP2HandlerFuncContext ¶

func DebugMockHTTP2HandlerFuncContext(ctx context.Context, handlerFunc http.HandlerFunc) (string, int)

func DebugMockHTTPEx ¶ added in v1.2.3

func DebugMockHTTPEx(handle func(req []byte) []byte) (string, int)

func DebugMockHTTPExContext ¶ added in v1.2.3

func DebugMockHTTPExContext(ctx context.Context, handle func(req []byte) []byte) (string, int)

func DebugMockHTTPHandlerFunc ¶ added in v1.2.4

func DebugMockHTTPHandlerFunc(handlerFunc http.HandlerFunc) (string, int)

func DebugMockHTTPHandlerFuncContext ¶ added in v1.2.4

func DebugMockHTTPHandlerFuncContext(ctx context.Context, handlerFunc http.HandlerFunc) (string, int)

func DebugMockHTTPKeepAliveEx ¶ added in v1.3.1

func DebugMockHTTPKeepAliveEx(handle func(req []byte) []byte) (string, int)

func DebugMockHTTPS ¶ added in v1.2.9

func DebugMockHTTPS(rsp []byte) (string, int)

func DebugMockHTTPSEx ¶ added in v1.2.3

func DebugMockHTTPSEx(handle func(req []byte) []byte) (string, int)

func DebugMockHTTPSKeepAliveEx ¶ added in v1.2.7

func DebugMockHTTPSKeepAliveEx(handle func(req []byte) []byte) (string, int)

func DebugMockHTTPServerWithContext ¶ added in v1.2.3

func DebugMockHTTPServerWithContext(ctx context.Context, https, h2, gmtlsFlag, onlyGmtls, keepAlive bool, handle func([]byte) []byte) (string, int)

func DebugMockHTTPServerWithContextWithAddress ¶ added in v1.3.0

func DebugMockHTTPServerWithContextWithAddress(ctx context.Context, addr string, https, h2, gmtlsFlag, onlyGmtls, keepAlive bool, checkServerName bool, handle func([]byte) []byte) (string, int)

func DebugMockHTTPWithTimeout ¶

func DebugMockHTTPWithTimeout(du time.Duration, rsp []byte) (string, int)

func DebugMockOnlyGMHTTP ¶ added in v1.3.1

func DebugMockOnlyGMHTTP(ctx context.Context, handler func(req []byte) []byte) (string, int)

func DebugMockTCP ¶ added in v1.2.7

func DebugMockTCP(rsp []byte) (string, int)

func DebugMockTCPEx ¶ added in v1.2.7

func DebugMockTCPEx(handleFunc handleTCPFunc) (string, int)

func DebugMockTCPHandlerFuncContext ¶ added in v1.2.7

func DebugMockTCPHandlerFuncContext(ctx context.Context, handlerFunc handleTCPFunc) (string, int)

func DebugMockWs ¶ added in v1.3.1

func DebugMockWs(handler func(conn *websocket.Conn)) (string, int)

func DomainToURLFilter ¶

func DomainToURLFilter(domain string) (*regexp.Regexp, error)

func DownloadFile ¶

func DownloadFile(ctx context.Context, client *http.Client, u string, localFile string, every1s ...func(float64)) error

func DumpFileWithTextAndFiles ¶

func DumpFileWithTextAndFiles(raw string, divider string, files ...string) (string, error)

func DumpHTTPRequest ¶ added in v1.2.6

func DumpHTTPRequest(req *http.Request, loadBody bool) ([]byte, error)

DumpHTTPRequest dumps http request to bytes **NO NOT HANDLE SMUGGLE HERE!** Transfer-Encoding is handled vai req.TransferEncoding / req.Header["Transfer-Encoding"] Content-Length is handled vai req.ContentLength / req.Header["Content-Length"] if Transfer-Encoding existed, check body chunked? if not, encode it if Transfer-Encoding and Content-Length existed at same time, use transfer-encoding

func DumpHTTPResponse ¶ added in v1.2.6

func DumpHTTPResponse(rsp *http.Response, loadBody bool, wr ...io.Writer) ([]byte, error)

DumpHTTPResponse dumps http response to bytes if loadBody is true, it will load body to memory

transfer-encoding is a special header

func DumpHostFileWithTextAndFiles ¶

func DumpHostFileWithTextAndFiles(raw string, divider string, files ...string) (string, error)

func EnableDebug ¶ added in v1.2.3

func EnableDebug()

func Error ¶

func Error(i interface{}) error

func ErrorStack ¶

func ErrorStack(origin any) (err error)

ErrorStack 捕获 panic 并返回 error

func Errorf ¶

func Errorf(format string, args ...interface{}) error

func EscapeInvalidUTF8Byte ¶

func EscapeInvalidUTF8Byte(s []byte) string

func ExportAppConfigToMap ¶

func ExportAppConfigToMap(ins any) (map[string]string, error)

func ExtractFaviconURL ¶ added in v1.3.1

func ExtractFaviconURL(siteURL string, content []byte) (string, error)

ExtractFaviconURL will receive a site url and html content return the favicon url Example:

http.ExtractFaviconURL("https://www.baidu.com", []byte(`<link rel="shortcut icon" href="/favicon.ico" type="image/x-icon">`))
http.ExtractFaviconURL("https://www.baidu.com", []byte(`<link rel="icon" href="/favicon.ico" type="image/x-icon">`))
http.ExtractFaviconURL("https://www.baidu.com", []byte(`<link rel="icon" href="/favicon.png" type="image/png">`))

func ExtractHost ¶

func ExtractHost(raw string) string

ExtractHost 尝试从字符串中解析出host和port，并返回host Example: ``` str.ExtractHost("127.0.0.1:8888") // 127.0.0.1 str.ExtractHost("https://example.com") // example.com ```

func ExtractHostPort ¶

func ExtractHostPort(raw string) string

ExtractHostPort 尝试从字符串中解析出host和port，并返回host:port Example: ``` str.ExtractHostPort("https://127.0.0.1:8888") // 127.0.0.1:8888 str.ExtractHostPort("https://baidu.com") // 127.0.0.1:443 ```

func ExtractMapValueBool ¶ added in v1.2.3

func ExtractMapValueBool(m any, key string) bool

func ExtractMapValueGeneralMap ¶ added in v1.2.3

func ExtractMapValueGeneralMap(m any, key string) map[string]any

func ExtractMapValueInt ¶ added in v1.2.3

func ExtractMapValueInt(m any, key string) int

func ExtractMapValueRaw ¶ added in v1.2.3

func ExtractMapValueRaw(m any, key string) any

func ExtractMapValueString ¶ added in v1.2.3

func ExtractMapValueString(m any, key string) string

func ExtractRawPath ¶

func ExtractRawPath(target string) string

func ExtractStrContextByKeyword ¶

func ExtractStrContextByKeyword(raw string, res []string) []string

ExtractStrContext 从字符串raw中提取一组关键字res上下文的内容，上下文的长度是512个字符确定。 Example: ``` str.ExtractStrContext("hello yak", ["hello"]) // ["hello yak"] ```

func ExtractTitleFromHTMLTitle ¶

func ExtractTitleFromHTMLTitle(s string, defaultValue string) string

func FileExists ¶

func FileExists(filename string) bool

FileExists checks if a file exists and is not a directory.

func FileLineReader ¶

func FileLineReader(file string) (chan []byte, error)

func FileLineReaderWithContext ¶

func FileLineReaderWithContext(file string, ctx context.Context) (chan []byte, error)

func FilterInterface ¶

func FilterInterface[T any](i []any) []T

func FindNearestAvailablePortWithTimeout ¶

func FindNearestAvailablePortWithTimeout(host string, originalPort int, timeout time.Duration) int

func FirstWriter ¶

func FirstWriter(onFirstWrite func([]byte)) io.Writer

func FixForParseIP ¶

func FixForParseIP(host string) string

func FixHTTPRequestForGolangNativeHTTPClient ¶ added in v1.2.6

func FixHTTPRequestForGolangNativeHTTPClient(req *http.Request)

FixHTTPRequestForGolangNativeHTTPClient utils.Read/DumpRequest is working as pair... if u want to use transport(golang native) do this `FixHTTPRequestForGolangNativeHTTPClient` helps because golang native transport will encode chunked body again

func FixHTTPRequestForHTTPDo ¶

func FixHTTPRequestForHTTPDo(r *http.Request) (*http.Request, error)

func FixHTTPRequestForHTTPDoWithHttps ¶

func FixHTTPRequestForHTTPDoWithHttps(r *http.Request, isHttps bool) (*http.Request, error)

func FixHTTPResponseForGolangNativeHTTPClient ¶ added in v1.2.6

func FixHTTPResponseForGolangNativeHTTPClient(ins *http.Response)

func FixJsonRawBytes ¶

func FixJsonRawBytes(rawBytes []byte) []byte

func FloatSecondDuration ¶

func FloatSecondDuration(f float64) time.Duration

func FlushWriter ¶ added in v1.2.8

func FlushWriter(writer io.Writer)

func Format ¶

func Format(raw string, data map[string]string) string

func GetAllFiles ¶

func GetAllFiles(path string) (fileNames []string, err error)

func GetCClassByIPv4 ¶

func GetCClassByIPv4(s string) (network string, err error)

IPv4ToCClassNetwork 尝试从一个 IPv4 地址中获取 C 类网络地址，并返回错误 Example: ``` network, err = str.IPv4ToCClassNetwork("192.168.0.1") // network = "192.168.0.0/24", err = nil ```

func GetCachedLog ¶ added in v1.2.2

func GetCachedLog() (res []string)

func GetConnectedToHostPortFromHTTPRequest ¶ added in v1.2.6

func GetConnectedToHostPortFromHTTPRequest(t *http.Request) (string, error)

func GetContextKeyBool ¶

func GetContextKeyBool(ctx context.Context, key string) bool

func GetContextKeyString ¶

func GetContextKeyString(ctx context.Context, key string) string

func GetCurrentDate ¶

func GetCurrentDate() (time.Time, error)

func GetCurrentWeekMonday ¶

func GetCurrentWeekMonday() (time.Time, error)

func GetDate ¶

func GetDate(t time.Time) (time.Time, error)

func GetDefaultGMTLSConfig ¶ added in v1.2.3

func GetDefaultGMTLSConfig(i float64) *gmtls.Config

func GetDefaultOnlyGMTLSConfig ¶ added in v1.3.1

func GetDefaultOnlyGMTLSConfig(i float64) *gmtls.Config

func GetDefaultTLSConfig ¶ added in v1.2.3

func GetDefaultTLSConfig(i float64) *tls.Config

func GetExecutableFromEnv ¶ added in v1.2.8

func GetExecutableFromEnv(cmd string) (string, error)

func GetFileAbsDir ¶

func GetFileAbsDir(filePath string) (string, error)

func GetFileAbsPath ¶

func GetFileAbsPath(filePath string) (string, error)

func GetFileMd5 ¶

func GetFileMd5(filepath string) string

func GetFileModTime ¶

func GetFileModTime(path string) int64

func GetFileSha256 ¶

func GetFileSha256(filepath string) string

GetFileSha256 计算文件的SHA256值

func GetFirstExcludedHighPort ¶

func GetFirstExcludedHighPort(excluded ...string) int

func GetFirstExistedExecutablePath ¶

func GetFirstExistedExecutablePath(paths ...string) string

func GetFirstExistedFile ¶

func GetFirstExistedFile(paths ...string) string

func GetFirstExistedFileE ¶

func GetFirstExistedFileE(paths ...string) (string, error)

func GetFirstExistedPath ¶

func GetFirstExistedPath(paths ...string) string

func GetFirstExistedPathE ¶

func GetFirstExistedPathE(paths ...string) (string, error)

func GetHTTPHeader ¶

func GetHTTPHeader(headers http.Header, key string) string

func GetHomeDir ¶

func GetHomeDir() (string, error)

func GetHomeDirDefault ¶

func GetHomeDirDefault(d string) string

func GetLastElement ¶ added in v1.2.8

func GetLastElement[T any](list []T) T

func GetLatestFile ¶

func GetLatestFile(dir, suffix string) (filename string, err error)

func GetLocalIPAddress ¶

func GetLocalIPAddress() string

func GetLocalIPAddressViaIface ¶

func GetLocalIPAddressViaIface() string

func GetMachineCode ¶

func GetMachineCode() string

func GetNExcludeExcludeHighPort ¶

func GetNExcludeExcludeHighPort(n int, excluded ...string) []int

func GetRandomAvailableTCPPort ¶

func GetRandomAvailableTCPPort() int

func GetRandomAvailableTCPPortWithCtx ¶

func GetRandomAvailableTCPPortWithCtx(ctx context.Context, host string) int

func GetRandomAvailableUDPPort ¶

func GetRandomAvailableUDPPort() int

func GetRandomIPAddress ¶

func GetRandomIPAddress() string

func GetRandomLocalAddr ¶

func GetRandomLocalAddr() string

func GetRangeAvailableTCPPort ¶ added in v1.3.0

func GetRangeAvailableTCPPort(startPort, endPort, maxRetries int) (int, error)

func GetSameSubStrings ¶

func GetSameSubStrings(raw ...string) []string

func GetSameSubStringsRunes ¶

func GetSameSubStringsRunes(text1, text2 []rune) [][]rune

func GetSimpleUri ¶

func GetSimpleUri(u *url.URL) string

func GetSortedMapKeys ¶ added in v1.3.1

func GetSortedMapKeys[K Ordered, V any](m map[K]V) []K

func GetSystemDnsServers ¶ added in v1.2.3

func GetSystemDnsServers() ([]string, error)

func GetSystemMachineCode ¶

func GetSystemMachineCode() (_ string, err error)

func GetSystemNameServerList ¶

func GetSystemNameServerList() ([]string, error)

func GetUnexportedField ¶

func GetUnexportedField(field reflect.Value) interface{}

func GetWeekStartMonday ¶

func GetWeekStartMonday(t time.Time) (time.Time, error)

func GetWeekStartSunday ¶

func GetWeekStartSunday() (time.Time, error)

func GormTransaction ¶ added in v1.3.0

func GormTransaction(db *gorm.DB, callback func(tx *gorm.DB) error) (err error)

func GormTransactionReturnDb ¶

func GormTransactionReturnDb(db *gorm.DB, callback func(tx *gorm.DB)) (tx *gorm.DB)

func GzipCompress ¶

func GzipCompress(i interface{}) ([]byte, error)

func GzipDeCompress ¶

func GzipDeCompress(ret []byte) ([]byte, error)

func HTTPFrameParser ¶

func HTTPFrameParser(raw io.Reader) ([][2]string, [][2]string, io.Reader, error)

func HTTPPacketIsLargerThanMaxContentLength ¶

func HTTPPacketIsLargerThanMaxContentLength(res interface{}, maxLength int) bool

func HandleStdout ¶

func HandleStdout(ctx context.Context, handle func(string)) error

func HandleStdoutBackgroundForTest ¶ added in v1.3.3

func HandleStdoutBackgroundForTest(handle func(string)) (func(), func(), error)

func HostContains ¶ added in v1.3.0

func HostContains(rule string, target string) bool

func HostPort ¶

func HostPort(host string, port interface{}) string

HostPort 将 host 和 port 拼接成 host:port 的形式 Example: ``` str.HostPort("yaklang.com", 443) // yaklang.com:443 ```

func HttpDumpWithBody ¶

func HttpDumpWithBody(i interface{}, body bool) ([]byte, error)

func HttpShow ¶

func HttpShow(i interface{}) []byte

func IContains ¶

func IContains(s, sub string) bool

func IHasPrefix ¶ added in v1.2.8

func IHasPrefix(s, sub string) bool

func IOCopy ¶

func IOCopy(dst io.Writer, src io.Reader, buf []byte) (written int64, err error)

func IPv4ToCClassNetwork ¶

func IPv4ToCClassNetwork(s string) (string, error)

func IPv4ToUint32 ¶

func IPv4ToUint32(ip net.IP) (uint32, error)

func IPv4ToUint64 ¶

func IPv4ToUint64(ip string) (int64, error)

func IStringContainsAnyOfSubString ¶

func IStringContainsAnyOfSubString(s string, subs []string) bool

func ImportAppConfigToStruct ¶

func ImportAppConfigToStruct(template any, data map[string]string) (err error)

func InDebugMode ¶

func InDebugMode() bool

func InGithubActions ¶ added in v1.3.1

func InGithubActions() bool

func InTestcase ¶ added in v1.3.1

func InTestcase() bool

func IncludeExcludeChecker ¶ added in v1.3.2

func IncludeExcludeChecker(includes, excludes []string, target string) (passed bool)

func IndexAllSubstrings ¶

func IndexAllSubstrings(s string, patterns ...string) (result [][2]int)

IndexAllSubstrings 只遍历一次查找所有子串位置返回值是一个二维数组，每个元素是一个[2]int类型匹配结果，其中第一个元素是规则index，第二个元素是索引位置

func InetAtoN ¶

func InetAtoN(ip net.IP) int64

func InetNtoA ¶

func InetNtoA(ip int64) net.IP

func InitialCapitalizationEachWords ¶

func InitialCapitalizationEachWords(str string) string

每个单词首字母大写

func InsertSliceItem ¶ added in v1.2.8

func InsertSliceItem[T comparable](slices []T, e T, index int) []T

func Int64SliceToIntSlice ¶

func Int64SliceToIntSlice(i []int64) []int

func IntArrayContains ¶

func IntArrayContains(array []int, element int) bool

func IntLargerZeroOr ¶

func IntLargerZeroOr(s ...int) int

func IntSliceToInt64Slice ¶

func IntSliceToInt64Slice(i []int) []int64

func InterfaceToBoolean ¶ added in v1.2.4

func InterfaceToBoolean(i any) bool

func InterfaceToBytes ¶

func InterfaceToBytes(i interface{}) (result []byte)

func InterfaceToBytesSlice ¶

func InterfaceToBytesSlice(i interface{}) [][]byte

func InterfaceToFloat64 ¶

func InterfaceToFloat64(i any) float64

func InterfaceToGeneralMap ¶

func InterfaceToGeneralMap(params interface{}) (finalResult map[string]interface{})

func InterfaceToInt ¶ added in v1.2.4

func InterfaceToInt(i any) int

func InterfaceToJsonString ¶ added in v1.3.3

func InterfaceToJsonString(i interface{}) string

func InterfaceToMap ¶

func InterfaceToMap(i interface{}) map[string][]string

func InterfaceToMapInterface ¶

func InterfaceToMapInterface(i interface{}) map[string]interface{}

func InterfaceToMapInterfaceE ¶

func InterfaceToMapInterfaceE(i interface{}) (map[string]interface{}, error)

func InterfaceToQuotedString ¶

func InterfaceToQuotedString(i interface{}) string

func InterfaceToSliceInterface ¶ added in v1.2.2

func InterfaceToSliceInterface(i interface{}) []any

func InterfaceToSliceInterfaceE ¶ added in v1.2.2

func InterfaceToSliceInterfaceE(i interface{}) ([]any, error)

func InterfaceToString ¶

func InterfaceToString(i interface{}) string

func InterfaceToStringSlice ¶

func InterfaceToStringSlice(i interface{}) (result []string)

ToStringSlice 将任意类型的数据转换为字符串切片 Example: ``` str.ToStringSlice("hello") // ["hello"] str.ToStringSlice([1, 2]) // ["1", "2"] ```

func IsASCIIPrint ¶

func IsASCIIPrint(s string) bool

isASCIIPrint returns whether s is ASCII and printable according to https://tools.ietf.org/html/rfc20#section-4.2.

func IsAudio ¶

func IsAudio(filePath string) (bool, error)

func IsBase64 ¶ added in v1.2.9

func IsBase64(s string) bool

func IsCommonHTTPRequestMethod ¶ added in v1.2.7

func IsCommonHTTPRequestMethod(i any) bool

func IsConnectResetError ¶

func IsConnectResetError(err error) bool

func IsDir ¶

func IsDir(path string) bool

func IsErrorNetOpTimeout ¶ added in v1.2.8

func IsErrorNetOpTimeout(err error) bool

func IsFile ¶

func IsFile(path string) bool

func IsFloat ¶ added in v1.3.2

func IsFloat(v interface{}) bool

func IsGenericTextFile ¶

func IsGenericTextFile(filePath string) (bool, error)

func IsGenericTextType ¶

func IsGenericTextType(fileType *mimetype.MIME) bool

func IsGzip ¶

func IsGzip(raw []byte) bool

func IsGzipBytes ¶

func IsGzipBytes(i interface{}) bool

func IsHttpOrHttpsUrl ¶ added in v1.2.4

func IsHttpOrHttpsUrl(raw string) bool

func IsIPv4 ¶

func IsIPv4(raw string) bool

IsIPv4 判断字符串是否是 IPv4 地址 Example: ``` str.IsIPv4("::1") // false str.IsIPv4("127.0.0.1") // true ```

func IsIPv6 ¶

func IsIPv6(raw string) bool

IsIPv6 判断字符串是否是 IPv6 地址 Example: ``` str.IsIPv6("::1") // true str.IsIPv6("127.0.0.1") // false ```

func IsImage ¶

func IsImage(i []byte) bool

func IsInt ¶ added in v1.3.2

func IsInt(v interface{}) bool

func IsJSON ¶

func IsJSON(raw string) (string, bool)

func IsLinux ¶ added in v1.2.3

func IsLinux() bool

func IsLoopback ¶

func IsLoopback(t string) bool

func IsMac ¶ added in v1.2.3

func IsMac() bool

func IsMap ¶

func IsMap(input any) bool

func IsMedia ¶

func IsMedia(filePath string) (bool, error)

func IsNil ¶ added in v1.2.8

func IsNil(input any) bool

func IsPlainText ¶

func IsPlainText(raw []byte) bool

func IsPortAvailable ¶

func IsPortAvailable(host string, p int) bool

func IsPortAvailableWithTimeout ¶

func IsPortAvailableWithTimeout(host string, port int, timeout time.Duration) bool

IsPortAvailableWithTimeout 使用超时检查端口是否可用

func IsPortAvailableWithUDP ¶

func IsPortAvailableWithUDP(host string, p int) bool

func IsPrivateIP ¶

func IsPrivateIP(ip net.IP) bool

func IsProtobuf ¶

func IsProtobuf(raw []byte) bool

func IsStrongPassword ¶

func IsStrongPassword(s string) bool

IsStrongPassword 判断字符串是否为强密码，强密码的定义为：长度大于8，同时包含特殊字符、小写字母、大写字母、数字 Example: ``` str.IsStrongPassword("12345678") // false str.IsStrongPassword("12345678a") // false str.IsStrongPassword("12345678aA") // false str.IsStrongPassword("12345678aA!") // true ```

func IsSubPath ¶ added in v1.3.1

func IsSubPath(sub, parent string) bool

func IsTCPPortAvailable ¶

func IsTCPPortAvailable(p int) bool

func IsTCPPortAvailableWithLoopback ¶

func IsTCPPortAvailableWithLoopback(p int) bool

func IsTCPPortOpen ¶

func IsTCPPortOpen(host string, p int) bool

func IsUDPPortAvailable ¶

func IsUDPPortAvailable(p int) bool

func IsUDPPortAvailableWithLoopback ¶

func IsUDPPortAvailableWithLoopback(p int) bool

func IsValidBool ¶ added in v1.3.1

func IsValidBool(raw string) bool

func IsValidCIDR ¶

func IsValidCIDR(raw string) bool

func IsValidDomain ¶

func IsValidDomain(raw string) bool

func IsValidFloat ¶

func IsValidFloat(raw string) bool

func IsValidHost ¶ added in v1.3.0

func IsValidHost(raw string) bool

func IsValidHostsRange ¶

func IsValidHostsRange(raw string) bool

func IsValidInteger ¶

func IsValidInteger(raw string) bool

func IsValidPortsRange ¶

func IsValidPortsRange(ports string) bool

func IsVideo ¶

func IsVideo(filePath string) (bool, error)

func IsWebsocketUrl ¶ added in v1.3.0

func IsWebsocketUrl(raw string) bool

func IsWindows ¶ added in v1.2.3

func IsWindows() bool

func JSONStringReader ¶

func JSONStringReader(reader io.Reader) io.Reader

Example (BasicUsage) ¶

// 基本使用示例
input := `"123"`
reader := JSONStringReader(strings.NewReader(input))
result, _ := io.ReadAll(reader)
fmt.Printf("输入: %s\n输出: %s\n", input, string(result))

Output:

输入: "123"
输出: 123

Example (ComplexEscapes) ¶

// 复杂转义示例
input := `"Hello\x20World\u0021\ud83d\ude0a"`
reader := JSONStringReader(strings.NewReader(input))
result, _ := io.ReadAll(reader)
fmt.Printf("输入: %s\n输出: %s\n", input, string(result))

Output:

输入: "Hello\x20World\u0021\ud83d\ude0a"
输出: Hello World!😊

Example (EscapeSequences) ¶

// 转义序列示例
input := `"abc\n123"`
reader := JSONStringReader(strings.NewReader(input))
result, _ := io.ReadAll(reader)
fmt.Printf("输入: %s\n输出: %s\n", input, string(result))

Output:

输入: "abc\n123"
输出: abc
123

Example (Fallback) ¶

// 回退模式示例
input := `123`
reader := JSONStringReader(strings.NewReader(input))
result, _ := io.ReadAll(reader)
fmt.Printf("输入: %s\n输出: %s\n", input, string(result))

Output:

输入: 123
输出: 123

Example (Malformed) ¶

// 畸形数据自动回退示例
input := `"hello"world"test"`
reader := JSONStringReader(strings.NewReader(input))
result, _ := io.ReadAll(reader)
fmt.Printf("输入: %s\n输出: %s\n", input, string(result))

Output:

输入: "hello"world"test"
输出: "hello"world"test"

Example (Streaming) ¶

// 流式读取示例
input := `"This is a long string that demonstrates streaming capabilities"`
reader := JSONStringReader(strings.NewReader(input))

// 使用小缓冲区分块读取
buf := make([]byte, 10)
var output strings.Builder

for {
	n, err := reader.Read(buf)
	if n > 0 {
		output.Write(buf[:n])
	}
	if err == io.EOF {
		break
	}
}

fmt.Printf("流式读取输出: %s\n", output.String())

Output:

流式读取输出: This is a long string that demonstrates streaming capabilities

func JavaTimeFormatter ¶

func JavaTimeFormatter(t time.Time, formatter string) string

func JitterBackoff ¶ added in v1.3.2

func JitterBackoff(min, max time.Duration, attempt int) time.Duration

Return capped exponential backoff with jitter http://www.awsarchitectureblog.com/2015/03/backoff.html

func JoinErrors ¶ added in v1.2.8

func JoinErrors(errs ...error) error

func Jsonify ¶

func Jsonify(i interface{}) []byte

func LastLine ¶

func LastLine(s []byte) []byte

func LoopEvery1sBreakUntil ¶

func LoopEvery1sBreakUntil(until func() bool)

func MIMEGlobRuleCheck ¶

func MIMEGlobRuleCheck(target string, rule string) bool

func MapGet ¶

func MapGet[T any](m map[string]any, key string) T

func MapGetBool ¶

func MapGetBool(m map[string]interface{}, key string) bool

func MapGetBoolOr ¶

func MapGetBoolOr(m map[string]interface{}, key string, value bool) bool

func MapGetFirstRaw ¶

func MapGetFirstRaw(m map[string]interface{}, key ...string) interface{}

func MapGetFloat32 ¶

func MapGetFloat32(m map[string]interface{}, key string) float32

func MapGetFloat32Or ¶

func MapGetFloat32Or(m map[string]interface{}, key string, value float32) float32

func MapGetFloat64 ¶

func MapGetFloat64(m map[string]interface{}, key string) float64

func MapGetFloat64Or ¶

func MapGetFloat64Or(m map[string]interface{}, key string, value float64) float64

func MapGetInt ¶

func MapGetInt(m map[string]interface{}, key string) int

func MapGetInt64 ¶

func MapGetInt64(m map[string]interface{}, key string) int64

func MapGetInt64Or ¶

func MapGetInt64Or(m map[string]interface{}, key string, value int64) int64

func MapGetInt64Slice ¶

func MapGetInt64Slice(m map[string]interface{}, key string) []int64

func MapGetIntEx ¶ added in v1.2.2

func MapGetIntEx(m map[string]interface{}, key ...string) int

func MapGetIntOr ¶

func MapGetIntOr(m map[string]interface{}, key string, value int) int

func MapGetMapRaw ¶

func MapGetMapRaw(m map[string]interface{}, key string) map[string]interface{}

func MapGetMapRawOr ¶

func MapGetMapRawOr(m map[string]interface{}, key string, value map[string]interface{}) map[string]interface{}

func MapGetMapStringInt64 ¶

func MapGetMapStringInt64(m map[string]interface{}, key string) map[string]int64

func MapGetOr ¶

func MapGetOr[T any](m map[string]any, key string, value T) T

func MapGetRaw ¶

func MapGetRaw(m map[string]interface{}, key string) interface{}

func MapGetRawOr ¶

func MapGetRawOr(m map[string]interface{}, key string, value interface{}) interface{}

func MapGetString ¶

func MapGetString(m map[string]interface{}, key string) string

func MapGetString2 ¶

func MapGetString2(m map[string]string, key string) string

func MapGetStringByManyFields ¶ added in v1.2.4

func MapGetStringByManyFields(m map[string]interface{}, key ...string) string

func MapGetStringOr ¶

func MapGetStringOr(m map[string]interface{}, key string, value string) string

func MapGetStringOr2 ¶

func MapGetStringOr2(m map[string]string, key string, value string) string

func MapGetStringSlice ¶ added in v1.2.7

func MapGetStringSlice(m map[string]interface{}, key string) []string

func MapQueryToString ¶

func MapQueryToString(values map[string][]string) string

map[string][]string to query

func MapStringGet ¶

func MapStringGet(m map[string]string, key string) string

func MapStringGetOr ¶

func MapStringGetOr(m map[string]string, key string, value string) string

func MapToStruct ¶ added in v1.2.6

func MapToStruct(input map[string]interface{}, output interface{}) error

func MarshalHTTPRequest ¶

func MarshalHTTPRequest(req *http.Request) ([]byte, error)

func MarshalIdempotent ¶ added in v1.3.0

func MarshalIdempotent(v interface{}) ([]byte, error)

func MatchAllOfGlob ¶

func MatchAllOfGlob(
	i interface{}, re ...string) bool

MatchAllOfGlob 尝试将 i 转换为字符串，然后使用 glob 匹配模式匹配，如果所有的glob模式都匹配成功，则返回 true，否则返回 false Example: ``` str.MatchAllOfGlob("abc", "a*", "?b?", "[a-z]?c") // true ```

func MatchAllOfRegexp ¶

func MatchAllOfRegexp(
	i interface{},
	re ...string) bool

MatchAllOfRegexp 尝试将 i 转换为字符串，然后使用正则表达式匹配，如果所有的正则表达式都匹配成功，则返回 true，否则返回 false Example: ``` str.MatchAllOfRegexp("abc", "a.+", ".?b.?", "\\w{2}c") // true ```

func MatchAllOfSubString ¶

func MatchAllOfSubString(i interface{}, subStr ...string) bool

MatchAllOfSubString 尝试将 i 转换为字符串，然后判断所有子串 subStr 是否都存在于 i 中，如果都存在则返回 true，否则返回 false，此函数忽略大小写 Example: ``` str.MatchAllOfSubString("abc", "a", "b", "c") // true ```

func MatchAnyOfGlob ¶

func MatchAnyOfGlob(
	i interface{}, re ...string) bool

MatchAnyOfGlob 尝试将 i 转换为字符串，然后使用 glob 匹配模式匹配，如果任意一个glob模式匹配成功，则返回 true，否则返回 false Example: ``` str.MatchAnyOfGlob("abc", "a*", "??b", "[^a-z]?c") // true ```

func MatchAnyOfRegexp ¶

func MatchAnyOfRegexp(
	i interface{},
	re ...string) bool

MatchAnyOfRegexp 尝试将 i 转换为字符串，然后使用正则表达式匹配，如果任意一个正则表达式匹配成功，则返回 true，否则返回 false Example: ``` str.MatchAnyOfRegexp("abc", "a.+", "Ab.?", ".?bC") // true ```

func MatchAnyOfSubString ¶

func MatchAnyOfSubString(i interface{}, subStr ...string) bool

MatchAnyOfSubString 尝试将 i 转换为字符串，然后判断是否有任意子串 subStr 存在于 i 中，如果有其中一个子串存在于 i 中则返回 true，否则返回 false，此函数忽略大小写 Example: ``` str.MatchAnyOfSubString("abc", "a", "z", "x") // true ```

func Max ¶

func Max(x, y int) int

func MaxByte ¶

func MaxByte(x, y byte) byte

func MaxInt64 ¶

func MaxInt64(x, y int64) int64

func MergeGeneralMap ¶ added in v1.2.2

func MergeGeneralMap(ms ...map[string]any) map[string]any

func MergeStringMap ¶

func MergeStringMap(ms ...map[string]string) map[string]string

func MergeToMap ¶

func MergeToMap[K comparable, V any](m map[K]V, ms ...map[K]V)

func Min ¶

func Min(x, y int) int

func MinByte ¶

func MinByte(x, y byte) byte

func MinInt64 ¶

func MinInt64(x, y int64) int64

func Mmh3Hash32 ¶

func Mmh3Hash32(raw []byte) string

func MustRenderTemplate ¶

func MustRenderTemplate(templateStr string, data any) string

func MustUnmarshalJson ¶ added in v1.2.4

func MustUnmarshalJson[T any](raw []byte) *T

func NeedsURLEncoding ¶ added in v1.3.3

func NeedsURLEncoding(s string) bool

func NestedSavepointTransaction ¶

func NestedSavepointTransaction(st *SavepointTransaction, callback func(*gorm.DB) error) error

NestedSavepointTransaction 嵌套SAVEPOINT事务，可以在已存在的SavepointTransaction中使用

func NetworkByteOrderBytesToUint16 ¶ added in v1.2.4

func NetworkByteOrderBytesToUint16(r []byte) uint16

func NetworkByteOrderUint16ToBytes ¶ added in v1.2.3

func NetworkByteOrderUint16ToBytes(i any) []byte

func NetworkByteOrderUint32ToBytes ¶ added in v1.2.3

func NetworkByteOrderUint32ToBytes(i any) []byte

func NetworkByteOrderUint64ToBytes ¶ added in v1.2.3

func NetworkByteOrderUint64ToBytes(i any) []byte

func NetworkByteOrderUint8ToBytes ¶ added in v1.2.3

func NetworkByteOrderUint8ToBytes(i any) []byte

func NewBlockParser ¶

func NewBlockParser(reader io.Reader) *blockParser

func NewDebounce ¶ added in v1.2.8

func NewDebounce(wait float64) func(f func())

func NewDebounceEx ¶

func NewDebounceEx(wait float64, lead bool, tail bool) func(f func())

NewDebounceEx 创建一个扩展的防抖函数 wait: 防抖时间间隔 lead: 是否在第一次调用时立即执行 tail: 是否在最后一次调用后延迟执行

func NewDefaultGMTLSConfig ¶

func NewDefaultGMTLSConfig() *gmtls.Config

func NewDefaultHTTPClient ¶

func NewDefaultHTTPClient() *http.Client

func NewDefaultHTTPClientWithProxy ¶

func NewDefaultHTTPClientWithProxy(proxy string) *http.Client

func NewDefaultTLSClient ¶

func NewDefaultTLSClient(conn net.Conn) *tls.Conn

func NewDefaultTLSConfig ¶

func NewDefaultTLSConfig() *tls.Config

func NewDialer ¶ added in v1.2.4

func NewDialer()

func NewFileLineWriter ¶ added in v1.3.0

func NewFileLineWriter(file string, flag int, perm fs.FileMode) (*fileLineWriter, error)

func NewMirrorPipe ¶

func NewMirrorPipe(count int) ([]*bufpipe.PipeReader, *bufpipe.PipeWriter)

func NewNetConnFromReadWriter ¶

func NewNetConnFromReadWriter()

func NewSignalChannel ¶

func NewSignalChannel(targetSignal ...os.Signal) chan os.Signal

func NewThrottle ¶ added in v1.2.8

func NewThrottle(wait float64) func(f func())

func NewThrottleEx ¶

func NewThrottleEx(wait float64, lead bool, tail bool) func(f func())

NewThrottleEx 创建一个扩展的节流函数 wait: 节流时间间隔 lead: 是否在第一次调用时立即执行 tail: 是否在最后一次调用后延迟执行

func NotSpaceRune ¶

func NotSpaceRune(r rune) bool

func OpenTempFile ¶ added in v1.2.8

func OpenTempFile(s string) (*os.File, error)

func OrderedParallelProcess ¶

func OrderedParallelProcess[I any, O any](
	ctx context.Context,
	inputCh <-chan I,
	processFunc func(I) (O, error),
	opts ...ParallelProcessOption,
) <-chan Result[O]

func OrderedParallelProcessSkipError ¶

func OrderedParallelProcessSkipError[I any, O any](
	ctx context.Context,
	inputCh <-chan I,
	processFunc func(I) (O, error),
	opts ...ParallelProcessOption,
) <-chan O

func ParseAppTag ¶

func ParseAppTag(tag string) map[string]string

func ParseAppTagToOptions ¶

func ParseAppTagToOptions(template any, ext ...map[string]string) (configInfo []*ypb.ThirdPartyAppConfigItemTemplate, err error)

func ParseCStyleBinaryRawToBytes ¶

func ParseCStyleBinaryRawToBytes(raw []byte) []byte

func ParseHTTPRequestLine ¶ added in v1.2.6

func ParseHTTPRequestLine(line string) (method, requestURI, proto string, ok bool)

ParseHTTPRequestLine parses "GET /foo HTTP/1.1" into its three parts.

func ParseHTTPResponseLine ¶ added in v1.2.6

func ParseHTTPResponseLine(line string) (string, int, string, bool)

ParseHTTPResponseLine parses `HTTP/1.1 200 OK` into its ports

func ParseHostToAddrString ¶

func ParseHostToAddrString(host string) string

func ParseIPNetToRange ¶

func ParseIPNetToRange(n *net.IPNet) (int64, int64, error)

func ParseLines ¶

func ParseLines(raw string) chan string

func ParsePortToProtoPort ¶ added in v1.2.6

func ParsePortToProtoPort(port int) (string, int)

func ParseStringToGeneralMap ¶ added in v1.2.3

func ParseStringToGeneralMap(i any) map[string]any

func ParseStringToHostPort ¶

func ParseStringToHostPort(raw string) (host string, port int, err error)

ParseStringToHostPort 尝试从字符串中解析出host和port，并与错误一起返回 Example: ``` host, port, err = str.ParseStringToHostPort("127.0.0.1:8888") // host = "127.0.0.1", port = 8888, err = nil host, port, err = str.ParseStringToHostPort("https://example.com") // host = "example.com", port = 443, err = nil host, port, err = str.ParseStringToHostPort("Hello Yak") // host = "", port = 0, err = error("unknown port for [Hello Yak]") ```

func ParseStringToHosts ¶

func ParseStringToHosts(raw string) []string

ParseStringToHosts 将字符串解析成 Host 列表， Host 可以以逗号、换行分隔，并且会解析 CIDR 网段 Example: ``` str.ParseStringToHosts("192.168.0.1/32,127.0.0.1") // ["192.168.0.1", "127.0.0.1"] ```

func ParseStringToHostsWithCallback ¶

func ParseStringToHostsWithCallback(raw string, callback func(string) bool)

func ParseStringToHttpsAndHostname ¶ added in v1.2.9

func ParseStringToHttpsAndHostname(res string) (bool, string)

func ParseStringToLines ¶

func ParseStringToLines(raw string) []string

ParseStringToLines 将字符串按换行符(\n)分割成字符串数组，并去除BOM头和空行 Example: ``` str.ParseStringToLines("Hello World\nHello Yak") // ["Hello World", "Hello Yak"] ```

func ParseStringToPorts ¶

func ParseStringToPorts(ports string) []int

ParseStringToPorts 将字符串解析成 Port 列表， Port 可以以逗号分隔，并且会解析-分隔的范围 Example: ``` str.ParseStringToPorts("10086-10088,23333") // [10086, 10087, 10088, 23333] ```

func ParseStringToRawLines ¶

func ParseStringToRawLines(raw string) []string

func ParseStringToUrl ¶ added in v1.2.6

func ParseStringToUrl(s string) *url.URL

func ParseStringToUrlParams ¶

func ParseStringToUrlParams(i interface{}) string

func ParseStringToUrls ¶

func ParseStringToUrls(targets ...string) []string

ParseStringToUrls 尝试从给定的字符串(ip,域名)中解析出 URL 列表，补全协议和端口 Example: ``` str.ParseStringToUrls("yaklang.com:443", "https://yaklang.io") // [https://yaklang.com, https://yaklang.io] ```

func ParseStringToUrlsWith3W ¶

func ParseStringToUrlsWith3W(sub ...string) []string

ParseStringToUrlsWith3W 尝试从给定的字符串(ip,域名)中解析出 URL 列表，补全协议和端口，还会补全域名前的 www 前缀 Example: ``` str.ParseStringToUrlsWith3W("yaklang.com:443", "https://yaklang.io") // [https://yaklang.com, https://www.yaklang.com, https://yaklang.io, https://www.yaklang.io] ```

func ParseStringToVisible ¶

func ParseStringToVisible(raw interface{}) string

func ParseStringUrlToUrlInstance ¶

func ParseStringUrlToUrlInstance(s string) (*url.URL, error)

ParseStringUrlToUrlInstance 将字符串 url 解析为 URL 结构体并返回错误 Example: ``` str.ParseStringUrlToUrlInstance("https://yaklang.com/abc?a=1") ```

func ParseStringUrlToWebsiteRootPath ¶

func ParseStringUrlToWebsiteRootPath(url string) (newURL string)

ParseStringUrlToWebsiteRootPath 将字符串 url 解析为其根路径的URL Example: ``` str.ParseStringUrlToWebsiteRootPath("https://yaklang.com/abc?a=1") // https://yaklang.com/ ```

func PathExists ¶

func PathExists(path string) (bool, error)

func PrefixLines ¶

func PrefixLines(input interface{}, prefix string) string

PrefixLines 为文本的每一行添加指定前缀对所有输入（包括单行和多行）都添加前缀 Example: ``` str.PrefixLines("hello", "> ") // "> hello" str.PrefixLines("line1\nline2", "> ") // "> line1\n> line2" ```

func PrefixLinesReader ¶

func PrefixLinesReader(input io.Reader, prefix string) io.Reader

PrefixLinesReader 为文本的每一行添加指定前缀，输入和输出都是 io.Reader 对所有输入（包括单行和多行）都添加前缀，适合处理大文件或流式数据 Example: ``` reader := strings.NewReader("line1\nline2") prefixedReader := str.PrefixLinesReader(reader, "> ") // 读取 prefixedReader 会得到 "> line1\n> line2" ```

func PrefixLinesReaderSimple ¶

func PrefixLinesReaderSimple(input io.Reader, prefix string) io.Reader

PrefixLinesReaderSimple 简化版本的 PrefixLinesReader，总是添加前缀适合已知是多行文本的场景，使用流式处理

func PrefixLinesWithLineNumbers ¶

func PrefixLinesWithLineNumbers(input interface{}) string

PrefixLinesWithLineNumbers 为文本的每一行添加行号前缀对所有输入（包括单行和多行）都添加行号前缀 Example: ``` str.PrefixLinesWithLineNumbers("hello") // "1 | hello" str.PrefixLinesWithLineNumbers("line1\nline2") // "1 | line1\n2 | line2" ```

func PrefixLinesWithLineNumbersReader ¶

func PrefixLinesWithLineNumbersReader(input io.Reader) io.Reader

PrefixLinesWithLineNumbersReader 为文本的每一行添加行号前缀，输入和输出都是 io.Reader 使用流式处理，逐行读取并添加行号前缀，适合处理大文件或流式数据 Example: ``` reader := strings.NewReader("line1\nline2") numberedReader := str.PrefixLinesWithLineNumbersReader(reader) // 读取 numberedReader 会得到 "1 | line1\n2 | line2" ```

func PrettifyJoin ¶ added in v1.2.9

func PrettifyJoin(sep string, s ...string) string

func PrettifyListFromStringSplitEx ¶

func PrettifyListFromStringSplitEx(Raw string, sep ...string) (targets []string)

PrettifyListFromStringSplitEx split string using given sep if no sep given sep = []string{",", "|"}

func PrettifyListFromStringSplited ¶

func PrettifyListFromStringSplited(Raw string, sep string) (targets []string)

SplitAndTrim 将字符串s按照sep分割成字符串切片，并且去除每个字符串的前后空白字符 Example: ``` str.SplitAndTrim(" hello yak ", " ") // ["hello", "yak"] ```

func PrettifyShrinkJoin ¶ added in v1.2.9

func PrettifyShrinkJoin(sep string, s ...string) string

func PrintCurrentGoroutineRuntimeStack ¶

func PrintCurrentGoroutineRuntimeStack()

func ProtoHostPort ¶ added in v1.2.6

func ProtoHostPort(proto string, host string, port int) string

func QuoteCSV ¶

func QuoteCSV(s string) string

func RRFRank ¶

func RRFRank[T RRFScoredData](scoredDataList []T, k int) []T

func RRFRankWithDefaultK ¶

func RRFRankWithDefaultK[T RRFScoredData](scoredDataList []T) []T

func RandAlphaNumStringBytes ¶

func RandAlphaNumStringBytes(n int) string

func RandBytes ¶

func RandBytes(n int) []byte

func RandChoice ¶ added in v1.3.1

func RandChoice(a ...string) string

func RandFloat64 ¶

func RandFloat64() float64

RandFloat64 returns a random float64 in [0.0, 1.0)

func RandNumberStringBytes ¶

func RandNumberStringBytes(n int) string

func RandSample ¶

func RandSample(n int, material ...string) string

func RandSampleInRange ¶ added in v1.3.0

func RandSampleInRange(minLen, maxLen int, material ...string) string

func RandSecret ¶

func RandSecret(n int) string

RandSecret 返回在所有可见ascii字符表中随机挑选 n 个字符组成的密码字符串，这个密码经过str.IsStrongPassword验证，即为强密码 Example: ``` str.RandSecret(10) ```

func RandStringBytes ¶

func RandStringBytes(n int) string

RandStringBytes 返回在大小写字母表中随机挑选 n 个字符组成的字符串 Example: ``` str.RandStr(10) ```

func ReadConnUntil ¶ added in v1.2.8

func ReadConnUntil(conn net.Conn, timeout time.Duration, sep ...byte) ([]byte, error)

func ReadConnWithTimeout ¶

func ReadConnWithTimeout(r net.Conn, timeout time.Duration) ([]byte, error)

func ReadDirsRecursivelyCallback ¶ added in v1.2.9

func ReadDirsRecursivelyCallback(p string, i func(info *FileInfo) bool) error

func ReadHTTPRequestFromBufioReader ¶ added in v1.2.6

func ReadHTTPRequestFromBufioReader(reader *bufio.Reader) (*http.Request, error)

func ReadHTTPRequestFromBufioReaderOnFirstLine ¶ added in v1.2.8

func ReadHTTPRequestFromBufioReaderOnFirstLine(reader *bufio.Reader, h func(string)) (*http.Request, error)

func ReadHTTPRequestFromBytes ¶ added in v1.2.6

func ReadHTTPRequestFromBytes(raw []byte) (*http.Request, error)

func ReadHTTPResponseFromBufioReader ¶ added in v1.2.6

func ReadHTTPResponseFromBufioReader(reader io.Reader, req *http.Request) (*http.Response, error)

func ReadHTTPResponseFromBufioReaderConn ¶ added in v1.2.8

func ReadHTTPResponseFromBufioReaderConn(reader io.Reader, conn net.Conn, req *http.Request) (*http.Response, error)

func ReadHTTPResponseFromBytes ¶ added in v1.2.6

func ReadHTTPResponseFromBytes(raw []byte, req *http.Request) (*http.Response, error)

func ReadLine ¶ added in v1.2.8

func ReadLine(reader io.Reader) ([]byte, error)

func ReadLineEx ¶

func ReadLineEx(reader io.Reader) (string, int64, error)

func ReadN ¶

func ReadN(reader io.Reader, n int) ([]byte, error)

func ReadTimeout ¶

func ReadTimeout(r io.Reader, timeout time.Duration) ([]byte, error)

func ReadUntilStable ¶ added in v1.2.8

func ReadUntilStable(reader io.Reader, conn net.Conn, timeout time.Duration, stableTimeout time.Duration, sep ...byte) ([]byte, error)

ReadUntilStable is a stable reader check interval(stableTimeout) safe for conn is empty

func ReadUntilStableEx ¶ added in v1.2.8

func ReadUntilStableEx(reader io.Reader, noTimeout bool, conn net.Conn, timeout time.Duration, stableTimeout time.Duration, sep ...byte) ([]byte, error)

ReadUntilStableEx allow skip timeout, read until stop word or timeout

func ReadWithContextTickCallback ¶

func ReadWithContextTickCallback(ctx context.Context, rc io.Reader, callback func([]byte) bool, interval time.Duration)

func ReadWithLen ¶

func ReadWithLen(r io.Reader, length int) ([]byte, int)

func ReaderOnFirstByte ¶

func ReaderOnFirstByte(origin io.Reader, onFirstByte func()) io.Reader

func RealTimeCopy ¶ added in v1.3.3

func RealTimeCopy(dst io.Writer, src io.Reader) (int64, error)

func Regexp2Compile ¶

func Regexp2Compile(rawRule string, opts ...int) (string, regexp2.RegexOptions, *regexp2.Regexp, error)

func RegisterDefaultTLSConfigGenerator ¶ added in v1.2.3

func RegisterDefaultTLSConfigGenerator(h func() (*tls.Config, *gmtls.Config, *gmtls.Config, *tls.Config, *gmtls.Config, []byte, []byte))

func RegisterTempFileOpener ¶ added in v1.2.8

func RegisterTempFileOpener(dialer FileOpenerType)

func RemoveBOM ¶

func RemoveBOM(raw []byte) []byte

func RemoveBOMForString ¶

func RemoveBOMForString(raw string) string

func RemoveRepeatIntSlice ¶

func RemoveRepeatIntSlice(slc []int) []int

元素去重

func RemoveRepeatIntSliceByLoop ¶

func RemoveRepeatIntSliceByLoop(slc []int) []int

func RemoveRepeatIntSliceByMap ¶

func RemoveRepeatIntSliceByMap(slc []int) []int

func RemoveRepeatStringSlice ¶

func RemoveRepeatStringSlice(slc []string) []string

RemoveRepeat 移除字符串切片slc中的重复元素 Example: ``` str.RemoveRepeat(["hello", "yak", "hello"]) // ["hello", "yak"] ```

func RemoveRepeatStringSliceByLoop ¶

func RemoveRepeatStringSliceByLoop(slc []string) []string

func RemoveRepeatStringSliceByMap ¶

func RemoveRepeatStringSliceByMap(slc []string) []string

func RemoveRepeatUintSlice ¶

func RemoveRepeatUintSlice(slc []uint) []uint

元素去重

func RemoveRepeatUintSliceByLoop ¶

func RemoveRepeatUintSliceByLoop(slc []uint) []uint

func RemoveRepeatUintSliceByMap ¶

func RemoveRepeatUintSliceByMap(slc []uint) []uint

func RemoveRepeatedWithStringSlice ¶

func RemoveRepeatedWithStringSlice(slice []string) []string

func RemoveSliceItem ¶ added in v1.2.8

func RemoveSliceItem[T comparable](slice []T, s T) []T

func RemoveUnprintableChars ¶

func RemoveUnprintableChars(raw string) string

func RemoveUnprintableCharsWithReplace ¶

func RemoveUnprintableCharsWithReplace(raw string, handle func(i byte) string) string

func RemoveUnprintableCharsWithReplaceItem ¶

func RemoveUnprintableCharsWithReplaceItem(raw string) string

func RenderTemplate ¶

func RenderTemplate(templateStr string, data any) (string, error)

RenderTemplate 渲染模板字符串，支持map和struct作为数据源 template: 模板字符串，使用Go模板语法 data: 数据源，可以是map[string]any或struct实例返回渲染后的字符串和可能的错误

func ReplaceLastSubString ¶ added in v1.3.2

func ReplaceLastSubString(s, sub, new string) string

func ReplaceSliceItem ¶ added in v1.2.8

func ReplaceSliceItem[T comparable](s []T, t T, to T) []T

func Retry ¶ added in v1.2.7

func Retry(times int, f func() error) error

func Retry2 ¶ added in v1.3.3

func Retry2(i int, handler func() bool)

retry 对第二个参数作为函数的情况，重试N次，如果第二个参数返回值是 true，则重试，否则就结束，如果遇到错误，停止重试 Example: ``` count = 0

retry(100, () => {
   defer recover()

   count++
   if count > 3 {
       die(111)
   }
   return true
})

assert count == 4, f`${count}`

count = 0

retry(100, () => {
   defer recover()

   count++
   if count > 3 {
       return false
   }
   return true
})

assert count == 4, f`${count}`

count = 0

retry(100, () => {
   count++
})

assert count == 1, f`${count}`

count = 0

retry(100, () => {
   count++
   return true
})

assert count == 100, f`${count}` ```

func RetryWithExpBackOff ¶ added in v1.2.7

func RetryWithExpBackOff(f func() error) error

func RetryWithExpBackOffEx ¶ added in v1.2.7

func RetryWithExpBackOffEx(times int, begin int, f func() error) error

func RuneIndex ¶

func RuneIndex(s, sub []rune) int

func RuneRead ¶

func RuneRead(r io.Reader, maxChars int) string

func SSDeepHash ¶

func SSDeepHash(raw []byte) string

CalcSSDeep 计算并返回一段文本的模糊哈希值 Example: ``` str.CalcSSDeep("hello") ```

func SafeReflectStructField ¶ added in v1.2.9

func SafeReflectStructField(refV reflect.Value, field reflect.Value) reflect.Value

func SafeReflectValue ¶ added in v1.2.9

func SafeReflectValue(refV reflect.Value) reflect.Value

func SaveFile ¶

func SaveFile(raw interface{}, filePath string) error

func SaveTempFile ¶ added in v1.3.0

func SaveTempFile(content interface{}, pattern string) (string, error)

func SavepointTransactionWithCallback ¶

func SavepointTransactionWithCallback(db *gorm.DB, callback func(st *SavepointTransaction) error) error

SavepointTransactionWithCallback 基于SAVEPOINT的事务回调函数

func ScanHTTPHeader ¶

func ScanHTTPHeader(reader io.Reader, headerCallback func(rawHeader []byte), prefix []byte, isResp bool) error

func ScanHTTPHeaderSimple ¶

func ScanHTTPHeaderSimple(reader io.Reader, headerCallback func(rawHeader []byte), prefix []byte) error

func ScanHTTPHeaderWithHeaderFolding ¶

func ScanHTTPHeaderWithHeaderFolding(reader io.Reader, headerCallback func(rawHeader []byte), prefix []byte) error

func SetContextKey ¶

func SetContextKey(ctx context.Context, key string, value any) context.Context

func SetCurrentAbsPath ¶ added in v1.2.8

func SetCurrentAbsPath(path ...string)

SetCurrentAbsPath set absolute path as current project path, ff you pass a string parameter, use this string as the absolute path of the project

func SetSkipBottomFrameNum ¶ added in v1.2.8

func SetSkipBottomFrameNum(skip int)

SetSkipBottomFrameNum set the number of frames to skip from bottom, default is 2

func SetSkipFrameNum ¶ added in v1.2.8

func SetSkipFrameNum(skip int)

SetSkipFrameNum set the number of frames to skip, default is 3

func SetUnexportedField ¶

func SetUnexportedField(field reflect.Value, value interface{})

func ShouldRemoveZeroContentLengthHeader ¶ added in v1.2.6

func ShouldRemoveZeroContentLengthHeader(s string) bool

func ShuffleInt ¶

func ShuffleInt(slice []int)

func ShuffleString ¶

func ShuffleString(slice []string)

func SimHash ¶

func SimHash(raw []byte) uint64

CalcSimHash 计算并返回一段文本的 SimHash 值 Example: ``` str.CalcSimHash("hello") ```

func SimilarStr ¶

func SimilarStr(str1 []rune, str2 []rune) (int, int, int)

return the len of longest string both in str1 and str2 and the positions in str1 and str2

func SimplifyUtf8 ¶

func SimplifyUtf8(raw []byte) ([]byte, error)

SimplifyUtf8 simplify utf8 bytes to utf8 bytes

func SliceGroup ¶

func SliceGroup(origin []string, groupSize int) [][]string

func SnakeString ¶

func SnakeString(s string) string

func SocketTypeUint32ToString ¶

func SocketTypeUint32ToString(i uint32) string

func Spinlock ¶ added in v1.2.3

func Spinlock(t float64, h func() bool) error

func SplitHostsToPrivateAndPublic ¶

func SplitHostsToPrivateAndPublic(hosts ...string) (privs, pub []string)

SplitHostsToPrivateAndPublic 将 hosts 按照私有 IP 和公有 IP 分开 Example: ``` str.SplitHostsToPrivateAndPublic("127.0.0.1", "8.8.8.8", "10.0.0.1") // ["127.0.0.1", "10.0.0.1"], ["8.8.8.8"] ```

func StableReader ¶

func StableReader(conn io.Reader, timeout time.Duration, maxSize int) []byte

func StableReaderEx ¶

func StableReaderEx(conn net.Conn, timeout time.Duration, maxSize int) []byte

func StandBase64 ¶

func StandBase64(braw []byte) []byte

func StarAsWildcardToRegexp ¶

func StarAsWildcardToRegexp(prefix string, target string) (*regexp.Regexp, error)

func StartCacheLog ¶ added in v1.2.2

func StartCacheLog(ctx context.Context, n int)

func StringAfter ¶

func StringAfter(value string, a string) string

func StringArrayContains ¶

func StringArrayContains(array []string, element string) bool

func StringArrayFilterEmpty ¶

func StringArrayFilterEmpty(array []string) []string

func StringArrayIndex ¶

func StringArrayIndex(array []string, element string) int

func StringArrayMerge ¶

func StringArrayMerge(t ...[]string) []string

func StringAsFileParams ¶

func StringAsFileParams(target interface{}) []byte

func StringBefore ¶

func StringBefore(value string, a string) string

func StringContainsAllOfSubString ¶

func StringContainsAllOfSubString(s string, subs []string) bool

func StringContainsAnyOfSubString ¶

func StringContainsAnyOfSubString(s string, subs []string) bool

StringContainsAnyOfSubString 判断字符串s中是否包含subs中的任意一个子串 Example: ``` str.StringContainsAnyOfSubString("hello yak", ["yak", "world"]) // true ```

func StringGlobArrayContains ¶

func StringGlobArrayContains(array []string, element string, seps ...rune) bool

func StringGlobContains ¶ added in v1.3.1

func StringGlobContains(pattern string, element string, seps ...rune) bool

func StringHasPrefix ¶

func StringHasPrefix(s string, prefix []string) bool

func StringLiteralToAny ¶ added in v1.3.3

func StringLiteralToAny(s string) any

by json unmarshal

func StringLowerAndTrimSpace ¶

func StringLowerAndTrimSpace(raw string) string

LowerAndTrimSpace 将字符串raw转换为小写并去除前后空白字符 Example: ``` str.LowerAndTrimSpace(" Hello ") // "hello" ```

func StringOr ¶

func StringOr(s ...string) string

func StringReverse ¶

func StringReverse(s string) string

Reverse the string

func StringSliceContain ¶

func StringSliceContain(s interface{}, raw string) (result bool)

StringSliceContains 判断字符串切片s中是否包含raw，对于非字符串的切片，会尝试将其元素转换为字符串再判断是否包含 Example: ``` str.StringSliceContains(["hello", "yak"], "yak") // true str.StringSliceContains([1, 2, 3], "4") // false ```

func StringSliceContainsAll ¶

func StringSliceContainsAll(s []string, elements ...string) bool

StringSliceContainsAll 判断字符串切片s中是否完全包含elements中的所有元素，对于非字符串的切片，会尝试将其元素转换为字符串再判断是否包含 Example: ``` str.StringSliceContainsAll(["hello", "yak"], "hello", "yak") // true str.StringSliceContainsAll(["hello", "yak"], "hello", "yak", "world") // false ```

func StringSplitAndStrip ¶

func StringSplitAndStrip(raw string, sep string) []string

func StringSubStringArrayContains ¶ added in v1.2.3

func StringSubStringArrayContains(array []string, element string) bool

func StringToAsciiBytes ¶

func StringToAsciiBytes(s string) []byte

func TCPNoDelay ¶

func TCPNoDelay(i net.Conn)

func TLSConfigSetCheckServerName ¶

func TLSConfigSetCheckServerName(tlsConfig *tls.Config, host string) *tls.Config

func Tick1sWithTimeout ¶

func Tick1sWithTimeout(timeout time.Duration, falseToBreak func() bool) (exitedByCondition bool)

func TickEvery1s ¶

func TickEvery1s(falseToBreak func() bool)

func TickWithTimeout ¶

func TickWithTimeout(timeout, interval time.Duration, falseToBreak func() bool) (exitedByCondition bool)

func TickWithTimeoutContext ¶

func TickWithTimeoutContext(ctx context.Context, timeout, interval time.Duration, falseToBreak func() bool) (exitedByCondition bool)

func TimeoutContext ¶

func TimeoutContext(d time.Duration) context.Context

func TimeoutContextSeconds ¶

func TimeoutContextSeconds(d float64) context.Context

func TimestampMs ¶

func TimestampMs() int64

func TimestampNano ¶

func TimestampNano() int64

func TimestampSecond ¶

func TimestampSecond() int64

func ToBytes ¶

func ToBytes(s string) (uint64, error)

ToBytes parses a string formatted by ByteSize as bytes. Note binary-prefixed and SI prefixed units both mean a base-2 units KB = K = KiB = 1024 MB = M = MiB = 1024 * K GB = G = GiB = 1024 * M TB = T = TiB = 1024 * G PB = P = PiB = 1024 * T EB = E = EiB = 1024 * P

func ToLowerAndStrip ¶

func ToLowerAndStrip(s string) string

func ToMapParams ¶

func ToMapParams(params any) (map[string]any, error)

func ToMegabytes ¶

func ToMegabytes(s string) (uint64, error)

ToMegabytes parses a string formatted by ByteSize as megabytes.

func ToNsServer ¶

func ToNsServer(server string) string

func TrimFileNameExt ¶

func TrimFileNameExt(raw string) string

func TryCloseChannel ¶ added in v1.2.2

func TryCloseChannel(i any)

func TryWriteChannel ¶ added in v1.2.9

func TryWriteChannel[T any](c chan T, data T) (ret bool)

func UTF8Reader ¶

func UTF8Reader(r io.Reader) io.Reader

Example ¶

ExampleUTF8Reader 演示UTF8Reader的基本用法

// 使用io.ReadAll来确保稳定的输出，避免CI环境的性能差异
text := "Hello 世界 🌍"
reader := &mockBytewiseReader{data: []byte(text)}

// 使用UTF8Reader包装
utf8Reader := UTF8Reader(reader)

// 一次性读取所有数据以确保输出一致性
result, err := io.ReadAll(utf8Reader)
if err != nil {
	panic(err)
}

fmt.Printf("Complete read: %s\n", string(result))

Output:

Complete read: Hello 世界 🌍

Example (BufferSize1) ¶

ExampleUTF8Reader_bufferSize1 演示缓冲区长度为1时失效的行为

text := "测试"
reader := &mockBytewiseReader{data: []byte(text)}
utf8Reader := UTF8Reader(reader)

// 使用1字节缓冲区（UTF8Reader失效）
buf := make([]byte, 1)

fmt.Println("Buffer size 1 (UTF8Reader disabled):")
var result []byte
for {
	n, err := utf8Reader.Read(buf)
	if n > 0 {
		result = append(result, buf[:n]...)
	}
	if err == io.EOF {
		break
	}
}

fmt.Printf("Final result: %s\n", string(result))

Output:

Buffer size 1 (UTF8Reader disabled):
Final result: 测试

Example (RealWorldUsage) ¶

ExampleUTF8Reader_realWorldUsage 展示实际使用场景

// 模拟网络数据流，可能会在UTF-8字符边界处中断
data := "API返回: {\"message\": \"你好，世界！🌍\"}"

// 创建一个按小块读取的reader来模拟网络传输
chunkedReader := &mockChunkedReader{
	data:      []byte(data),
	chunkSize: 3, // 每次只读3字节，会打断UTF-8字符
}

// 使用UTF8Reader确保读取完整的UTF-8字符
utf8Reader := UTF8Reader(chunkedReader)

result, err := io.ReadAll(utf8Reader)
if err != nil {
	panic(err)
}

fmt.Printf("完整读取: %s\n", string(result))

Output:

完整读取: API返回: {"message": "你好，世界！🌍"}

Example (SmallBuffer) ¶

ExampleUTF8Reader_smallBuffer 演示小缓冲区的行为

text := "你好"
reader := &mockBytewiseReader{data: []byte(text)}
utf8Reader := UTF8Reader(reader)

// 使用2字节缓冲区（小于UTF-8字符长度）
buf := make([]byte, 2)

fmt.Println("Small buffer (2 bytes) behavior:")
for {
	n, err := utf8Reader.Read(buf)
	if n > 0 {
		// 统一使用复数形式以避免CI环境下的差异
		fmt.Printf("Read %d bytes: %v\n", n, buf[:n])
	}
	if err == io.EOF {
		break
	}
}

Output:

Small buffer (2 bytes) behavior:
Read 1 bytes: [228]
Read 1 bytes: [189]
Read 1 bytes: [160]
Read 1 bytes: [229]
Read 1 bytes: [165]
Read 1 bytes: [189]

func Uint32ToIPv4 ¶

func Uint32ToIPv4(ip uint32) net.IP

func UnquoteANSIC ¶

func UnquoteANSIC(s string) (string, error)

UnquoteANSIC 解码ANSI-C风格的引号字符串

func UnquoteANSICWithQuote ¶

func UnquoteANSICWithQuote(s string, quote rune) (string, error)

func UnquoteCSV ¶

func UnquoteCSV(s string) string

func UnsafeBytesToString ¶ added in v1.2.6

func UnsafeBytesToString(b []byte) string

func UnsafeStringToBytes ¶ added in v1.2.6

func UnsafeStringToBytes(s string) []byte

func Url2UnEscapeString ¶

func Url2UnEscapeString(u *url.URL) string

func UrlJoin ¶

func UrlJoin(origin string, paths ...string) (newURL string, err error)

UrlJoin 将字符串 origin 和字符串数组 paths 拼接成一个新的 URL 字符串，并返回错误 Example: ``` newURL, err = str.UrlJoin("https://yaklang.com", "asd", "qwe") // newURL = "https://yaklang.com/asd/qwe", err = nil newURL, err = str.UrlJoin("https://yaklang.com/zxc", "/asd", "qwe") // newURL = "https://yaklang.com/asd/qwe", err = nil ```

func UrlJoinParams ¶

func UrlJoinParams(i string, params ...interface{}) string

func Utf8EncodeBySpecificLength ¶

func Utf8EncodeBySpecificLength(str []byte, l int) []byte

Utf8EncodeBySpecificLength force encode unicode bytes to utf8 bytes by specific encode length

func VersionClean ¶ added in v1.2.3

func VersionClean(v string) string

func VersionCompare ¶

func VersionCompare(v1, v2 string) (int, error)

VersionCompare 泛用形的版本比较,传入(p1,p2 string), p1>p2返回1,nil, p1<p2返回-1,nil, p1==p2返回0,nil, 比较失败返回 -2,err

func VersionEqual ¶

func VersionEqual(v1, v2 string) bool

VersionEqual 使用版本比较算法比较版本 v1 与版本 v2，如果 v1 等于 v2 返回 true，否则返回 false Example: ``` str.VersionEqual("3.0", "3.0") // true str.VersionEqual("3.0", "3.0a") // false ```

func VersionGreater ¶

func VersionGreater(v1, v2 string) bool

VersionGreater 使用版本比较算法比较版本 v1 与版本 v2，如果 v1 大于 v2 返回 true，否则返回 false Example: ``` str.VersionGreater("1.0.0", "0.9.9") // true str.VersionGreater("3.0", "2.8.8alpha") // true ```

func VersionGreaterEqual ¶

func VersionGreaterEqual(v1, v2 string) bool

VersionGreaterEqual 使用版本比较算法比较版本 v1 与版本 v2，如果 v1 大于等于 v2 返回 true，否则返回 false Example: ``` str.VersionGreaterEqual("1.0.0", "0.9.9") // true str.VersionGreaterEqual("3.0", "3.0") // true str.VersionGreaterEqual("3.0", "3.0a") // false ```

func VersionLess ¶

func VersionLess(v1, v2 string) bool

VersionLess 使用版本比较算法比较版本 v1 与版本 v2，如果 v1 小于 v2 返回 true，否则返回 false Example: ``` str.VersionLess("0.9.9", "1.0.0") // true str.VersionLess("3.0", "3.0a") // true ```

func VersionLessEqual ¶

func VersionLessEqual(v1, v2 string) bool

VersionLessEqual 使用版本比较算法比较版本 v1 与版本 v2，如果 v1 小于等于 v2 返回 true，否则返回 false Example: ``` str.VersionLessEqual("0.9.9", "1.0.0") // true str.VersionLessEqual("3.0", "3.0") // true str.VersionLessEqual("3.0a", "3.0") // false ```

func WaitConnect ¶

func WaitConnect(addr string, timeout float64) error

func WaitRoutinesFromSlice ¶ added in v1.2.6

func WaitRoutinesFromSlice[T any](arg []T, job func(T))

func WithCacheCapacity ¶

func WithCacheCapacity(capacity uint64) cacheExOption

func WithCacheTTL ¶

func WithCacheTTL(ttl ...time.Duration) cacheExOption

func Wrap ¶ added in v1.2.8

func Wrap(err error, msg string) error

func Wrapf ¶ added in v1.2.8

func Wrapf(err error, format string, args ...interface{}) error

func ZlibCompress ¶

func ZlibCompress(i interface{}) ([]byte, error)

func ZlibDeCompress ¶

func ZlibDeCompress(ret []byte) ([]byte, error)

Types ¶

type AssertTestingT ¶

type AssertTestingT func(msg string, args ...any)

func (AssertTestingT) Errorf ¶

func (a AssertTestingT) Errorf(format string, args ...interface{})

type AsyncFactory ¶

type AsyncFactory[T any] struct {
	// contains filtered or unexported fields
}

func NewAsyncFactory ¶

func NewAsyncFactory[T any](
	CTX context.Context,
	factor func() (T, error),
) *AsyncFactory[T]

func (*AsyncFactory[T]) Close ¶

func (af *AsyncFactory[T]) Close()

func (*AsyncFactory[T]) Get ¶

func (af *AsyncFactory[T]) Get() (T, error)

type AtomicBool ¶

type AtomicBool int32

AtomicBool is an atomic Boolean Its methods are all atomic, thus safe to be called by multiple goroutines simultaneously Note: When embedding into a struct, one should always use *AtomicBool to avoid copy

Example ¶

cond := NewAtomicBool() // default to false
cond.Set()              // set to true
cond.IsSet()            // returns true
cond.UnSet()            // set to false
cond.SetTo(true)        // set to whatever you want

func NewAtomicBool ¶

func NewAtomicBool() *AtomicBool

New creates an AtomicBool with default to false

func NewBool ¶

func NewBool(ok bool) *AtomicBool

NewBool creates an AtomicBool with given default value

func (*AtomicBool) IsSet ¶

func (ab *AtomicBool) IsSet() bool

IsSet returns whether the Boolean is true

func (*AtomicBool) Set ¶

func (ab *AtomicBool) Set()

Set sets the Boolean to true

func (*AtomicBool) SetTo ¶

func (ab *AtomicBool) SetTo(yes bool)

SetTo sets the boolean with given Boolean

func (*AtomicBool) SetToIf ¶

func (ab *AtomicBool) SetToIf(old, new bool) (set bool)

SetToIf sets the Boolean to new only if the Boolean matches the old Returns whether the set was done

func (*AtomicBool) UnSet ¶

func (ab *AtomicBool) UnSet()

UnSet sets the Boolean to false

type AutoFlushWriter ¶

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

func WriterAutoFlush ¶

func WriterAutoFlush(writer io.Writer) *AutoFlushWriter

func (*AutoFlushWriter) Write ¶

func (w *AutoFlushWriter) Write(data []byte) (int, error)

type Barrier ¶

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

Barrier 表示单个条件屏障，支持重入（类似 WaitGroup）

func (*Barrier) Add ¶

func (b *Barrier) Add(delta int)

Add 增加屏障计数（重入功能）

func (*Barrier) Done ¶

func (b *Barrier) Done()

Done 减少屏障计数，当计数为0时标记该屏障条件已完成

type BatchProcessor ¶

type BatchProcessor[T any] struct {
	// contains filtered or unexported fields
}

func NewBatchProcessor ¶

func NewBatchProcessor[T any](ctx context.Context, dataChannel <-chan T, opts ...BatchProcessorOption[T]) *BatchProcessor[T]

func (*BatchProcessor[T]) Start ¶

func (b *BatchProcessor[T]) Start()

func (*BatchProcessor[T]) Wait ¶

func (b *BatchProcessor[T]) Wait()

type BatchProcessorConfig ¶

type BatchProcessorConfig[T any] struct {
	// contains filtered or unexported fields
}

type BatchProcessorOption ¶

type BatchProcessorOption[T any] func(*BatchProcessorConfig[T])

func WithBatchProcessorCallBack ¶

func WithBatchProcessorCallBack[T any](cb func([]T)) BatchProcessorOption[T]

func WithBatchProcessorSize ¶

func WithBatchProcessorSize[T any](size int) BatchProcessorOption[T]

func WithBatchProcessorTimeout ¶

func WithBatchProcessorTimeout[T any](timeout int) BatchProcessorOption[T]

type BruteDictParser ¶

type BruteDictParser struct {
	UserDictFile, PassDictFile *os.File
	UserDict, PassDict         *bufio.Scanner
	// contains filtered or unexported fields
}

func NewBruteDictParser ¶

func NewBruteDictParser(userDict, passDict string) (*BruteDictParser, error)

func (*BruteDictParser) Next ¶

func (b *BruteDictParser) Next() (*UserPassPair, error)

type BufferedPeekableConn ¶

type BufferedPeekableConn struct {
	net.Conn
	// contains filtered or unexported fields
}

func NewPeekableNetConn ¶

func NewPeekableNetConn(r net.Conn) *BufferedPeekableConn

func (*BufferedPeekableConn) GetBuf ¶

func (b *BufferedPeekableConn) GetBuf() []byte

func (*BufferedPeekableConn) GetOriginConn ¶

func (b *BufferedPeekableConn) GetOriginConn() net.Conn

func (*BufferedPeekableConn) GetReader ¶

func (b *BufferedPeekableConn) GetReader() io.Reader

func (*BufferedPeekableConn) Peek ¶

func (b *BufferedPeekableConn) Peek(i int) ([]byte, error)

func (*BufferedPeekableConn) PeekByte ¶

func (b *BufferedPeekableConn) PeekByte() (byte, error)

func (*BufferedPeekableConn) PeekUint16 ¶

func (b *BufferedPeekableConn) PeekUint16() uint16

func (*BufferedPeekableConn) Read ¶

func (b *BufferedPeekableConn) Read(buf []byte) (int, error)

func (*BufferedPeekableConn) SetBuf ¶

func (b *BufferedPeekableConn) SetBuf(buf []byte)

type BufferedPeekableReader ¶

type BufferedPeekableReader struct {
	io.Reader
	// contains filtered or unexported fields
}

func NewPeekableReader ¶

func NewPeekableReader(r io.Reader) *BufferedPeekableReader

func (*BufferedPeekableReader) GetBuf ¶

func (b *BufferedPeekableReader) GetBuf() []byte

func (*BufferedPeekableReader) GetReader ¶

func (b *BufferedPeekableReader) GetReader() io.Reader

func (*BufferedPeekableReader) Peek ¶

func (b *BufferedPeekableReader) Peek(i int) ([]byte, error)

func (*BufferedPeekableReader) Read ¶

func (b *BufferedPeekableReader) Read(buf []byte) (int, error)

func (*BufferedPeekableReader) SetBuf ¶

func (b *BufferedPeekableReader) SetBuf(buf []byte)

type BufferedPeekableReaderWriter ¶

type BufferedPeekableReaderWriter struct {
	io.ReadWriter
	// contains filtered or unexported fields
}

func NewPeekableReaderWriter ¶

func NewPeekableReaderWriter(r io.ReadWriter) *BufferedPeekableReaderWriter

func (*BufferedPeekableReaderWriter) GetBuf ¶

func (b *BufferedPeekableReaderWriter) GetBuf() []byte

func (*BufferedPeekableReaderWriter) GetReader ¶

func (b *BufferedPeekableReaderWriter) GetReader() io.Reader

func (*BufferedPeekableReaderWriter) Peek ¶

func (b *BufferedPeekableReaderWriter) Peek(i int) ([]byte, error)

func (*BufferedPeekableReaderWriter) Read ¶

func (b *BufferedPeekableReaderWriter) Read(buf []byte) (int, error)

func (*BufferedPeekableReaderWriter) SetBuf ¶

func (b *BufferedPeekableReaderWriter) SetBuf(buf []byte)

type CRLFtoLFReader ¶

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

func NewCRLFtoLFReader ¶

func NewCRLFtoLFReader(source io.Reader) *CRLFtoLFReader

NewCRLFtoLFReader 是 CRLFtoLFReader 的构造函数。

func (*CRLFtoLFReader) Read ¶

func (r *CRLFtoLFReader) Read(p []byte) (n int, err error)

Read 实现了 io.Reader 接口。这是实现转换逻辑的核心。

type Cache ¶ added in v1.3.1

type Cache[T any] struct {
	*CacheWithKey[string, T]
}

func NewLRUCache ¶

func NewLRUCache[T any](capacity uint64) *Cache[T]

func NewTTLCache ¶ added in v1.3.1

func NewTTLCache[T any](ttls ...time.Duration) *Cache[T]

NewTTLCache is a helper to create instance of the Cache struct

type CacheEx ¶

type CacheEx[T any] struct {
	*CacheExWithKey[string, T]
}

func NewCacheEx ¶

func NewCacheEx[T any](opt ...cacheExOption) *CacheEx[T]

type CacheExWithKey ¶

type CacheExWithKey[U comparable, T any] struct {
	*ttlcache.Cache[U, T]
	// contains filtered or unexported fields
}

CacheExWithKey is a synchronized map of items that can auto-expire once stale

func NewCacheExWithKey ¶

func NewCacheExWithKey[U comparable, T any](opt ...cacheExOption) *CacheExWithKey[U, T]

func (*CacheExWithKey[U, T]) Close ¶

func (cache *CacheExWithKey[U, T]) Close()

Can only close once

func (*CacheExWithKey[U, T]) Count ¶

func (cache *CacheExWithKey[U, T]) Count() int

Count returns the number of items in the cache

func (*CacheExWithKey[U, T]) ForEach ¶

func (cache *CacheExWithKey[U, T]) ForEach(handler func(U, T))

func (*CacheExWithKey[U, T]) Get ¶

func (cache *CacheExWithKey[U, T]) Get(key U) (value T, exists bool)

Get is a thread-safe way to lookup items Every lookup, also touches the item, hence extending it's life

func (*CacheExWithKey[U, T]) GetAll ¶

func (cache *CacheExWithKey[U, T]) GetAll() map[U]T

func (*CacheExWithKey[U, T]) GetOrLoad ¶

func (c *CacheExWithKey[U, T]) GetOrLoad(key U, dataLoader func() (T, error)) (T, error)

GetOrLoad attempts to retrieve data from the cache for the given key. If the data is not present, or is currently being prepared by another goroutine, it will wait for the data to become ready. If no preparation is in progress, it initiates the data preparation using the provided dataLoader function.

This method provides single-flight behavior: for a given key, the dataLoader function is executed only once concurrently. Multiple concurrent requests for the same key will wait for the single loading operation to complete and then receive its result.

The dataLoader function should be idempotent and thread-safe if it's external, as it will be executed by only one goroutine for a given key at a time.

func (*CacheExWithKey[U, T]) Purge ¶

func (cache *CacheExWithKey[U, T]) Purge()

Purge will remove all entries

func (*CacheExWithKey[U, T]) Remove ¶

func (cache *CacheExWithKey[U, T]) Remove(key U) bool

func (*CacheExWithKey[U, T]) Set ¶

func (cache *CacheExWithKey[U, T]) Set(key U, value T)

Set is a thread-safe way to add new items to the map

func (*CacheExWithKey[U, T]) SetExpirationCallback ¶

func (cache *CacheExWithKey[U, T]) SetExpirationCallback(callback expireCallback[U, T])

SetExpirationCallback sets a callback that will be called when an item expires

func (*CacheExWithKey[U, T]) SetNewItemCallback ¶

func (cache *CacheExWithKey[U, T]) SetNewItemCallback(callback itemCallback[U, T])

SetNewItemCallback sets a callback that will be called when a new item is added to the cache

func (*CacheExWithKey[U, T]) SetTTL ¶

func (cache *CacheExWithKey[U, T]) SetTTL(ttl time.Duration)

func (*CacheExWithKey[U, T]) SetWithTTL ¶

func (cache *CacheExWithKey[U, T]) SetWithTTL(key U, value T, ttl time.Duration)

SetWithTTL is a thread-safe way to add new items to the map with individual ttl

func (*CacheExWithKey[U, T]) SkipTtlExtensionOnHit ¶

func (cache *CacheExWithKey[U, T]) SkipTtlExtensionOnHit(value bool)

SkipTtlExtensionOnHit allows the user to change the cache behaviour. When this flag is set to true it will no longer extend TTL of items when they are retrieved using Get, or when their expiration condition is evaluated using SetCheckExpirationCallback.

type CacheWithKey ¶ added in v1.3.2

type CacheWithKey[U comparable, T any] struct {
	*CacheExWithKey[U, T]
	// contains filtered or unexported fields
}

func NewLRUCacheWithKey ¶

func NewLRUCacheWithKey[U comparable, T any](capacity uint64) *CacheWithKey[U, T]

func NewTTLCacheWithKey ¶ added in v1.3.2

func NewTTLCacheWithKey[U comparable, T any](ttls ...time.Duration) *CacheWithKey[U, T]

NewTTLCacheWithKey is a helper to create instance of the CacheWithKey struct, allow set Key and Value

func (*CacheWithKey[U, T]) GetOrLoad ¶

func (cache *CacheWithKey[U, T]) GetOrLoad(key U, dataLoader func() (T, error)) (T, error)

GetOrLoad attempts to retrieve data from the cache for the given key. If the data is not present, it will execute the dataLoader function to load it. This method provides single-flight behavior: for a given key, the dataLoader function is executed only once concurrently. Multiple concurrent requests for the same key will wait for the single loading operation to complete and then receive its result.

func (*CacheWithKey[U, T]) SetExpirationCallback ¶ added in v1.3.2

func (cache *CacheWithKey[U, T]) SetExpirationCallback(callback expireCallbackWithoutReason[U, T])

SetExpirationCallback sets a callback that will be called when an item expires

type CircularQueue ¶ added in v1.2.2

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

func NewCircularQueue ¶ added in v1.2.2

func NewCircularQueue(capacity int) *CircularQueue

func (*CircularQueue) GetElements ¶ added in v1.2.2

func (q *CircularQueue) GetElements() []interface{}

func (*CircularQueue) Push ¶ added in v1.2.2

func (q *CircularQueue) Push(x interface{})

type Complex ¶ added in v1.3.1

type Complex interface {
	~complex64 | ~complex128
}

Complex is a constraint that permits any complex numeric type. If future releases of Go add new predeclared complex numeric types, this constraint will be modified to include them.

type CondBarrier ¶

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

CondBarrier 条件屏障管理器

func NewCondBarrier ¶

func NewCondBarrier() *CondBarrier

NewCondBarrier 创建新的条件屏障管理器

func NewCondBarrierContext ¶

func NewCondBarrierContext(ctx context.Context) *CondBarrier

NewCondBarrierContext 创建带上下文的条件屏障管理器

func (*CondBarrier) Cancel ¶

func (cb *CondBarrier) Cancel()

Cancel 取消所有等待，使所有Wait操作立即返回调用 Cancel 后： - 所有正在等待的 Wait 操作将立即返回 nil（不返回错误） - 新创建的屏障将立即处于完成状态 - 可以安全地多次调用 Cancel

func (*CondBarrier) CreateBarrier ¶

func (cb *CondBarrier) CreateBarrier(name string) *Barrier

CreateBarrier 创建一个命名的屏障条件

func (*CondBarrier) Wait ¶

func (cb *CondBarrier) Wait(names ...string) error

Wait 等待指定的屏障条件完成参数：

names - 要等待的屏障名称列表，如果为空则等待所有屏障

返回：

error - 只有在上下文超时/取消时才返回错误，Cancel 操作不会返回错误

特性：

支持等待尚未创建的屏障（会等待其被创建并完成）
支持同时等待多个屏障
空参数时等同于 WaitAll()
线程安全，可以并发调用

func (*CondBarrier) WaitAll ¶

func (cb *CondBarrier) WaitAll() error

WaitAll 等待所有已创建的屏障完成

type CoolDown ¶

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

func NewCoolDown ¶

func NewCoolDown(d time.Duration) *CoolDown

func NewCoolDownContext ¶

func NewCoolDownContext(d time.Duration, ctx context.Context) *CoolDown

func (*CoolDown) Do ¶

func (c *CoolDown) Do(f func())

func (*CoolDown) DoOr ¶

func (c *CoolDown) DoOr(f func(), fallback func())

func (*CoolDown) Reset ¶

func (c *CoolDown) Reset(d time.Duration)

type CoolDownFetcher ¶

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

func NewCoolDownFetcher ¶

func NewCoolDownFetcher(timeoutDuration time.Duration) *CoolDownFetcher

func (*CoolDownFetcher) Fetch ¶

func (c *CoolDownFetcher) Fetch(handler func() (any, error)) (any, error)

type CountingReadWriter ¶ added in v1.3.2

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

CountingReadWriter 是一个包装了 io.Writer 的结构体，用于统计写入的字符数

func NewCountingReadWriter ¶ added in v1.3.2

func NewCountingReadWriter(w io.ReadWriter) *CountingReadWriter

NewCountingReadWriter 返回一个新的 CountingWriter，它包装了给定的 io.Writer

func (*CountingReadWriter) Count ¶ added in v1.3.2

func (cw *CountingReadWriter) Count() int

Count 返回到目前为止写入的字符数

func (*CountingReadWriter) Read ¶ added in v1.3.2

func (cr *CountingReadWriter) Read(p []byte) (n int, err error)

Read 实现了 io.Reader 接口，读取数据的同时统计字符数

func (*CountingReadWriter) Write ¶ added in v1.3.2

func (cw *CountingReadWriter) Write(p []byte) (n int, err error)

Write 实现了 io.Writer 接口，写入数据的同时统计字符数

type CountingReader ¶ added in v1.3.2

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

CountingReader 是一个包装了 io.Reader 的结构体，用于统计读取的字符数

func NewCountingReader ¶ added in v1.3.2

func NewCountingReader(r io.Reader) *CountingReader

NewCountingReader 返回一个新的 CountingReader，它包装了给定的 io.Reader

func (*CountingReader) Count ¶ added in v1.3.2

func (cr *CountingReader) Count() int

Count 返回到目前为止读取的字符数

func (*CountingReader) Read ¶ added in v1.3.2

func (cr *CountingReader) Read(p []byte) (n int, err error)

Read 实现了 io.Reader 接口，读取数据的同时统计字符数

type CountingWriter ¶ added in v1.3.2

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

CountingWriter 是一个包装了 io.Writer 的结构体，用于统计写入的字符数

func NewCountingWriter ¶ added in v1.3.2

func NewCountingWriter(w io.Writer) *CountingWriter

NewCountingWriter 返回一个新的 CountingWriter，它包装了给定的 io.Writer

func (*CountingWriter) Count ¶ added in v1.3.2

func (cw *CountingWriter) Count() int

Count 返回到目前为止写入的字符数

func (*CountingWriter) Write ¶ added in v1.3.2

func (cw *CountingWriter) Write(p []byte) (n int, err error)

Write 实现了 io.Writer 接口，写入数据的同时统计字符数

type CustomWriter ¶ added in v1.2.8

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

func NewWriter ¶ added in v1.2.8

func NewWriter(f func(p []byte) (n int, err error)) *CustomWriter

func (*CustomWriter) Write ¶ added in v1.2.8

func (c *CustomWriter) Write(p []byte) (n int, err error)

type DelayWaiter ¶

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

delay with range

func NewDelayWaiter ¶

func NewDelayWaiter(min int32, max int32) (*DelayWaiter, error)

func (*DelayWaiter) Wait ¶

func (d *DelayWaiter) Wait()

func (*DelayWaiter) WaitWithProbabilityPercent ¶

func (d *DelayWaiter) WaitWithProbabilityPercent(raw float64)

type EventWatcherManager ¶

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

func NewEntityWatcher ¶

func NewEntityWatcher(ctx context.Context, triggerTime time.Duration, triggerCount int) *EventWatcherManager

func (*EventWatcherManager) StopWatch ¶

func (ew *EventWatcherManager) StopWatch(key string)

func (*EventWatcherManager) Watch ¶

func (ew *EventWatcherManager) Watch(key string, callback func(key string), firstWatch func(key string))

type EvictionReason ¶

type EvictionReason int

EvictionReason is used to specify why a certain item was evicted/deleted.

const (
	EvictionReasonDeleted EvictionReason = iota + 1
	EvictionReasonCapacityReached
	EvictionReasonExpired
)

Available eviction reasons.

type FileInfo ¶

type FileInfo struct {
	BuildIn os.FileInfo
	Path    string
	Name    string
	IsDir   bool
}

func ReadDir ¶

func ReadDir(p string) ([]*FileInfo, error)

func ReadDirWithLimit ¶

func ReadDirWithLimit(p string, limit int) ([]*FileInfo, error)

func ReadDirsRecursively ¶

func ReadDirsRecursively(p string) ([]*FileInfo, error)

func ReadFilesRecursively ¶

func ReadFilesRecursively(p string) ([]*FileInfo, error)

func ReadFilesRecursivelyWithLimit ¶

func ReadFilesRecursivelyWithLimit(p string, limit int) ([]*FileInfo, error)

type FileOpenerType ¶ added in v1.2.8

type FileOpenerType func(s string) (*os.File, error)

type Float ¶ added in v1.3.1

type Float interface {
	~float32 | ~float64
}

Float is a constraint that permits any floating-point type. If future releases of Go add new predeclared floating-point types, this constraint will be modified to include them.

type FloatSecondsDelayWaiter ¶

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

delay with range

func NewFloatSecondsDelayWaiter ¶

func NewFloatSecondsDelayWaiter(min, max float64) (*FloatSecondsDelayWaiter, error)

func NewFloatSecondsDelayWaiterSingle ¶

func NewFloatSecondsDelayWaiterSingle(min float64) (*FloatSecondsDelayWaiter, error)

func (*FloatSecondsDelayWaiter) Wait ¶

func (d *FloatSecondsDelayWaiter) Wait()

func (*FloatSecondsDelayWaiter) WaitWithProbabilityPercent ¶

func (d *FloatSecondsDelayWaiter) WaitWithProbabilityPercent(raw float64)

type Frame ¶ added in v1.2.8

type Frame uintptr

Frame represents a program counter inside a stack frame. For historical reasons if Frame is interpreted as a uintptr its value represents the program counter + 1.

func (Frame) Format ¶ added in v1.2.8

func (f Frame) Format(s fmt.State, verb rune)

Format formats the frame according to the fmt.Formatter interface.

%s    source file
%d    source line
%n    function name
%v    equivalent to %s:%d

Format accepts flags that alter the printing of some verbs, as follows:

%+s   function name and path of source file relative to the compile time
      GOPATH separated by \n\t (<funcname>\n\t<path>)
%+v   equivalent to %+s:%d

func (Frame) MarshalText ¶ added in v1.2.8

func (f Frame) MarshalText() ([]byte, error)

MarshalText formats a stacktrace Frame as a text string. The output is the same as that of fmt.Sprintf("%+v", f), but without newlines or tabs.

type GlobFilter ¶

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

func NewGlobFilter ¶

func NewGlobFilter(separator rune, exclude ...string) *GlobFilter

func (*GlobFilter) Add ¶

func (f *GlobFilter) Add(block ...string)

func (*GlobFilter) Contains ¶

func (f *GlobFilter) Contains(target string) bool

type GoroutineLogBuffer ¶

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

GoroutineLogBuffer multiplexes writes coming from different goroutines into per-goroutine buffers. Attach the current goroutine before running the work you want to capture; flush the buffer when the task completes.

Typical usage:

b := utils.NewGoroutineLogBuffer(os.Stdout)
buf, detach := b.Attach()
defer func() {
    b.Flush("task name", buf)
    detach()
}()
... // perform work that writes logs via b

func NewGoroutineLogBuffer ¶

func NewGoroutineLogBuffer(fallback io.Writer, opts ...GoroutineLogBufferOption) *GoroutineLogBuffer

NewGoroutineLogBuffer creates a GoroutineLogBuffer that writes to fallback when there is no active buffer for the calling goroutine. If fallback is nil, io.Discard is used.

func (*GoroutineLogBuffer) Attach ¶

func (b *GoroutineLogBuffer) Attach() (*bytes.Buffer, func())

Attach registers a new buffer for the current goroutine and returns it along with a detach function. Detach should be called after the goroutine finishes using the buffer to avoid leaks.

func (*GoroutineLogBuffer) Flush ¶

func (b *GoroutineLogBuffer) Flush(label string, buf *bytes.Buffer, failed bool)

Flush writes the collected buffer to the fallback writer with a simple header/footer so the output stands out in shared logs. When the buffer is configured to only flush failures and `failed` is false, the call is a no-op.

func (*GoroutineLogBuffer) FlushDefault ¶

func (b *GoroutineLogBuffer) FlushDefault()

FlushDefault flushes logs collected from goroutines without explicit attachments. It always flushes regardless of the failed flag.

func (*GoroutineLogBuffer) Write ¶

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

Write implements io.Writer, routing the bytes to the buffer registered for the calling goroutine when present, or falling back to the shared writer.

type GoroutineLogBufferOption ¶

type GoroutineLogBufferOption func(*GoroutineLogBuffer)

func WithGoroutineLogFailedOnly ¶

func WithGoroutineLogFailedOnly(b bool) GoroutineLogBufferOption

WithGoroutineLogFailedOnly toggles the behavior to only flush buffers when the associated work failed.

type GoroutineLogCapture ¶

type GoroutineLogCapture struct {
	Buffer *GoroutineLogBuffer
	// contains filtered or unexported fields
}

GoroutineLogCapture wires os.Stdout/os.Stderr and the logging subsystems to a GoroutineLogBuffer, enabling per-goroutine log buffering with a single cleanup function.

func StartGoroutineLogCapture ¶

func StartGoroutineLogCapture(fallback io.Writer, opts ...GoroutineLogBufferOption) (*GoroutineLogCapture, error)

StartGoroutineLogCapture creates a new GoroutineLogBuffer (using fallback as the shared writer) and redirects stdout/stderr, the standard log package, and yaklang's common log package into that buffer. Call Stop to restore the previous state.

func (*GoroutineLogCapture) Stop ¶

func (c *GoroutineLogCapture) Stop()

Stop restores stdout/stderr and log outputs back to their original targets. It is safe to call multiple times.

type HTTPPacketFilter ¶

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

func NewHTTPPacketFilter ¶

func NewHTTPPacketFilter() *HTTPPacketFilter

func (*HTTPPacketFilter) Conditions ¶

func (j *HTTPPacketFilter) Conditions() []string

func (*HTTPPacketFilter) Hash ¶

func (h *HTTPPacketFilter) Hash() string

func (*HTTPPacketFilter) IsAllowed ¶

func (h *HTTPPacketFilter) IsAllowed(req *http.Request, rsp *http.Response) bool

func (*HTTPPacketFilter) Remove ¶

func (i *HTTPPacketFilter) Remove(name string)

func (*HTTPPacketFilter) SetAllowForRequestHeader ¶

func (j *HTTPPacketFilter) SetAllowForRequestHeader(header, regexp string)

func (*HTTPPacketFilter) SetAllowForRequestPath ¶

func (j *HTTPPacketFilter) SetAllowForRequestPath(regexp string)

func (*HTTPPacketFilter) SetAllowForRequestRaw ¶

func (j *HTTPPacketFilter) SetAllowForRequestRaw(regexp string)

func (*HTTPPacketFilter) SetAllowForResponseHeader ¶

func (j *HTTPPacketFilter) SetAllowForResponseHeader(header, regexp string)

func (*HTTPPacketFilter) SetAllowForResponseRaw ¶

func (j *HTTPPacketFilter) SetAllowForResponseRaw(regexp string)

func (*HTTPPacketFilter) SetRejectForRequestHeader ¶

func (j *HTTPPacketFilter) SetRejectForRequestHeader(header, regexp string)

func (*HTTPPacketFilter) SetRejectForRequestPath ¶

func (j *HTTPPacketFilter) SetRejectForRequestPath(regexp string)

func (*HTTPPacketFilter) SetRejectForRequestRaw ¶

func (j *HTTPPacketFilter) SetRejectForRequestRaw(regexp string)

func (*HTTPPacketFilter) SetRejectForResponseHeader ¶

func (j *HTTPPacketFilter) SetRejectForResponseHeader(header, regexp string)

func (*HTTPPacketFilter) SetRejectForResponseRaw ¶

func (j *HTTPPacketFilter) SetRejectForResponseRaw(regexp string)

type HostPortClassifier ¶

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

func NewHostPortClassifier ¶

func NewHostPortClassifier() *HostPortClassifier

func (*HostPortClassifier) AddHostPort ¶

func (h *HostPortClassifier) AddHostPort(tag string, hosts []string, ports []string, ttl time.Duration) error

func (*HostPortClassifier) FilterTagByHostPort ¶

func (h *HostPortClassifier) FilterTagByHostPort(host string, port int) []string

type HostsFilter ¶

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

func NewHostsFilter ¶

func NewHostsFilter(excludeHosts ...string) *HostsFilter

func (*HostsFilter) Add ¶

func (f *HostsFilter) Add(block ...string)

func (*HostsFilter) Contains ¶

func (f *HostsFilter) Contains(target string) bool

type IntHeap ¶ added in v1.3.3

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

func NewIntHeap ¶ added in v1.3.3

func NewIntHeap(init ...[]int) *IntHeap

func (*IntHeap) Index ¶ added in v1.3.3

func (h *IntHeap) Index(i int) int

func (*IntHeap) Len ¶ added in v1.3.3

func (h *IntHeap) Len() int

func (*IntHeap) Pop ¶ added in v1.3.3

func (h *IntHeap) Pop() interface{}

func (*IntHeap) Push ¶ added in v1.3.3

func (h *IntHeap) Push(x interface{})

type Integer ¶ added in v1.3.1

type Integer interface {
	Signed | Unsigned
}

Integer is a constraint that permits any integer type. If future releases of Go add new predeclared integer types, this constraint will be modified to include them.

type LimitRate ¶

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

func NewLimitRate ¶

func NewLimitRate(d time.Duration) *LimitRate

func (*LimitRate) WaitUntilNextAsync ¶

func (l *LimitRate) WaitUntilNextAsync()

func (*LimitRate) WaitUntilNextAsyncWithFallback ¶

func (l *LimitRate) WaitUntilNextAsyncWithFallback(f func())

func (*LimitRate) WaitUntilNextSync ¶

func (l *LimitRate) WaitUntilNextSync()

type MatchedRule ¶

type MatchedRule struct {
	Matched *regexp.Regexp
}

func ParseNmapServiceMatchedRule ¶

func ParseNmapServiceMatchedRule(raw []byte) []*MatchedRule

type Once ¶

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

Once 是一个可以确保某个操作只执行一次的结构体相比于 sync.Once，它提供了更灵活的接口，支持 DoOr 方法

func NewOnce ¶

func NewOnce() *Once

NewOnce 创建一个新的 Once 实例

func (*Once) Do ¶

func (o *Once) Do(f func())

Do 执行函数 f，确保 f 只会被执行一次如果已经执行过，则直接返回如果正在执行，其他 goroutine 会阻塞等待执行完成

func (*Once) DoOr ¶

func (o *Once) DoOr(f func(), fallback func())

DoOr 尝试执行函数 f，如果已经执行过则执行回调函数 fallback 如果正在执行，其他 goroutine 会执行回调函数 fallback 这与 Do 的区别在于：Do 会阻塞等待，DoOr 会立即执行回调

func (*Once) Done ¶

func (o *Once) Done() bool

Done 返回是否已经执行过

func (*Once) Reset ¶

func (o *Once) Reset()

Reset 重置 Once 状态，使其可以再次执行注意：这个方法不是并发安全的，只应该在确保没有并发访问时使用

type Ordered ¶ added in v1.3.1

type Ordered interface {
	Integer | Float | ~string
}

Ordered is a constraint that permits any ordered type: any type that supports the operators < <= >= >. If future releases of Go add new ordered types, this constraint will be modified to include them.

type ParallelProcessConfig ¶

type ParallelProcessConfig struct {
	Concurrency    int
	StartCallback  func()
	FinishCallback func()

	StartTask func()
	DeferTask func()
}

type ParallelProcessOption ¶

type ParallelProcessOption func(*ParallelProcessConfig)

func WithParallelProcessConcurrency ¶

func WithParallelProcessConcurrency(concurrency int) ParallelProcessOption

func WithParallelProcessDeferTask ¶

func WithParallelProcessDeferTask(h func()) ParallelProcessOption

func WithParallelProcessFinishCallback ¶

func WithParallelProcessFinishCallback(callback func()) ParallelProcessOption

func WithParallelProcessStartCallback ¶

func WithParallelProcessStartCallback(callback func()) ParallelProcessOption

func WithParallelProcessStartTask ¶

func WithParallelProcessStartTask(h func()) ParallelProcessOption

type PathForest ¶

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

func GeneratePathTrees ¶

func GeneratePathTrees(l ...string) (*PathForest, error)

func (*PathForest) AddPath ¶

func (p *PathForest) AddPath(path string, f any) error

func (*PathForest) Get ¶

func (p *PathForest) Get(path string) (*PathNode, error)

func (*PathForest) Output ¶

func (p *PathForest) Output() []*PathNode

func (*PathForest) ReadOnly ¶

func (w *PathForest) ReadOnly()

func (*PathForest) Recursive ¶ added in v1.3.2

func (p *PathForest) Recursive(f func(node2 *PathNode))

type PathNode ¶ added in v1.3.2

type PathNode struct {
	Parent        *PathNode `json:"-"`
	Path          string    `json:"path"`
	RelativePaths []string  `json:"relative_paths"`
	Name          string    `json:"name"`

	Children []*PathNode `json:"children"`
	Depth    int         `json:"depth"`
	Value    any         `json:"-"`
	ReadOnly bool        `json:"-"`
	// contains filtered or unexported fields
}

func (*PathNode) AllChildren ¶ added in v1.3.2

func (p *PathNode) AllChildren() []*PathNode

func (*PathNode) Existed ¶

func (p *PathNode) Existed(i string) bool

func (*PathNode) GetDepth ¶ added in v1.3.2

func (n *PathNode) GetDepth() int

type PathNodes ¶

type PathNodes []*PathNode

type PortScanTarget ¶

type PortScanTarget struct {
	Targets []string
	TCPPort string
	UDPPort string
}

func SplitHostsAndPorts ¶

func SplitHostsAndPorts(hosts, ports string, portGroupSize int, proto string) []PortScanTarget

func (*PortScanTarget) String ¶

func (t *PortScanTarget) String() string

type PortsFilter ¶

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

func NewPortsFilter ¶

func NewPortsFilter(blocks ...string) *PortsFilter

func (*PortsFilter) Add ¶

func (f *PortsFilter) Add(block ...string)

func (*PortsFilter) Contains ¶

func (f *PortsFilter) Contains(port int) bool

type ProbeRule ¶

type ProbeRule struct {
	Type    ProtoType
	Payload []byte
	Matched []*MatchedRule
}

func ParseNmapServiceProbeRule ¶

func ParseNmapServiceProbeRule(raw []byte) []*ProbeRule

type ProtoReader ¶

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

ProtoReader 提供从 io.Reader 读取 protobuf 编码数据的方法

func NewProtoReader ¶

func NewProtoReader(reader io.Reader) *ProtoReader

NewProtoReader 创建一个新的 ProtoReader

func (*ProtoReader) ReadBool ¶

func (pr *ProtoReader) ReadBool() (bool, error)

ReadBool 读取布尔值

func (*ProtoReader) ReadBytes ¶

func (pr *ProtoReader) ReadBytes() ([]byte, error)

ReadBytes 读取字节数组

func (*ProtoReader) ReadFloat32 ¶

func (pr *ProtoReader) ReadFloat32() (float32, error)

ReadFloat32 读取一个 float32 值

func (*ProtoReader) ReadInt32 ¶

func (pr *ProtoReader) ReadInt32() (int32, error)

ReadInt32 读取 int32 值

func (*ProtoReader) ReadInt64 ¶

func (pr *ProtoReader) ReadInt64() (int64, error)

ReadInt64 读取 int64 值

func (*ProtoReader) ReadMagicHeader ¶

func (pr *ProtoReader) ReadMagicHeader(expectedMagic string) error

ReadMagicHeader 读取并验证魔数头（固定16字节）

func (*ProtoReader) ReadString ¶

func (pr *ProtoReader) ReadString() (string, error)

ReadString 读取字符串

func (*ProtoReader) ReadUint32 ¶

func (pr *ProtoReader) ReadUint32() (uint32, error)

ReadUint32 读取一个 uint32 值

func (*ProtoReader) ReadVarint ¶

func (pr *ProtoReader) ReadVarint() (uint64, error)

ReadVarint 读取一个 varint 值

type ProtoType ¶

type ProtoType string

var (
	TCPProbe ProtoType = "tcp"
	UDPProbe ProtoType = "udp"
)

type ProtoWriter ¶

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

ProtoWriter 提供向 io.Writer 写入 protobuf 编码数据的方法

func NewProtoWriter ¶

func NewProtoWriter(writer io.Writer) *ProtoWriter

NewProtoWriter 创建一个新的 ProtoWriter

func (*ProtoWriter) WriteBool ¶

func (pw *ProtoWriter) WriteBool(value bool) error

WriteBool 写入布尔值

func (*ProtoWriter) WriteBytes ¶

func (pw *ProtoWriter) WriteBytes(value []byte) error

WriteBytes 写入字节数组

func (*ProtoWriter) WriteFloat32 ¶

func (pw *ProtoWriter) WriteFloat32(value float32) error

WriteFloat32 写入 float32 值

func (*ProtoWriter) WriteInt32 ¶

func (pw *ProtoWriter) WriteInt32(value int32) error

WriteInt32 写入 int32 值

func (*ProtoWriter) WriteInt64 ¶

func (pw *ProtoWriter) WriteInt64(value int64) error

WriteInt64 写入 int64 值

func (*ProtoWriter) WriteMagicHeader ¶

func (pw *ProtoWriter) WriteMagicHeader(magic string) error

WriteMagicHeader 写入魔数头（固定16字节）

func (*ProtoWriter) WriteString ¶

func (pw *ProtoWriter) WriteString(value string) error

WriteString 写入字符串

func (*ProtoWriter) WriteUint32 ¶

func (pw *ProtoWriter) WriteUint32(value uint32) error

WriteUint32 写入 uint32 值

func (*ProtoWriter) WriteVarint ¶

func (pw *ProtoWriter) WriteVarint(value uint64) error

WriteVarint 写入一个 varint 值

type RRFScoredData ¶

type RRFScoredData interface {
	GetScoreMethod() string
	GetScore() float64
	GetUUID() string
}

type RankScoredData ¶

type RankScoredData struct {
	ID           string
	RRFRankScore float64
}

type RequireTestingT ¶

type RequireTestingT struct {
	AssertTestingT
	FalNow func()
}

func NewRequireTestT ¶

func NewRequireTestT(a AssertTestingT, f func()) *RequireTestingT

func (*RequireTestingT) FailNow ¶

func (r *RequireTestingT) FailNow()

type Result ¶

type Result[O any] struct {
	Index  int
	Output O
	Err    error
}

type SSHClient ¶

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

func SSHDial ¶

func SSHDial(network, addr string, config *ssh.ClientConfig) (*SSHClient, error)

SSHDial starts a client connection to the given SSH server. This is wrap the ssh.SSHDial

func SSHDialWithKey ¶

func SSHDialWithKey(addr, user, keyfile string) (*SSHClient, error)

SSHDialWithKey starts a client connection to the given SSH server with key authmethod.

func SSHDialWithKeyWithPassphrase ¶

func SSHDialWithKeyWithPassphrase(addr, user, keyfile string, passphrase string) (*SSHClient, error)

SSHDialWithKeyWithPassphrase same as SSHDialWithKey but with a passphrase to decrypt the private key

func SSHDialWithPasswd ¶

func SSHDialWithPasswd(addr, user, passwd string) (*SSHClient, error)

SSHDialWithPasswd starts a client connection to the given SSH server with passwd authmethod.

func (*SSHClient) Close ¶

func (c *SSHClient) Close() error

func (*SSHClient) Cmd ¶

func (c *SSHClient) Cmd(cmd string) *SSHRemoteScript

Cmd create a command on client

func (*SSHClient) CopyLocalFileToRemote ¶

func (c *SSHClient) CopyLocalFileToRemote(srcFilePath string, dstFilePath string) error

Copy local file to remote

func (*SSHClient) CopyRemoteFileToLocal ¶

func (c *SSHClient) CopyRemoteFileToLocal(dstFilePath string, srcFilePath string) error

Copy remote file to local

func (*SSHClient) Script ¶

func (c *SSHClient) Script(script string) *SSHRemoteScript

Script

func (*SSHClient) ScriptFile ¶

func (c *SSHClient) ScriptFile(fname string) *SSHRemoteScript

ScriptFile

func (*SSHClient) Shell ¶

func (c *SSHClient) Shell() *SSHRemoteShell

Shell create a noninteractive shell on client.

func (*SSHClient) Terminal ¶

func (c *SSHClient) Terminal(config *TerminalConfig) *SSHRemoteShell

Terminal create a interactive shell on client.

type SSHRemoteScript ¶

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

func (*SSHRemoteScript) Cmd ¶

func (rs *SSHRemoteScript) Cmd(cmd string) *SSHRemoteScript

func (*SSHRemoteScript) Output ¶

func (rs *SSHRemoteScript) Output() ([]byte, error)

func (*SSHRemoteScript) Run ¶

func (rs *SSHRemoteScript) Run() error

Run

func (*SSHRemoteScript) SetStdio ¶

func (rs *SSHRemoteScript) SetStdio(stdout, stderr io.Writer) *SSHRemoteScript

func (*SSHRemoteScript) SmartOutput ¶

func (rs *SSHRemoteScript) SmartOutput() ([]byte, error)

type SSHRemoteScriptType ¶

type SSHRemoteScriptType byte

type SSHRemoteShell ¶

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

func (*SSHRemoteShell) SetStdio ¶

func (rs *SSHRemoteShell) SetStdio(stdin io.Reader, stdout, stderr io.Writer) *SSHRemoteShell

func (*SSHRemoteShell) Start ¶

func (rs *SSHRemoteShell) Start() error

Start start a remote shell on client

type SSHRemoteShellType ¶

type SSHRemoteShellType byte

type SafeMap ¶

type SafeMap[V any] struct {
	*SafeMapWithKey[string, V]
}

func NewSafeMap ¶

func NewSafeMap[V any]() *SafeMap[V]

type SafeMapWithKey ¶

type SafeMapWithKey[K comparable, V any] struct {
	// contains filtered or unexported fields
}

func NewSafeMapWithKey ¶

func NewSafeMapWithKey[K comparable, V any]() *SafeMapWithKey[K, V]

func (*SafeMapWithKey[K, V]) Clear ¶

func (sm *SafeMapWithKey[K, V]) Clear()

func (*SafeMapWithKey[K, V]) Count ¶

func (sm *SafeMapWithKey[K, V]) Count() int

func (*SafeMapWithKey[K, V]) Delete ¶

func (sm *SafeMapWithKey[K, V]) Delete(key K)

func (*SafeMapWithKey[K, V]) ForEach ¶

func (sm *SafeMapWithKey[K, V]) ForEach(f func(key K, value V) bool)

func (*SafeMapWithKey[K, V]) Get ¶

func (sm *SafeMapWithKey[K, V]) Get(key K) (V, bool)

func (*SafeMapWithKey[K, V]) GetAll ¶

func (sm *SafeMapWithKey[K, V]) GetAll() map[K]V

func (*SafeMapWithKey[K, V]) GetOrLoad ¶

func (sm *SafeMapWithKey[K, V]) GetOrLoad(key K, f func() V) V

func (*SafeMapWithKey[K, V]) Have ¶

func (sm *SafeMapWithKey[K, V]) Have(key K) bool

func (*SafeMapWithKey[K, V]) Set ¶

func (sm *SafeMapWithKey[K, V]) Set(key K, value V)

func (*SafeMapWithKey[K, V]) Values ¶

func (sm *SafeMapWithKey[K, V]) Values() []V

type SavepointTransaction ¶

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

SavepointTransaction 基于SAVEPOINT的多层事务管理器

func NewSavepointTransaction ¶

func NewSavepointTransaction(db *gorm.DB) *SavepointTransaction

NewSavepointTransaction 创建一个新的SAVEPOINT事务管理器

func (*SavepointTransaction) Begin ¶

func (st *SavepointTransaction) Begin() (*gorm.DB, error)

Begin 开始一个新的事务层级

func (*SavepointTransaction) Commit ¶

func (st *SavepointTransaction) Commit() error

Commit 提交当前层级的事务

func (*SavepointTransaction) GetDB ¶

func (st *SavepointTransaction) GetDB() *gorm.DB

GetDB 获取当前的数据库连接

func (*SavepointTransaction) GetLevel ¶

func (st *SavepointTransaction) GetLevel() int

GetLevel 获取当前事务层级

func (*SavepointTransaction) IsInTransaction ¶

func (st *SavepointTransaction) IsInTransaction() bool

IsInTransaction 检查是否在事务中

func (*SavepointTransaction) Rollback ¶

func (st *SavepointTransaction) Rollback() error

Rollback 回滚当前层级的事务

type Set ¶

type Set[T comparable] struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewSet ¶ added in v1.2.3

func NewSet[T comparable](list ...[]T) *Set[T]

func (*Set[T]) Add ¶

func (s *Set[T]) Add(item T)

Add add

func (*Set[T]) AddList ¶ added in v1.2.6

func (s *Set[T]) AddList(items []T)

func (*Set[T]) And ¶ added in v1.3.1

func (s *Set[T]) And(other *Set[T]) *Set[T]

func (*Set[T]) Clear ¶

func (s *Set[T]) Clear()

Clear removes all items from the set

func (*Set[T]) Diff ¶ added in v1.3.1

func (s *Set[T]) Diff(other *Set[T]) *Set[T]

func (*Set[T]) ForEach ¶ added in v1.3.1

func (s *Set[T]) ForEach(h func(T))

func (*Set[T]) Has ¶

func (s *Set[T]) Has(item T) bool

Has looks for the existence of an item

func (*Set[T]) IsEmpty ¶

func (s *Set[T]) IsEmpty() bool

IsEmpty checks for emptiness

func (*Set[T]) Len ¶

func (s *Set[T]) Len() int

Len returns the number of items in a set.

func (*Set[T]) List ¶

func (s *Set[T]) List() []T

Set returns a slice of all items

func (*Set[T]) Or ¶ added in v1.3.1

func (s *Set[T]) Or(other *Set[T]) *Set[T]

func (*Set[T]) Remove ¶

func (s *Set[T]) Remove(item T)

Remove deletes the specified item from the map

type Signed ¶ added in v1.3.1

type Signed interface {
	~int | ~int8 | ~int16 | ~int32 | ~int64
}

Signed is a constraint that permits any signed integer type. If future releases of Go add new predeclared signed integer types, this constraint will be modified to include them.

type SizedWaitGroup ¶

type SizedWaitGroup struct {
	Size              int
	WaitingEventCount atomic.Int64
	// contains filtered or unexported fields
}

SizedWaitGroup has the same role and close to the same API as the Golang sync.WaitGroup but adds a limit of the amount of goroutines started concurrently.

func NewSizedWaitGroup ¶

func NewSizedWaitGroup(limit int, ctxs ...context.Context) *SizedWaitGroup

New creates a SizedWaitGroup. The limit parameter is the maximum amount of goroutines which can be started concurrently.

func (*SizedWaitGroup) Add ¶

func (s *SizedWaitGroup) Add(delta ...int)

Add increments the internal WaitGroup counter. It can be blocking if the limit of spawned goroutines has been reached. It will stop blocking when Done is been called.

See sync.WaitGroup documentation for more information.

func (*SizedWaitGroup) AddWithContext ¶

func (s *SizedWaitGroup) AddWithContext(ctx context.Context, delta ...int) error

AddWithContext increments the internal WaitGroup counter. It can be blocking if the limit of spawned goroutines has been reached. It will stop blocking when Done is been called, or when the context is canceled. Returns nil on success or an error if the context is canceled before the lock is acquired.

See sync.WaitGroup documentation for more information.

func (*SizedWaitGroup) Done ¶

func (s *SizedWaitGroup) Done()

Done decrements the SizedWaitGroup counter. See sync.WaitGroup documentation for more information.

func (*SizedWaitGroup) SetContext ¶ added in v1.3.2

func (s *SizedWaitGroup) SetContext(ctx context.Context)

SetContext sets the context for the SizedWaitGroup. ! If Call twice or more, any of the previous context Done will cause the WaitGroup to be SetZero.

func (*SizedWaitGroup) SetZero ¶ added in v1.3.2

func (s *SizedWaitGroup) SetZero()

func (*SizedWaitGroup) Wait ¶

func (s *SizedWaitGroup) Wait()

Wait blocks until the SizedWaitGroup counter is zero. See sync.WaitGroup documentation for more information.

type Stack ¶

type Stack[T any] struct {
	// contains filtered or unexported fields
}

func NewStack ¶

func NewStack[T any]() *Stack[T]

Create a new stack

func (*Stack[T]) CreateShadowStack ¶ added in v1.2.8

func (this *Stack[T]) CreateShadowStack() func()

CreateShadowStack creates a shadow stack, which can be used to restore the stack to its current state. dont pop the top item of the stack.

func (*Stack[T]) ForeachStack ¶

func (this *Stack[T]) ForeachStack(f func(T) bool)

func (*Stack[T]) Free ¶

func (this *Stack[T]) Free()

func (*Stack[T]) HaveLastStackValue ¶ added in v1.3.0

func (this *Stack[T]) HaveLastStackValue() bool

func (*Stack[T]) IsEmpty ¶

func (this *Stack[T]) IsEmpty() bool

func (*Stack[T]) LastStackValue ¶ added in v1.3.0

func (this *Stack[T]) LastStackValue() T

func (*Stack[T]) Len ¶ added in v1.2.8

func (this *Stack[T]) Len() int

Return the number of items in the stack

func (*Stack[T]) Peek ¶

func (this *Stack[T]) Peek() T

View the top item on the stack

func (*Stack[T]) PeekN ¶ added in v1.2.8

func (this *Stack[T]) PeekN(n int) T

View the top n item on the stack

func (*Stack[T]) Pop ¶

func (this *Stack[T]) Pop() T

Pop the top item of the stack and return it

func (*Stack[T]) PopN ¶ added in v1.3.0

func (this *Stack[T]) PopN(n int) []T

PopN the top item of the stack and return it

func (*Stack[T]) Push ¶

func (this *Stack[T]) Push(value T)

Push a value onto the top of the stack

func (*Stack[T]) Size ¶

func (this *Stack[T]) Size() int

func (*Stack[T]) Values ¶

func (this *Stack[T]) Values(sizes ...int) []T

type StackTrace ¶ added in v1.2.8

type StackTrace []Frame

StackTrace is stack of Frames from innermost (newest) to outermost (oldest).

func (StackTrace) Format ¶ added in v1.2.8

func (st StackTrace) Format(s fmt.State, verb rune)

Format formats the stack of Frames according to the fmt.Formatter interface.

%s	lists source files for each Frame in the stack
%v	lists the source file and line number for each Frame in the stack

Format accepts flags that alter the printing of some verbs, as follows:

%+v   Prints filename, function, and line number for each Frame in the stack.

type StringRoundRobinSelector ¶

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

func NewStringRoundRobinSelector ¶

func NewStringRoundRobinSelector(l ...string) *StringRoundRobinSelector

func (*StringRoundRobinSelector) Add ¶

func (s *StringRoundRobinSelector) Add(raw ...string)

func (*StringRoundRobinSelector) Len ¶

func (s *StringRoundRobinSelector) Len() int

func (*StringRoundRobinSelector) List ¶

func (s *StringRoundRobinSelector) List() []string

func (*StringRoundRobinSelector) Next ¶

func (s *StringRoundRobinSelector) Next() string

type Switch ¶ added in v1.3.1

type Switch struct {
	*sync.Cond
	// contains filtered or unexported fields
}

func NewSwitch ¶ added in v1.3.1

func NewSwitch(b ...bool) *Switch

func (*Switch) Condition ¶ added in v1.3.1

func (c *Switch) Condition() bool

func (*Switch) Switch ¶ added in v1.3.1

func (c *Switch) Switch()

func (*Switch) SwitchTo ¶ added in v1.3.1

func (c *Switch) SwitchTo(b bool)

func (*Switch) WaitUntilOpen ¶ added in v1.3.1

func (c *Switch) WaitUntilOpen()

type TerminalConfig ¶

type TerminalConfig struct {
	Term   string
	Height int
	Weight int
	Modes  ssh.TerminalModes
}

type TextSplitter ¶

type TextSplitter struct {
	ChunkSize    int
	ChunkOverlap int
	Separators   []string
}

func NewTextSplitter ¶

func NewTextSplitter() *TextSplitter

func (*TextSplitter) Split ¶

func (ts *TextSplitter) Split(ctx context.Context, text string) []string

核心分割方法

func (*TextSplitter) SplitReader ¶

func (ts *TextSplitter) SplitReader(ctx context.Context, reader io.Reader) chan string

type TriggerWriter ¶ added in v1.2.8

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

func NewTriggerWriter ¶ added in v1.2.8

func NewTriggerWriter(trigger uint64, h func(buffer io.ReadCloser, triggerEvent string)) *TriggerWriter

func NewTriggerWriterEx ¶

func NewTriggerWriterEx(sizeTrigger uint64, timeTrigger time.Duration, h func(buffer io.ReadCloser, triggerEvent string)) *TriggerWriter

func (*TriggerWriter) Close ¶ added in v1.2.8

func (f *TriggerWriter) Close() error

func (*TriggerWriter) GetCount ¶ added in v1.2.8

func (f *TriggerWriter) GetCount() int64

func (*TriggerWriter) Write ¶ added in v1.2.8

func (f *TriggerWriter) Write(p []byte) (n int, err error)

type TrimLeftReader ¶ added in v1.3.2

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

TrimLeftReader wraps an io.Reader and trims leading white space from the input.

func NewTrimLeftReader ¶ added in v1.3.2

func NewTrimLeftReader(r io.Reader) *TrimLeftReader

func (*TrimLeftReader) Read ¶ added in v1.3.2

func (t *TrimLeftReader) Read(p []byte) (int, error)

Read implements the io.Reader interface for TrimLeftReader.

type Unsigned ¶ added in v1.3.1

type Unsigned interface {
	~uint | ~uint8 | ~uint16 | ~uint32 | ~uint64 | ~uintptr
}

Unsigned is a constraint that permits any unsigned integer type. If future releases of Go add new predeclared unsigned integer types, this constraint will be modified to include them.

type UserPassPair ¶

type UserPassPair struct {
	Username, Password     string
	UserOffset, PassOffset int64
}

type WebHookServer ¶

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

func NewWebHookServer ¶

func NewWebHookServer(port int, cb func(data interface{})) *WebHookServer

func (*WebHookServer) Addr ¶

func (w *WebHookServer) Addr() string

func (*WebHookServer) Shutdown ¶

func (w *WebHookServer) Shutdown()

func (*WebHookServer) Start ¶

func (w *WebHookServer) Start()

type YakError ¶ added in v1.2.8

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

func (*YakError) Cause ¶ added in v1.2.8

func (err *YakError) Cause() []error

func (*YakError) Error ¶ added in v1.2.8

func (err *YakError) Error() string

func (*YakError) ErrorWithStack ¶ added in v1.3.2

func (e *YakError) ErrorWithStack() string

func (*YakError) Format ¶ added in v1.2.8

func (err *YakError) Format(s fmt.State, verb rune)

func (*YakError) Is ¶ added in v1.2.9

func (e *YakError) Is(rerr error) bool

func (YakError) StackTrace ¶ added in v1.2.8

func (s YakError) StackTrace() StackTrace

func (*YakError) Unwrap ¶ added in v1.2.8

func (err *YakError) Unwrap() []error

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
algorithm
arptable
asyncdb
asynchelper
backup
big
bizhelper Package bizhelper 提供业务逻辑相关的帮助函数和工具包含表数据的导入导出、分页查询、数据处理等常用功能	Package bizhelper 提供业务逻辑相关的帮助函数和工具包含表数据的导入导出、分页查询、数据处理等常用功能
bot
bruteutils
grdp
grdp/core
grdp/emission
grdp/glog
grdp/protocol/lic
grdp/protocol/nla
grdp/protocol/pdu
grdp/protocol/rfb rfb.go	rfb.go
grdp/protocol/sec
grdp/protocol/t125
grdp/protocol/t125/ber
grdp/protocol/t125/gcc
grdp/protocol/t125/per
grdp/protocol/tpkt
grdp/protocol/x224
bs4
bufpipe
chanx
cli
comparer
dateparse Package dateparse parses date-strings without knowing the format in advance, using a fast lex based approach to eliminate shotgun attempts.	Package dateparse parses date-strings without knowing the format in advance, using a fast lex based approach to eliminate shotgun attempts.
dingrobot
dnsutil
dot
extrafp
ffmpegutils
fileparser
excelparser
pptparser
resources
types
utils
wordparser
filesys
filesys_interface
treeview
fuzzy Origin: https://github.com/lithammer/fuzzysearch Fuzzy searching allows for flexibly matching a string with partial input, useful for filtering data very quickly based on lightweight user input.	Origin: https://github.com/lithammer/fuzzysearch Fuzzy searching allows for flexibly matching a string with partial input, useful for filtering data very quickly based on lightweight user input.
glob
graph
grpc_auth Package auth is a middleware that authenticates incoming gRPC requests.	Package auth is a middleware that authenticates incoming gRPC requests.
grpc_recovery Package recovery is a middleware that recovers from panics and logs the panic message.	Package recovery is a middleware that recovers from panics and logs the panic message.
gzip_embed
gzip-embed command
test
healthinfo
hostsparser
htmlquery Package htmlquery provides extract data from HTML documents using XPath expression.	Package htmlquery provides extract data from HTML documents using XPath expression.
imageutils
jodatime
jreader
jsonquery
jsonstream Reference: https://github.com/simon-engledew/jsoniter	Reference: https://github.com/simon-engledew/jsoniter
larkrobot
license
cmd command
limitedmap
linktable
lowhttp Ref: https://github.com/gobwas/ws	Ref: https://github.com/gobwas/ws
http_struct
httpctx
poc
mailutil
memedit
memfile
mfreader
mixer
multipart rewrite multipart reader for compatibility with invalid boundary	rewrite multipart reader for compatibility with invalid boundary
netutil
cmd command
netroute Originally found in https://github.com/gopacket/gopacket/blob/master/routing/routing.go	Originally found in https://github.com/gopacket/gopacket/blob/master/routing/routing.go
routewrapper
routewrapper/examples command
network
omap
orderedmap
pandocutils
pcapfix
permutil
pingutil
pipeline
pop3 Package pop3 is a simple POP3 e-mail client library.	Package pop3 is a simple POP3 e-mail client library.
pprofutils Package pprofutils provides utilities for runtime profiling of Go applications.	Package pprofutils provides utilities for runtime profiling of Go applications.
privileged
progresswriter
redis Reference: https://github.com/astaxie/goredis	Reference: https://github.com/astaxie/goredis
reducer
regen
regexp-utils
resources_monitor
sasl Library for Simple Authentication and Security Layer (SASL) defined in RFC 4422.	Library for Simple Authentication and Security Layer (SASL) defined in RFC 4422.
sched
shlex Package shlex implements a simple lexer which splits input in to tokens using shell-style rules for quoting and commenting.	Package shlex implements a simple lexer which splits input in to tokens using shell-style rules for quoting and commenting.
smb Reference: https://github.com/stacktitan/smb	Reference: https://github.com/stacktitan/smb
spacengine
base
fofa
go-shodan Package shodan is an interface for the Shodan API	Package shodan is an interface for the Shodan API
hunter
quake
zoomeye
ssdeep
suspect
sysproc
tcpreverse
cmd command
tlsutils
go-pkcs12 Package pkcs12 implements some of PKCS#12 (also known as P12 or PFX).	Package pkcs12 implements some of PKCS#12 (also known as P12 or PFX).
go-pkcs12/rc2 Package rc2 implements the RC2 cipher	Package rc2 implements the RC2 cipher
umask
webextractor
webforest
whisperutils
workpool
workwxrobot
xml2
xmlfmt
yakgit
yakdiff
yakunquote
yakxml Package xml implements a simple XML 1.0 parser that understands XML name spaces.	Package xml implements a simple XML 1.0 parser that understands XML name spaces.
xml-tools
ziputil

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

Documentation ¶

Overview ¶

Index ¶

Examples ¶

Constants ¶

Variables ¶

Functions ¶

func AddressFamilyUint32ToString ¶

func AppendDefaultPort ¶ added in v1.2.3

func AppendSliceItemWhenNotExists ¶

func AsDebugString ¶ added in v1.2.9

func AsciiBytesToRegexpMatchedRunes ¶

func AsciiBytesToRegexpMatchedString ¶

func AsciiEqualFold ¶

func AsciiToLower ¶

func AttemptWithDelay ¶

func AttemptWithDelayFast ¶

func BKDRHash ¶

func BufioReadLine ¶

func BufioReadLineString ¶ added in v1.3.0

func ByteCountBinary ¶

func ByteCountDecimal ¶

func ByteSize ¶

func BytesClone ¶

func CacheFunc ¶ added in v1.2.7

func CalcMd5 ¶

func CalcSSDeepStability ¶

func CalcSha1 ¶

func CalcSha1WithSuffix ¶

func CalcSha256 ¶ added in v1.2.8

func CalcSimHashStability ¶

func CalcSimilarity ¶

func CalcTextSubStringStability ¶

func CallGeneralClose ¶

func CallWithCtx ¶ added in v1.2.9

func CallWithTimeout ¶ added in v1.2.9

func ChanStringToSlice ¶

func CloseConnSafe ¶

func CloseWrite ¶

func ConcatPorts ¶

func ConcurrentCopyDirectory ¶ added in v1.2.9

func ConnExpect ¶

func ContainsAll ¶ added in v1.3.3

func ContainsAny ¶ added in v1.3.3

func ContainsJSON ¶ added in v1.3.3

func ConvertTextFileToYakFuzztagByPath ¶

func ConvertToStringSlice ¶

func CopyBytes ¶

func CopyDirectory ¶ added in v1.2.9

func CopyDirectoryEx ¶

func CopyFile ¶ added in v1.2.8

func CopyFileEx ¶

func CopyMapInterface ¶

func CopyMapShallow ¶

func CopySlice ¶

func CreateTempTestDatabaseInMemory ¶

func CreateUTF8StreamMirror ¶

func CutBytesPrefixFunc ¶

func DataVerbose ¶

func DatePretty ¶ added in v1.3.3

func DatetimePretty ¶

func DatetimePretty2 ¶

func Debug ¶

func DebugMockEchoWs ¶ added in v1.3.1

func DebugMockEchoWss ¶

func DebugMockGMHTTP ¶ added in v1.2.3

func DebugMockHTTP ¶

func DebugMockHTTP2 ¶ added in v1.2.3

func DebugMockHTTP2HandlerFuncContext ¶

func DebugMockHTTPEx ¶ added in v1.2.3

func DebugMockHTTPExContext ¶ added in v1.2.3

func DebugMockHTTPHandlerFunc ¶ added in v1.2.4

func DebugMockHTTPHandlerFuncContext ¶ added in v1.2.4

func DebugMockHTTPKeepAliveEx ¶ added in v1.3.1

func DebugMockHTTPS ¶ added in v1.2.9

func DebugMockHTTPSEx ¶ added in v1.2.3

func DebugMockHTTPSKeepAliveEx ¶ added in v1.2.7

func DebugMockHTTPServerWithContext ¶ added in v1.2.3

func DebugMockHTTPServerWithContextWithAddress ¶ added in v1.3.0

func DebugMockHTTPWithTimeout ¶