util

package module

Go to main page

Versions in this module

v0

v0.0.20

May 8, 2024

Changes in this version

type Redis

+ func (r *Redis) SetLogger(fn func(err error, cmd string, args ...any))

v0.0.19

Apr 30, 2024

v0.0.18

Apr 30, 2024

Changes in this version

+ func NewMongoClient(dsn string) (*mongo.Client, error)

type MemCache

+ func (s *MemCache) GetOrSingleDo(k string, fn func(k string, mc *MemCache) (any, error)) (any, error)

type Redis

+ func (r *Redis) GetOrSingleDo(key string, fn func(key string, redis *Redis) (any, error)) (any, error)

+ func (r *Redis) GetStr(key string) (string, error)

+ func (r *Redis) HGetAllOrSingleDo(key string, fn func(key string, redis *Redis) (any, error)) (map[string]string, error)

v0.0.17

Apr 29, 2024

v0.0.16

Apr 29, 2024

v0.0.15

Apr 29, 2024

Changes in this version

+ var ErrWrongRedisDsn = errors.New("wrong redis dsn")

type Redis

+ Options []redis.DialOption

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

+ func (r *Redis) GetBool(key string) (bool, error)

+ func (r *Redis) GetInt(key string) (int64, error)

+ func (r *Redis) GetNum(key string) (float64, error)

v0.0.14

Apr 29, 2024

Changes in this version

+ var ErrRsaWrongKey = fmt.Errorf("wrong key")

+ var ErrWongRedisDsn = errors.New("wong redis dsn")

+ type Redis struct

+ Dsn string

+ Pool *redis.Pool

+ func NewRedis(dsn string, options ...redis.DialOption) (*Redis, error)

+ func (r *Redis) Decr(key string, step int) (int64, error)

+ func (r *Redis) Del(keys ...any) (int64, error)

+ func (r *Redis) Do(cmd string, args ...any) (any, error)

+ func (r *Redis) DoContext(ctx context.Context, cmd string, args ...any) (any, error)

+ func (r *Redis) DoWithTimeout(timeout time.Duration, cmd string, args ...any) (any, error)

+ func (r *Redis) Exists(key string) bool

+ func (r *Redis) Expire(key string, period time.Duration) (bool, error)

+ func (r *Redis) ExpireAt(key string, at int64) (bool, error)

+ func (r *Redis) HGet(key string, k string) (any, error)

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

+ func (r *Redis) HMGet(key string, ks ...any) (map[string]string, error)

+ func (r *Redis) HMSet(key string, obj map[string]any) (bool, error)

+ func (r *Redis) HSet(key string, k string, v any) (bool, error)

+ func (r *Redis) Incr(key string, step int) (int64, error)

+ func (r *Redis) RateLimit(key string, rate uint, period time.Duration) (bool, error)

+ func (r *Redis) Set(key string, val any, period time.Duration, NXorXX string) (bool, error)

v0.0.13

Apr 28, 2024

v0.0.12

Apr 28, 2024

Changes in this version

type Mysql

+ func NewMysqlEasy(dsn ...string) (*Mysql, error)

v0.0.11

Apr 25, 2024

Changes in this version

type Mysql

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

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

+ func (m *Mysql) ColumnsWalk(fn func(row *MysqlRow) error, table string) error

type MysqlTable

+ func (mt *MysqlTable) ColumnTypes() (map[string]string, error)

v0.0.10

Apr 14, 2024

Changes in this version

+ func RandRange(min, max int) int

v0.0.9

Apr 12, 2024

v0.0.8

Apr 10, 2024

v0.0.7

Mar 26, 2024

Changes in this version

type MysqlTable

+ func (mt *MysqlTable) AllWalk(fn func(row *MysqlRow) error, cols ...string) error

v0.0.6

Mar 20, 2024

Changes in this version

type MemCache

+ func (s *MemCache) GC(td time.Duration, num uint64)

type RateLimit

+ func (rl *RateLimit) SetDuration(td time.Duration)

v0.0.5

Dec 25, 2023

Changes in this version

+ var ErrAesCiphertextTooShort = errors.New(`ciphertext is too short`)

+ var ErrAesCiphertextWrong = errors.New(`ciphertext is not a multiple of the block size`)

+ var ErrAmqpChannelClosed = errors.New(`channel is closed`)

