gathertool

package module

Go to main page

Versions in this module

v0

v0.4.7

Nov 1, 2023

Changes in this version

+ var DNSServer = map[string]string

+ var RootWhoisServers = "whois.iana.org:43"

+ var ShowTablesSql = "SHOW TABLES"

+ func ApplicationTerminalOutClose()

+ func DebugF(format string, args ...interface{})

+ func DebugFTimes(format string, times int, args ...interface{})

+ func InfoFTimes(times int, format string, args ...interface{})

+ func IsUrl(url string) bool

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

+ func UrlStr(url string) string

+ func UsefulUrl(str string) bool

+ func WarnF(format string, args ...interface{})

+ func WarnFTimes(format string, times int, args ...interface{})

+ func WindowsSendPipe(command1, command2 []string) (opStr string)

+ type DNSInfo struct

+ DnsServerIP string

+ DnsServerName string

+ IPs []string

+ IsCDN bool

+ LookupCNAME string

+ Ms float64

+ func NsLookUp(host string) *DNSInfo

+ func NsLookUpAll(host string) ([]*DNSInfo, []string)

+ func NsLookUpFromDNSServer(host, dnsServer string) *DNSInfo

+ type IsRetry bool

+ type SSLCertificateInfo struct

+ CRLDistributionPoints string

+ DNSName string

+ EffectiveTime string

+ Issuer string

+ IssuingCertificateURL string

+ NotAfter int64

+ NotBefore int64

+ OCSPServer string

+ PublicKeyAlgorithm string

+ SignatureAlgorithm string

+ Subject string

+ Url string

+ Version string

+ func GetCertificateInfo(caseUrl string) (SSLCertificateInfo, bool)

+ func (s SSLCertificateInfo) Echo()

+ func (s SSLCertificateInfo) Expire() int64

type StressUrl

+ func (s *StressUrl) OpenRetry()

+ type WhoisInfo struct

+ Root string

+ Rse string

+ func Whois(host string) *WhoisInfo

v0.4.5

Sep 4, 2023

Changes in this version

+ var ApplicationTerminalOut = true

+ func Any2Int64(data interface{}) int64

+ func ClosePingTerminalPrint()

+ func IP2Binary(ip string) string

+ func IP2Int64(ip string) int64

+ func JsonFind2Int(jsonStr, find string) (int, error)

+ func JsonFind2Int64(jsonStr, find string) (int64, error)

+ func JsonFind2Str(jsonStr, find string) (string, error)

+ func LatestDate(date int) []string

+ func RegHtmlDescription(str string, property ...string) []string

+ func RegHtmlDescriptionTxt(str string, property ...string) []string

+ func RegHtmlKeyword(str string, property ...string) []string

+ func RegHtmlKeywordTxt(str string, property ...string) []string

+ func UInt32ToIP(ip uint32) net.IP

+ type Mail struct

+ AuthCode string

+ C *gomail.Dialer

+ From string

+ Host string

+ Msg *gomail.Message

+ Port int

+ func NewMail(host, from, auth string, port int) *Mail

+ func (m *Mail) HtmlBody(body string) *Mail

+ func (m *Mail) Send(to string) error

+ func (m *Mail) SendMore(to []string) error

+ func (m *Mail) Title(title string) *Mail

v0.4.4

Apr 27, 2023

v0.4.3

Apr 21, 2023

Changes in this version

+ func HTTPTimes(times int, args ...interface{})

type Context

+ StateCode int

+ type HostPageSpeedCheck struct

+ Depth int

+ Host string

+ PageSpeed map[string]time.Duration

+ UrlSet map[string]struct{}

+ func NewHostPageSpeedCheck(host string, depth int) *HostPageSpeedCheck

+ func (scan *HostPageSpeedCheck) AverageSpeed() float64

+ func (scan *HostPageSpeedCheck) MaxSpeed() int64

+ func (scan *HostPageSpeedCheck) MinSpeed() int64

+ func (scan *HostPageSpeedCheck) Report() map[string]string

+ func (scan *HostPageSpeedCheck) Result() map[string]time.Duration

+ func (scan *HostPageSpeedCheck) Run() ([]string, int)

+ type HostScanBadLink struct

+ Depth int

+ Host string

+ PageState map[string]int

+ UrlSet map[string]struct{}

+ func NewHostScanBadLink(host string, depth int) *HostScanBadLink

+ func (scan *HostScanBadLink) Report() map[string]int

+ func (scan *HostScanBadLink) Result() map[string]int

+ func (scan *HostScanBadLink) Run() ([]string, int)

+ type HostScanExtLinks struct

+ Host string

+ func NewHostScanExtLinks(host string) *HostScanExtLinks

+ func (scan *HostScanExtLinks) Run() ([]string, int)

+ type HostScanUrl struct

+ Count int

+ Depth int

+ Host string

+ MaxCount int64

+ UrlSet map[string]struct{}

+ func NewHostScanUrl(host string, depth int) *HostScanUrl

+ func (scan *HostScanUrl) Run() ([]string, int)

+ type HostToolEr interface

+ Run func() ([]string, int)

type Rds

+ func (r *Rds) BitCount(key string) (int64, error)

+ func (r *Rds) GetBit(key string, offset int64) (int64, error)

+ func (r *Rds) SetBit(key string, offset, value int64) error

v0.4.2

Mar 31, 2023

Changes in this version

+ const TimeMilliTemplate

+ var Leaps = []int

+ var Pyears = []int

+ var RdsNotConnError = fmt.Errorf("未连接redis")

+ func GetChineseMonthDay(date string) (rMonth, rDay int64)

+ func IsLeap(year int) bool

+ func IsToday(timestamp int64) string

+ func IsTodayList(timestamp int64) string

+ func NowToEnd() (int64, error)

+ func Timestamp2Week(timestamp int64) string

+ func Timestamp2WeekXinQi(timestamp int64) string

+ type MQKafkaService struct

+ Server []string

+ func (m *MQKafkaService) Consumer(topic string) []byte

+ func (m *MQKafkaService) Producer(topic string, data []byte)

+ type MQNsqService struct

+ ConsumerPort int

+ NsqServerIP string

+ ProducerPort int

+ func (m *MQNsqService) Consumer(topic string) []byte

+ func (m *MQNsqService) Producer(topic string, data []byte)

+ type MQRabbitService struct

+ AmqpUrl string

+ func (m *MQRabbitService) Consumer(topic string) []byte

+ func (m *MQRabbitService) Producer(topic string, data []byte)

+ type MQer interface

+ Consumer func(topic string) []byte

+ Producer func(topic string, data []byte)

+ func NewKafka(server []string) MQer

+ func NewNsq(server string, port ...int) MQer

+ func NewRabbit(amqpUrl string) MQer

+ type RabbitMQ struct

+ Exchange string

+ Key string

+ MqUrl string

+ QueueName string

