common

package
v0.9.8 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 15, 2021 License: Apache-2.0 Imports: 17 Imported by: 14

Documentation

Index

Constants

View Source 
const (
	AddressIDBytes = 20
	AddressBytes   = AddressIDBytes + 1
)
View Source 
const (
	TypeAddress = iota + codec.TypeCustom
	TypeInt
)
View Source 
const PrefixLen = 4

Variables

View Source 
var (
	ErrUnknown         = errors.ErrUnknown
	ErrIllegalArgument = errors.ErrIllegalArgument
	ErrInvalidState    = errors.ErrInvalidState
	ErrUnsupported     = errors.ErrUnsupported
	ErrNotFound        = errors.ErrNotFound
)
View Source 
var (
	NullHashBytes  = make([]byte, crypto.HashLen)
	NullHashJSON   = []byte("\"0x" + hex.EncodeToString(NullHashBytes) + "\"")
	NullHashString = "0x" + hex.EncodeToString(NullHashBytes)
)
View Source 
var HexIntZero = &hexIntZero
View Source 
var TypeCodec = &typeCodec{}

Functions

func AddressEqual added in v0.9.4 

func AddressEqual(a, b module.Address) bool

func AnyForJSON added in v0.9.4 

func AnyForJSON(o interface{}) (interface{}, error)

func BlockInfoEqual added in v0.9.4 

func BlockInfoEqual(bi1 module.BlockInfo, bi2 module.BlockInfo) bool

func BytesToAddress added in v0.9.4 

func BytesToAddress(b []byte) (module.Address, error)

func CompactJSON added in v0.9.4 

func CompactJSON(js []byte) ([]byte, error)

func Compress 

func Compress(bs []byte) []byte

func ConsensusInfoEqual added in v0.9.4 

func ConsensusInfoEqual(csi1, csi2 module.ConsensusInfo) bool

func DecodeAny 

func DecodeAny(o *codec.TypedObj) (interface{}, error)

func DecodeAnyForJSON 

func DecodeAnyForJSON(o *codec.TypedObj) (interface{}, error)

func DecodeAsString 

func DecodeAsString(o *codec.TypedObj, s string) string

func Decompress 

func Decompress(bs []byte) []byte

func EncodeAny 

func EncodeAny(obj interface{}) (*codec.TypedObj, error)

func HexPre 

func HexPre(bs []byte) string

HexPre returns hexadecimal string of prefix of byte slice bs.

func MarshalAny 

func MarshalAny(c codec.Codec, obj interface{}) ([]byte, error)

func MustDecodeAny 

func MustDecodeAny(o *codec.TypedObj) interface{}

func MustEncodeAny 

func MustEncodeAny(obj interface{}) *codec.TypedObj

func NewBlockInfo 

func NewBlockInfo(height, timestamp int64) module.BlockInfo

func NewConsensusInfo added in v0.9.4 

func NewConsensusInfo(
	proposer module.Address,
	voters module.ValidatorList,
	voted []bool,
) module.ConsensusInfo

func StrLeft 

func StrLeft(n int, s string) string

func UnixMicroFromTime 

func UnixMicroFromTime(t time.Time) int64

func UnmarshalAny 

func UnmarshalAny(c codec.Codec, bs []byte) (interface{}, error)

func ValidatorListEqual added in v0.9.4 

func ValidatorListEqual(vl1, vl2 module.ValidatorList) bool

Types

type Address 

type Address [AddressBytes]byte

func AddressToPtr added in v0.9.3 

func AddressToPtr(addr module.Address) *Address

func MustNewAddress added in v0.9.4 

func MustNewAddress(b []byte) *Address

func MustNewAddressFromString added in v0.9.6 

func MustNewAddressFromString(s string) *Address

func NewAccountAddress 

func NewAccountAddress(b []byte) *Address

func NewAccountAddressFromPublicKey 

func NewAccountAddressFromPublicKey(pubKey *crypto.PublicKey) *Address

func NewAddress 

func NewAddress(b []byte) (*Address, error)

func NewAddressFromString 

