itools

package module
v0.0.0-...-48c478d Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 15, 2025 License: MIT Imports: 67 Imported by: 0

README

itools

工具包

GitHub releaselicense

简体中文 | English

安装

go get github.com/mazezen/itools

包元素

邮件发送 163邮箱、QQ邮箱、126邮箱、Gmail邮箱 ✅
加密 md5、sh1、文件md5、aes ✅
jwt ✅
map ✅
redis ✅
gorm 动态搜索+分页 ✅
xorm ✅
oss 七牛云文 ✅
mongodb 单个写入、批量写入、修改、统计、删除 ✅
etcd 写入、读取、修改、删除 ✅
敏感词过滤 ✅
切片 ✅
参数校验 ✅
限流 计数器、漏桶算法、令牌桶算法 ✅
基于内存的缓存系统 ✅
定时监听器 ✅
api统一返回格式 ✅
http请求 POST、GET ✅
常见正则校验 ✅
使用Lua操作redis ✅
解决TCP粘包拆包问题 ✅
leveldb ✅
viper ✅
load_polling 随机、轮询、一致性HASH、权重 ✅
scheduler 定时调度器,只执行一次 ✅

Documentation

Index

Constants

View Source 
const DBDriverDefault = "mysql"
View Source 
const MsgHeader = "12345678"

Variables

View Source 
var (
	AppLog *zap.Logger
)
View Source 
var Db *xorm.Engine
View Source 
var (
	ErrEmptyKey = errors.New("key could not be empty")
)
View Source 
var (
	ParamsNoEnoughError = errors.New("at least one parameter is required")
)
View Source 
var Rc *redis.Client
View Source 
var Response *result
View Source 
var ResponsePage *pageList
View Source 
var (
	Wf *wordsfilter.WordsFilter
)

Functions

func CalculateCurrentTimeAndZeroTime 

func CalculateCurrentTimeAndZeroTime() time.Duration

CalculateCurrentTimeAndZeroTime 计算当前时间和零点的时间差

func CompactStr 

func CompactStr(str ...string) string

CompactStr compact more string

func ContentFilter 

func ContentFilter(text string) bool

ContentFilter 需要过滤的地方，调用此方法，将要过滤的内容传递进去即可

func CurrentDayEnd 

func CurrentDayEnd() string

CurrentDayEnd 获取当天结束时间

func CurrentDayZero 

func CurrentDayZero() string

CurrentDayZero 获取当天零点时间

func Decode 

func Decode(bytesBuffer io.Reader) (bodyBuf []byte, err error)

func EnValidateParam 

func EnValidateParam(param interface{}) string

EnValidateParam validate params english

func Encode 

func Encode(bytesBuffer io.Writer, content string) error

func FileMd5 

func FileMd5(filepath string) (string, error)

func FilterString 

func FilterString(key, value, operator string) func(db *gorm.DB) *gorm.DB

FilterString 进行快速条件过滤

func Get 

func Get(url string, header map[string]string, params map[string]interface{}) ([]byte, error)

func InOrNotInFilter 

func InOrNotInFilter(key string, value interface{}, operator string) func(db *gorm.DB) *gorm.DB

InOrNotInFilter where in 或者 where not in

func LoadConfig 

func LoadConfig(cf string)

LoadConfig load config file

func Md5SaltCode 

func Md5SaltCode(code, slat string) string

Md5SaltCode 加密加盐

func Md5StrToUpper 

func Md5StrToUpper(code string) string

func Md5encoder 

func Md5encoder(code string) string

func MergeMap 

func MergeMap(dest, src map[interface{}]interface{}) map[interface{}]interface{}

MergeMap desc: 合并源 map 到目标 map

func NewClusterEtcd 

func NewClusterEtcd(addr []string) (*clientv3.Client, error)

func NewEtcd 

func NewEtcd(addr string) (*clientv3.Client, error)

func NewGorm 

func NewGorm(dsn string, args ...[]int) (*gorm.DB, error)

NewGorm gorm 初始化mysql连接 eg: root:123456@tcp(127.0.0.1:3306)/demo?charset=utf8mb4&parseTime=True&loc=Local

func NewTicker 

func NewTicker(ttl time.Duration, sch chan string, fn func(sch chan string) int)

func PKCS5Adding 

func PKCS5Adding(ciphertext []byte, blockSize int) []byte

