util

Dec 11, 2025

Changes in this version

type Broadcaster

+ func (b *Broadcaster[T]) BroadcastSync(msg T, timeout ...time.Duration) int

Dec 10, 2025

Changes in this version

+ func SafeRun(fn func(), catchHandler func(err any))

type Broadcaster

+ func (b *Broadcaster[T]) BroadcastWaitAll(msg T) int

Nov 25, 2025

Changes in this version

+ func EffectsPrint(str string, n int, opts ...EffectsPrintOptions)

+ func ReadLastNLines(data io.ReadSeeker, n int, whence int, setChunkSize ...int64) ([]string, error)

+ type EffectsPrintOptions struct

+ EffectsPrintTime time.Duration

+ Out io.Writer

Nov 21, 2025

Changes in this version

+ func AsError[T any](err error) bool

+ func IsError[T any](err error) bool

+ func MarkAsError[T any](err error) error

+ func UnwrapError[T any](err error) error

+ type Error struct

+ func (e *Error[T]) Error() string

+ func (e *Error[T]) Unwrap() error

Oct 9, 2025

Changes in this version

+ func NewWorkerPool[T any](f job[T], poolSize ...int) *workerPool[T]

type Snowflake

+ func NewSnowflake(baseTime time.Time, logicalId int) (*Snowflake, error)

+ func (s *Snowflake) ParseInfo(id int64) (milliseconds time.Duration, logicalId int64, counter int64)

May 23, 2025

Changes in this version

+ type Broadcaster struct

+ func NewBroadcaster[T any](chanBufSize ...int) *Broadcaster[T]

+ func (b *Broadcaster[T]) Broadcast(msg T)

+ func (b *Broadcaster[T]) BroadcastAsync(msg T)

+ func (b *Broadcaster[T]) Close()

+ func (b *Broadcaster[T]) Len() int

+ func (b *Broadcaster[T]) Subscribe() <-chan T

+ func (b *Broadcaster[T]) SubscribeHandle(f func(T) (exit bool))

+ func (b *Broadcaster[T]) Unsubscribe(ch <-chan T)

+ func (b *Broadcaster[T]) UnsubscribesAll()

Jan 27, 2025

Changes in this version

+ const MaxPort

Jul 23, 2024

Changes in this version

+ func BigIntToIP(i *big.Int) net.IP

+ func CalculateCIDR(startIP, endIP string) (string, error)

+ func CopyToClipboardUseOsc52(str string) error — linux/amd64

+ func Duration2String(t time.Duration, secondPrecision ...string) string

+ func FindMissingNumbers(numbers []int) []int

+ func GroupNumbers(numbers []int, groupSize int) [][]int

+ func IpToBigInt(ip net.IP) *big.Int

+ func UniqueArray[T any, N any](data []N, f func(N) T) []T

+ type MapItem struct

+ type Maps map[uint8]*MapItem

+ func NewMap() Maps

+ func (m Maps) Delete(key string, f ...func())

+ func (m Maps) Get(key string, f ...func(any, bool)) (any, bool)

+ func (m Maps) Set(key string, value any, f ...func())

+ type Num interface

+ type Snowflake struct

+ AutoIncrementBit int64

+ BaseTime time.Time

+ BaseTimeBit int64

+ LogicalId int64

+ LogicalIdBit int64

+ func (s *Snowflake) GenerateId() (int64, error)

Nov 16, 2023

Changes in this version

+ func Getenv(key string, defaultValue string) string

+ func Try(fn func()) (t *try)

May 16, 2023

Changes in this version

+ func Sha256(data []byte) []byte

Mar 14, 2023

Changes in this version

+ func DeepCopy(value interface{}) interface

+ func DeleteSelf()

+ func GetGitBranchHash(url, branch string) (string, error)

+ func IsProcessExist(pid string) bool

+ func RandomPort(start, end int, seed int64) int

+ func TimeToPrt(t time.Time) *time.Time

+ type FileInfo struct

+ Content string

+ DownloadUrl string

+ Encoding string

+ GitUrl string

+ HtmlUrl string

+ Links struct{ ... }

+ Name string

+ Path string

+ Sha string

+ Size int

+ Type string

+ Url string

+ func GetGitHubFileInfo(owner, repo, filePath string) (*FileInfo, error)