func NewAddressFromString(s string) (*Address, error)

func NewAddressWithTypeAndID added in v0.9.4 

func NewAddressWithTypeAndID(isContract bool, id []byte) *Address

func NewContractAddress 

func NewContractAddress(b []byte) *Address

func (*Address) Bytes 

func (a *Address) Bytes() []byte

func (*Address) Equal 

func (a *Address) Equal(a2 module.Address) bool

func (*Address) ID 

func (a *Address) ID() []byte

BytesPart returns part of address without type prefix.

func (*Address) IsContract 

func (a *Address) IsContract() bool

func (Address) MarshalJSON 

func (a Address) MarshalJSON() ([]byte, error)

func (*Address) RLPDecodeSelf 

func (a *Address) RLPDecodeSelf(d codec.Decoder) error

func (*Address) RLPEncodeSelf 

func (a *Address) RLPEncodeSelf(e codec.Encoder) error

func (*Address) Set added in v0.9.3 

func (a *Address) Set(address module.Address) *Address

func (*Address) SetBytes 

func (a *Address) SetBytes(b []byte) error

func (*Address) SetString 

func (a *Address) SetString(s string) error

func (*Address) SetStringStrict added in v0.9.6 

func (a *Address) SetStringStrict(s string) error

func (*Address) SetTypeAndID 

func (a *Address) SetTypeAndID(ic bool, id []byte)

func (*Address) String 

func (a *Address) String() string

func (*Address) UnmarshalJSON 

func (a *Address) UnmarshalJSON(b []byte) error

type AutoCallLocker 

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

func LockForAutoCall 

func LockForAutoCall(locker sync.Locker) *AutoCallLocker

func (*AutoCallLocker) CallAfterUnlock 

func (m *AutoCallLocker) CallAfterUnlock(f func())

CallAfterUnlock schedules to call f after next unlock. This function shall be called while lock is acquired.

func (*AutoCallLocker) CallBeforeUnlock 

func (m *AutoCallLocker) CallBeforeUnlock(f func())

CallBeforeUnlock schedules to call f before next unlock. This function shall be called while lock is acquired.

func (*AutoCallLocker) Unlock 

func (m *AutoCallLocker) Unlock()

Unlock calls scheduled functions and releases lock.

type AutoUnlock 

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

func Lock 

func Lock(l sync.Locker) AutoUnlock

Lock lock the locker and return handle for unlock to be used for deferred unlock.

func (*AutoUnlock) Unlock 

func (l *AutoUnlock) Unlock()

type Clock 

type Clock interface {
	Now() time.Time
	AfterFunc(d time.Duration, f func()) Timer
	NewTimer(d time.Duration) Timer
	Sleep(d time.Duration)
}

type GoTimeClock 

type GoTimeClock struct {
}

func (*GoTimeClock) AfterFunc 

func (cl *GoTimeClock) AfterFunc(d time.Duration, f func()) Timer

func (*GoTimeClock) NewTimer 

func (cl *GoTimeClock) NewTimer(d time.Duration) Timer

func (*GoTimeClock) Now 

func (cl *GoTimeClock) Now() time.Time

func (*GoTimeClock) Sleep 

func (cl *GoTimeClock) Sleep(d time.Duration)

type HexBytes 

type HexBytes []byte

func SliceOfHexBytes 

func SliceOfHexBytes(bss [][]byte) []HexBytes

func (HexBytes) Bytes 

func (hs HexBytes) Bytes() []byte

func (HexBytes) MarshalJSON 

func (hs HexBytes) MarshalJSON() ([]byte, error)

func (HexBytes) String 

func (hs HexBytes) String() string

func (*HexBytes) UnmarshalJSON 

func (hs *HexBytes) UnmarshalJSON(b []byte) error

type HexHash added in v0.9.6 

type HexHash []byte

func (HexHash) Bytes added in v0.9.6 

func (hs HexHash) Bytes() []byte

func (HexHash) MarshalJSON added in v0.9.6 

func (hs HexHash) MarshalJSON() ([]byte, error)

func (HexHash) String added in v0.9.6 