+ func NewRabbitMQ(queueName, exchange, key, amqpUrl string) (*RabbitMQ, error)

+ func NewRabbitMQPubSub(exchangeName, amqpUrl string) (*RabbitMQ, error)

+ func NewRabbitMQRouting(exchange string, routingKey string) (*RabbitMQ, error)

+ func NewRabbitMQSimple(queueName string) (*RabbitMQ, error)

+ func NewRabbitMQTopic(exchange string, routingKey string) (*RabbitMQ, error)

+ func (r *RabbitMQ) Destroy()

+ func (r *RabbitMQ) PublishPub(message []byte) (err error)

+ func (r *RabbitMQ) PublishRouting(message []byte) (err error)

+ func (r *RabbitMQ) PublishSimple(message []byte) (err error)

+ func (r *RabbitMQ) PublishTopic(message []byte) (err error)

+ func (r *RabbitMQ) RegistryConsumeSimple() (msg <-chan amqp.Delivery)

+ func (r *RabbitMQ) RegistryReceiveRouting() (msg <-chan amqp.Delivery)

+ func (r *RabbitMQ) RegistryReceiveSub() (msg <-chan amqp.Delivery)

+ func (r *RabbitMQ) RegistryReceiveTopic() (msg <-chan amqp.Delivery)

type Rds

+ func (r *Rds) Append(key string, value interface{}) error

+ func (r *Rds) DUMP(key string) bool

+ func (r *Rds) Decr(key string) (int64, error)

+ func (r *Rds) DecrBy(key, decrement string) (int64, error)

+ func (r *Rds) DelKey(key string) bool

+ func (r *Rds) Expire(key string, ttl int64) bool

+ func (r *Rds) ExpireAt(key string, date int64) bool

+ func (r *Rds) Get(key string) (string, error)

+ func (r *Rds) GetAllKeys(match string) (ksyList map[string]int)

+ func (r *Rds) GetRange(key string, start, end int64) (string, error)

+ func (r *Rds) GetSet(key string, value interface{}) (string, error)

+ func (r *Rds) HDel(key string, fields []string) error

+ func (r *Rds) HExIsTs(key, fields string) bool

+ func (r *Rds) HGet(key, fields string) (string, error)

+ func (r *Rds) HGetAll(key string) (map[string]string, error)

+ func (r *Rds) HGetAllInt(key string) (map[string]int, error)

+ func (r *Rds) HGetAllInt64(key string) (map[string]int64, error)

+ func (r *Rds) HIncrBy(key, field string, increment int64) (int64, error)

+ func (r *Rds) HIncrByFloat(key, field string, increment float64) (float64, error)

+ func (r *Rds) HKeys(key string) ([]string, error)

+ func (r *Rds) HLen(key string) (int64, error)

+ func (r *Rds) HMGet(key string, fields []string) ([]string, error)

+ func (r *Rds) HMSet(key string, values map[interface{}]interface{}) error

+ func (r *Rds) HSet(key, field string, value interface{}) (int64, error)

+ func (r *Rds) HSetNx(key, field string, value interface{}) error

+ func (r *Rds) HVaLs(key string) ([]string, error)

+ func (r *Rds) Incr(key string) (int64, error)

+ func (r *Rds) IncrBy(key, increment string) (int64, error)

+ func (r *Rds) IncrByFloat(key, increment float64) (float64, error)

+ func (r *Rds) LIndex(key string, index int64) (string, error)

+ func (r *Rds) LInsert(direction bool, key, pivot, value string) error

+ func (r *Rds) LLen(key string) (int64, error)

+ func (r *Rds) LPusHx(key string, value interface{}) error

+ func (r *Rds) LPush(key string, values []interface{}) error

+ func (r *Rds) LRange(key string) ([]interface{}, error)

+ func (r *Rds) LRangeST(key string, start, stop int64) ([]interface{}, error)

+ func (r *Rds) LRem(key string, count int64, value interface{}) error

+ func (r *Rds) LSet(key string, index int64, value interface{}) error

+ func (r *Rds) LTrim(key string, start, stop int64) error

+ func (r *Rds) ListLPOP(key string) (string, error)

+ func (r *Rds) MGet(key []interface{}) ([]string, error)

+ func (r *Rds) MSet(values []interface{}) error

+ func (r *Rds) MSetNx(values []interface{}) error

+ func (r *Rds) MqConsumer(mqName string) (reply interface{}, err error)

+ func (r *Rds) MqLen(mqName string) int64

+ func (r *Rds) MqProducer(mqName string, data interface{}) error

+ func (r *Rds) PSetEx(key string, ttl int64, value interface{}) error

+ func (r *Rds) RPop(key string) (string, error)

+ func (r *Rds) RPopLPush(key, destination string) (string, error)

+ func (r *Rds) RPush(key string, values []interface{}) error

+ func (r *Rds) RPushX(key string, value interface{}) error

+ func (r *Rds) Rename(name, newName string) bool

+ func (r *Rds) SAdd(key string, values []interface{}) error

+ func (r *Rds) SCard(key string) error

+ func (r *Rds) SDiff(keys []string) ([]interface{}, error)

+ func (r *Rds) SDiffStore(key string, keys []string) ([]interface{}, error)

+ func (r *Rds) SInter(keys []string) ([]interface{}, error)

+ func (r *Rds) SInterStore(key string, keys []string) ([]interface{}, error)

+ func (r *Rds) SIsMember(key string, value interface{}) (resBool bool, err error)

+ func (r *Rds) SMemeRs(key string) ([]interface{}, error)

+ func (r *Rds) SMove(key, destination string, member interface{}) (resBool bool, err error)

+ func (r *Rds) SPop(key string) (string, error)

+ func (r *Rds) SRandMember(key string, count int64) ([]interface{}, error)

+ func (r *Rds) SRem(key string, member []interface{}) error

+ func (r *Rds) SUnion(keys []string) ([]interface{}, error)

+ func (r *Rds) SUnionStore(key string, keys []string) ([]interface{}, error)

+ func (r *Rds) SearchKeys(match string) (ksyList map[string]int)

+ func (r *Rds) Set(key string, value interface{}) error

+ func (r *Rds) SetEx(key string, ttl int64, value interface{}) error

+ func (r *Rds) SetNx(key string, value interface{}) error

+ func (r *Rds) SetRange(key string, offset int64, value interface{}) error

+ func (r *Rds) ToBool(reply interface{}, err error) (bool, error)

+ func (r *Rds) ToByteSlices(reply interface{}, err error) ([][]byte, error)

+ func (r *Rds) ToBytes(reply interface{}, err error) ([]byte, error)

+ func (r *Rds) ToFloat64(reply interface{}, err error) (float64, error)

+ func (r *Rds) ToFloat64s(reply interface{}, err error) ([]float64, error)

+ func (r *Rds) ToInt(reply interface{}, err error) (int, error)

