utils

package
v1.4.8 Latest Latest
Warning

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

 Go to latest Published: Mar 9, 2026 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Index

Examples

Constants

View Source 
const (
	OnlineNodes        = "dlock:online" //在线节点
	NodeIdKey          = "dlock:nodeId" //自增ID
	NodeFileDir        = "./runtime"
	NodeIdFile         = "./runtime/node_locker_id_"
	NotifyEventChannel = "SET_NX:notify_unlock_event"
)

Variables

This section is empty.

Functions

func Auth01Validate added in v1.2.6 

func Auth01Validate(auth int64, operation int) bool

Auth01Validate 验证操权限值和操作值

func DeepClone 

func DeepClone(v interface{}) interface{}

DeepClone v

Example 
package main

import (
	"fmt"
	"github.com/helloh2o/lucky/utils"
)

func main() {
	src := []int{1, 2, 3}

	dst := utils.DeepClone(src).([]int)

	for _, v := range dst {
		fmt.Println(v)
	}

}

Output:
1
2
3

func DeepCopy 

func DeepCopy(dst, src interface{})

DeepCopy src to dst

Example 
package main

import (
	"fmt"
	"github.com/helloh2o/lucky/utils"
)

func main() {
	src := []int{1, 2, 3}

	var dst []int
	utils.DeepCopy(&dst, &src)

	for _, v := range dst {
		fmt.Println(v)
	}

}

Output:
1
2
3

func DelOpKey added in v1.4.8 

func DelOpKey(key string)

DelOpKey 删除锁定的建

func DispatchReadPK 

func DispatchReadPK(money float64, amount int, average bool) (pks []float64)

DispatchReadPK random || @average money/amount

func ExistedCache added in v1.2.5 

func ExistedCache(key string) bool

是否存在redis key

func Exists added in v1.1.7 

func Exists(path string) bool

Exists 判断所给路径文件/文件夹是否存在

func FormatTime2String added in v1.1.7 

func FormatTime2String(t time.Time) string

FormatTime2String 时间to字符串

func GetIrisRemoteAddr added in v1.1.7 

func GetIrisRemoteAddr(ctx *context.Context) string

GetIrisRemoteAddr 获取Iris 客户端IP

func GetMD5Hash added in v1.1.7 

func GetMD5Hash(text string) string

GetMD5Hash get md5 of text

func GetTodayUnix added in v1.2.5 

func GetTodayUnix() int64

GetTodayUnix 获取今日凌晨时间戳s

func GetTomorrowUnix added in v1.2.5 

func GetTomorrowUnix() int64

GetTomorrowUnix 获取明日凌晨时间戳s

func GraceExit added in v1.4.8 

func GraceExit(done chan struct{}, callbacks ...func())

GraceExit 优雅退出

func InitDsbLocker added in v1.4.8 

func InitDsbLocker(nodeId string, rdb redis.UniversalClient, notifies ...func(string)) func()

InitDsbLocker 初始化默认分布式锁节点 @nodeId 节点ID @rdb Redis 客户端 @notifies 解锁通知方法

func IrisSVExit added in v1.4.8 

func IrisSVExit(done chan struct{}, callbacks ...func())

IrisSVExit Iris服务优雅退出

func IsDir added in v1.1.7 

func IsDir(path string) bool

IsDir 判断所给路径是否为文件夹

func IsEmail added in v1.2.6 

func IsEmail(email string) bool

func IsFile added in v1.1.7 

func IsFile(path string) bool

IsFile 判断所给路径是否为文件

func IsPhone added in v1.2.6 

func IsPhone(phoneStr string) bool

func OpLockTimeout added in v1.4.8 

func OpLockTimeout(key string, timeout time.Duration) func()

OpLockTimeout 单机锁一个操作字符串可超时

func OpLocked added in v1.4.8 

func OpLocked(key string) (func(), error)

OpLocked 单机锁一个操作字符串

func OpLockedWait added in v1.4.8 

func OpLockedWait(key string) func()

