utils

Documentation

Index

• Constants
• Variables
• func Assert(ps ...func() error) (err error)
• func BytesToInt(b []byte, n interface{}) error
• func Ceil[T constraints.Integer](a, b T) (r T)
• func CloneMap[T1 comparable, T2 comparable](src map[T1]T2) map[T1]T2
• func Empty(data interface{}) bool
• func EmptyReflect(object interface{}) bool
• func FloatPrecision(value float64, precision float64) float64
• func GZipCompress(data []byte) []byte
• func GZipUnCompress(data []byte) ([]byte, error)
• func GetIPv4ByInterface(name string) ([]string, error)
• func IPv4Decode(code uint64) string
• func IPv4Encode(address string) uint64
• func IncludeNotPrintableChar(s string) bool
• func IntToBuffer(buffer *bytes.Buffer, n interface{}) error
• func IntToBytes(n interface{}) ([]byte, error)
• func IsOsBindError(err error) bool
• func LocalIPv4() (ip string, err error)
• func LocalIPv4s() ([]string, error)
• func LocalValid(ip string) bool
• func MD5(data string) string
• func MapKeys[T1 comparable, T2 comparable](src map[T1]T2) []T1
• func Max[T constraints.Integer](nums ...T) (r T)
• func Min[T constraints.Integer](nums ...T) (r T)
• func NewUrl(address, scheme string) (*url.URL, error)
• func PKCS7Padding(data []byte, blockSize int) []byte
• func PKCS7UnPadding(data []byte) []byte
• func SHA256(message string) string
• func Sprintf(format interface{}, args ...interface{}) (r string)
• func Timeout(d time.Duration, fn func() error) error
• func Try(f func(), handle ...TryHandle)
• func UTF8StringLen(str string) int
• func ZlibCompress(data []byte) []byte
• func ZlibUnCompress(data []byte) ([]byte, error)
• type Address
  • func NewAddress(address ...string) (r *Address)
  • func (this *Address) Encode() uint64
  • func (this *Address) Handle(handle func(network, address string) error) (err error)
  • func (this *Address) HandleWithNetwork(handle func(address string) error) (err error)
  • func (this *Address) Local(withPort ...bool) string
  • func (this *Address) Parse(address string)
  • func (this *Address) String(withScheme ...bool) string
  • func (this *Address) Valid() bool
• type CryptoType
• type Job
• type TaskData
• type TimeWheel
  • func New(interval time.Duration, slotNum int) *TimeWheel
  • func (tw *TimeWheel) AddTask(interval time.Duration, times int, key interface{}, data TaskData, job Job) error
  • func (tw *TimeWheel) RemoveTask(key interface{}) error
  • func (tw *TimeWheel) Start()
  • func (tw *TimeWheel) Stop()
  • func (tw *TimeWheel) UpdateTask(key interface{}, interval time.Duration, taskData TaskData) error
• type TryHandle

Constants

const (
	IntZero     = int(0)
	Int8Zero    = int8(0)
	Int16Zero   = int16(0)
	Int32Zero   = int32(0)
	Int64Zero   = int64(0)
	UintZero    = uint(0)
	Uint8Zero   = uint8(0)
	Uint16Zero  = uint16(0)
	Uint32Zero  = uint32(0)
	Uint64Zero  = uint64(0)
	Float32Zero = float32(0)
	Float64Zero = float64(0)
	StringZero  = ""
)

Variables

var Crypto = crypto{}

Functions

func Assert

func Assert(ps ...func() error) (err error)

func BytesToInt

func BytesToInt(b []byte, n interface{}) error

BytesToInt 字节转换成整形,n 必须是指针 var a int32 BytesToInt([]byte{1},&a)

func Ceil

func Ceil[T constraints.Integer](a, b T) (r T)

Ceil 除法向上取整

func CloneMap

func CloneMap[T1 comparable, T2 comparable](src map[T1]T2) map[T1]T2

func Empty

func Empty(data interface{}) bool

func EmptyReflect

func EmptyReflect(object interface{}) bool

EmptyReflect 通过反射判断复杂类型是否为空,一般确定参数不为基础类型时才直接使用，否则应该使用 IsEmpty

func FloatPrecision

func FloatPrecision(value float64, precision float64) float64

FloatPrecision 四舍五入，保留到Precision位小数

func GZipCompress

func GZipCompress(data []byte) []byte

func GZipUnCompress

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

func GetIPv4ByInterface