+ func (r *Rds) ToInt64(reply interface{}, err error) (int64, error)

+ func (r *Rds) ToInt64Map(reply interface{}, err error) (map[string]int64, error)

+ func (r *Rds) ToInt64s(reply interface{}, err error) ([]int64, error)

+ func (r *Rds) ToIntMap(reply interface{}, err error) (map[string]int, error)

+ func (r *Rds) ToInts(reply interface{}, err error) ([]int, error)

+ func (r *Rds) ToString(reply interface{}, err error) (string, error)

+ func (r *Rds) ToStringMap(reply interface{}, err error) (map[string]string, error)

+ func (r *Rds) ToStrings(reply interface{}, err error) ([]string, error)

+ func (r *Rds) Ttl(key string) int64

+ func (r *Rds) Type(key string) string

+ func (r *Rds) ZAdd(key string, values []interface{}) error

+ func (r *Rds) ZCard(key string) (int64, error)

+ func (r *Rds) ZCount(key string, min, max int64) (int64, error)

+ func (r *Rds) ZIncrBy(key, member string, increment int64) (string, error)

+ func (r *Rds) ZRange(key string) ([]interface{}, error)

+ func (r *Rds) ZRangeByScore(key string, min, max, offset, count int64) ([]interface{}, error)

+ func (r *Rds) ZRangeByScoreAll(key string) ([]interface{}, error)

+ func (r *Rds) ZRangeST(key string, start, stop int64) ([]interface{}, error)

+ func (r *Rds) ZRank(key string, member interface{}) (int64, error)

+ func (r *Rds) ZRem(key string, member []interface{}) error

+ func (r *Rds) ZRemRangeByRank(key string, start, stop int64) error

+ func (r *Rds) ZRemRangeByScore(key string, min, max int64) error

+ func (r *Rds) ZRevRange(key string, start, stop int64) ([]interface{}, error)

+ func (r *Rds) ZRevRangeByScore(key string, min, max, offset, count int64) ([]interface{}, error)

+ func (r *Rds) ZRevRangeByScoreAll(key string) ([]interface{}, error)

+ func (r *Rds) ZRevRank(key string, member interface{}) (int64, error)

+ func (r *Rds) ZScore(key string, member interface{}) (string, error)

v0.4.1

Nov 21, 2022

Changes in this version

+ var Config *conf

+ func CompressDirZip(src, outFile string) error

+ func CompressFiles(files []string, dest string) error

+ func DayDiff(beginDay string, endDay string) int

+ func DeCompressTAR(tarFile, dest string) error

+ func DeCompressZIP(zipFile, dest string) error

+ func DecompressionZipFile(src, dest string) error

+ func Get16MD5Encode(data string) string

+ func GetAllFile(pathname string) ([]string, error)

+ func GetMD5Encode(data string) string

+ func ID() int64

+ func ID64() (int64, error)

+ func IDMd5() string

+ func IDStr() string

+ func Int642Str(i int64) string

+ func LinuxSendCommand(command string) (opStr string)

+ func OutJsonFile(data interface{}, fileName string) error

+ func SocketProxy(addr string)

+ func WindowsSendCommand(command []string) (opStr string)

+ func WindwsSendPipe(command1, command2 []string) (opStr string)

+ type IdWorker struct

+ func (idw *IdWorker) InitIdWorker(workerId, datacenterId int64) error

+ func (idw *IdWorker) NextId() (int64, error)

v0.3.9

Oct 11, 2022

Changes in this version

+ func RegHtmlOption(str string, property ...string) []string

+ func RegHtmlOptionTxt(str string, property ...string) []string

+ func RegValue(str string, property ...string) []string

+ type Conf struct

+ Data map[string]interface{}

+ Path string

+ func NewConf(appConfigPath string) (*Conf, error)

+ func (c *Conf) Get(key string) interface{}

+ func (c *Conf) GetInt(key string) int

+ func (c *Conf) Init() error

v0.3.8

Jul 29, 2022

Changes in this version

+ func IsHaveKey(data map[string]interface{}, key string) bool

+ func IsJson(str string) bool

+ func JsonFind(jsonStr, find string) (interface{}, error)

+ func JsonFind2Arr(jsonStr, find string) ([]interface{}, error)

+ func JsonFind2Json(jsonStr, find string) (string, error)

+ func JsonFind2Map(jsonStr, find string) (map[string]interface{}, error)

v0.3.7

Jul 7, 2022

Changes in this version

+ const TimeTemplate

+ func DebugTimes(times int, args ...interface{})

+ func DebugfTimes(format string, times int, args ...interface{})

+ func ErrorTimes(times int, args ...interface{})

+ func ErrorfTimes(format string, times int, args ...interface{})

+ func GetPointClassHTML(htmlStr, label, val string) ([]string, error)

+ func GetPointHTML(htmlStr, label, attr, val string) ([]string, error)

+ func GetPointIDHTML(htmlStr, label, val string) ([]string, error)

+ func RegFindAllTxt(regStr, rest string) (dataList []string)

+ func RegHtmlDiv(str string, property ...string) []string

+ func RegHtmlDivTxt(str string, property ...string) []string

+ func Struct2MapV2(obj interface{}, hasValue bool) (map[string]interface{}, error)

+ func Struct2MapV3(obj interface{}) map[string]interface

+ func Timestamp2Date(timestamp int64) string

+ func WarnTimes(times int, args ...interface{})

+ func WarnfTimes(format string, times int, args ...interface{})

v0.3.6

Jun 13, 2022

Changes in this version

+ var LogClose bool = false

+ func CloseLog()

+ func SimpleServer(addr string, g *grpc.Server)

type Task

+ func NewTask() *Task

+ func (task *Task) SetJsonParam(jsonStr string) *Task

+ func (task *Task) SetUrl(urlStr string) *Task

v0.3.5

Jun 7, 2022

Changes in this version

+ func AbPathByCaller() string

+ func ByteToGBK(strBuf []byte) []byte

+ func ByteToUTF8(strBuf []byte) []byte

+ func ConvertGBK2Str(gbkStr string) string

+ func ConvertStr2GBK(str string) string

+ func GetWD() string

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

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

+ func IsUtf8(buf []byte) bool

+ func RegHtmlTableOlny(str string, property ...string) []string

+ func SockerProxy(addr string)

+ func Struct2Map2(obj interface{}) map[string]interface

type HttpPackage

+ func (pack *HttpPackage) ToFile(path string) error

+ func (pack *HttpPackage) Txt() string

v0.3.4

May 27, 2022

Changes in this version

+ var ContentType map[string]string = map[string]string

+ var TABLE_IS_NULL = fmt.Errorf("table is null.")

+ func AccountRational(str string) bool

+ func IsBase64(str string) bool

+ func IsDNSName(str string) bool

+ func IsFullWidth(str string) bool

+ func IsHalfWidth(str string) bool

+ func IsIPv4(str string) bool