OpLockedWait 单机锁一个操作字符串，等待

func RandGroup 

func RandGroup(p ...uint32) int

RandGroup by []unit32

Example 
package main

import (
	"fmt"
	"github.com/helloh2o/lucky/utils"
)

func main() {
	i := utils.RandGroup(0, 0, 50, 50)
	switch i {
	case 2, 3:
		fmt.Println("ok")
	}

}

Output:
ok

func RandInterval 

func RandInterval(b1, b2 int32) int32

RandInterval b1 to b2

Example 
package main

import (
	"fmt"
	"github.com/helloh2o/lucky/utils"
)

func main() {
	v := utils.RandInterval(-1, 1)
	switch v {
	case -1, 0, 1:
		fmt.Println("ok")
	}

}

Output:
ok

func RandIntervalN 

func RandIntervalN(b1, b2 int32, n uint32) []int32

RandIntervalN b1, b2, n

Example 
package main

import (
	"fmt"
	"github.com/helloh2o/lucky/utils"
)

func main() {
	r := utils.RandIntervalN(-1, 0, 2)
	if r[0] == -1 && r[1] == 0 ||
		r[0] == 0 && r[1] == -1 {
		fmt.Println("ok")
	}

}

Output:
ok

func RandItemWeight added in v1.2.2 

func RandItemWeight(rd *rand.Rand, data map[interface{}]int64) (interface{}, error)

RandItemWeight 根据权重随机

func RandString 

func RandString(len int) string

RandString by len

func ReplaceKeyword added in v1.2.3 

func ReplaceKeyword(cfg, value string) string

ReplaceKeyword 替换关键字

func Reverse added in v1.4.5 

func Reverse(s interface{})

Reverse Answers for Go version 1.20 and earlier:

func RunCmd added in v1.1.7 

func RunCmd(command string, args ...string) error

RunCmd 调用命令

func SignalExit added in v1.1.7 

func SignalExit(callback func())

func SyncObjByStr added in v1.1.6 

func SyncObjByStr(objKey string) func()

SyncObjByStr 锁定一个字符串的同步操作

func SyncStrWithTimeout added in v1.1.7 

func SyncStrWithTimeout(objKey string, duration time.Duration) func()

SyncStrWithTimeout 锁定一个字符串的同步操作,允许过期

Types

type AuthValidator added in v1.2.3 

type AuthValidator struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewAuthValidator added in v1.2.3 

func NewAuthValidator() *AuthValidator

NewAuthValidator 创建一个权限检验器

func (*AuthValidator) AddAuthData added in v1.2.3 

func (au *AuthValidator) AddAuthData(key interface{}, maxAuth int)

AddAuthData 添加对象权限

func (*AuthValidator) GetAuth added in v1.2.3 

func (au *AuthValidator) GetAuth(key interface{}) int

GetAuth 获取对象的权限值

func (*AuthValidator) Validate added in v1.2.3 

func (au *AuthValidator) Validate(key interface{}, operation int) bool

Validate 验证操作是否有权限

type Callback added in v1.4.8 

type Callback[T comparable] func(T)

type DedupQueue added in v1.4.8 

type DedupQueue[T comparable] struct {
	// contains filtered or unexported fields
}

DedupQueue 这是安全的去重排队queue

func NewDedupQueue added in v1.4.8 

func NewDedupQueue[T comparable](
	size int,
	workers int,
	interval time.Duration,
	cb Callback[T],
) *DedupQueue[T]

func (*DedupQueue[T]) Enqueue added in v1.4.8 

func (q *DedupQueue[T]) Enqueue(key T) bool

Enqueue 入队，如果 key 已存在返回 false

func (*DedupQueue[T]) Len added in v1.4.8 

func (q *DedupQueue[T]) Len() int64

func (*DedupQueue[T]) Stop added in v1.4.8 

func (q *DedupQueue[T]) Stop()

type LazyQueue added in v1.1.5 

type LazyQueue struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