func PKCS5UnPadding 

func PKCS5UnPadding(origData []byte) []byte

func Paginate 

func Paginate(page interface{}, pageSize interface{}, s map[string]interface{}) func(db *gorm.DB) *gorm.DB

Paginate page, pageSize 传入参数 s 分页默认配置

func Post 

func Post(url string, header map[string]string, param map[string]interface{}) ([]byte, error)

func PostMultipart 

func PostMultipart(url string, header map[string]string, payload *bytes.Buffer) ([]byte, error)

func PreviousAfterDate 

func PreviousAfterDate(n int) string

PreviousAfterDate 获取前后指定的时间日期

func PreviousAfterTime 

func PreviousAfterTime(n int) string

PreviousAfterTime 获取前后指定的日期的当前时间

func PreviousDayEndTime 

func PreviousDayEndTime() string

PreviousDayEndTime 获取前一天结束时间

func PreviousDayStartTime 

func PreviousDayStartTime() string

PreviousDayStartTime 获取前一天零点时间

func PrintConfigMap 

func PrintConfigMap(config map[string]interface{})

func QiNiuFileUpload 

func QiNiuFileUpload(r *http.Request, store string) (string, error)

QiNiuFileUpload 上传文件到七牛云

func QiNiuResumeUploadFile 

func QiNiuResumeUploadFile(r *http.Request, store string) (string, error)

QiNiuResumeUploadFile 七牛云文件断点续传

func QiNiuUploadChunk 

func QiNiuUploadChunk(r *http.Request, store string) (string, string, error)

QiNiuUploadChunk 七牛云分片上传

func SendGmail 

func SendGmail(from string, to []string, content []byte, mailServer, mailServerPort, mailPassword string) (err error)

SendGmail 发送谷歌邮件 支持同时给多人发送

func SendGmailEmail 

func SendGmailEmail(from, to, title, content, mailServer, mailServerPort, mailPassword string) (err error)

SendGmailEmail 发送谷歌邮件 支持 Gmail邮箱 from 发件人邮箱 `[email protected]` to 接受人邮箱 title 邮箱标题 content 邮箱内容 mailServer Gmail邮箱服务地址 `smtp.gmail.com` mailServerPort Gmail邮箱端口 `:587` mailPassword Gmail邮箱登陆密码

func SendMail 

func SendMail(from, to, title, content, mailServer, mailServerPort, mailPassword string) (err error)

SendMail 发送邮件 支持 163邮箱、QQ邮箱、126邮箱 from 发件人邮箱 `[email protected]`、`[email protected]`、`[email protected]` to 接受人邮箱 title 邮箱标题 content 邮箱内容 mailServer 163邮箱服务地址 163: `smtp.163.com`、 QQ邮箱: `smtp.qq.com`、 126邮箱: `smtp.126.com` mailServerPort 163邮箱端口 163: `:465` 、 QQ邮箱端口: `:465`、 126邮箱: `:465` mailPassword 163邮箱、QQ邮箱、126邮箱 授权码 `xxxxxxxxxxx`

func SetWordsFilter 

func SetWordsFilter()

SetWordsFilter 项目启动的时候，通过此方法将敏感词库加载进去

func Sha1 

func Sha1(code string) string

func Sha256 

func Sha256(code string) string

func ToString 

func ToString(i interface{}) (string, error)

func Transaction 

func Transaction(fs ...func(tx *xorm.Session) error) (err error)

func ZhValidateParam 

func ZhValidateParam(param interface{}) string

ZhValidateParam validate params english

Types

type AesEncrypt 

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

func NewAesEncryptInstance 

func NewAesEncryptInstance(key string, secret string) (*AesEncrypt, error)

func (*AesEncrypt) AesBase64Decrypt 

func (a *AesEncrypt) AesBase64Decrypt(b string) (string, error)

AesBase64Decrypt aes Base64 解密

func (*AesEncrypt) AesBase64Encrypt 

func (a *AesEncrypt) AesBase64Encrypt(in string) (string, error)

AesBase64Encrypt aes Base64 加密

type ConsistentHashPolling 

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

func NewConsistentHashPolling 

func NewConsistentHashPolling(replicas int, fn Hash) *ConsistentHashPolling

func (*ConsistentHashPolling) Add 

func (p *ConsistentHashPolling) Add(params ...interface{}) error

