lib

Dec 15, 2025

Changes in this version

+ func CastErrorData(errData []byte, abis []*abi.ABI) (abi.Error, interface{}, bool)

+ func ExtractGETHErrorData(err error) ([]byte, bool)

+ func MustParseURL(urlStr string) *url.URL

+ func TryConvertGethError(err error, contractMeta []Meta) error

+ type EVMError struct

+ Abi abi.Error

+ Args interface{}

+ Cause error

+ func ConvertGethError(gethErr error, contractMeta []Meta) (*EVMError, bool)

+ func (e EVMError) As(target interface{}) bool

+ func (e EVMError) Error() string

+ type InputEntry struct

+ Key string

+ Type string

+ Value interface{}

+ func DecodeInput(rawInput []byte, meta []Meta) (methodName string, entries []InputEntry, err error)

+ type Meta interface

+ GetAbi func() (*abi.ABI, error)

Feb 21, 2025

Changes in this version

+ const CharNewLine

+ var ErrInvalidPrivateKey = fmt.Errorf("invalid private key")

+ var ErrTimeout = context.DeadlineExceeded

+ func Abs[T Number](a T) T

+ func AddrShort(addr string) string

+ func AlmostEqual[T Number](a, b T, tolerance float64) bool

+ func CopySlice[T any](s []T) []T

+ func CopyURL(u *url.URL) *url.URL

+ func DecryptString(str string, privateKey string) (string, error)

+ func EncryptString(str string, publicKeyHex string) (string, error)

+ func FilterValue[T comparable](arr []T, val T) (ret []T)

+ func Filter[T any](arr []T, f func(T) bool) (ret []T)

+ func GetRandomAddr() common.Address

+ func JoinUsername(accountName, userName string) string

+ func Merge[T any](cs ...<-chan T) <-chan T

+ func MustPrivKeyStringToAddr(privateKey string) common.Address

+ func MustPrivKeyToAddr(privateKey *ecdsa.PrivateKey) common.Address

+ func MustUnmarshallString(value json.RawMessage) string

+ func NewRat(numerator, denominator *big.Int) *big.Rat

+ func NormalizeJson(msg []byte) ([]byte, error)

+ func ParsePort(addr string) (port string)

+ func PrKeyToCompressedPubKey(prkey *ecdsa.PrivateKey) (yParity bool, x common.Hash, err error)

+ func PrivKeyStringToAddr(privateKey string) (common.Address, error)

+ func PrivKeyToAddr(privateKey *ecdsa.PrivateKey) (common.Address, error)

+ func RelativeError[T Number](target, actual T) float64

+ func SanitizeFilename(fileName string) string

+ func SetUserName(u *url.URL, userName string)

+ func SetWorkerName(u *url.URL, workerName string)

+ func SplitUsername(username string) (accountName string, workerName string, ok bool)

+ func StrShort(str string) string

+ func StrShortConf(str string, prefix, suffix int) string

+ func TCPPipe() (clientConn net.Conn, serverConn net.Conn, err error)

+ func WrapError(parent error, child error) error

+ type AtomicValue struct

+ func NewAtomicValue[T any](v T) *AtomicValue[T]

+ func (a *AtomicValue[T]) CompareAndSwap(old, new T) bool

+ func (a *AtomicValue[T]) Load() T

+ func (a *AtomicValue[T]) Store(v T)

+ func (a *AtomicValue[T]) Swap(v T) T

+ type BoundStackMap struct

+ func NewBoundStackMap[T any](size int) *BoundStackMap[T]

+ func (bs *BoundStackMap[T]) At(index int) (T, bool)

+ func (bs *BoundStackMap[T]) Capacity() int

+ func (bs *BoundStackMap[T]) Clear()

+ func (bs *BoundStackMap[T]) Count() int

+ func (bs *BoundStackMap[T]) Filter(f func(key string, value T) bool)

+ func (bs *BoundStackMap[T]) Get(key string) (T, bool)

+ func (bs *BoundStackMap[T]) Push(key string, item T)

+ func (bs *BoundStackMap[T]) Range(f func(key string, value T) bool)

+ func (bs *BoundStackMap[T]) String() string

+ type ChanRecvStop struct

+ DataCh chan T

+ StopCh chan struct{}

+ func NewChanRecvStop[T any]() *ChanRecvStop[T]

+ func (c *ChanRecvStop[T]) Receive() <-chan T

+ func (c *ChanRecvStop[T]) Send(data T)

+ func (c *ChanRecvStop[T]) Stop()

+ type Collection struct

+ func NewCollection[T IModel]() *Collection[T]

+ func (p *Collection[T]) Delete(ID string)

+ func (p *Collection[T]) Len() int

+ func (p *Collection[T]) Load(ID string) (item T, ok bool)