LazyQueue 排队保存，重复的数据只排一次，时效性一般的情况，场景：降低数据库写压力

func NewLazyQueue added in v1.1.4 

func NewLazyQueue(qps, size int, cf func(interface{}) error) (*LazyQueue, error)

func (*LazyQueue) Executed added in v1.3.8 

func (lazy *LazyQueue) Executed(f func(interface{}, error))

Executed 已执行

func (*LazyQueue) Length added in v1.2.2 

func (lazy *LazyQueue) Length() int

Length 队列长度

func (*LazyQueue) OutOfQueue added in v1.1.5 

func (lazy *LazyQueue) OutOfQueue(key interface{})

OutOfQueue 解除对象慢保存排队

func (*LazyQueue) PushToQueue added in v1.1.5 

func (lazy *LazyQueue) PushToQueue(obj interface{})

PushToQueue 对象加入保存队列

func (*LazyQueue) PushToQueueWait added in v1.2.2 

func (lazy *LazyQueue) PushToQueueWait(obj interface{})

PushToQueueWait 对象同步加入保存队列

func (*LazyQueue) Queued added in v1.3.8 

func (lazy *LazyQueue) Queued(f func(interface{}))

Queued 已排队

func (*LazyQueue) Reset added in v1.2.2 

func (lazy *LazyQueue) Reset()

Reset 重置队列

func (*LazyQueue) Run added in v1.1.5 

func (lazy *LazyQueue) Run()

Run 启动LazySave 并返回错误

type LimiterMap 

type LimiterMap struct {
	sync.RWMutex
	// contains filtered or unexported fields
}
var Limiter *LimiterMap

func (*LimiterMap) Add 

func (l *LimiterMap) Add(key interface{}, duration time.Duration)

func (*LimiterMap) Clean 

func (l *LimiterMap) Clean()

Clean self clean

func (*LimiterMap) Del 

func (l *LimiterMap) Del(key interface{})

func (*LimiterMap) IsLimited 

func (l *LimiterMap) IsLimited(key interface{}, seconds int64) bool

func (*LimiterMap) IsV2Limited added in v1.1.9 

func (l *LimiterMap) IsV2Limited(key interface{}, duration time.Duration, max int64) (bool, int64)

func (*LimiterMap) UnSafeDel 

func (l *LimiterMap) UnSafeDel(key interface{})

func (*LimiterMap) UnsafeAdd added in v1.1.2 

func (l *LimiterMap) UnsafeAdd(key interface{}, duration time.Duration)

type RNodeLock added in v1.4.8 

type RNodeLock struct {
	// 节点ID
	Nid string
	sync.Mutex

	SelfNotify func(string) // 自定义解锁通知
	// contains filtered or unexported fields
}

RNodeLock 基于Redis的分布式锁

func DsbLock added in v1.4.8 

func DsbLock() *RNodeLock

func (*RNodeLock) HandleMsg added in v1.4.8 

func (locker *RNodeLock) HandleMsg(msg string)

func (*RNodeLock) Pub added in v1.4.8 

func (locker *RNodeLock) Pub(key string)

func (*RNodeLock) RDLockAsync added in v1.4.8 

func (locker *RNodeLock) RDLockAsync(operation string, lockExp time.Duration) (func(), bool)

RDLockAsync 获取锁，不阻塞只返回结果，ok的情况，业务执行defer done()释放锁

func (*RNodeLock) RDLockAuto added in v1.4.8 

func (locker *RNodeLock) RDLockAuto(operation string) func()

RDLockAuto 默认15分钟，自动续期

func (*RNodeLock) RDLockWait added in v1.4.8 

func (locker *RNodeLock) RDLockWait(operation string) func()

RDLockWait redis 等待分布式锁，直到获取锁，锁不过期 (一般情况下不推荐使用此方法)

func (*RNodeLock) RDLockWaitHasExp added in v1.4.8 

func (locker *RNodeLock) RDLockWaitHasExp(operation string, lockExp time.Duration) func()