+ func IsLatitude(str string) bool

+ func IsLongitude(str string) bool

+ func IsRGB(str string) bool

+ func IsUUID3(str string) bool

+ func IsUUID4(str string) bool

+ func IsUUID5(str string) bool

+ func IsUnixPath(str string) bool

+ func IsWindowsPath(str string) bool

+ func IsXMLFile(str string) bool

+ func RegBase64(str string, property ...string) []string

+ func RegDNSName(str string, property ...string) []string

+ func RegEmail2(str string, property ...string) []string

+ func RegFloat(str string, property ...string) []string

+ func RegFullURL(str string, property ...string) []string

+ func RegFullWidth(str string, property ...string) []string

+ func RegHalfWidth(str string, property ...string) []string

+ func RegInt(str string, property ...string) []string

+ func RegLatitude(str string, property ...string) []string

+ func RegLongitude(str string, property ...string) []string

+ func RegRGBColor(str string, property ...string) []string

+ func RegURLIP(str string, property ...string) []string

+ func RegURLPath(str string, property ...string) []string

+ func RegURLPort(str string, property ...string) []string

+ func RegURLSchema(str string, property ...string) []string

+ func RegURLSubdomain(str string, property ...string) []string

+ func RegURLUsername(str string, property ...string) []string

+ func RegUUID(str string, property ...string) []string

+ func RegUUID3(str string, property ...string) []string

+ func RegUUID4(str string, property ...string) []string

+ func RegUUID5(str string, property ...string) []string

+ func RegUnixPath(str string, property ...string) []string

+ func RegWinPath(str string, property ...string) []string

type Context

+ func (c *Context) GetRetryTimes() int

+ func (c *Context) SetSleep(i int) *Context

+ func (c *Context) SetSleepRand(min, max int) *Context

type Csv

+ func (c *Csv) Close()

+ type HttpPackage struct

+ Body []byte

+ ContentType string

+ Header map[string][]string

+ Url *url.URL

+ func (pack *HttpPackage) Html() string

+ func (pack *HttpPackage) Img2Base64() string

+ func (pack *HttpPackage) Json() string

+ func (pack *HttpPackage) SaveImage(path string) error

+ type Intercept struct

+ HttpPackageFunc func(pack *HttpPackage)

+ Ip string

+ func (ipt *Intercept) RunHttpIntercept()

+ func (ipt *Intercept) RunServer()

type Mysql

+ func (m *Mysql) GetFieldList(table string) (fieldList []string)

+ func (m *Mysql) InsertAtJson(table, jsonStr string) error

+ func (m *Mysql) ToXls(sql, outPath string)

v0.3.1

Mar 24, 2022

Changes in this version

+ func InfofTimes(format string, times int, args ...interface{})

type Context

+ func (c *Context) SetProxyPool(pool *ProxyPool) *Context

+ type ProxyIP struct

+ IP string

+ IsTLS bool

+ Pass string

+ Post int

+ User string

+ func NewProxyIP(ip string, port int, user, pass string, isTls bool) *ProxyIP

+ func (p *ProxyIP) String() string

+ type ProxyPool struct

+ func NewProxyPool() *ProxyPool

+ func (p *ProxyPool) Add(proxyIP *ProxyIP)

+ func (p *ProxyPool) Del(n int)

+ func (p *ProxyPool) Get() (string, int)

v0.2.9

Mar 16, 2022

Changes in this version

+ func DeepCopy(dst, src interface{}) error

+ func Str2Float32(str string) float32

+ func Str2Int(str string) int

+ func Str2Int32(str string) int32

+ type Bar struct

+ func (bar *Bar) Finish()

+ func (bar *Bar) NewOption(start, total int64)

+ func (bar *Bar) NewOptionWithGraph(start, total int64, graph string)

+ func (bar *Bar) Play(cur int64)

type Context

+ Param map[string]interface{}

+ func PostFile(url, paramName, filePath string, vs ...interface{}) *Context

+ func (c *Context) AddParam(key string, val interface{})

+ func (c *Context) DelParam(key string)

+ func (c *Context) GetParam(key string) interface{}

+ func (c *Context) GetRespHeader() string

+ func (c *Context) RespContentLength() int64

type GDMapApi

+ RangeAt func(f func(id int, k string, v interface{})) *gDMap

+ Reverse func()

type Mysql

+ func (m *Mysql) DeleteTable(tableName string) error

+ func (m *Mysql) HasTable(tableName string) bool

+ type TcpClient struct

+ CmdChan chan string

+ Connection *net.TCPConn

+ HawkServer *net.TCPAddr

+ RConn chan struct{}

+ StopChan chan struct{}

+ Token string

+ func NewTcpClient() *TcpClient

+ func (c *TcpClient) Addr() string

+ func (c *TcpClient) Close()

+ func (c *TcpClient) ReConn()

+ func (c *TcpClient) Read(b []byte) (int, error)

+ func (c *TcpClient) Run(serverHost string, r func(c *TcpClient, data []byte), w func(c *TcpClient))

+ func (c *TcpClient) Send(b []byte) (int, error)

+ func (c *TcpClient) Stop()

+ type UdpClient struct

+ Conn *net.UDPConn

+ DstAddr *net.UDPAddr

+ SrcAddr *net.UDPAddr

+ Token string

+ func NewUdpClient() *UdpClient

+ func (u *UdpClient) Addr() string

+ func (u *UdpClient) Close()

+ func (u *UdpClient) Read(b []byte) (int, *net.UDPAddr, error)

+ func (u *UdpClient) Run(hostServer string, port int, r func(u *UdpClient, data []byte), ...)

+ func (u *UdpClient) Send(b []byte) (int, error)

v0.2.8

Jan 7, 2022

Changes in this version

+ const TiB

+ var LevelMap = map[Level]string

+ func BIG5To(dstCharset string, src string) (dst string, err error)

+ func Bit2Byte(b []uint8) []byte

+ func Bool2Byte(b bool) []byte

+ func Byte2Bit(b []byte) []uint8

+ func Byte2Bool(b []byte) bool

+ func Byte2Float32(b []byte) float32

+ func Byte2Float64(b []byte) float64

+ func Byte2Int(b []byte) int

+ func Byte2Int64(b []byte) int64

+ func Chdir(dir string) error

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

+ func Debugf(format string, args ...interface{})

+ func DecodeByte(b []byte) (interface{}, error)

+ func EncodeByte(v interface{}) []byte

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

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

+ func Exists(path string) bool

+ func Float322Byte(f float32) []byte

+ func Float322Uint32(f float32) uint32

+ func Float642Byte(f float64) []byte

+ func Float642Uint64(f float64) uint64

+ func GB18030To(dstCharset string, src string) (dst string, err error)

+ func GB2312To(dstCharset string, src string) (dst string, err error)

+ func GDKTo(dstCharset string, src string) (dst string, err error)