+ var ErrMemCacheKeyExists = errors.New(`key已存在`)

+ var ErrMemCacheKeyExpired = errors.New(`key已过期`)

+ var ErrMemCacheKeyNotExist = errors.New(`key不存在`)

type MemCache

+ func (s *MemCache) ExpireAt(k string) int64

+ func (s *MemCache) SetExpire(k string, exp int64) error

v0.0.4

Dec 8, 2023

v0.0.3

Nov 24, 2023

Changes in this version

+ func HttpSrvRun(addr string, hdl http.Handler)

v0.0.2

Nov 23, 2023

Changes in this version

+ const AlphabetAndNumbers

+ const DateFormat

+ const DateTimeAsSN

+ const DateTimeFormat

+ const TimeFormat

+ func AddSlashes(str string) string

+ func AesCBCDecrypt(str, key string) (string, error)

+ func AesCBCEncrypt(str, key string) (string, error)

+ func FileAppend(file, content string) (bool, error)

+ func FileDel(file string) (bool, error)

+ func FileDelAll(dir string) (bool, error)

+ func FileExist(file string) bool

+ func FileInfo(file string) (fs.FileInfo, error)

+ func FileIsDir(file string) (bool, error)

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

+ func FileMkDir(dir string) (bool, error)

+ func FileRead(file string) ([]byte, error)

+ func FileReadDir(dir string) ([]string, error)

+ func FileReadDirAll(dir string) ([]string, error)

+ func FileReadLines(file string) (lines []string, err error)

+ func FileReadPart(file string, offset, length int64) ([]byte, error)

+ func FileWalkLines(file string, fn func(l string) error) (err error)

+ func FileWrite(file, content string) (bool, error)

+ func GetBinPath() (string, error)

+ func GetHomeDir() (string, error)

+ func InArray(needle interface{}, haystack interface{}) (isIn bool, err error)

+ func InterfaceToFloat64(v interface{}) (ret float64)

+ func InterfaceToInt(v interface{}) (ret int)

+ func InterfaceToInt64(v interface{}) (ret int64)

+ func InterfaceToStr(v interface{}) (ret string)

+ func LocalIp() string

+ func MongoClient(dsn string) (*mongo.Client, error)

+ func MongoPing(client *mongo.Client) error

+ func PKCS7Padding(ciphertext []byte, blockSize int) []byte

+ func PKCS7UnPadding(origData []byte) []byte

+ func RandInt(i int) int

+ func RedisDel(rc redis.Conn, key ...interface{}) (int64, error)

+ func RedisExpire(rc redis.Conn, key string, period time.Duration) (bool, error)

+ func RedisIncr(rc redis.Conn, key string, step int) (int64, error)

+ func RedisPool(name string, options ...redis.DialOption) (*redis.Pool, error)

+ func RedisRateLimit(rc redis.Conn, key string, rate uint, period time.Duration) (bool, error)

+ func RedisSet(rc redis.Conn, key string, value string, period time.Duration, NXorXX string) (bool, error)

+ func Retry(attempt uint, sleep time.Duration, fn func() error) error

+ func RsaGenKeys(bits int) (publicKey, privateKey []byte, err error)

+ func ShellExec(cmdBin string, args ...string) (ret []string, err error)

+ func ShellExecWalk(fn func(s string) error, cmdBin string, args ...string) error

+ func StrAToFloat64(s string) (f float64, err error)

+ func StrCamelToCase(s string) string

+ func StrCaseToCamel(s string) string

+ func StrCheckPass(pass, hash string) bool

+ func StrEndWith(str, find string) bool

+ func StrFileName(name string) (string, error)

+ func StrHashPass(pass string) (string, error)

+ func StrHexDecode(s string) ([]byte, error)

+ func StrHexEncode(bs []byte) string

+ func StrImplode(gap string, ss ...string) string

+ func StrMd5(s string) string

+ func StrNiceSize(sizeI int64) string

+ func StrRandom(l int, c string) string

+ func StrSha1(s string) string

+ func StrSha256(s string) string

+ func StrStartWith(str, find string) bool

+ func StrSubZh(str string, start, end uint) string

+ func StrTrim(s string) string

+ func StripSlashes(str string) string

+ func StripXSS(s string, isUGC bool) string

