utils

package
v0.0.0-...-a0c90f5 Latest Latest
Warning

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

 Go to latest Published: May 7, 2025 License: MIT Imports: 43 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Base62Chars    = "0123456789abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ"
	Base62CharsLen = len(Base62Chars)

	Linux   = runtime.GOOS == "linux"
	Windows = runtime.GOOS == "windows"
)
View Source 
const (
	TimestampFormat = "2006-01-02 15:04:05"
)

Variables

View Source 
var (
	TypeOfError    = reflect.TypeOf((*error)(nil)).Elem()
	TypeOfBytes    = reflect.TypeOf(([]byte)(nil))
	TypeOfContext  = reflect.TypeOf(new(context.Context)).Elem()
	TypeOfProtoMsg = reflect.TypeOf(new(proto.Message)).Elem()

	TypesOfBaseType = []reflect.Kind{
		reflect.Bool, reflect.Int, reflect.Int8, reflect.Int16, reflect.Int32, reflect.Int64,
		reflect.Uint, reflect.Uint8, reflect.Uint16, reflect.Uint32, reflect.Uint64, reflect.Uintptr,
		reflect.Float32, reflect.Float64, reflect.Complex64, reflect.Complex128, reflect.String,
	}
)
View Source 
var (
	RandomSeed *rand.Rand
)

Functions

func Abs 

func Abs[T NumberType](i T) T

func AppendMaps 

func AppendMaps[T any](sources ...map[string]T) map[string]T

AppendMaps 浅拷贝合并maps

func BackoffDelay 

func BackoffDelay(attempts int) time.Duration

func CRC32Sum 

func CRC32Sum(value []byte) string

func CopyFile 

func CopyFile(src, dst string) (err error)

func CopyMap 

func CopyMap[M ~map[K]V, K comparable, V any](m M) M

CopyMap 拷贝map（maps.Clone）

func CopySlice 

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

CopySlice 拷贝列表

func DJB33 

func DJB33(seed uint32, k string) uint32

func DeepCopyMap 

func DeepCopyMap[T any](src map[string]T) (map[string]T, error)

DeepCopyMap 通过序列号深拷贝

func DownloadToBuffer 

func DownloadToBuffer(url string, writer io.Writer) error

func DownloadToFile 

func DownloadToFile(url, path string) (err error)

DownloadToFile 下载文件

func DownloadToFolder 

func DownloadToFolder(url, folder string) (err error)

DownloadToFolder 下载文件到目录

func ExpireTime 

func ExpireTime(timeout int64) (int64, int64)

func FromBase62 

func FromBase62(s string) (n int, err error)

func GetAllFiles 

func GetAllFiles(root, suffix string, total int) ([]string, error)

func GetDay 

func GetDay(at ...int64) int64

GetDay 获取当日零点

func GetField 

func GetField(object any, key string) (any, error)

func GetHostAddr 

func GetHostAddr(host string) (string, error)

func GetHostTLD 

func GetHostTLD(host string) (string, error)

func GetMonday 

func GetMonday(at ...int64) int64

GetMonday 获取本周一

func GetMonth 

func GetMonth(at ...int64) int64

GetMonth 获取月初

func GetNextDay 

func GetNextDay(at ...int64) int64

GetNextDay 获取明日零点

func GetNextMonth 

func GetNextMonth(at ...int64) int64

GetNextMonth 获取下个月

func GetNextYear 

func GetNextYear(at ...int64) int64

GetNextYear 获取次年

func GetStringsByField 

func GetStringsByField[T any](object []T, key string) ([]string, error)

func GetYear 

func GetYear(at ...int64) int64

GetYear 获取今年第一天

func HasIntersection 

func HasIntersection[T comparable](slice1, slice2 []T) bool

HasIntersection 判断是否有交集

func HashString 

func HashString(mode HashMode, s ...string) string

func HashStringToInt 

func HashStringToInt(s string, min, max int) int

HashStringToInt hashes a string to an int value and limits the result within a specified range. 用于散列字符串到分区 [a, b)

func HostPort 

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

HostPort format addr and port suitable for dial.

func IPs 

func IPs() []string

IPs returns all available interface IP addresses.

func IncludeInSlice 

func IncludeInSlice[T comparable](s []T, target T) bool

IncludeInSlice 判断包含

func InsertSlice 

func InsertSlice[T any](s []T, value T) []T

InsertSlice 插入到最开始

func IntSliceToString 

func IntSliceToString[T IntType](s []T) []string

IntSliceToString int类型转换string

func IntToString 

func IntToString[T IntType](value T) string

func IsLocal 

func IsLocal(addr string) bool

