Documentation
¶
Index ¶
- Constants
- Variables
- func CheckBySalt(check, hash, salt string) bool
- func CostTimeDur(fn func()) time.Duration
- func DeepCopyByGob(src, dst any) error
- func DeepCopyByJson(src, dst any) error
- func DelRightRN(item string, r string, n int) string
- func DiffField[T comparable](o, n T) (t T)
- func GetLocalIpv4ByUdp() (ip string, err error)
- func GetLocalIpv4List() ([]string, error)
- func GetMacAddr() (map[string]string, error)
- func GetPubIpVipip(typ IpTyp) (ip string, err error)
- func GetPubIpVipsb(typ IpTyp) (ip string, err error)
- func HasNum(s string) bool
- func HmacHashWithSalt(ps, salt string) string
- func IfEx[T any](boolExpr bool, trueReturn, falseReturn T) T
- func Ip2Long(str string) uint32
- func ItemIsInSlice[T comparable](item T, slice []T) bool
- func JsonMarshal(v any) ([]byte, error)
- func JsonMarshalToString(v any) (string, error)
- func JsonMarshalToStringV2(v any) (string, error)
- func JsonMarshalV2(v any) ([]byte, error)
- func JsonUnmarshal(data []byte, v any) error
- func JsonUnmarshalFromString(str string, v any) error
- func JsonUnmarshalFromStringV2(str string, v any) error
- func JsonUnmarshalV2(data []byte, v any) error
- func MapClear[M ~map[K]V, K comparable, V any](m M)
- func MapClone[M ~map[K]V, K comparable, V any](m M) M
- func MapCopy[M1 ~map[K]V, M2 ~map[K]V, K comparable, V any](dst M1, src M2)
- func MapDeleteFunc[M ~map[K]V, K comparable, V any](m M, del func(K, V) bool)
- func MapEqual[M1, M2 ~map[K]V, K, V comparable](m1 M1, m2 M2) bool
- func MapEqualFunc[M1 ~map[K]V1, M2 ~map[K]V2, K comparable, V1, V2 any](m1 M1, m2 M2, eq func(V1, V2) bool) bool
- func MapKeys[M ~map[K]V, K comparable, V any](m M) []K
- func MapToObj(m map[string]any, obj any) error
- func MapValues[M ~map[K]V, K comparable, V any](m M) []V
- func NewGoogleUUID() string
- func ObjToMap(obj any, m *map[string]any) error
- func PanicIfErr(err error)
- func PanicToErr(fn func()) (err error)
- func Ptr2Value[T any](ptr *T) T
- func RandBytesMask(n int) []byte
- func RandCodeMask(n int) string
- func RandIdMask(n int) string
- func RandSelfDefMask(n int, bs string) string
- func RandStringMask(n int) string
- func RemoteIp(req *http.Request) string
- func RemoveInvalidParentheses(s string, pair [2]rune) string
- func SliceEqual[T comparable](s1, s2 []T) bool
- func SliceGroupsOf[T any](arr []T, num int64) [][]T
- func SliceIsInSlice[T comparable](item []T, slice []T) bool
- func SliceSub[T comparable](s1 []T, s2 []T) []T
- func SliceUnique[T comparable](arr []T) []T
- func TlsCertGenerateToFile(path string) error
- func TlsCertGenerateToMap() (cert map[string]string, err error)
- func Value2Ptr[T any](v T) *T
- type IpTyp
- type Quit
- type Rate
- type WorkerPool
- func (p *WorkerPool) Pause(ctx context.Context)
- func (p *WorkerPool) Size() int
- func (p *WorkerPool) Stop()
- func (p *WorkerPool) StopWait()
- func (p *WorkerPool) Stopped() bool
- func (p *WorkerPool) Submit(task func())
- func (p *WorkerPool) SubmitBlockBySize(task func())
- func (p *WorkerPool) SubmitWait(task func())
- func (p *WorkerPool) WaitingQueueSize() int
Constants ¶
const ( IPSB4URL = `http://api-ipv4.ip.sb/ip` IPSB6URL = `http://api-ipv6.ip.sb/ip` )
const ( XForwardedFor = "X-Forwarded-For" XRealIP = "X-Real-IP" )
const (
IPIP4URL = `http://myip.ipip.net/s`
)
Variables ¶
var ( CertName = "cert.pem" KeyName = "key.pem" )
Functions ¶
func CheckBySalt ¶
CheckBySalt check HmacHashWithSalt
func DelRightRN ¶ added in v1.1.3
DelRightRN 移除字符串 item 中最后 n 个特定字符 r，并返回修改后的字符串。 如果 item 中 r 出现的次数小于 n，则不进行修改。 参数:
item: 要处理的字符串 r: 要移除的特定字符 n: 要移除的 r 的数量
返回值:
修改后的字符串
func GetLocalIpv4ByUdp ¶
GetLocalIpv4ByUdp 获取 localIp by net.Dial("udp", "8.8.8.8:53")
func GetMacAddr ¶ added in v1.1.0
GetMacAddr 获取本机的MAC地址
func GetPubIpVipip ¶ added in v1.1.0
GetPubIpVipip 通过ip.sb获取公网ip 仅支持ipv4
func GetPubIpVipsb ¶ added in v1.1.0
GetPubIpVipsb 通过ip.sb获取公网ip
func HmacHashWithSalt ¶ added in v1.1.0
HmacHashWithSalt hmac sha2 and salt make hash
func ItemIsInSlice ¶
func ItemIsInSlice[T comparable](item T, slice []T) bool
func JsonMarshal ¶
func JsonMarshalToString ¶
func JsonMarshalToStringV2 ¶
func JsonMarshalV2 ¶
func JsonUnmarshal ¶
func JsonUnmarshalFromString ¶
func JsonUnmarshalV2 ¶
func MapClear ¶
func MapClear[M ~map[K]V, K comparable, V any](m M)
MapClear removes all entries from m, leaving it empty.
func MapClone ¶
func MapClone[M ~map[K]V, K comparable, V any](m M) M
MapClone returns a copy of m. This is a shallow clone: the new keys and values are set using ordinary assignment.
func MapCopy ¶
func MapCopy[M1 ~map[K]V, M2 ~map[K]V, K comparable, V any](dst M1, src M2)
MapCopy copies all key/value pairs in src adding them to dst. When a key in src is already present in dst, the value in dst will be overwritten by the value associated with the key in src.
func MapDeleteFunc ¶
func MapDeleteFunc[M ~map[K]V, K comparable, V any](m M, del func(K, V) bool)
MapDeleteFunc deletes any key/value pairs from m for which del returns true.
func MapEqual ¶
func MapEqual[M1, M2 ~map[K]V, K, V comparable](m1 M1, m2 M2) bool
MapEqual reports whether two maps contain the same key/value pairs. MapValues are compared using ==.
func MapEqualFunc ¶
func MapEqualFunc[M1 ~map[K]V1, M2 ~map[K]V2, K comparable, V1, V2 any](m1 M1, m2 M2, eq func(V1, V2) bool) bool
MapEqualFunc is like MapEqual, but compares values using eq. MapKeys are still compared with ==.
func MapKeys ¶
func MapKeys[M ~map[K]V, K comparable, V any](m M) []K
MapKeys returns the keys of the map m. The keys will be in an indeterminate order.
func MapValues ¶
func MapValues[M ~map[K]V, K comparable, V any](m M) []V
MapValues returns the values of the map m. The values will be in an indeterminate order.
func PanicIfErr ¶
func PanicIfErr(err error)
func PanicToErr ¶
func PanicToErr(fn func()) (err error)
func Ptr2Value ¶
func Ptr2Value[T any](ptr *T) T
Ptr2Value return ptr's value; if ptr==nil,return zero Ts
func RandBytesMask ¶
func RandCodeMask ¶
func RandIdMask ¶
func RandSelfDefMask ¶
func RandStringMask ¶
func RemoveInvalidParentheses ¶
RemoveInvalidParentheses 去除s中不成对的括号，pair为成对的括号
func SliceEqual ¶
func SliceEqual[T comparable](s1, s2 []T) bool
func SliceGroupsOf ¶
func SliceIsInSlice ¶
func SliceIsInSlice[T comparable](item []T, slice []T) bool
func SliceSub ¶
func SliceSub[T comparable](s1 []T, s2 []T) []T
func SliceUnique ¶
func SliceUnique[T comparable](arr []T) []T
func TlsCertGenerateToFile ¶
TlsCertGenerateToFile 生成自签tls证书 cert.pem key.pem 到指定文件夹中
func TlsCertGenerateToMap ¶
TlsCertGenerateToMap 生成自签tls证书 cert.pem key.pem 到map
Types ¶
type Quit ¶
type Quit struct {
// contains filtered or unexported fields
}
func (*Quit) WaitCloseWithFn ¶
func (q *Quit) WaitCloseWithFn(fn func())
type WorkerPool ¶
type WorkerPool struct {
// contains filtered or unexported fields
}
WorkerPool is a collection of goroutines, where the number of concurrent goroutines processing requests does not exceed the specified maximum.
func NewWorkerPool ¶
func NewWorkerPool(maxWorkers int) *WorkerPool
NewWorkerPool creates and starts a pool of worker goroutines.
The maxWorkers parameter specifies the maximum number of workers that can execute tasks concurrently. When there are no incoming tasks, workers are gradually stopped until there are no remaining workers.
func (*WorkerPool) Pause ¶
func (p *WorkerPool) Pause(ctx context.Context)
Pause causes all workers to wait on the given Context, thereby making them unavailable to run tasks. Pause returns when all workers are waiting. Tasks can continue to be queued to the workerpool, but are not executed until the Context is canceled or times out.
Calling Pause when the worker pool is already paused causes Pause to wait until all previous pauses are canceled. This allows a goroutine to take control of pausing and unpausing the pool as soon as other goroutines have unpaused it.
When the workerpool is stopped, workers are unpaused and queued tasks are executed during StopWait.
func (*WorkerPool) Size ¶
func (p *WorkerPool) Size() int
Size returns the maximum number of concurrent workers.
func (*WorkerPool) Stop ¶
func (p *WorkerPool) Stop()
Stop stops the worker pool and waits for only currently running tasks to complete. Pending tasks that are not currently running are abandoned. Tasks must not be submitted to the worker pool after calling stop.
Since creating the worker pool starts at least one goroutine, for the dispatcher, Stop() or StopWait() should be called when the worker pool is no longer needed.
func (*WorkerPool) StopWait ¶
func (p *WorkerPool) StopWait()
StopWait stops the worker pool and waits for all queued tasks tasks to complete. No additional tasks may be submitted, but all pending tasks are executed by workers before this function returns.
func (*WorkerPool) Stopped ¶
func (p *WorkerPool) Stopped() bool
Stopped returns true if this worker pool has been stopped.
func (*WorkerPool) Submit ¶
func (p *WorkerPool) Submit(task func())
Submit enqueues a function for a worker to execute.
Any external values needed by the task function must be captured in a closure. Any return values should be returned over a channel that is captured in the task function closure.
Submit will not block regardless of the number of tasks submitted. Each task is immediately given to an available worker or to a newly started worker. If there are no available workers, and the maximum number of workers are already created, then the task is put onto a waiting queue.
When there are tasks on the waiting queue, any additional new tasks are put on the waiting queue. Tasks are removed from the waiting queue as workers become available.
As long as no new tasks arrive, one available worker is shutdown each time period until there are no more idle workers. Since the time to start new goroutines is not significant, there is no need to retain idle workers indefinitely.
func (*WorkerPool) SubmitBlockBySize ¶
func (p *WorkerPool) SubmitBlockBySize(task func())
when queue length equal maximum block
func (*WorkerPool) SubmitWait ¶
func (p *WorkerPool) SubmitWait(task func())
SubmitWait enqueues the given function and waits for it to be executed.
func (*WorkerPool) WaitingQueueSize ¶
func (p *WorkerPool) WaitingQueueSize() int
WaitingQueueSize returns the count of tasks in the waiting queue.
Source Files
Directories