+ func TimeDateFromStamp(ts int64) string

+ func TimeDateToStamp(str string) (int64, error)

+ func TimeFormStamp(ts int64) string

+ func TimeLocationBJ() *time.Location

+ func TimeNice(t time.Time) string

+ func TimeNowAsSN() string

+ func TimeNowDateNice() string

+ func TimeNowNice() string

+ func TimeNowTimeNice() string

+ func TimeToStamp(str string) (int64, error)

+ func VarDump(v ...interface{})

+ type AmqpClient struct

+ Connection *amqp.Connection

+ func NewAmqpClient(url string) (*AmqpClient, error)

+ func (ac *AmqpClient) Close() error

+ func (ac *AmqpClient) GetChannel() (*amqp.Channel, error)

+ func (ac *AmqpClient) PutChannel(ch *amqp.Channel)

+ type CacheItem struct

+ type MemCache struct

+ func NewMemCache() *MemCache

+ func (s *MemCache) Clear()

+ func (s *MemCache) Del(k string)

+ func (s *MemCache) Get(k string) (any, error)

+ func (s *MemCache) Set(k string, v any, exp int64)

+ func (s *MemCache) SetNX(k string, v any, exp int64) error

+ type MongoCollection struct

+ Collection *mongo.Collection

+ Logger func(ctx context.Context, log *MongoOperationLog)

+ func NewMongoCollection(cli *mongo.Client, db, col string, ...) *MongoCollection

+ func (mc *MongoCollection) AggregateWalk(ctx context.Context, fn func(v bson.M) error, pipeline mongo.Pipeline, ...) error

+ func (mc *MongoCollection) BulkWrite(ctx context.Context, models []mongo.WriteModel, ...) (res *mongo.BulkWriteResult, err error)

+ func (mc *MongoCollection) CountDocuments(ctx context.Context, where any, opts ...*options.CountOptions) (int64, error)

+ func (mc *MongoCollection) CursorAll(ctx context.Context, cursor *mongo.Cursor) ([]bson.M, error)

+ func (mc *MongoCollection) CursorWalk(ctx context.Context, fn func(v bson.M) error, cursor *mongo.Cursor) error

+ func (mc *MongoCollection) DeleteMany(ctx context.Context, where any, opts ...*options.DeleteOptions) (num int64, err error)

+ func (mc *MongoCollection) DeleteOne(ctx context.Context, where any, opts ...*options.DeleteOptions) (num int64, err error)

+ func (mc *MongoCollection) Distinct(ctx context.Context, name string, where any, opts ...*options.DistinctOptions) ([]any, error)

+ func (mc *MongoCollection) Drop(ctx context.Context) (err error)

+ func (mc *MongoCollection) Find(ctx context.Context, where any, opts ...*options.FindOptions) ([]bson.M, error)

+ func (mc *MongoCollection) FindOne(ctx context.Context, where any, opts ...*options.FindOneOptions) (bson.M, error)

+ func (mc *MongoCollection) FindOneAndDelete(ctx context.Context, where any, opts ...*options.FindOneAndDeleteOptions) (res bson.M, err error)

+ func (mc *MongoCollection) FindOneAndReplace(ctx context.Context, where, set any, opts ...*options.FindOneAndReplaceOptions) (res bson.M, err error)

+ func (mc *MongoCollection) FindOneAndUpdate(ctx context.Context, where, set any, opts ...*options.FindOneAndUpdateOptions) (res bson.M, err error)

+ func (mc *MongoCollection) FindWalk(ctx context.Context, fn func(v bson.M) error, where any, ...) error

+ func (mc *MongoCollection) IndexesCreateMany(ctx context.Context, models []mongo.IndexModel, ...) (res []string, err error)

+ func (mc *MongoCollection) IndexesCreateOne(ctx context.Context, model mongo.IndexModel, ...) (res string, err error)

+ func (mc *MongoCollection) IndexesDropAll(ctx context.Context, opts ...*options.DropIndexesOptions) (res bson.Raw, err error)

+ func (mc *MongoCollection) IndexesDropOne(ctx context.Context, name string, opts ...*options.DropIndexesOptions) (res bson.Raw, err error)

+ func (mc *MongoCollection) IndexesList(ctx context.Context, opts ...*options.ListIndexesOptions) ([]bson.M, error)