func GetIPv4ByInterface(name string) ([]string, error)

GetIPv4ByInterface return IPv4 address from a specific interface IPv4 addresses

func IPv4Decode

func IPv4Decode(code uint64) string

func IPv4Encode

func IPv4Encode(address string) uint64

IPv4Encode Ip2Int Ipv4 转uint64

func IncludeNotPrintableChar

func IncludeNotPrintableChar(s string) bool

func IntToBuffer

func IntToBuffer(buffer *bytes.Buffer, n interface{}) error

IntToBuffer 将数字写入BUFFER, buffer := bytes.NewBuffer([]byte{})

func IntToBytes

func IntToBytes(n interface{}) ([]byte, error)

IntToBytes 整形转换成字节

func IsOsBindError

func IsOsBindError(err error) bool

IsOsBindError 是否端口绑定错误

func LocalIPv4

func LocalIPv4() (ip string, err error)

func LocalIPv4s

func LocalIPv4s() ([]string, error)

LocalIPv4s return all non-loopback IPv4 addresses

func LocalValid

func LocalValid(ip string) bool

LocalValid 是否本机IP

func MD5

func MD5(data string) string

func MapKeys

func MapKeys[T1 comparable, T2 comparable](src map[T1]T2) []T1

func Max

func Max[T constraints.Integer](nums ...T) (r T)

func Min

func Min[T constraints.Integer](nums ...T) (r T)

func NewUrl

func NewUrl(address, scheme string) (*url.URL, error)

func PKCS7Padding

func PKCS7Padding(data []byte, blockSize int) []byte

PKCS7Padding 填充字节的函数

func PKCS7UnPadding

func PKCS7UnPadding(data []byte) []byte

PKCS7UnPadding 去除填充字节的函数

func SHA256

func SHA256(message string) string

func Sprintf

func Sprintf(format interface{}, args ...interface{}) (r string)

func Timeout

func Timeout(d time.Duration, fn func() error) error

func Try

func Try(f func(), handle ...TryHandle)

func UTF8StringLen

func UTF8StringLen(str string) int

func ZlibCompress

func ZlibCompress(data []byte) []byte

func ZlibUnCompress

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

Types

type Address

type Address struct {
	Port   int    `json:"port"`
	Host   string `json:"host"`
	Retry  int    `json:"retry"`
	Scheme string `json:"scheme"`
}

func NewAddress

func NewAddress(address ...string) (r *Address)

NewAddress 解析url,scheme:默认协议

func (*Address) Encode

func (this *Address) Encode() uint64

func (*Address) Handle

func (this *Address) Handle(handle func(network, address string) error) (err error)

func (*Address) HandleWithNetwork

func (this *Address) HandleWithNetwork(handle func(address string) error) (err error)

HandleWithNetwork network 写入地址中,tcp://0.0.0.0:80

func (*Address) Local

func (this *Address) Local(withPort ...bool) string

func (*Address) Parse

func (this *Address) Parse(address string)

func (*Address) String

func (this *Address) String(withScheme ...bool) string

String 转换成string

func (*Address) Valid

func (this *Address) Valid() bool

Valid 是否有效的IP（非本机IP）

type CryptoType

type CryptoType int

const (
	CryptoTypeDES CryptoType = iota //秘钥长度8字节 也就是64位
	CryptoTypeAES                   //秘钥长度位16 24 32 字节 也就是128 192 256位。
	CryptoType3DES
)

type Job

type Job func(TaskData)

Job callback function

type TaskData

type TaskData map[interface{}]interface{}

TaskData callback params

type TimeWheel

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

time wheel struct

func New

func New(interval time.Duration, slotNum int) *TimeWheel

New create a empty time wheel

func (*TimeWheel) AddTask

func (tw *TimeWheel) AddTask(interval time.Duration, times int, key interface{}, data TaskData, job Job) error

AddTask add new task to the time wheel

func (*TimeWheel) RemoveTask

func (tw *TimeWheel) RemoveTask(key interface{}) error

RemoveTask remove the task from time wheel

func (*TimeWheel) Start

func (tw *TimeWheel) Start()

Start start the time wheel

func (*TimeWheel) Stop

func (tw *TimeWheel) Stop()

Stop stop the time wheel

func (*TimeWheel) UpdateTask

func (tw *TimeWheel) UpdateTask(key interface{}, interval time.Duration, taskData TaskData) error

UpdateTask update task times and data

type TryHandle

type TryHandle func(any)