+ func (p *Collection[T]) LoadOrStore(item T) (actual T, loaded bool)

+ func (p *Collection[T]) Range(f func(item T) bool)

+ func (p *Collection[T]) Store(item T)

+ type IModel interface

+ ID func() string

+ type Logger struct

+ func NewLogger(level string, color, isProd bool, isJSON bool, filepath string) (*Logger, error)

+ func NewLoggerMemory(level string, color, isProd bool, isJSON bool, filepath string, wr io.Writer) (*Logger, error)

+ func NewTestLogger() *Logger

+ func (l *Logger) Close() error

+ func (l *Logger) Log(lvl zapcore.Level, msg string, fields ...zapcore.Field)

+ func (l *Logger) Named(name string) interfaces.ILogger

+ func (l *Logger) With(args ...interface{}) interfaces.ILogger

+ type LoggerMock struct

+ func (l *LoggerMock) Close() error

+ func (l *LoggerMock) DPanic(args ...interface{})

+ func (l *LoggerMock) DPanicf(template string, args ...interface{})

+ func (l *LoggerMock) DPanicw(template string, args ...interface{})

+ func (l *LoggerMock) Debug(args ...interface{})

+ func (l *LoggerMock) Debugf(template string, args ...interface{})

+ func (l *LoggerMock) Debugw(template string, args ...interface{})

+ func (l *LoggerMock) Error(args ...interface{})

+ func (l *LoggerMock) Errorf(template string, args ...interface{})

+ func (l *LoggerMock) Errorw(template string, args ...interface{})

+ func (l *LoggerMock) Fatal(args ...interface{})

+ func (l *LoggerMock) Fatalf(template string, args ...interface{})

+ func (l *LoggerMock) Fatalw(template string, args ...interface{})

+ func (l *LoggerMock) Info(args ...interface{})

+ func (l *LoggerMock) Infof(template string, args ...interface{})

+ func (l *LoggerMock) Infow(template string, args ...interface{})

+ func (l *LoggerMock) Log(lvl zapcore.Level, msg string, fields ...zapcore.Field)

+ func (l *LoggerMock) Named(n string) i.ILogger

+ func (l *LoggerMock) Panic(args ...interface{})

+ func (l *LoggerMock) Panicf(template string, args ...interface{})

+ func (l *LoggerMock) Panicw(template string, args ...interface{})

+ func (l *LoggerMock) Sync() error

+ func (l *LoggerMock) Warn(args ...interface{})

+ func (l *LoggerMock) Warnf(template string, args ...interface{})

+ func (l *LoggerMock) Warnw(template string, args ...interface{})

+ func (l *LoggerMock) With(args ...interface{}) i.ILogger

+ type Mutex struct

+ func NewMutex() Mutex

+ func (m *Mutex) Lock()

+ func (m *Mutex) LockCtx(ctx context.Context) error

+ func (m *Mutex) LockTimeout(d time.Duration) error

+ func (m *Mutex) Unlock()

+ type Number interface

+ type PubKey struct

+ X common.Hash

+ YParity bool

+ func (p *PubKey) Compressed() []byte

+ func (p *PubKey) String() string

+ type Runnable interface

+ Run func(ctx context.Context) error

+ type Set struct

+ func NewSet() Set

+ func NewSetFromSlice(slice []string) Set

+ func (s Set) Add(value ...string)

+ func (s Set) Clear()

+ func (s Set) Contains(value string) bool

+ func (s Set) Len() int

+ func (s Set) Remove(value string) bool

+ func (s Set) ToSlice() []string

+ type Stack []T

+ func NewStack[T any]() *Stack[T]

+ func (s *Stack[T]) Clear()

+ func (s *Stack[T]) Copy() *Stack[T]

+ func (s *Stack[T]) IsEmpty() bool

+ func (s *Stack[T]) Peek() (T, bool)

+ func (s *Stack[T]) Pop() (T, bool)

+ func (s *Stack[T]) Push(str T)

+ func (s *Stack[T]) Range(f func(T) bool)

+ func (s *Stack[T]) Remove(f func(T) bool)

+ func (s *Stack[T]) Size() int

+ type Subscription struct

+ func NewSubscription(producer func(quit <-chan struct{}) error, ch chan interface{}) *Subscription

+ func (s *Subscription) Ch() chan interface{}

+ func (s *Subscription) Err() <-chan error

+ func (s *Subscription) Events() <-chan interface{}

+ func (s *Subscription) Unsubscribe()

+ type Task struct

+ func NewTask(runnable Runnable) *Task

+ func NewTaskFunc(f func(ctx context.Context) error) *Task

+ func (s *Task) Done() <-chan struct{}

+ func (s *Task) Err() error

+ func (s *Task) Start(ctx context.Context)

+ func (s *Task) Stop() <-chan struct{}