IsLocal checks whether an IP belongs to one of the device's interfaces.

func IsSafePathName 

func IsSafePathName(name string) bool

func IsSafeUnixLikePath 

func IsSafeUnixLikePath(path string) bool

func JsonConvert 

func JsonConvert(a, b any) error

func Listen 

func Listen(addr string) (net.Listener, error)

func LoadBuff 

func LoadBuff(path string) ([]byte, error)

func LoadGeneralJsonFiles 

func LoadGeneralJsonFiles(targets []string, skip bool, loop int) (map[string]any, error)

func LoadJson 

func LoadJson(path string, payload any) error

func MD5Sum 

func MD5Sum(value []byte) string

func MakeDirs 

func MakeDirs(path string, strict ...bool) error

func MapClear 

func MapClear[M ~map[K]V, K comparable, V any](m M)

func MapKeyToSlice 

func MapKeyToSlice[T1 comparable, T2 any](m map[T1]T2) []T1

MapKeyToSlice map key转换成列表

func MapKeys 

func MapKeys[M ~map[K]V, K comparable, V any](m M) []K

func MapToSliceByField 

func MapToSliceByField[T any, K comparable](s []T, field ...string) (map[K]T, error)

MapToSliceByField 提取结构体中的自定字段转为列表

func MapValueToSlice 

func MapValueToSlice[T1 comparable, T2 any](m map[T1]T2) []T2

MapValueToSlice map 值转换成列表

func MapValues 

func MapValues[M ~map[K]V, K comparable, V any](m M) []V

func Md5Hmac 

func Md5Hmac(value, key []byte) string

func MergeJsonMaps 

func MergeJsonMaps(dest, src map[string]any) map[string]any

func MergeMaps 

func MergeMaps[T any](sources ...map[string]T) (map[string]T, error)

MergeMaps 通过序列号深拷贝后合并

func MergeSlice 

func MergeSlice[T any](slices ...[]T) []T

MergeSlice 列表合并

func MergeSliceMaps 

func MergeSliceMaps[T any](key string, sources ...any) (map[string]T, error)

MergeSliceMaps 通过序列号深拷贝后合并

func Monotonic 

func Monotonic() time.Duration

func New62Sqid 

func New62Sqid(len uint8) (*sqids.Sqids, error)

func Now 

func Now() time.Time

func NowUnix 

func NowUnix() int64

func NumberSliceJoin 

func NumberSliceJoin[T NumberType](values []T) string

NumberSliceJoin 数字合并

func OrderedQuery 

func OrderedQuery(values *OrderedMap[string, string]) string

OrderedQuery 按照字典写入顺的生成query string

func ParseQuery 

func ParseQuery(query string) (values map[string]string, err error)

ParseQuery query string转化为map

func PathExist 

func PathExist(path string) (bool, error)

func PathFileInfo 

func PathFileInfo(path string) (os.FileInfo, error)

func PathIsDir 

func PathIsDir(path string) (bool, error)

func PathIsRegularFile 

func PathIsRegularFile(path string) (bool, error)

func PathIsUnixSockFile 

func PathIsUnixSockFile(path string) (bool, error)

func PopQuery 

func PopQuery(query string, skip ...string) (string, error)

func RandString 

func RandString(n int) string

RandString 返回一个指定长度的随机字符串

func RandomHex 

func RandomHex(length int) string

func RandomInt 

func RandomInt(n int) int

func ReadFile 

func ReadFile(path string) ([]byte, error)

func RemoveElementSlice 

func RemoveElementSlice[T comparable](sp *[]T, target T)

RemoveElementSlice 从列表中剔除元素(不创建新列表)

func RepeatSlice 

func RepeatSlice[T any](slice []T, times int) []T

RepeatSlice 实现python [1] * n的功能

func SaveBuff 

func SaveBuff(path string, payload []byte, overwrite ...bool) error

func SaveJson 

func SaveJson(path string, payload any, overwrite ...bool) error

func Sets 

func Sets[T comparable](slices []T) []T

func Sha1Hmac 

func Sha1Hmac(value, key []byte) string

func Sha1Sum 

func Sha1Sum(value []byte) string

func Sha256Hmac 

func Sha256Hmac(value, key []byte) string

func Sha256Sum 

func Sha256Sum(value []byte) string

func ShuffleSlice 

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

ShuffleSlice 使用 Fisher-Yates 算法随机打乱切片

func SliceJoin 

func SliceJoin[T SortAbleType](values []T, quote string, split ...string) string

SliceJoin 列表合并

func SliceReverse 

func SliceReverse[T any](s []T) []T