func (hs HexHash) String() string

func (*HexHash) UnmarshalJSON added in v0.9.6 

func (hs *HexHash) UnmarshalJSON(b []byte) error

type HexInt 

type HexInt struct {
	big.Int
}

func NewHexInt 

func NewHexInt(v int64) *HexInt

func (*HexInt) AddValue added in v0.9.4 

func (i *HexInt) AddValue(x, y *big.Int) *HexInt

func (*HexInt) Bytes 

func (i *HexInt) Bytes() []byte

func (*HexInt) Clone 

func (i *HexInt) Clone() HexInt

func (*HexInt) MarshalBinary 

func (i *HexInt) MarshalBinary() (data []byte, err error)

func (HexInt) MarshalJSON 

func (i HexInt) MarshalJSON() ([]byte, error)

func (*HexInt) SetBytes 

func (i *HexInt) SetBytes(bs []byte) *big.Int

func (*HexInt) SetValue added in v0.9.4 

func (i *HexInt) SetValue(x *big.Int) *HexInt

func (HexInt) String 

func (i HexInt) String() string

func (*HexInt) UnmarshalBinary 

func (i *HexInt) UnmarshalBinary(data []byte) error

func (*HexInt) UnmarshalJSON 

func (i *HexInt) UnmarshalJSON(b []byte) error

func (*HexInt) Value added in v0.9.4 

func (i *HexInt) Value() *big.Int

type HexInt16 

type HexInt16 struct {
	Value int16
}

func (HexInt16) Bytes 

func (i HexInt16) Bytes() []byte

func (HexInt16) MarshalJSON 

func (i HexInt16) MarshalJSON() ([]byte, error)

func (*HexInt16) RLPDecodeSelf 

func (i *HexInt16) RLPDecodeSelf(d codec.Decoder) error

func (*HexInt16) RLPEncodeSelf 

func (i *HexInt16) RLPEncodeSelf(e codec.Encoder) error

func (HexInt16) String 

func (i HexInt16) String() string

func (*HexInt16) UnmarshalJSON 

func (i *HexInt16) UnmarshalJSON(b []byte) error

type HexInt32 

type HexInt32 struct {
	Value int32
}

func (HexInt32) MarshalJSON 

func (i HexInt32) MarshalJSON() ([]byte, error)

func (*HexInt32) RLPDecodeSelf 

func (i *HexInt32) RLPDecodeSelf(d codec.Decoder) error

func (*HexInt32) RLPEncodeSelf 

func (i *HexInt32) RLPEncodeSelf(e codec.Encoder) error

func (HexInt32) String 

func (i HexInt32) String() string

func (*HexInt32) UnmarshalJSON 

func (i *HexInt32) UnmarshalJSON(b []byte) error

type HexInt64 

type HexInt64 struct {
	Value int64
}

func (HexInt64) MarshalJSON 

func (i HexInt64) MarshalJSON() ([]byte, error)

func (*HexInt64) RLPDecodeSelf 

func (i *HexInt64) RLPDecodeSelf(d codec.Decoder) error

func (*HexInt64) RLPEncodeSelf 

func (i *HexInt64) RLPEncodeSelf(e codec.Encoder) error

func (HexInt64) String 

func (i HexInt64) String() string

func (*HexInt64) UnmarshalJSON 

func (i *HexInt64) UnmarshalJSON(b []byte) error

type HexUint16 

type HexUint16 struct {
	Value uint16
}

func (HexUint16) Bytes 

func (i HexUint16) Bytes() []byte

func (HexUint16) MarshalJSON 

func (i HexUint16) MarshalJSON() ([]byte, error)

func (*HexUint16) RLPDecodeSelf 

func (i *HexUint16) RLPDecodeSelf(d codec.Decoder) error

func (*HexUint16) RLPEncodeSelf 

func (i *HexUint16) RLPEncodeSelf(e codec.Encoder) error

func (HexUint16) String 

func (i HexUint16) String() string

func (*HexUint16) UnmarshalJSON 

func (i *HexUint16) UnmarshalJSON(b []byte) error

type HexUint32 

