common

Apr 22, 2025

Changes in this version

+ const ANSIBgBlack

+ const ANSIBgBlue

+ const ANSIBgCyan

+ const ANSIBgGreen

+ const ANSIBgMagenta

+ const ANSIBgRed

+ const ANSIBgWhite

+ const ANSIBgYellow

+ const ANSIBlink

+ const ANSIBright

+ const ANSIDim

+ const ANSIFgBlack

+ const ANSIFgBlue

+ const ANSIFgCyan

+ const ANSIFgGreen

+ const ANSIFgMagenta

+ const ANSIFgRed

+ const ANSIFgWhite

+ const ANSIFgYellow

+ const ANSIHidden

+ const ANSIReset

+ const ANSIReverse

+ const ANSIUnderscore

+ var ErrDeserialization = errors.New("bls12381: deserialization error")

+ var ErrInfinitePubKey = errors.New("bls12381: pubkey is infinite")

+ var TimeLayout = "2006-01-02"

+ func ASCIITrim(s string) string

+ func ApplyUpdatesToValidatorSet(vset *cmttypes.ValidatorSet, validatorUpdates []v1.ValidatorUpdate) *cmttypes.ValidatorSet

+ func Black(args ...interface{}) string

+ func BlsPublicKeyFromCmtPubKey(cmtPubKey cmtcrypto.PubKey) (common.PublicKey, error)

+ func Blue(args ...interface{}) string

+ func Byte32ToByteSlice(b [][32]byte) []byte

+ func ByteSliceToByte32(b []byte) [][32]byte

+ func ColoredBytes(data []byte, textColor, bytesColor func(...interface{}) string) string

+ func Connect(protoAddr string) (net.Conn, error)

+ func CopyFile(src, dst string) error

+ func Cyan(args ...interface{}) string

+ func EnsureDir(dir string, mode os.FileMode) error

+ func Exit(s string)

+ func FileExists(filePath string) bool

+ func Fingerprint(slice []byte) []byte

+ func Green(args ...interface{}) string

+ func IntInSlice(a int, list []int) bool

+ func IsASCIIText(s string) bool

+ func IsEmpty(o interface{}) bool

+ func IsTypedNil(o interface{}) bool

+ func Kill() error

+ func Magenta(args ...interface{}) string

+ func MaxInt(a, b int) int

+ func MaxInt64(a, b int64) int64

+ func MinInt(a, b int) int

+ func MinInt64(a, b int64) int64

+ func MustReadFile(filePath string) []byte

+ func MustWriteFile(filePath string, contents []byte, mode os.FileMode)

+ func PanicConsensus(v interface{})

+ func PanicCrisis(v interface{})

+ func PanicQ(v interface{})

+ func PanicSanity(v interface{})

+ func ParseDateRange(dateRange string) (startDate, endDate time.Time, err error)

+ func ProtocolAndAddress(listenAddr string) (string, string)

+ func PublicKeyFromBytes(pubKey []byte) (common.PublicKey, error)

+ func RandBool() bool

+ func RandBytes(n int) []byte

+ func RandFloat32() float32

+ func RandFloat64() float64

+ func RandInt() int

+ func RandInt16() int16

+ func RandInt31() int32

+ func RandInt31n(n int32) int32

+ func RandInt32() int32

+ func RandInt63() int64

+ func RandInt63n(n int64) int64

+ func RandInt64() int64

+ func RandIntn(n int) int

+ func RandPerm(n int) []int

+ func RandStr(length int) string

+ func RandTime() time.Time

+ func RandUint() uint

+ func RandUint16() uint16

+ func RandUint32() uint32

+ func RandUint64() uint64

+ func ReadFile(filePath string) ([]byte, error)

+ func Red(args ...interface{}) string

+ func Seed(seed int64)

+ func SplitAndTrim(s, sep, cutset string) []string

+ func StringInSlice(a string, list []string) bool

+ func TrapSignal(cb func())

+ func ValidatorName(v *cmttypes.Validator) string