SliceReverse 列表倒转

func SliceToMap 

func SliceToMap[T any, K comparable](s []T, keyFunc func(T) K) map[K]T

SliceToMap 列表传字典,key通过传入的keyFunc 获取

func SliceToMapByField 

func SliceToMapByField[T any, K comparable](s []T, field ...string) (map[K]T, error)

SliceToMapByField 列表转字典，以列表中结构体的指定字段为key

func SliceToMapByStringField 

func SliceToMapByStringField[T any](s []T, key ...string) (map[string]T, error)

SliceToMapByStringField 列表转字典，以列表中结构体的指定字符串字段为key

func SortSlice 

func SortSlice[T SortAbleType](src []T, reverse ...bool) []T

SortSlice 排序

func SortedQuery 

func SortedQuery(values map[string]string) string

SortedQuery 按照key升序的顺序生成的query string

func SplitSlice 

func SplitSlice[T any](slice []T, total int) [][]T

func StrSliceJoin 

func StrSliceJoin(values []string) string

StrSliceJoin 数字合并

func StrToI32 

func StrToI32(value string) (int32, error)

func StringSliceToInt 

func StringSliceToInt[T IntType](s []string) ([]T, error)

StringSliceToInt string 转换未int

func StringToInt 

func StringToInt(value string) (int, error)

func StringToMoney 

func StringToMoney(s string) (value decimal.Decimal, err error)

func StringToTime 

func StringToTime(s string) (time.Time, error)

func Supported 

func Supported(supports []string, target string) bool

func ToBase62 

func ToBase62(n int) string

func ToBase62Bytes 

func ToBase62Bytes(n int) (s []byte)

func ToString 

func ToString(i any) (string, error)

ToString casts any type to a string type.

func TopLevelDomain 

func TopLevelDomain(domain string) (string, error)

TopLevelDomain 获取顶级域名

func UnSafeGetStringsByField 

func UnSafeGetStringsByField[T any](object []T, key string) []string

func UnZip 

func UnZip(source, output string) error

UnZip 解压到文件夹

func UnsafeStrToI32 

func UnsafeStrToI32(value string) int32

func UnsafeStrToI64 

func UnsafeStrToI64(value string) int64

func UnsafeToString 

func UnsafeToString(i any) string

func VerifyAddr 

func VerifyAddr(listen string) bool

func VerifyIP 

func VerifyIP(addr string) (string, error)

VerifyIP (Extract) returns a valid IP address. If the address provided is a valid address, it will be returned directly. Otherwise the available interfaces be itterated over to find an IP address, prefferably private.

func Zip 

func Zip(source, output string) error

Zip 压缩指定文件、文件夹

func ZipCompress 

func ZipCompress(data []byte) ([]byte, error)

func ZipDecompress 

func ZipDecompress(data []byte) ([]byte, error)

func ZipFileBuff 

func ZipFileBuff(name string, data []byte) ([]byte, error)

Types

type BaseType 

type BaseType interface {
	~int | ~int8 | ~int32 | ~int64 | ~uint | ~uint8 | ~uint16 | ~uint32 | ~uint64 | ~float32 | ~float64 | ~bool | ~string | ~complex64 | ~complex128
}

type Element 

type Element[K comparable, V any] struct {

	// The key that corresponds to this element in the ordered map.
	Key K

	// The value stored with this element.
	Value V
	// contains filtered or unexported fields
}

Element is an element of a null terminated (non circular) intrusive doubly linked list that contains the key of the correspondent element in the ordered map too.

func (*Element[K, V]) Next 

func (e *Element[K, V]) Next() *Element[K, V]

Next returns the next list element or nil.

func (*Element[K, V]) Prev 

func (e *Element[K, V]) Prev() *Element[K, V]

Prev returns the previous list element or nil.

type ExpireMap 

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

func NewExpireMap 

func NewExpireMap[K comparable, V any](
	fetch func(...K) (map[K]V, error),
	handler func(K, error),
	expire int64, delay ...int64) *ExpireMap[K, V]

func (*ExpireMap[K, V]) All 

func (m *ExpireMap[K, V]) All() map[K]V

func (*ExpireMap[K, V]) Delete 

func (m *ExpireMap[K, V]) Delete(key K)

func (*ExpireMap[K, V]) DeleteAll 

func (m *ExpireMap[K, V]) DeleteAll()

func (*ExpireMap[K, V]) Len 

func (m *ExpireMap[K, V]) Len() int

func (*ExpireMap[K, V]) Load 

func (m *ExpireMap[K, V]) Load(key K, expired bool) (V, bool)

Load 加载缓存, 允许过期值