+ func (mc *MongoCollection) InsertMany(ctx context.Context, items []any, opts ...*options.InsertManyOptions) (newIds []any, err error)

+ func (mc *MongoCollection) InsertOne(ctx context.Context, item any, opts ...*options.InsertOneOptions) (newId any, err error)

+ func (mc *MongoCollection) Names() (string, string)

+ func (mc *MongoCollection) NewOperationLog(do string, set, whr, opt, res any, err error) *MongoOperationLog

+ func (mc *MongoCollection) PageWalk(ctx context.Context, fn func(v bson.M) error, page, pageSize int64, ...) (itemTotal, pageTotal int64, err error)

+ func (mc *MongoCollection) UpdateByID(ctx context.Context, id, set any, opts ...*options.UpdateOptions) (res *mongo.UpdateResult, err error)

+ func (mc *MongoCollection) UpdateMany(ctx context.Context, where, set any, opts ...*options.UpdateOptions) (res *mongo.UpdateResult, err error)

+ func (mc *MongoCollection) UpdateOne(ctx context.Context, where, set any, opts ...*options.UpdateOptions) (res *mongo.UpdateResult, err error)

+ type MongoOperationLog bson.M

+ type Mysql struct

+ ConnParam *MysqlConnParam

+ Listener func(err error, query string, param ...interface{})

+ Logger *Queue

+ MasterAsSlave bool

+ TimeoutInsert time.Duration

+ TimeoutSelect time.Duration

+ TimeoutTrans time.Duration

+ TimeoutUpdate time.Duration

+ func NewMysql(param *MysqlConnParam) *Mysql

+ func (m *Mysql) AddLog(query string, params []interface{}, err error)

+ func (m *Mysql) CloseDB()

+ func (m *Mysql) Count(query string, params ...interface{}) (cnt int64, err error)

+ func (m *Mysql) DelByIds(table, pk string, ids ...interface{}) (i int64, err error)

+ func (m *Mysql) Delete(query string, params ...interface{}) (int64, error)

+ func (m *Mysql) GetByIds(table, pk string, ids []interface{}, cols ...string) (rows []*MysqlRow, err error)

+ func (m *Mysql) GetDB(useSlave bool) (*sql.DB, error)

+ func (m *Mysql) GetOne(table, pk, id string, cols ...string) (*MysqlRow, error)

+ func (m *Mysql) IdsWalk(fn func(row *MysqlRow) error, table string, pk string, ids []interface{}, ...) error

+ func (m *Mysql) Insert(table string, row *MysqlRow, ignoreOrReplace ...bool) (int64, error)

+ func (m *Mysql) InsertBatch(table string, rows []*MysqlRow) (ret int64, err error)

+ func (m *Mysql) InsertDuplicate(table string, row *MysqlRow) (int64, error)

+ func (m *Mysql) InsertIgnore(table string, row *MysqlRow) (int64, error)

+ func (m *Mysql) InsertReplace(table string, row *MysqlRow) (int64, error)

+ func (m *Mysql) PopLogs(fn func(ql *MysqlLog) error) error

+ func (m *Mysql) SelPage(page, numPerPage int64, table, queryWhere, queryOrder, selCols string, ...) (totalItem, totalPage, curPage int64, err error)

+ func (m *Mysql) SelWalk(fn func(row *MysqlRow) error, query string, params ...interface{}) error

+ func (m *Mysql) Select(query string, params ...interface{}) (rows []*MysqlRow, err error)

+ func (m *Mysql) SetListener(fn func(err error, query string, param ...interface{}))

+ func (m *Mysql) Transaction(...) error

+ func (m *Mysql) Truncate(table string) error

+ func (m *Mysql) Update(query string, params ...interface{}) (int64, error)

+ func (m *Mysql) UpdateById(table string, row *MysqlRow, pk, id string) (int64, error)

+ type MysqlConnOption struct

+ Addr string

+ ConnMaxIdleTime time.Duration

+ ConnMaxLifetime time.Duration

+ DBName string

+ Dsn string

+ MaxIdleConn int

+ MaxOpenConn int

+ func NewMysqlConnOption(dsn string, maxOpen, maxIdle int, maxIdleTime, maxLifeTime time.Duration) (*MysqlConnOption, error)

+ type MysqlConnParam struct

+ Master *MysqlConnOption