+ func White(args ...interface{}) string

+ func WriteFile(filePath string, contents []byte, mode os.FileMode) error

+ func WriteFileAtomic(filename string, data []byte, perm os.FileMode) (err error)

+ func Yellow(args ...interface{}) string

+ type BitArray struct

+ Bits uint32

+ Elems []uint64

+ func NewBitArray(bits int) *BitArray

+ func (bA *BitArray) And(o *BitArray) *BitArray

+ func (bA *BitArray) Bytes() []byte

+ func (bA *BitArray) Copy() *BitArray

+ func (bA *BitArray) Count() int

+ func (bA *BitArray) CountNo() uint32

+ func (bA *BitArray) CountYes() uint32

+ func (bA *BitArray) GetIndex(i int) bool

+ func (bA *BitArray) IsEmpty() bool

+ func (bA *BitArray) IsFull() bool

+ func (bA *BitArray) MarshalJSON() ([]byte, error)

+ func (bA *BitArray) Not() *BitArray

+ func (bA *BitArray) Or(o *BitArray) *BitArray

+ func (bA *BitArray) PickRandom() (int, bool)

+ func (bA *BitArray) SetIndex(i int, v bool) bool

+ func (bA *BitArray) Size() int

+ func (bA *BitArray) String() string

+ func (bA *BitArray) StringIndented(indent string) string

+ func (bA *BitArray) Sub(o *BitArray) *BitArray

+ func (bA *BitArray) UnmarshalJSON(bz []byte) error

+ func (bA *BitArray) Update(o *BitArray)

+ func (ba *BitArray) DecodeRLP(s *rlp.Stream) error

+ func (ba *BitArray) EncodeRLP(w io.Writer) error

+ type BufferCloser struct

+ Closed bool

+ func NewBufferCloser(buf []byte) *BufferCloser

+ func (bc *BufferCloser) Close() error

+ func (bc *BufferCloser) Write(p []byte) (n int, err error)

+ func (bc *BufferCloser) WriteByte(c byte) error

+ func (bc *BufferCloser) WriteRune(r rune) (n int, err error)

+ func (bc *BufferCloser) WriteString(s string) (n int, err error)

+ type CMap struct

+ func NewCMap() *CMap

+ func (cm *CMap) Clear()

+ func (cm *CMap) Delete(key string)

+ func (cm *CMap) Get(key string) interface{}

+ func (cm *CMap) Has(key string) bool

+ func (cm *CMap) Keys() []string

+ func (cm *CMap) Set(key string, value interface{})

+ func (cm *CMap) Size() int

+ func (cm *CMap) Values() []interface{}

+ type Comparable interface

+ Less func(o interface{}) bool

+ type Error interface

+ Data func() interface{}

+ Error func() string

+ Stacktrace func() Error

+ Trace func(offset int, format string, args ...interface{}) Error

+ func ErrorWrap(cause interface{}, format string, args ...interface{}) Error

+ func NewError(format string, args ...interface{}) Error

+ func NewErrorWithData(data interface{}) Error

+ type FmtError struct

+ func (fe FmtError) Error() string

+ func (fe FmtError) Format() string

+ func (fe FmtError) String() string

+ type Heap struct

+ func NewHeap() *Heap

+ func (h *Heap) Len() int64

+ func (h *Heap) Peek() interface{}

+ func (h *Heap) Pop() interface{}

+ func (h *Heap) Push(value interface{}, priority int)

+ func (h *Heap) PushBytes(value interface{}, priority []byte)

+ func (h *Heap) PushComparable(value interface{}, priority Comparable)

+ func (h *Heap) Update(value interface{}, priority Comparable)

+ type HexBytes []byte

+ func (bz *HexBytes) Unmarshal(data []byte) error

+ func (bz *HexBytes) UnmarshalJSON(data []byte) error

+ func (bz HexBytes) Bytes() []byte

+ func (bz HexBytes) Format(s fmt.State, verb rune)

+ func (bz HexBytes) Marshal() ([]byte, error)