+ func HZGB2312To(dstCharset string, src string) (dst string, err error)

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

+ func InfoTimes(times int, args ...interface{})

+ func Infof(format string, args ...interface{})

+ func Int2Byte(i int) []byte

+ func Int642Byte(i int64) []byte

+ func IsDir(path string) bool

+ func IsFile(path string) bool

+ func Map2Slice(data interface{}) []interface

+ func MapCopy(data map[string]interface{}) (copy map[string]interface{})

+ func MapMergeCopy(src ...map[string]interface{}) (copy map[string]interface{})

+ func Pwd() string

+ func SetLogFile(name string)

+ func Slice2Map(slice interface{}) map[string]interface

+ func SliceCopy(data []interface{}) []interface

+ func Str2Byte(s string) []byte

+ func StrToSize(sizeStr string) int64

+ func ToBIG5(srcCharset string, src string) (dst string, err error)

+ func ToGB18030(srcCharset string, src string) (dst string, err error)

+ func ToGB2312(srcCharset string, src string) (dst string, err error)

+ func ToGDK(srcCharset string, src string) (dst string, err error)

+ func ToHZGB2312(srcCharset string, src string) (dst string, err error)

+ func ToUTF16(srcCharset string, src string) (dst string, err error)

+ func ToUTF8(srcCharset string, src string) (dst string, err error)

+ func UTF16To(dstCharset string, src string) (dst string, err error)

+ func UTF8To(dstCharset string, src string) (dst string, err error)

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

+ func Warnf(format string, args ...interface{})

type Context

+ Html string

+ func (c *Context) RespBodyHtml() string

+ type Level int

v0.2.7

Dec 21, 2021

Changes in this version

+ func JwtDecrypt(tokenString, secret string) (data map[string]interface{}, err error)

+ func JwtEncrypt(data map[string]interface{}, secret, method string) (string, error)

+ func JwtEncrypt256(data map[string]interface{}, secret string) (string, error)

+ func JwtEncrypt384(data map[string]interface{}, secret string) (string, error)

+ func JwtEncrypt512(data map[string]interface{}, secret string) (string, error)

+ func RegDelHtmlA(str string) string

+ func RegDelHtmlButton(str string, property ...string) string

+ func RegDelHtmlCanvas(str string, property ...string) string

+ func RegDelHtmlCode(str string, property ...string) string

+ func RegDelHtmlH(str, typeH string, property ...string) string

+ func RegDelHtmlHref(str string, property ...string) string

+ func RegDelHtmlImg(str string, property ...string) string

+ func RegDelHtmlInput(str string, property ...string) string

+ func RegDelHtmlLi(str string, property ...string) string

+ func RegDelHtmlMeta(str string, property ...string) string

+ func RegDelHtmlP(str string, property ...string) string

+ func RegDelHtmlSelect(str string, property ...string) string

+ func RegDelHtmlSpan(str string, property ...string) string

+ func RegDelHtmlSrc(str string, property ...string) string

+ func RegDelHtmlTable(str string, property ...string) string

+ func RegDelHtmlTbody(str string, property ...string) string

+ func RegDelHtmlTd(str string, property ...string) string

+ func RegDelHtmlTitle(str string) string

+ func RegDelHtmlTr(str string) string

+ func RegDelHtmlUl(str string, property ...string) string

+ func RegDelHtmlVideo(str string, property ...string) string

type Context

+ Json string

+ Text string

+ Xml string

+ func NewPostForm(u string, data map[string]string, vs ...interface{}) *Context

+ type Cookie map[string]string

+ func NewCookie(data map[string]string) Cookie

+ func (c Cookie) Delete(key string) Cookie

+ func (c Cookie) Set(key, value string) Cookie

+ type FormData map[string]string

type GDMapApi

+ AddMap func(data map[string]interface{}) *gDMap

type Mysql

+ func (m *Mysql) InsertAtGd(table string, fieldData *gDMap) error

+ func (m *Mysql) NewTableGd(table string, fields *gDMap) error

v0.2.4

Dec 17, 2021

Changes in this version

+ const Base64

+ const DNSName

+ const Email

+ const Float

+ const FullURL

+ const FullWidth

+ const GiB

+ const HalfWidth

+ const Int

+ const KiB

+ const Latitude

+ const Longitude

+ const MiB

+ const RGBColor

+ const RegEmail

+ const RegGUID

+ const RegIP

+ const RegIPv4

+ const RegIPv6

+ const RegLink

+ const RegMACAddress

+ const RegMD5Hex

+ const RegSHA1Hex

+ const RegSHA256Hex

+ const RegTime

+ const URLIP

+ const URLPath

+ const URLPort

+ const URLSchema

+ const URLSubdomain

+ const URLUsername

+ const UUID

+ const UUID3

+ const UUID4

+ const UUID5

+ const UnixPath

+ const WinPath

+ var ChineseMoney = []string

+ var ChineseMoneyAll = []string

+ var ChineseNumber = []string

+ func Bytes2Str(b []byte) string

+ func Hex2Int(s string) int

+ func Hex2Int64(s string) int64

+ func HumanFriendlyTraffic(bytes uint64) string

+ func Int2Hex(i int64) string

+ func Int642Hex(i int64) string

+ func IsAllCapital(str string) bool

+ func IsAllLower(str string) bool

+ func IsChinese(str string) bool

+ func IsChineseAll(str string) bool

+ func IsChineseMoney(str string) bool

+ func IsChineseN(str string, number int) bool

+ func IsChineseNumber(str string) bool

+ func IsDomain(str string) bool

+ func IsEngAll(str string) bool

+ func IsEngLen(str string, l int) bool

+ func IsEngNumber(str string) bool

+ func IsFloat(str string) bool

+ func IsFloat2Len(str string, l int) bool

+ func IsHaveCapital(str string) bool

+ func IsHaveLower(str string) bool

+ func IsIP(str string) bool

+ func IsLandline(str string) bool

+ func IsLeastCapital(str string, n int) bool

+ func IsLeastLower(str string, n int) bool

+ func IsLeastNumber(str string, n int) bool

+ func IsLeastSpecial(str string, n int) bool

+ func IsNumber(str string) bool

+ func IsNumber2Heard(str string, n int) bool

+ func IsNumber2Len(str string, l int) bool

+ func IsPhone(str string) bool

+ func IsURL(str string) bool

+ func MapStr2Any(m map[string]string) map[string]interface

+ func NewCookiePool() *cookiePool

+ func RegDelHtml(str string) string

+ func RegDelNumber(str string) string

+ func Str2Bytes(s string) []byte

+ func StrDuplicates(a []string) []string

+ func UnicodeDec(raw string) string

+ func UnicodeDecByte(raw []byte) []byte

type Csv

+ func NewCSV(fileName string) (*Csv, error)

+ type GDMapApi interface

+ Add func(key string, value interface{}) *gDMap

+ CheckValue func(value interface{}) bool