func (*ConsistentHashPolling) Next 

func (p *ConsistentHashPolling) Next(key string) (interface{}, error)

type Counter 

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

func (*Counter) Pass 

func (c *Counter) Pass() bool

func (*Counter) Reset 

func (c *Counter) Reset(t time.Time)

func (*Counter) Set 

func (c *Counter) Set(r int, tt time.Duration)

type Database 

type Database interface {
	Put(key string, value interface{}) error
	BatchPut(kvs map[string]interface{}) error
	Get(key string) ([]byte, error)
	Has(key string) (bool, error)
	Delete(key string) error
	BatchDelete(keys []string) error
	SelectAll() iterator.Iterator
	SelectPrefixSubsetKeyAll(key string) ([]map[string]interface{}, error)
	CountPrefixSubsetKey(key string) (int64, error)
	CountAll() (int64, error)
	DeletePrefixSubsetKey(key string) (bool, error)
}

type DbEngine 

type DbEngine struct {
	DbOption
}

func NewXrmEngine 

func NewXrmEngine(options ...EngineOption) *DbEngine

func (*DbEngine) Close 

func (d *DbEngine) Close()

func (*DbEngine) Connect 

func (d *DbEngine) Connect()

type DbOption 

type DbOption struct {
	DbDriver    string `json:"db_driver"`
	Host        string `json:"host"`
	Port        string `json:"port"`
	Username    string `json:"username"`
	Password    string `json:"password"`
	Database    string `json:"database"`
	Charset     string `json:"charset"`
	MaxIdleConn int    `json:"max_idle_conn"`
	MaxOpenConn int    `json:"max_open_conn"`
	ShowSql     bool   `json:"show_sql"`
}

type EchoLogger 

type EchoLogger struct {
}
var EchoLog *EchoLogger

func (*EchoLogger) Write 

func (el *EchoLogger) Write(p []byte) (n int, err error)

type EngineOption 

type EngineOption func(option *DbOption)

func WithXrmCharset 

func WithXrmCharset(charset string) EngineOption

func WithXrmDatabase 

func WithXrmDatabase(database string) EngineOption

func WithXrmDbDriver 

func WithXrmDbDriver(driver string) EngineOption

func WithXrmHost 

func WithXrmHost(host string) EngineOption

func WithXrmMaxIdleConn 

func WithXrmMaxIdleConn(maxIdleConn int) EngineOption

func WithXrmMaxOpenConn 

func WithXrmMaxOpenConn(maxOpenConn int) EngineOption

func WithXrmPassword 

func WithXrmPassword(password string) EngineOption

func WithXrmPort 

func WithXrmPort(port string) EngineOption

func WithXrmShowSql 

func WithXrmShowSql(showSql bool) EngineOption

func WithXrmUsername 

func WithXrmUsername(username string) EngineOption

type EtcdS 

type EtcdS struct{}

func (*EtcdS) Delete 

func (w *EtcdS) Delete(client *clientv3.Client, key string) (err error)

func (*EtcdS) Get 

func (w *EtcdS) Get(client *clientv3.Client, key string) (string, error)

func (*EtcdS) Put 

func (w *EtcdS) Put(client *clientv3.Client, key, value string) (err error)

func (*EtcdS) Update 

func (w *EtcdS) Update(client *clientv3.Client, key, value string) (err error)

type GMap 

type GMap struct {
	M map[string]any
	// contains filtered or unexported fields
}
var Gm *GMap

func (*GMap) Delete 

func (g *GMap) Delete(key string)

func (*GMap) Get 

func (g *GMap) Get(key string) interface{}

func (*GMap) Has 

func (g *GMap) Has(key string) bool

func (*GMap) Set 

func (g *GMap) Set(key string, value interface{})

type GoRegs 

type GoRegs struct{}

func NewGoRegs 

func NewGoRegs() *GoRegs

func (*GoRegs) MatchChineseCharacter 

func (g *GoRegs) MatchChineseCharacter(str string) bool

MatchChineseCharacter 纯汉字

func (*GoRegs) MatchChineseIDCardNumber 

func (g *GoRegs) MatchChineseIDCardNumber(id string) bool

MatchChineseIDCardNumber 验证大陆身份证号

func (*GoRegs) MatchChinesePhoneNumber 

func (g *GoRegs) MatchChinesePhoneNumber(str string) bool