func (*ExpireMap[K, V]) LoadOrStore 

func (m *ExpireMap[K, V]) LoadOrStore(key K, value V, expire int64) (V, bool)

LoadOrStore 存储或者加载( ok表示加载成功)

func (*ExpireMap[K, V]) Store 

func (m *ExpireMap[K, V]) Store(key K, value V, expire int64)

func (*ExpireMap[K, V]) SyncLoad 

func (m *ExpireMap[K, V]) SyncLoad(key K) (V, bool)

type ExpiredItem 

type ExpiredItem[V any] struct {
	ExpiredAt *int64
	Payload   V
}

type HashMode 

type HashMode string
const (
	MD5    HashMode = "md5"
	SHA1   HashMode = "sha1"
	SHA256 HashMode = "sha256"
	CRC32  HashMode = "crc32"
)

type IntType 

type IntType interface {
	~int | ~int8 | ~int16 | ~int32 | ~int64 | ~uint | ~uint8 | ~uint16 | ~uint32 | ~uint64
}

type KeyLocks 

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

func NewKeyLocks 

func NewKeyLocks() *KeyLocks

func (*KeyLocks) Get 

func (m *KeyLocks) Get(key string) *sync.RWMutex

func (*KeyLocks) Lock 

func (m *KeyLocks) Lock(key string)

func (*KeyLocks) RLock 

func (m *KeyLocks) RLock(key string)

func (*KeyLocks) UnLock 

func (m *KeyLocks) UnLock(key string)

func (*KeyLocks) UnRLock 

func (m *KeyLocks) UnRLock(key string)

type NumberType 

type NumberType interface {
	~int | ~int8 | ~int32 | ~int64 | ~uint | ~uint8 | ~uint16 | ~uint32 | ~uint64 | ~float32 | ~float64
}

type OrderedMap 

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

func NewOrderedMap 

func NewOrderedMap[K comparable, V any]() *OrderedMap[K, V]

func (*OrderedMap[K, V]) Back 

func (m *OrderedMap[K, V]) Back() *Element[K, V]

Back will return the element that is the last (most recent Set element). If there are no elements this will return nil.

func (*OrderedMap[K, V]) Copy 

func (m *OrderedMap[K, V]) Copy() *OrderedMap[K, V]

Copy returns a new OrderedMap with the same elements. Using Copy while there are concurrent writes may mangle the result.

func (*OrderedMap[K, V]) Delete 

func (m *OrderedMap[K, V]) Delete(key K) (didDelete bool)

Delete will remove a key from the map. It will return true if the key was removed (the key did exist).

func (*OrderedMap[K, V]) Front 

func (m *OrderedMap[K, V]) Front() *Element[K, V]

Front will return the element that is the first (oldest Set element). If there are no elements this will return nil.

func (*OrderedMap[K, V]) Get 

func (m *OrderedMap[K, V]) Get(key K) (value V, ok bool)

Get returns the value for a key. If the key does not exist, the second return parameter will be false and the value will be nil.

func (*OrderedMap[K, V]) GetElement 

func (m *OrderedMap[K, V]) GetElement(key K) *Element[K, V]

GetElement returns the element for a key. If the key does not exist, the pointer will be nil.

func (*OrderedMap[K, V]) GetOrDefault 

func (m *OrderedMap[K, V]) GetOrDefault(key K, defaultValue V) V

GetOrDefault returns the value for a key. If the key does not exist, returns the default value instead.

func (*OrderedMap[K, V]) Keys 

func (m *OrderedMap[K, V]) Keys() (keys []K)

Keys returns all of the keys in the order they were inserted. If a key was replaced it will retain the same position. To ensure most recently set keys are always at the end you must always Delete before Set.

func (*OrderedMap[K, V]) Len 

func (m *OrderedMap[K, V]) Len() int

Len returns the number of elements in the map.

func (*OrderedMap[K, V]) ReplaceKey 

func (m *OrderedMap[K, V]) ReplaceKey(originalKey, newKey K) bool

ReplaceKey replaces an existing key with a new key while preserving order of the value. This function will return true if the operation was successful, or false if 'originalKey' is not found OR 'newKey' already exists (which would be an overwrite).

func (*OrderedMap[K, V]) Set 

func (m *OrderedMap[K, V]) Set(key K, value V) bool

Set will set (or replace) a value for a key. If the key was new, then true will be returned. The returned value will be false if the value was replaced (even if the value was the same).

type Sequence 

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

func NewSequence 

func NewSequence(chars string, length uint8, bulk ...uint16) (*Sequence, error)