+ Del func(key string) *gDMap

+ Get func(key string) interface{}

+ KeyList func() []string

+ Len func() int

+ Range func(f func(k string, v interface{})) *gDMap

+ func NewGDMap() GDMapApi

type Header

+ func NewHeader() Header

+ func (h Header) Delete(key string) Header

+ func (h Header) Set(key, value string) Header

+ type Sleep time.Duration

+ func SetSleep(min, max int) Sleep

+ func SetSleepMs(min, max int) Sleep

v0.2.1

Oct 8, 2021

Changes in this version

+ func Any2Json(data interface{}) (string, error)

+ func CopySlice(s []interface{}) []interface

+ func CopySliceInt(s []int) []int

+ func CopySliceInt64(s []int64) []int64

+ func CopySliceStr(s []string) []string

+ func DayAgo(i int) int64

+ func HourAgo(i int) int64

+ func IsInSlice(s []interface{}, v interface{}) bool

+ func Map2Json(m map[string]interface{}) (string, error)

+ func MinuteAgo(i int) int64

+ func OSLine() string

+ func P2E()

+ func RegHtmlButton(str string) []string

+ func RegHtmlButtonTxt(str string) []string

+ func RegHtmlCanvas(str string) []string

+ func RegHtmlCode(str string) []string

+ func RegHtmlCodeTxt(str string) []string

+ func RegHtmlImg(str string) []string

+ func RegHtmlLi(str string) []string

+ func RegHtmlLiTxt(str string) []string

+ func RegHtmlMeta(str string) []string

+ func RegHtmlSelect(str string) []string

+ func RegHtmlSelectTxt(str string) []string

+ func RegHtmlTable(str string) []string

+ func RegHtmlTableTxt(str string) []string

+ func RegHtmlUl(str string) []string

+ func RegHtmlUlTxt(str string) []string

+ func RegHtmlVideo(str string) []string

+ func ReplaceAllToOne(str string, from []string, to string) string

+ type SliceToolAPI interface

+ ContainsByte func(a []byte, x byte) bool

+ ContainsInt func(a []int, x int) bool

+ ContainsInt64 func(a []int64, x int64) bool

+ ContainsStr func(a []string, x string) bool

+ CopyInt func(a []int) []int

+ CopyInt64 func(a []int64) []int64

+ CopyStr func(a []string) []string

+ DeduplicateInt func(a []int) []int

+ DeduplicateInt64 func(a []int64) []int64

+ DeduplicateStr func(a []string) []string

+ DelInt func(a []int, i int) []int

+ DelInt64 func(a []int64, i int) []int64

+ DelStr func(a []string, i int) []string

+ MaxInt func(a []int) int

+ MaxInt64 func(a []int64) int64

+ MinInt func(a []int) int

+ MinInt64 func(a []int64) int64

+ PopInt func(a []int) (int, []int)

+ PopInt64 func(a []int64) (int64, []int64)

+ PopStr func(a []string) (string, []string)

+ ReverseInt func(a []int) []int

+ ReverseInt64 func(a []int64) []int64

+ ReverseStr func(a []string) []string

+ ShuffleInt func(a []int) []int

+ func SliceTool() SliceToolAPI

v0.1.18

Aug 21, 2021

Changes in this version

+ const CBC

+ const CFB

+ const CTR

+ const ECB

+ func HmacMD5(str, key string) string

+ func HmacSHA1(str, key string) string

+ func HmacSHA256(str, key string) string

+ func HmacSHA512(str, key string) string

+ func PBKDF2(str, salt []byte) []byte

+ func SearchBytesIndex(bSrc []byte, b byte) int

+ type AES interface

+ Decrypt func(str, key []byte) ([]byte, error)

+ Encrypt func(str, key []byte) ([]byte, error)

+ func NewAES(typeName string, arg ...[]byte) AES

+ type DES interface

+ Decrypt func(str, key []byte) ([]byte, error)

+ Encrypt func(str, key []byte) ([]byte, error)

+ func NewDES(typeName string, arg ...[]byte) DES

v0.1.17

Aug 19, 2021

Changes in this version

+ const SHOW_TABLES

+ const TABLE_NAME_NULL

+ func Any2Arr(data interface{}) []interface

type Mysql

+ func (m *Mysql) InsertAt(table string, fieldData map[string]interface{}) error

+ func (m *Mysql) IsHaveTable(name string) bool

v0.1.16

Aug 18, 2021

v0.1.14

Aug 18, 2021

Changes in this version

+ const ANY

+ const DELETE

+ const GET

+ const HEAD

+ const OPTIONS

+ const PATCH

+ const POST

+ const PUT

type Context

+ func (c *Context) SetProxyFunc(f func() *http.Transport) *Context

type Task

+ func (task Task) AddData(key string, value interface{}) Task

v0.1.13

Aug 17, 2021

v0.1.12

Aug 17, 2021

Changes in this version

+ func IF(condition bool, a, b interface{}) interface

+ func StringValueMysql(i interface{}) string

type Context

+ func (c *Context) RespBodyArr() []interface{}

+ func (c *Context) RespBodyMap() map[string]interface{}

type Task

+ func (task Task) GetDataStr(key string) string

v0.1.11

Aug 12, 2021

Changes in this version

+ func CPUMax()

type Mysql

+ func (m *Mysql) SetMaxIdleConn(number int)

+ func (m *Mysql) SetMaxOpenConn(number int)

v0.1.10

Aug 9, 2021

v0.1.9

Jul 13, 2021

Changes in this version

+ var AgentType = map[UserAgentType][]int

+ var UrlNil error = errors.New("url is null.")

+ func FileMd5sum(fileName string) string

+ func IsElementStr(list []string, element string) bool

+ func RegHtmlTbody(str string) []string

+ func SetAgent(agentType UserAgentType, agent string)

+ func SetMaxOpenFile() error

+ func SetRLimit(number int) error

type Context

+ func NewDelete(url string, vs ...interface{}) *Context

+ func NewGet(url string, vs ...interface{}) *Context

+ func NewOptions(url string, vs ...interface{}) *Context

+ func NewPost(url string, data []byte, contentType string, vs ...interface{}) *Context

+ func NewPut(url string, data []byte, contentType string, vs ...interface{}) *Context

+ func NewRequest(url, method string, data []byte, contentType string, vs ...interface{}) *Context

+ func PostForm(url string, data url.Values, vs ...interface{}) (*Context, error)

+ func (c *Context) CheckMd5() string

+ func (c *Context) CheckReqMd5() string

+ func (c *Context) RespBodyString() string

+ func (c *Context) SetProxy(proxyUrl string)

+ type IsLog bool

type Mysql

+ func (m *Mysql) Query(sql string) ([]map[string]string, error)

+ func (m *Mysql) ToVarChar(data interface{}) string

+ type ProxyUrl string

type StressUrl

+ ContentType string

+ type WSClient interface