MatchChinesePhoneNumber 大陆手机号

func (*GoRegs) MatchContainChineseCharacter 

func (g *GoRegs) MatchContainChineseCharacter(str string) bool

MatchContainChineseCharacter 大陆手机号

func (*GoRegs) MatchDoubleByte 

func (g *GoRegs) MatchDoubleByte(input string) bool

MatchDoubleByte 匹配双字节字符(包括汉字在内)

func (*GoRegs) MatchEmail 

func (g *GoRegs) MatchEmail(str string) bool

MatchEmail email

func (*GoRegs) MatchEmptyLine 

func (g *GoRegs) MatchEmptyLine(input string) bool

MatchEmptyLine 匹配零个或多个空白字符（包括空格、制表符、换页符等）

func (*GoRegs) MatchEnCharacter 

func (g *GoRegs) MatchEnCharacter(str string) bool

MatchEnCharacter 纯英文字符串,大小写不敏感

func (*GoRegs) MatchGeNNumber 

func (g *GoRegs) MatchGeNNumber(str string, n int) bool

MatchGeNNumber 长度不小于n位的纯数字

func (*GoRegs) MatchIPv4 

func (g *GoRegs) MatchIPv4(input string) bool

MatchIPv4 ipv4

func (*GoRegs) MatchIPv6 

func (g *GoRegs) MatchIPv6(input string) bool

MatchIPv6 ipv6

func (*GoRegs) MatchIntOrFloat 

func (g *GoRegs) MatchIntOrFloat(str string) bool

MatchIntOrFloat 整数或者小数

func (*GoRegs) MatchIsContainSpecialCharacter 

func (g *GoRegs) MatchIsContainSpecialCharacter(str string) bool

MatchIsContainSpecialCharacter 验证是否包含特殊字符串

func (*GoRegs) MatchLenNNumber 

func (g *GoRegs) MatchLenNNumber(str string, n int) bool

MatchLenNNumber 长度为n的纯数字

func (*GoRegs) MatchLowerEnCharacter 

func (g *GoRegs) MatchLowerEnCharacter(str string) bool

MatchLowerEnCharacter 纯小写英文字符串

func (*GoRegs) MatchMKNoContainSpecialCharacter 

func (g *GoRegs) MatchMKNoContainSpecialCharacter(str string, m, k int) bool

MatchMKNoContainSpecialCharacter 长度m-k的字符串，包含数字、字母、汉字，不包含特殊字符 一般多用于校验用户名或昵称等

func (*GoRegs) MatchMNIntervalNumber 

func (g *GoRegs) MatchMNIntervalNumber(str string, m, n int) bool

MatchMNIntervalNumber 长度m~n位的纯数字

func (*GoRegs) MatchMNLeCharacter 

func (g *GoRegs) MatchMNLeCharacter(str string, m, z int) bool

MatchMNLeCharacter 长度m-z的字符串，包含特殊字符、数字、字母、汉字， 一般多用于校验用户名或昵称等

func (*GoRegs) MatchMNNovelsOfRealNumber 

func (g *GoRegs) MatchMNNovelsOfRealNumber(str string, m, n int) bool

MatchMNNovelsOfRealNumber m~n位小数的正实数

func (*GoRegs) MatchNLeCharacter 

func (g *GoRegs) MatchNLeCharacter(str string, n int) bool

MatchNLeCharacter 长度为n的字符，特殊字符除外

func (*GoRegs) MatchNNovelsOfRealNumber 

func (g *GoRegs) MatchNNovelsOfRealNumber(str string, n int) bool

MatchNNovelsOfRealNumber 有n位小数的正实数

func (*GoRegs) MatchNanZeroNegNumber 

func (g *GoRegs) MatchNanZeroNegNumber(str string) bool

MatchNanZeroNegNumber 非零的负整数

func (*GoRegs) MatchNanZeroNumber 

func (g *GoRegs) MatchNanZeroNumber(str string) bool

MatchNanZeroNumber 非零的正整数

func (*GoRegs) MatchNumber 

func (g *GoRegs) MatchNumber(str string) bool

MatchNumber 纯数字

func (*GoRegs) MatchNumberEnCharacter 

func (g *GoRegs) MatchNumberEnCharacter(str string) bool

MatchNumberEnCharacter 数字和26个英文字母组成的字符串,大小写不敏感