NewSequence 创建数字转字符串的序列化对象 @param chars 可用的字符串 @param length 输出最大长度 @param bulk 并发队列书香,默认4

func (*Sequence) Decode 

func (s *Sequence) Decode(id string) []uint64

func (*Sequence) Next 

func (s *Sequence) Next(a uint64, b uint64) (string, error)

type SizeBuff 

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

SizeBuff 有最大值限制的buff

func NewSizeBuff 

func NewSizeBuff(size int) *SizeBuff

func (*SizeBuff) Bytes 

func (s *SizeBuff) Bytes() []byte

func (*SizeBuff) Reader 

func (s *SizeBuff) Reader() *bytes.Reader

func (*SizeBuff) Write 

func (s *SizeBuff) Write(p []byte) (int, error)

type SortAbleSlice 

type SortAbleSlice[T SortAbleType] []T

SortAbleSlice 可排序列表,从小到大

func (SortAbleSlice[T]) Len 

func (x SortAbleSlice[T]) Len() int

func (SortAbleSlice[T]) Less 

func (x SortAbleSlice[T]) Less(i, j int) bool

func (SortAbleSlice[T]) Swap 

func (x SortAbleSlice[T]) Swap(i, j int)

type SortAbleType 

type SortAbleType interface {
	~int | ~int8 | ~int32 | ~int64 | ~uint | ~uint8 | ~uint16 | ~uint32 | ~uint64 | ~float32 | ~float64 | ~string
}

type SyncMap 

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

func NewSyncMap 

func NewSyncMap[K comparable, V any]() *SyncMap[K, V]

func (*SyncMap[K, V]) All 

func (m *SyncMap[K, V]) All() map[K]V

func (*SyncMap[K, V]) Delete 

func (m *SyncMap[K, V]) Delete(key K)

func (*SyncMap[K, V]) DeleteAll 

func (m *SyncMap[K, V]) DeleteAll()

func (*SyncMap[K, V]) Len 

func (m *SyncMap[K, V]) Len() int

func (*SyncMap[K, V]) Load 

func (m *SyncMap[K, V]) Load(key K) (value V, ok bool)

func (*SyncMap[K, V]) LoadAndDelete 

func (m *SyncMap[K, V]) LoadAndDelete(key K) (value V, loaded bool)

func (*SyncMap[K, V]) LoadOrStore 

func (m *SyncMap[K, V]) LoadOrStore(key K, value V) (actual V, loaded bool)

func (*SyncMap[K, V]) Range 

func (m *SyncMap[K, V]) Range(f func(key K, value V) bool)

func (*SyncMap[K, V]) Store 

func (m *SyncMap[K, V]) Store(key K, value V)

func (*SyncMap[K, V]) Swap 

func (m *SyncMap[K, V]) Swap(key K, value V) (previous V, loaded bool)

type UnsignedIntType 

type UnsignedIntType interface {
	~uint | ~uint8 | ~uint16 | ~uint32 | ~uint64
}

type Versioned 

type Versioned interface {
	Version() int64
}

type VersionedMap 

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

func NewVersionedMap 

func NewVersionedMap[K comparable, V Versioned]() *VersionedMap[K, V]

func (*VersionedMap[K, V]) Clear 

func (m *VersionedMap[K, V]) Clear()

func (*VersionedMap[K, V]) Clone 

func (m *VersionedMap[K, V]) Clone() map[K]V

func (*VersionedMap[K, V]) Keys 

func (m *VersionedMap[K, V]) Keys() []K

func (*VersionedMap[K, V]) Len 

func (m *VersionedMap[K, V]) Len() int

func (*VersionedMap[K, V]) Load 

func (m *VersionedMap[K, V]) Load(key K) (V, bool)

func (*VersionedMap[K, V]) LoadAndDelete 

func (m *VersionedMap[K, V]) LoadAndDelete(key K) (V, bool)

func (*VersionedMap[K, V]) LoadOrStore 

func (m *VersionedMap[K, V]) LoadOrStore(key K, value V) (ret V, find bool)

LoadOrStore 存储一个值、find表示值存在,没有进行存储

func (*VersionedMap[K, V]) Store 

func (m *VersionedMap[K, V]) Store(key K, value V)

func (*VersionedMap[K, V]) StoreNew 

func (m *VersionedMap[K, V]) StoreNew(key K, value V) bool

StoreNew 存储一个新值、返回值表示是否存储成功

func (*VersionedMap[K, V]) Values 

func (m *VersionedMap[K, V]) Values() []V

Source Files

View all Source files

Directories

Path Synopsis
Package flock implements a thread-safe interface for file locking.
 Package flock implements a thread-safe interface for file locking.

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.