+ Close func()

+ Read func(data []byte) error

+ Send func(body []byte) error

+ func WsClient(host, path string) (WSClient, error)

v0.1.8

May 20, 2021

Changes in this version

+ type Err2Retry bool

v0.1.7

May 19, 2021

v0.1.6

May 19, 2021

Changes in this version

type Context

+ func (c *Context) CloseRetry()

+ func (c *Context) OpenErr2Retry()

v0.1.5

May 19, 2021

Changes in this version

+ func GetNowPath() string

+ func SetStatusCodeFailEvent(code int)

+ func SetStatusCodeRetryEvent(code int)

+ func SetStatusCodeSuccessEvent(code int)

type Context

+ IsLog bool

+ func (c *Context) CloseLog()

+ func (c *Context) OpenFail2Retry()

v0.1.4

May 17, 2021

Changes in this version

+ const GB18030

+ const GB2312

+ const GBK

+ const UTF8

+ func Base64Decode(str string) (string, error)

+ func Base64Encode(str string) string

+ func Base64UrlDecode(str string) (string, error)

+ func Base64UrlEncode(str string) string

+ func Byte2Str(b []byte) string

+ func ByteToBinaryString(data byte) (str string)

+ func ConvertByte2String(byte []byte, charset Charset) string

+ func Daydiff(beginDay string, endDay string) int

+ func FileMd5(path string) (string, error)

+ func IsContainStr(items []string, item string) bool

+ func MongoConn()

+ func MongoConn1()

+ func PathExists(path string)

+ func Ping(ip string)

+ func ReadCsvFile(filename string) [][]string

+ func RegHtmlATxt(str string) []string

+ func RegHtmlH(str, typeH string) []string

+ func RegHtmlHTxt(str, typeH string) []string

+ func RegHtmlHref(str string) []string

+ func RegHtmlHrefTxt(str string) []string

+ func RegHtmlInputTxt(str string) []string

+ func RegHtmlPTxt(str string) []string

+ func RegHtmlSpanTxt(str string) []string

+ func RegHtmlSrc(str string) []string

+ func RegHtmlSrcTxt(str string) []string

+ func RegHtmlTdTxt(str string) []string

+ func RegHtmlTitleTxt(str string) []string

+ func RegHtmlTrTxt(str string) []string

+ func SearchDomain(ip string)

+ func SearchPort(ipStr string, vs ...interface{})

+ func StrsDuplicates(a []string) []string

+ func TickerRun(t time.Duration, f func())

+ func Timestamp() string

+ func UnescapeUnicode(raw []byte) ([]byte, error)

+ type Charset string

type Context

+ func GetRun(url string, vs ...interface{}) (ctx *Context, err error)

+ type Header map[string]string

+ type Mongo struct

+ Collection *mongo.Collection

+ Conn *mongo.Client

+ Database *mongo.Database

+ Host string

+ MaxPoolSize int

+ Password string

+ Port string

+ TimeOut time.Duration

+ User string

+ func NewMongo(user, password, host, port string) (*Mongo, error)

+ func (m *Mongo) GetCollection(dbname, name string)

+ func (m *Mongo) GetConn() (err error)

+ func (m *Mongo) GetDB(dbname string)

+ func (m *Mongo) Insert(document interface{}) error

+ type Set map[string]struct

+ func (s Set) Add(key string)

+ func (s Set) Delete(key string)

+ func (s Set) Has(key string) bool

+ type Stack struct

+ func New() *Stack

+ func (s *Stack) Pop()

+ func (s *Stack) Push(data interface{})

+ func (s *Stack) String() string

v0.1.3

May 6, 2021

Changes in this version

+ func Json2Map(str string) map[string]interface

+ func PanicToError(fn func()) (err error)

+ func Struct2Map(obj interface{}, hasValue bool) (map[string]interface{}, error)

type Mysql

+ func GetMysqlDBConn() *Mysql

type Task

+ HeaderMap *http.Header

+ JsonParam string

+ func CrawlerTask(url, jsonParam string, vs ...interface{}) *Task

v0.1.2

Apr 30, 2021

Changes in this version

+ func BeginDayUnix() int64

+ func EndDayUnix() int64

+ func RedisDELKeys(rds *Rds, keys string, jobNumber int)

+ type Rds struct

+ Conn redis.Conn

+ Pool *redis.Pool

+ RedisDB int

+ RedisHost string

+ RedisIdleTimeoutSec int

+ RedisMaxActive int

+ RedisMaxIdle int

+ RedisPassword string

+ RedisPost string

+ SSHAddr string

+ SSHPassword string

+ SSHUser string

+ func NewRedis(host, port, password string, db int, vs ...interface{}) *Rds

+ func NewRedisPool(host, port, password string, db, maxIdle, maxActive, idleTimeoutSec int, ...) *Rds

+ func (r *Rds) GetConn() redis.Conn

+ func (r *Rds) RedisConn() (err error)

+ func (r *Rds) RedisPool() error

+ func (r *Rds) SelectDB(dbNumber int) error

+ type SSHConnInfo struct

+ SSHAddr string

+ SSHPassword string

+ SSHUser string

+ func NewSSHInfo(addr, user, password string) *SSHConnInfo

v0.1.1

Apr 29, 2021

Changes in this version

+ var CookiePool = &cookiePool

+ func FileSizeFormat(fileSize int64) (size string)

+ func RedisSSHConn(user string, pass string, addr string, ip string, port int, password string) (redis.Conn, error)

+ func RegFindAll(regStr, rest string) [][]string

+ func RegHtmlA(str string) []string

+ func RegHtmlInput(str string) []string

+ func RegHtmlP(str string) []string

+ func RegHtmlSpan(str string) []string

+ func RegHtmlTd(str string) []string

+ func RegHtmlTitle(str string) []string

+ func RegHtmlTr(str string) []string

+ func SSHClient(user string, pass string, addr string) (*ssh.Client, error)

+ func Str2Float64(str string) float64

+ func Str2Int64(str string) int64

+ func Uint82Str(bs []uint8) string

+ func Upload(url, savePath string, vs ...interface{}) error

type Context

+ func Delete(url string, vs ...interface{}) (*Context, error)

+ func Options(url string, vs ...interface{}) (*Context, error)

+ func Put(url string, data []byte, contentType string, vs ...interface{}) (*Context, error)

+ func (c *Context) CookieNext() error

+ func (c *Context) Upload(filePath string) func()

+ type Csv struct

+ FileName string

+ R *csv.Reader

+ W *csv.Writer

+ func NewCsv(fileName string) *Csv

+ func (c *Csv) Add(data []string) error

+ func (c *Csv) ReadAll() ([][]string, error)

type Mysql

+ func (m *Mysql) Delete(sql string) error

+ func (m *Mysql) Exec(sql string) error

+ func (m *Mysql) Update(sql string) error

type StressUrl

+ JsonData string