func (*GoRegs) MatchNumberEnUnderscores 

func (g *GoRegs) MatchNumberEnUnderscores(str string) bool

MatchNumberEnUnderscores 数字和26个英文字母组成的字符串,大小写不敏感

func (*GoRegs) MatchPass1 

func (g *GoRegs) MatchPass1(str string, m, n int) bool

MatchPass1 密码1 由数字、26个英文字母或者下划线组成的英文开头的字符串, 长度m~n位

func (*GoRegs) MatchPass2 

func (g *GoRegs) MatchPass2(str string) bool

MatchPass2 密码2 密码长度至少为8个字符。 包含至少一个小写字母。 包含至少一个大写字母。 包含至少一个数字。 包含至少一个特殊字符（例如 !@#$%^&*() 等

func (*GoRegs) MatchStartingWithNonZero 

func (g *GoRegs) MatchStartingWithNonZero(str string) bool

MatchStartingWithNonZero 非零开头的纯数字

func (*GoRegs) MatchUpEnCharacter 

func (g *GoRegs) MatchUpEnCharacter(str string) bool

MatchUpEnCharacter 纯大写英文字符串

type Hash 

type Hash func(data []byte) uint32

type JwtClaims 

type JwtClaims struct {
	Expire    time.Duration
	Secret    string
	LoginInfo interface{} `json:"login_info"`
	jwt.StandardClaims
}

func NewJwt 

func NewJwt(expire time.Duration, secret string) *JwtClaims

func (*JwtClaims) GenerateToken 

func (j *JwtClaims) GenerateToken(data interface{}) (string, error)

GenerateToken 签发Token

func (*JwtClaims) ParseToken 

func (j *JwtClaims) ParseToken(token string) (*JwtClaims, error)

ParseToken 解析TOKEN

type LeakyBucket 

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

func (*LeakyBucket) Pass 

func (l *LeakyBucket) Pass() bool

func (*LeakyBucket) Set 

func (l *LeakyBucket) Set(r, c float64)

type LevelDB 

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

func NewLevelDB 

func NewLevelDB(path string) (*LevelDB, error)

type LevelDBWithCache 

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

func NewLevelDBWithCache 

func NewLevelDBWithCache(path string) (*LevelDBWithCache, error)

func (*LevelDBWithCache) BatchDelete 

func (db *LevelDBWithCache) BatchDelete(keys []string) error

func (*LevelDBWithCache) BatchPut 

func (db *LevelDBWithCache) BatchPut(kvs map[string]interface{}) error

func (*LevelDBWithCache) CountAll 

func (db *LevelDBWithCache) CountAll() (int64, error)

func (*LevelDBWithCache) CountPrefixSubsetKey 

func (db *LevelDBWithCache) CountPrefixSubsetKey(key string) (int64, error)

func (*LevelDBWithCache) Delete 

func (db *LevelDBWithCache) Delete(key string) error

func (*LevelDBWithCache) DeleteAll 

func (db *LevelDBWithCache) DeleteAll() (bool, error)

func (*LevelDBWithCache) DeletePrefixSubsetKey 

func (db *LevelDBWithCache) DeletePrefixSubsetKey(key string) (bool, error)

func (*LevelDBWithCache) Get 

func (db *LevelDBWithCache) Get(key string) ([]byte, error)

func (*LevelDBWithCache) Has 

func (db *LevelDBWithCache) Has(key string) (bool, error)

func (*LevelDBWithCache) Put 

func (db *LevelDBWithCache) Put(key string, value interface{}) error

func (*LevelDBWithCache) SelectAll 

func (db *LevelDBWithCache) SelectAll() iterator.Iterator

func (*LevelDBWithCache) SelectPrefixSubsetKeyAll 

func (db *LevelDBWithCache) SelectPrefixSubsetKeyAll(key string) ([]map[string]interface{}, error)

type LoggerEngineOption 

type LoggerEngineOption func(*LoggerOption)

func WithLoggerCompress 

func WithLoggerCompress() LoggerEngineOption

func WithLoggerFilePath 

func WithLoggerFilePath(path string) LoggerEngineOption

func WithLoggerLocalTime 

func WithLoggerLocalTime() LoggerEngineOption

func WithLoggerMaxAge 

func WithLoggerMaxAge(age int) LoggerEngineOption

func WithLoggerMaxSize 