RDLockWaitHasExp redis 等待分布式锁，直到获取锁, 锁自定义过期时间（确保自己的逻辑时间足够）

func (*RNodeLock) RDLockWaitHour added in v1.4.8 

func (locker *RNodeLock) RDLockWaitHour(operation string) func()

RDLockWaitHour redis 等待分布式锁，直到获取锁，锁一小时过期 （推荐使用，一小时足够完成逻辑执行）

func (*RNodeLock) RDLockWithContext added in v1.4.8 

func (locker *RNodeLock) RDLockWithContext(ctx context.Context, operation string) (func(), bool)

func (*RNodeLock) RDLockWithContextExp added in v1.4.8 

func (locker *RNodeLock) RDLockWithContextExp(ctx context.Context, operation string, exp time.Duration) (func(), bool)

RDLockWithContextExp redis 上下文获取锁， 超时上下文可

func (*RNodeLock) Release added in v1.4.8 

func (locker *RNodeLock) Release()

func (*RNodeLock) Sub added in v1.4.8 

func (locker *RNodeLock) Sub()

func (*RNodeLock) WatchKeys added in v1.4.8 

func (locker *RNodeLock) WatchKeys()

type RankItem added in v1.1.5 

type RankItem struct {
	// 键
	Key interface{}
	// 原始值
	Data interface{}
	// 排名值
	RankVal int64
}

RankItem 排序项目

type RateLimiter added in v1.1.3 

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

From:: https://github.com/beefsack/go-rate/blob/master/rate.go A RateLimiter limits the rate at which an action can be performed. It applies neither smoothing (like one could achieve in a token bucket system) nor does it offer any conception of warmup, wherein the rate of actions granted are steadily increased until a steady throughput equilibrium is reached.

func New added in v1.1.3 

func New(limit int, interval time.Duration) *RateLimiter

New creates a new rate limiter for the limit and interval.

func (*RateLimiter) Try added in v1.1.3 

func (r *RateLimiter) Try() (ok bool, remaining time.Duration)

Try returns true if under the rate limit, or false if over and the remaining time before the rate limit expires.

func (*RateLimiter) Wait added in v1.1.3 

func (r *RateLimiter) Wait()

Wait blocks if the rate limit has been reached. Wait offers no guarantees of fairness for multiple actors if the allowed rate has been temporarily exhausted.

type RkPool added in v1.1.5 

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

RankPool 排序池

func NewRKPool added in v1.1.5 

func NewRKPool(name string, size int, rankCycle time.Duration, selfSort func([]RankItem) []RankItem) *RkPool

NewRKPool 创建一个新的排序池

func (*RkPool) Clean added in v1.1.5 

func (rp *RkPool) Clean()

Clean 清空排序池

func (*RkPool) GetNO1 added in v1.1.5 

func (rp *RkPool) GetNO1() *RankItem

GetNO1 获取第一个用户

func (*RkPool) GetRankData added in v1.1.5 

func (rp *RkPool) GetRankData(from, to int) (data []RankItem)

GetRankData 获取已排序数据

func (*RkPool) IsInPool added in v1.1.5 

func (rp *RkPool) IsInPool(item RankItem) bool

IsInPool 是否在池子中

func (*RkPool) Queue added in v1.1.5 

func (rp *RkPool) Queue(item RankItem)

Queue 排队到池

func (*RkPool) Rank added in v1.1.5 

func (rp *RkPool) Rank()

进行排序

func (*RkPool) Remove added in v1.1.5 

func (rp *RkPool) Remove(key interface{})

Remove from pool

func (*RkPool) Serve added in v1.1.5 

func (rp *RkPool) Serve()

Serve 开启间隙自动排序

type Waiter added in v1.2.0 

type Waiter struct {
	N         int64
	WC        chan struct{}
	Expired   time.Duration
	ExpiredAt time.Time
	Timer     *time.Timer
}

Source Files

View all Source files

Directories

Path Synopsis
http_proxy command
s5_proxy command

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.