+ func (s *StressUrl) SetJson(str string)

type Task

+ FileName string

+ SaveDir string

+ SavePath string

+ Type string

type TodoQueue

+ func NewUploadQueue() TodoQueue

+ type UploadQueue struct

+ func (q *UploadQueue) Add(task *Task) error

+ func (q *UploadQueue) Clear() bool

+ func (q *UploadQueue) IsEmpty() bool

+ func (q *UploadQueue) Poll() *Task

+ func (q *UploadQueue) Print()

+ func (q *UploadQueue) Size() int

v0.0.11

Apr 28, 2021

Changes in this version

+ var MysqlDB = &Mysql

+ func CleaningStr(str string) string

+ func NewMysqlDB(host string, port int, user, password, database string) (err error)

+ func StatusCodeFailEvent(code int)

+ func StatusCodeRetryEvent(code int)

+ func StatusCodeSuccessEvent(code int)

+ func StrDeleteSpace(str string) string

type Context

+ Ctx context.Context

type Mysql

+ Log bool

+ func (m *Mysql) CloseLog()

type Task

+ Data map[string]interface{}

v0.0.10

Apr 27, 2021

Changes in this version

+ func Any2AnyList(data interface{}) []interface

+ func Any2Float64(data interface{}) float64

+ func Any2Int(data interface{}) int

+ func Any2Map(data interface{}) map[string]interface

+ func Any2String(data interface{}) string

+ func Any2Strings(data interface{}) []string

+ func Any2int64(data interface{}) int64

+ func JSON2Map(str string) map[string]interface

+ func MD5(str string) string

type Context

+ func (c *Context) AddCookie(cookie *http.Cookie)

+ func (c *Context) AddHeader(k, v string)

v0.0.9

Apr 27, 2021

Changes in this version

+ func StringValue(i interface{}) string

+ type Mysql struct

+ DB *sql.DB

+ DataBase string

+ Host string

+ MaxIdleConn int

+ MaxOpenConn int

+ Password string

+ Port int

+ User string

+ func NewMysql(host string, port int, user, password, database string) (*Mysql, error)

+ func (m *Mysql) Conn() (err error)

+ func (m *Mysql) Describe(table string) (map[string]string, error)

+ func (m *Mysql) Insert(table string, fieldData map[string]interface{}) error

+ func (m *Mysql) NewTable(table string, fields map[string]string) error

+ func (m *Mysql) Select(sql string) ([]map[string]string, error)

+ type TableInfo struct

+ Default interface{}

+ Extra string

+ Field string

+ Key string

+ Null string

+ Type string

v0.0.8

Apr 26, 2021

v0.0.7

Apr 26, 2021

Changes in this version

+ var UrlBad error = errors.New("url is bad.")

+ func StartJob()

+ func StartJobGet(jobNumber int, queue TodoQueue, vs ...interface{})

+ func StartJobPost()

+ type Context struct

+ Client *http.Client

+ EndFunc EndFunc

+ Err error

+ FailedFunc FailedFunc

+ JobNumber int

+ MaxTimes RetryTimes

+ Ms time.Duration

+ Req *http.Request

+ Resp *http.Response

+ RespBody []byte

+ RetryFunc RetryFunc

+ StartFunc StartFunc

+ SucceedFunc SucceedFunc

+ Task *Task

+ Token string

+ func Post(url string, data []byte, contentType string, vs ...interface{}) (*Context, error)

+ func PostJson(url string, jsonStr string, vs ...interface{}) (*Context, error)

+ func Request(url, method string, data []byte, contentType string, vs ...interface{}) (*Context, error)

+ func (c *Context) Do() func()

+ func (c *Context) SetFailedFunc(failedFunc func(c *Context))

+ func (c *Context) SetRetryFunc(retryFunc func(c *Context))

+ func (c *Context) SetRetryTimes(times int)

+ func (c *Context) SetSucceedFunc(successFunc func(c *Context))

+ type EndFunc func(c *Context)

+ type FailedFunc func(c *Context)

+ type ReqTimeOut int

+ type ReqTimeOutMs int

+ type ReqUrl struct

+ Method string

+ Params map[string]interface{}

+ Url string

+ type RetryFunc func(c *Context)

+ type StartFunc func(c *Context)

+ type StressUrl struct

+ Method string

+ Sum int64

+ TQueue TodoQueue

+ TimeOut int64

+ Total int

+ Url string

+ func NewTestUrl(url, method string, sum int64, total int, timeOut int64) *StressUrl

+ func (s *StressUrl) Run(vs ...interface{})

+ type SucceedFunc func(c *Context)

type Task

+ Urls []*ReqUrl

v0.0.6

Apr 24, 2021

v0.0.5

Apr 24, 2021

Changes in this version

type Req

+ SucceedTaskFunc func(*Task, []byte)

+ Task *Task

+ func (r *Req) SucceedTask(successTask func(*Task, []byte))

+ type Task struct

+ Context map[string]interface{}

+ Url string

v0.0.4

Apr 24, 2021

Changes in this version

+ var UserAgentMap map[int]string = map[int]string

+ func GetAgent(agentType UserAgentType) string

+ func JobStartGet(jobNumber int, queue TodoQueue, client *http.Client, SucceedFunc func([]byte), ...)

+ func NewGoquery(html string) (*goquery.Document, error)

+ type Queue struct

+ func (q *Queue) Add(url string)

+ func (q *Queue) Clear() bool

+ func (q *Queue) IsEmpty() bool

+ func (q *Queue) Poll() string

+ func (q *Queue) Print()

+ func (q *Queue) Size() int

type Req

+ RetryFunc func(req *Req)

+ func (r *Req) Retry(retryFunc func(c *Req))

+ type RetryTimes int64

+ type TodoQueue interface

+ Add func(url string)

+ Clear func() bool

+ IsEmpty func() bool

+ Poll func() string

+ Print func()

+ Size func() int

+ func NewQueue() TodoQueue

+ type UserAgentType int

+ const AndroidAgent

+ const IosAgent

+ const LinuxAgent

+ const MacAgent

+ const PCAgent

+ const PhoneAgent

+ const UCAgent

+ const WindowsAgent

+ const WindowsPhoneAgent

v0.0.3

Apr 23, 2021

Changes in this version

+ var StatusCodeMap map[int]string = map[int]string

type Req

+ func (r *Req) Failed(failedFunc func(c *Req))

+ func (r *Req) Succeed(successFunc func([]byte))

v0.0.2

Apr 23, 2021

Changes in this version

+ type Req struct

+ Client *http.Client

+ FailFunc func(req *Req)

+ MaxTimes int64

+ Req *http.Request

+ SuccessFunc func([]byte)

+ func Get(url string, maxTimes int64, sf func([]byte), vs ...interface{}) (*Req, error)

+ func (r *Req) Do() func()

+ func (r *Req) SetFailed(failedFunc func(c *Req))

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