func WithLoggerMaxSize(size int) LoggerEngineOption

type LoggerOption 

type LoggerOption struct {
	FilePath  string
	MaxSize   int
	MaxAge    int
	LocalTime bool
	Compress  bool
}

func NewLogger 

func NewLogger(option ...LoggerEngineOption) *LoggerOption

func (*LoggerOption) Start 

func (l *LoggerOption) Start()

type MongoDb 

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

func NewMongoDb 

func NewMongoDb(c *mongo.Client, addr string) (*MongoDb, error)

NewMongoDb mongodb 连接

func (*MongoDb) BatchInsertCollection 

func (m *MongoDb) BatchInsertCollection(c *mongo.Client, db string, collection string, data []interface{}) (
	res *mongo.InsertManyResult, err error)

BatchInsertCollection 批量写入

func (*MongoDb) CountCollection 

func (m *MongoDb) CountCollection(c *mongo.Client, db string, collection string, filter map[string]interface{}) (int64, int64, error)

CountCollection 统计

func (*MongoDb) DeleteOneRecord 

func (m *MongoDb) DeleteOneRecord(c *mongo.Client, db string, collection string, filter map[string]interface{}) (
	res *mongo.DeleteResult, err error)

DeleteOneRecord 删除单条记录

func (*MongoDb) InsertCollection 

func (m *MongoDb) InsertCollection(c *mongo.Client, db string, collection string, data interface{}) (
	res *mongo.InsertOneResult, err error)

InsertCollection 写入 db 写入的数据库 collection 写入的文档（表） data 写入的数据

func (*MongoDb) UpdateOneRecord 

func (m *MongoDb) UpdateOneRecord(c *mongo.Client, db string, collection string, id string, data bson.D) (
	res *mongo.UpdateResult, err error)

UpdateOneRecord 修改单条记录

type RandomPolling 

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

func (*RandomPolling) Add 

func (p *RandomPolling) Add(params ...interface{}) error

func (*RandomPolling) RandomNext 

func (p *RandomPolling) RandomNext() interface{}

type RedisClientOption 

type RedisClientOption func(option *RedisOption)

func WithRedisAddress 

func WithRedisAddress(address string) RedisClientOption

func WithRedisDB 

func WithRedisDB(db int) RedisClientOption

func WithRedisPassword 

func WithRedisPassword(password string) RedisClientOption

type RedisOption 

type RedisOption struct {
	Addr     string `json:"addr"`
	Password string `json:"password"`
	DB       int    `json:"db"`
}

func NewRedisClient 

func NewRedisClient(option ...RedisClientOption) *RedisOption

func (*RedisOption) Connect 

func (c *RedisOption) Connect()

type RotationPolling 

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

func (*RotationPolling) Add 

func (p *RotationPolling) Add(params ...interface{}) error

func (*RotationPolling) RotationNext 

func (p *RotationPolling) RotationNext() interface{}

type Scheduler 

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

Scheduler 调度器结构

func NewScheduler 

func NewScheduler() *Scheduler

NewScheduler 创建新的调度器

func (*Scheduler) AddTask 

func (s *Scheduler) AddTask(id int, name string, execTime time.Time, job func(ctx context.Context))

AddTask 添加新任务

func (*Scheduler) CancelTask 

func (s *Scheduler) CancelTask(id int)

CancelTask 取消指定任务

func (*Scheduler) Run 

func (s *Scheduler) Run(ctx context.Context)

Run 启动调度器

type TokenBucket 

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

func (*TokenBucket) Pass 

func (l *TokenBucket) Pass() bool

func (*TokenBucket) Set 

func (l *TokenBucket) Set(r, c int64)

type ToolsSlice 

type ToolsSlice struct{}

func (*ToolsSlice) CompareSliceByte 

func (w *ToolsSlice) CompareSliceByte(s1, s2 []byte) bool

func (*ToolsSlice) CompareSliceInt 

func (w *ToolsSlice) CompareSliceInt(s1, s2 []int) bool

func (*ToolsSlice) CompareSliceStr 

func (w *ToolsSlice) CompareSliceStr(s1, s2 []string) bool

func (*ToolsSlice) Count 

func (w *ToolsSlice) Count(arr []interface{}) int

repeat item in slice. No contain self item

func (*ToolsSlice) DifferentSet 

func (w *ToolsSlice) DifferentSet(s1, s2 []string) []string