type HexUint32 struct {
	Value uint32
}

func (HexUint32) MarshalJSON 

func (i HexUint32) MarshalJSON() ([]byte, error)

func (*HexUint32) RLPDecodeSelf 

func (i *HexUint32) RLPDecodeSelf(d codec.Decoder) error

func (*HexUint32) RLPEncodeSelf 

func (i *HexUint32) RLPEncodeSelf(e codec.Encoder) error

func (HexUint32) String 

func (i HexUint32) String() string

func (*HexUint32) UnmarshalJSON 

func (i *HexUint32) UnmarshalJSON(b []byte) error

type HexUint64 

type HexUint64 struct {
	Value uint64
}

func (HexUint64) MarshalJSON 

func (i HexUint64) MarshalJSON() ([]byte, error)

func (*HexUint64) RLPDecodeSelf 

func (i *HexUint64) RLPDecodeSelf(d codec.Decoder) error

func (*HexUint64) RLPEncodeSelf 

func (i *HexUint64) RLPEncodeSelf(e codec.Encoder) error

func (HexUint64) String 

func (i HexUint64) String() string

func (*HexUint64) UnmarshalJSON 

func (i *HexUint64) UnmarshalJSON(b []byte) error

type ITimer 

type ITimer interface {
	Stop() bool
}

type Mutex 

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

Mutex is wrapper for sync.Mutex.

func (*Mutex) CallAfterUnlock 

func (m *Mutex) CallAfterUnlock(f func())

CallAfterUnlock schedules to call f after next unlock. This function shall be called while lock is acquired.

func (*Mutex) CallBeforeUnlock 

func (m *Mutex) CallBeforeUnlock(f func())

CallBeforeUnlock schedules to call f before next unlock. This function shall be called while lock is acquired.

func (*Mutex) Lock 

func (m *Mutex) Lock()

Lock acquires lock.

func (*Mutex) Unlock 

func (m *Mutex) Unlock()

Unlock calls scheduled functions and releases lock.

type RawHexBytes 

type RawHexBytes []byte

func (RawHexBytes) Bytes 

func (rh RawHexBytes) Bytes() []byte

func (RawHexBytes) MarshalJSON 

func (rh RawHexBytes) MarshalJSON() ([]byte, error)

func (RawHexBytes) String 

func (rh RawHexBytes) String() string

func (*RawHexBytes) UnmarshalJSON 

func (rh *RawHexBytes) UnmarshalJSON(b []byte) error

type Signature 

type Signature struct {
	*crypto.Signature
}

func (*Signature) MarshalBinary 

func (sig *Signature) MarshalBinary() ([]byte, error)

func (Signature) MarshalJSON 

func (sig Signature) MarshalJSON() ([]byte, error)

func (Signature) RecoverPublicKey 

func (sig Signature) RecoverPublicKey(hash []byte) (*crypto.PublicKey, error)

func (*Signature) UnmarshalBinary 

func (sig *Signature) UnmarshalBinary(s []byte) error

func (*Signature) UnmarshalJSON 

func (sig *Signature) UnmarshalJSON(s []byte) error

type TestClock 

type TestClock struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*TestClock) AfterFunc 

func (cl *TestClock) AfterFunc(d time.Duration, f func()) Timer

func (*TestClock) NewTimer 

func (cl *TestClock) NewTimer(d time.Duration) Timer

func (*TestClock) Now 

func (cl *TestClock) Now() time.Time

func (*TestClock) PassTime 

func (cl *TestClock) PassTime(d time.Duration)

func (*TestClock) SetTime 

func (cl *TestClock) SetTime(t time.Time)

func (*TestClock) Sleep 

func (cl *TestClock) Sleep(d time.Duration)

type Timer 

type Timer struct {
	ITimer
	C <-chan time.Time
}

func (*Timer) Stop 

func (timer *Timer) Stop()

Source Files

View all Source files

Directories

Path Synopsis
* Copyright 2020 ICON Foundation * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License.
 * Copyright 2020 ICON Foundation * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License.
cache
mta
ompt
trie_manager

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.