+ Slaves []*MysqlConnOption

+ type MysqlDBs struct

+ type MysqlLog struct

+ Err error

+ Params []interface{}

+ Query string

+ When string

+ type MysqlRow map[string]interface

+ func (row *MysqlRow) ToInt64(key string) int64

+ func (row *MysqlRow) ToNum(key string) float64

+ func (row *MysqlRow) ToStr(key string) string

+ type MysqlTable struct

+ Conn *Mysql

+ Name string

+ PK string

+ func NewMysqlTable(mysql *Mysql, tableName, primaryKey string) (*MysqlTable, error)

+ func (mt *MysqlTable) Count(query string, params ...interface{}) (int64, error)

+ func (mt *MysqlTable) DelByIds(ids ...interface{}) (int64, error)

+ func (mt *MysqlTable) Delete(query string, params ...interface{}) (int64, error)

+ func (mt *MysqlTable) GetByIds(ids []interface{}, cols ...string) ([]*MysqlRow, error)

+ func (mt *MysqlTable) GetOne(id string, cols ...string) (*MysqlRow, error)

+ func (mt *MysqlTable) IdsWalk(fn func(row *MysqlRow) error, ids []interface{}, cols ...string) error

+ func (mt *MysqlTable) Insert(row *MysqlRow) (int64, error)

+ func (mt *MysqlTable) InsertBatch(rows []*MysqlRow) (int64, error)

+ func (mt *MysqlTable) InsertDuplicate(row *MysqlRow) (int64, error)

+ func (mt *MysqlTable) InsertIgnore(row *MysqlRow) (int64, error)

+ func (mt *MysqlTable) InsertReplace(row *MysqlRow) (int64, error)

+ func (mt *MysqlTable) SelPage(fn func(row *MysqlRow) error, page, numPerPage int64, ...) (int64, int64, int64, error)

+ func (mt *MysqlTable) SelWalk(fn func(row *MysqlRow) error, query string, params ...interface{}) error

+ func (mt *MysqlTable) Select(query string, params ...interface{}) ([]*MysqlRow, error)

+ func (mt *MysqlTable) Transaction(...) error

+ func (mt *MysqlTable) Truncate() error

+ func (mt *MysqlTable) Update(query string, params ...interface{}) (int64, error)

+ func (mt *MysqlTable) UpdateById(row *MysqlRow, id string) (int64, error)

+ type QueryLog struct

+ Err error

+ Params []interface{}

+ Query string

+ When string

+ type Queue struct

+ func NewQueue(size uint64) *Queue

+ func (q *Queue) Pause(b bool)

+ func (q *Queue) Pop() (interface{}, bool)

+ func (q *Queue) PopAll() (ret []interface{})

+ func (q *Queue) PopAllWalk(fn func(item interface{}))

+ func (q *Queue) PopWait(td time.Duration) (interface{}, error)

+ func (q *Queue) Push(items ...interface{})

+ func (q *Queue) PushWait(items ...interface{})

+ func (q *Queue) TryPushOne(item interface{}) bool

+ type RateLimit struct

+ func NewRateLimit(size, sec uint64) (rl *RateLimit)

+ func (rl *RateLimit) Check() bool

+ func (rl *RateLimit) CheckWait(td time.Duration) bool

+ func (rl *RateLimit) Close()

+ func (rl *RateLimit) Open()

+ func (rl *RateLimit) Status() int

+ type RedisPoolMap struct

+ type RsaKeys struct

+ PrivateKey *rsa.PrivateKey

+ PrivateKeyStr string

+ PublicKey *rsa.PublicKey

+ PublicKeyStr string

+ func NewRsaKeys(publicKey, privateKey string) (*RsaKeys, error)

+ func (rk *RsaKeys) DecodeWithPrivateKey(txt string) (string, error)

+ func (rk *RsaKeys) EncodeWithPublicKey(txt string) (string, error)

+ func (rk *RsaKeys) SignWithPrivateKey(txt string) (string, error)

+ func (rk *RsaKeys) VerifyWithPublicKey(sign, txt string) error

+ type WaitGroup struct

+ func NewWaitGroup(size int) *WaitGroup

+ func (p *WaitGroup) Add(delta int)

+ func (p *WaitGroup) Done()

+ func (p *WaitGroup) Wait()

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