DifferentSet 取两个列表的差集

func (*ToolsSlice) ExpandStringSlice 

func (w *ToolsSlice) ExpandStringSlice(s []string, split string) []string

func (*ToolsSlice) InSlice 

func (w *ToolsSlice) InSlice(s string, ts []string) bool

InSlice 检查字符串是否存在字符串切片中

func (*ToolsSlice) InSliceInterface 

func (w *ToolsSlice) InSliceInterface(s interface{}, ts []interface{}) bool

InSliceInterface 检查Interface是否存在Interface切片中

func (*ToolsSlice) Intersect 

func (w *ToolsSlice) Intersect(s1, s2 []string) []string

Intersect 取两个列表的交集

func (*ToolsSlice) Merge 

func (w *ToolsSlice) Merge(s1, s2 []string) []string

Merge 合集

func (*ToolsSlice) MergeRepeatedElement 

func (w *ToolsSlice) MergeRepeatedElement(s1, s2 []string) []string

MergeRepeatedElement 合集去重

func (*ToolsSlice) MergeSlice 

func (w *ToolsSlice) MergeSlice(s1, s2 []interface{}) (s3 []interface{})

MergeSlice merge two interface slices to one slice

func (*ToolsSlice) MoveStr2Slice 

func (w *ToolsSlice) MoveStr2Slice(str string, buf []byte)

func (*ToolsSlice) PaginateArray 

func (w *ToolsSlice) PaginateArray(arr []interface{}, page, pageSize int) []interface{}

func (*ToolsSlice) RandSlice 

func (w *ToolsSlice) RandSlice(min, max int) []int

func (*ToolsSlice) RemoveRepeatedElement 

func (w *ToolsSlice) RemoveRepeatedElement(arr []string) (newArr []string)

RemoveRepeatedElement 数组切片去重

func (*ToolsSlice) SliceChunk 

func (w *ToolsSlice) SliceChunk(s []interface{}, size int) (chunkSlice [][]interface{})

func (*ToolsSlice) SliceDiff 

func (w *ToolsSlice) SliceDiff(s1, s2 []interface{}) (s3 []interface{})

func (*ToolsSlice) SliceFilter 

func (w *ToolsSlice) SliceFilter(s []interface{}, a filterType) (ftSlice []interface{})

func (*ToolsSlice) SliceHex2SliceUInt16 

func (w *ToolsSlice) SliceHex2SliceUInt16(s []string) (ret []uint16)

func (*ToolsSlice) SliceIntersect 

func (w *ToolsSlice) SliceIntersect(s1, s2 []interface{}) (s3 []interface{})

func (*ToolsSlice) SlicePad 

func (w *ToolsSlice) SlicePad(slice []interface{}, size int, val interface{}) []interface{}

func (*ToolsSlice) SliceRand 

func (w *ToolsSlice) SliceRand(a []interface{}) (b interface{})

func (*ToolsSlice) SliceRange 

func (w *ToolsSlice) SliceRange(start, end, step int64) (intSlice []int64)

func (*ToolsSlice) SliceReduce 

func (w *ToolsSlice) SliceReduce(s []interface{}, a reduceType) (s2 []interface{})

func (*ToolsSlice) SliceShuffle 

func (w *ToolsSlice) SliceShuffle(slice []interface{}) []interface{}

func (*ToolsSlice) SliceStr2SliceInt 

func (w *ToolsSlice) SliceStr2SliceInt(s []string) (ret []int)

func (*ToolsSlice) SliceSum 

func (w *ToolsSlice) SliceSum(s []int64) (sum int64)

func (*ToolsSlice) SliceUnique 

func (w *ToolsSlice) SliceUnique(slice []interface{}) (uniqueSlice []interface{})

type Uint32Slice 

type Uint32Slice []uint32

func (Uint32Slice) Len 

func (p Uint32Slice) Len() int

func (Uint32Slice) Less 

func (p Uint32Slice) Less(i, j int) bool

func (Uint32Slice) Swap 

func (p Uint32Slice) Swap(i, j int)

type WeightPolling 

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

func (*WeightPolling) Add 

func (r *WeightPolling) Add(params ...string) error

func (*WeightPolling) Next 

func (r *WeightPolling) Next() string

type WeightedNode 

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

Source Files

View all Source files

Directories

Path Synopsis
models

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.