+ func (bz HexBytes) MarshalJSON() ([]byte, error)

+ func (bz HexBytes) String() string

+ type PrefixedReader struct

+ Prefix []byte

+ func NewPrefixedReader(prefix []byte, reader io.Reader) *PrefixedReader

+ func (pr *PrefixedReader) Read(p []byte) (n int, err error)

+ type Rand struct

+ func NewRand() *Rand

+ func (r *Rand) Bool() bool

+ func (r *Rand) Bytes(n int) []byte

+ func (r *Rand) Float32() float32

+ func (r *Rand) Float64() float64

+ func (r *Rand) Int() int

+ func (r *Rand) Int16() int16

+ func (r *Rand) Int31() int32

+ func (r *Rand) Int31n(n int32) int32

+ func (r *Rand) Int32() int32

+ func (r *Rand) Int63() int64

+ func (r *Rand) Int63n(n int64) int64

+ func (r *Rand) Int64() int64

+ func (r *Rand) Intn(n int) int

+ func (r *Rand) Perm(n int) []int

+ func (r *Rand) Seed(seed int64)

+ func (r *Rand) Str(length int) string

+ func (r *Rand) Time() time.Time

+ func (r *Rand) Uint() uint

+ func (r *Rand) Uint16() uint16

+ func (r *Rand) Uint32() uint32

+ func (r *Rand) Uint64() uint64

+ type RepeatTimer struct

+ func NewRepeatTimer(name string, dur time.Duration) *RepeatTimer

+ func NewRepeatTimerWithTickerMaker(name string, dur time.Duration, tm TickerMaker) *RepeatTimer

+ func (t *RepeatTimer) Chan() <-chan time.Time

+ func (t *RepeatTimer) Reset()

+ func (t *RepeatTimer) Stop()

+ type Task func(i int) (val interface{}, err error, abort bool)

+ type TaskResult struct

+ Error error

+ Value interface{}

+ type TaskResultCh <-chan TaskResult

+ type TaskResultSet struct

+ func Parallel(tasks ...Task) (trs *TaskResultSet, ok bool)

+ func (trs *TaskResultSet) Channels() []TaskResultCh

+ func (trs *TaskResultSet) FirstError() error

+ func (trs *TaskResultSet) FirstValue() interface{}

+ func (trs *TaskResultSet) LatestResult(index int) (TaskResult, bool)

+ func (trs *TaskResultSet) Reap() *TaskResultSet

+ func (trs *TaskResultSet) Wait() *TaskResultSet

+ type ThrottleTimer struct

+ Ch chan struct{}

+ Name string

+ func NewThrottleTimer(name string, dur time.Duration) *ThrottleTimer

+ func (t *ThrottleTimer) Set()

+ func (t *ThrottleTimer) Stop() bool

+ func (t *ThrottleTimer) Unset()

+ type Ticker interface

+ Chan func() <-chan time.Time

+ Stop func()

+ type TickerMaker func(dur time.Duration) Ticker

+ func NewLogicalTickerMaker(source chan time.Time) TickerMaker

+ type ValidatorSetAdapter struct

+ Validators []*cmttypes.Validator

+ func NewValidatorSetAdapter(vset *cmttypes.ValidatorSet) *ValidatorSetAdapter

+ func (vals *ValidatorSetAdapter) DeleteByPubkey(pubkeyBytes []byte)

+ func (vals *ValidatorSetAdapter) GetByPubkey(pubkeyBytes []byte) (val *cmttypes.Validator)

+ func (vals *ValidatorSetAdapter) SortWithNonce(nonce uint64) *cmttypes.ValidatorSet

+ func (vals *ValidatorSetAdapter) String() string

+ func (vals *ValidatorSetAdapter) ToValidatorSet() *cmttypes.ValidatorSet

+ func (vals *ValidatorSetAdapter) Upsert(newV *cmttypes.Validator)

+ type ValidatorSortKey struct

+ PubKey cmtcrypto.PubKey

+ SortKey []byte