common

Dec 19, 2023

Changes in this version

+ func DecodeHex(h string) ([]byte, error)

Jul 4, 2023

Changes in this version

type EraNum

+ func (e *EraNum) Slice() []byte

type Height

+ func (h *Height) Slice() []byte

type Seed

+ func (s *Seed) Slice() []byte

Jul 1, 2023

Changes in this version

+ type HashProvider interface

+ Hasher func() hash.Hash

+ var SystemHashProvider HashProvider = systemHasher{}

Jun 21, 2023

Changes in this version

+ func BigIntForRLP(i *big.Int) *big.Int

+ func BytesForRLP(bs []byte) []byte

type Address

+ func (a *Address) ForRLP() *Address

+ func (a *Address) FromRLP() *Address

type Hash

+ func (h *Hash) ForRLP() *Hash

+ func (h *Hash) FromRLP() *Hash

Mar 21, 2023

Changes in this version

+ func BytesSliceEqual(a, b [][]byte) bool

+ func SlicesMerkleHash(values [][]byte, toBeProof int, proofs *MerkleProofs) (rootHash []byte, err error)

+ func SlicesMerkleHashComplete(values [][]byte, toBeProof int, proofs *MerkleProofs) (rootHash []byte, err error)

+ func SlicesToHashs(bss [][]byte) [][]byte

Mar 13, 2023

Changes in this version

+ var EmptyPublicKey = make([]byte, RealCipher.LengthOfPublicKey())

+ var EmptySignature = make([]byte, RealCipher.LengthOfSignature())

Jan 31, 2023

Changes in this version

+ func MerkleHashCompleteOld(hashList [][]byte, toBeProof int, proofs *MerkleProofs) ([]byte, error)

+ func RandomByteSlices(count, size int) [][]byte

type Seed

+ func BytesToSeedP(b []byte) *Seed

+ func (s *Seed) Equal(o *Seed) bool

Jan 5, 2023

Changes in this version

type ChainIDs

+ func (ids ChainIDs) Equal(os ChainIDs) bool

+ func (ids ChainIDs) String() string

Nov 2, 2022

Changes in this version

type ChainID

+ func (id ChainID) FromBig(bi *big.Int) (cid ChainID, ok bool)

type Height

+ func (h Height) FromBig(bi *big.Int) (height Height, ok bool)

type IndentLevel

+ func (l IndentLevel) DoubleByteSlice(slices [][]byte) string

Aug 10, 2022

Changes in this version

+ func ShiftBits(b0, b1 byte, shifts uint8, length ...uint8) byte

+ func SubBytes(bs []byte, from, size int) ([]byte, error)

+ type HashItem struct

+ Order bool

+ Val Hash

type MerkleProofs

+ Repeats MoreTimes

+ func (p *MerkleProofs) ToItems() ([]HashItem, error)

+ type MoreTime struct

+ Index int

+ Times int

+ func (m MoreTime) Equal(o MoreTime) bool

+ func (m MoreTime) IsValid() bool

+ func (m MoreTime) String() string

+ type MoreTimes []MoreTime

+ func (ms MoreTimes) Append(index int) MoreTimes

+ func (ms MoreTimes) Clone() MoreTimes

+ func (ms MoreTimes) Count() int

+ func (ms MoreTimes) Equal(os MoreTimes) bool

+ func (ms MoreTimes) Find(index int) (times int, exist bool)

+ func (ms MoreTimes) GetHashsIndex(fullIndex int) int

+ func (ms MoreTimes) IsValid() bool

Jul 18, 2022

Changes in this version

type Address

+ func (a *Address) Value() Address

+ func (a Address) Copy() *Address

Jul 5, 2022

Changes in this version

type Address

+ func (a *Address) Equal(o *Address) bool

+ func (a *Address) ToString() string

type CommID

+ func (i CommID) ShouldPropose(commSize int) int

type EpochNum

+ func (en *EpochNum) Clone() *EpochNum

+ func (en *EpochNum) Cmp(o *EpochNum) int

+ func (en *EpochNum) ToString() string

type EraNum

+ func (e *EraNum) Hash() Hash

type Height

+ func (h *Height) Hash() Hash

type Seed

+ func (s *Seed) Hash() Hash

May 14, 2022

Changes in this version

+ func PointerCompare(a, b interface{}) (cmp int, needCompare bool)

type BlockNum

+ func (bn BlockNum) IsFirstOfEpoch() bool

type EpochNum

+ func (en EpochNum) FirstHeight() Height

type Height

+ func (h Height) IsFirstOfEpoch() bool

type MerkleProofs

+ func (p *MerkleProofs) Summary() string

Apr 6, 2022

Changes in this version

+ const ChainInfoVersion

+ var EmptyNodeHash Hash

+ var EmptyNodeHashSlice []byte

+ func InvalidHash(bs []byte) bool

+ func ValuesMerkleHash(values interface{}, toBeProof int, proofs *MerkleProofs) (rootHash []byte, err error)

type BlockNum

+ func (bn BlockNum) IsValid() bool

type ChainID

+ func (id ChainID) FromFormalize(bs []byte) ChainID

type ChainInfos

+ Auditors NodeIDs

+ Version uint16

+ func (c *ChainInfos) GetAuditorIds() NodeIDs

+ func (c *ChainInfos) GetAuditorMap() map[NodeID]struct{}

+ func (c *ChainInfos) HashValue() ([]byte, error)

type EpochNum

+ func (en EpochNum) Compare(o EpochNum) int

+ func (en EpochNum) Diff(o EpochNum) (diff uint64, cmpRet int)

+ func (en EpochNum) LastHeight() Height

type EraNum

+ func (e *EraNum) Clone() *EraNum

+ func (e *EraNum) Cmp(o *EraNum) int

+ func (e *EraNum) Equal(o *EraNum) bool

+ func (e EraNum) Compare(o EraNum) int

type Hash

+ func (h *Hash) Equal(v *Hash) bool

+ func (h Hash) Invalid() bool

+ func (h Hash) IsEmptyNode() bool

type Height

+ func (h *Height) Clone() *Height

+ func (h Height) Diff(o Height) (diff uint64, cmpRet int)

+ func (h Height) RemoveRemainder(n Height) Height

type MerkleProofs

+ func (p *MerkleProofs) Equal(o *MerkleProofs) bool

type NodeIDs

+ func (ns NodeIDs) Equal(os NodeIDs) bool

Mar 3, 2022

Changes in this version

+ func ValuesToHashs(values interface{}) ([][]byte, error)

Mar 2, 2022

Changes in this version

+ func HashPairOrder(order bool, a, b []byte) ([]byte, error)

type MerkleProofs

+ func (p *MerkleProofs) Iterate(hashCallback func(val []byte, order bool) error) error

Jan 24, 2022

Changes in this version

+ func PubKeyCanRecover() bool

+ func VerifyHashWithPub(hash, pub, sig []byte) (bool, []byte)

+ func VerifyMsgWithPub(v interface{}, pub, sig []byte) (bool, []byte)

Jan 14, 2022

Changes in this version

+ func BytesInfoString(level IndentLevel, bss [][]byte) string

Jan 11, 2022

Changes in this version

type NodeID

+ func (nid NodeID) InfoString(_ IndentLevel) string

type NodeIDs

+ func (ns NodeIDs) InfoString(level IndentLevel) string

Dec 28, 2021

Changes in this version

+ var ErrNoAdapter = errors.New("no adapter")

type MerkleProofs

+ func (p *MerkleProofs) BigKey(bigKey *big.Int, startAt int) int

+ func (p *MerkleProofs) InfoString(level IndentLevel) string

Nov 16, 2021

Changes in this version

+ type Version uint64

+ func NewNodeVersion(major, minor, patch uint64) (Version, error)

+ func (v Version) Major() uint64

+ func (v Version) Minor() uint64

+ func (v Version) Patch() uint64

+ func (v Version) String() string

Nov 15, 2021

Changes in this version

+ func InfoStringer(v reflect.Value, level IndentLevel) string

type IndentLevel

+ func (l IndentLevel) InfoString(o interface{}) string

+ type Infoer interface

+ InfoString func(level IndentLevel) string

Nov 10, 2021

Changes in this version

+ const BigChainIDBaseV2

Oct 28, 2021

Changes in this version

+ const BigChainIDBase

Oct 25, 2021

Changes in this version

+ const DefaultEthRpcAddress

+ var DefaultEthRpcEndpoint = Endpoint

Oct 14, 2021

Changes in this version

type Height

+ func (h Height) UsefulBlock() BlockNum

Oct 13, 2021

Changes in this version

type Height

+ func (h Height) UsefulEpoch() EpochNum

type RoutinePool

+ func (p *RoutinePool) String() string

Sep 28, 2021

Changes in this version

+ var EmptyAddress = Address

+ func CompareSlices(a, b interface{}, objComparer func(c, d interface{}) int) int

type AccountSharding

+ func (as AccountSharding) Clone() ShardInfo

type AccountShards

+ func (s AccountShards) Clone() AccountShards

type Address

+ func (a *Address) Cmp(o *Address) int

+ func (a *Address) Slice() []byte

type ChainStruct

+ func (s ChainStruct) Clone() ChainStruct

type Height

+ func (h *Height) Equal(o *Height) bool

+ type IndentLevel int

+ func (l IndentLevel) IndentString() string

type NodeID

+ func BytesToNodeIDP(b []byte) *NodeID

type ShardInfo

+ Clone func() ShardInfo

Sep 16, 2021

Changes in this version

type Address

+ func (a *Address) UnmarshalJSON(input []byte) error

type Hash

+ func PrefixedRlpHash(prefix byte, x interface{}) (h Hash)

+ func RlpHash(x interface{}) (h Hash)

+ type KeccakState interface

+ Read func([]byte) (int, error)

Jun 7, 2021

Changes in this version

+ const DefaultStarterPK

type ChainID

+ func (id ChainID) Compare(o ChainID) int

May 19, 2021

Changes in this version

+ func InitSharedObjectWithError(sopath string) (*plugin.Plugin, error)

type RoutinePool

+ func (p *RoutinePool) HigherLen() int

+ func (p *RoutinePool) LowerLen() int

Jan 14, 2021

Changes in this version

type Address

+ func CreateAddress2(b Address, salt [32]byte, inithash []byte) Address

Jan 6, 2021

Changes in this version

+ const AddressLength

+ const Block

+ const BlocksInEpoch

+ const BlocksInEra

+ const ChainBytesLength

+ const DefaultCompatible

+ const DefaultP2PPort1

+ const DefaultP2pPort2

+ const DefaultRpcAddress

+ const ETFixedCommittee

+ const ETFixedSpectator

+ const ETManagedCommittee

+ const ETNone

+ const ETVrf

+ const EpochsInEra

+ const Event

+ const HashLength

+ const HeightBytesLength

+ const INTMAX

+ const INTMIN

+ const MainChainID

+ const MaxExponentOfShards

+ const NilBlock

+ const NilChainID

+ const NilEpoch

+ const NilEra

+ const NilHeight

+ const NodeIDBits

+ const NodeIDBytes

+ const P2P

+ const ReservedMaxChainID

+ const SeedLength

+ var BigIntPool = sync.Pool

+ var BytesBufferPool = sync.Pool

+ var DefaultRpcEndpoint = Endpoint

+ var EmptyByteSliceHolder []byte = make([]byte, 0)

+ var EmptyHash = Hash

+ var EmptyNodeID = NodeID

+ var EmptyPlaceHolder struct{} = struct{}

+ var ErrAlreadyDone = errors.New("already done, operation ignored")

+ var ErrAlreadyInitialized = errors.New("already initialized")

+ var ErrAlreadyStarted = errors.New("already started")

+ var ErrAlreadyStopped = errors.New("already stopped")

+ var ErrDuplicated = errors.New("duplicated")

+ var ErrGasLimitReached = errors.New("gas limit reached")

+ var ErrIllegalParams = errors.New("illegal parameters")

+ var ErrIllegalStatus = errors.New("illegal status")

+ var ErrInsufficientBalance = errors.New("insufficient balance for transfer")

+ var ErrInsufficientLength = errors.New("insufficient length")

+ var ErrLength = errors.New("length error")

+ var ErrMissMatch = errors.New("miss match")

+ var ErrNeedInitialization = errors.New("need initialization")

+ var ErrNil = errors.New("nil value")

+ var ErrNotFound = errors.New("not found")

+ var ErrNotStarted = errors.New("not started yet")

+ var ErrReservedAddress = errors.New("reserved address")

+ var ErrSignatureVerifyFailed = errors.New("signature verify failed")

+ var ErrUnknown = errors.New("unknown error")

+ var ErrUnsupported = errors.New("unsupported")

+ var ForChain *ChainID

+ var FullData bool

+ var LastBlockTime int64

+ var LastBlocks = LastBlockMap

+ var LastEventTime int64

+ var LastMsgTime int64

+ var MainChainStruct = ChainStruct

+ var NdType *NodeType

+ var NetDelay []int

+ var NilHash = BytesToHash(NilHashSlice)

+ var NilHashSlice = []byte(nil)

+ var NodeIDMap = make(map[NodeID]int)

+ var Overflow bool

+ var PkgedBlocks = LastBlockMap

+ var RealCipher cipher.Cipher = cipher.NewCipher(cipher.SECP256K1SHA3)

+ var StandAlone bool

+ var SystemNodeID NodeID

+ var SystemPrivKey cipher.ECCPrivateKey

+ var TxCount uint64

+ var TypeOfAddress = reflect.TypeOf((*Address)(nil)).Elem()

+ var TypeOfChainInfosPtr = reflect.TypeOf((*ChainInfos)(nil))

+ var TypeOfHash = reflect.TypeOf((*Hash)(nil)).Elem()

+ var WaitingTime time.Duration

+ func Bytes2Hex(d []byte) string

+ func BytesIntersection(a, b [][]byte) [][]byte

+ func BytesIntersectionMap(a map[string]struct{}, b [][]byte) [][]byte

+ func BytesToUint32(b []byte) uint32

+ func CipherHash256(cipher cipher.Cipher, in ...[]byte) []byte

+ func CloneByteSlice(bytes []byte) []byte

+ func ConcatenateBytes(bss [][]byte) []byte

+ func CopyBytes(b []byte) (copiedBytes []byte)

+ func CopyBytesSlice(in [][]byte) [][]byte

+ func DatabasePath(basePath string, id ChainID) string

+ func EncodeAndHash(o interface{}) ([]byte, error)

+ func ForPrint(v interface{}, poss ...int) []byte

+ func ForPrintSlice(s []byte, startPos int, endPos int) []byte

+ func ForPrintSliceString(v interface{}, maxSize ...int) string

+ func ForPrintValue(val reflect.Value, startPos, endPos int) []byte

+ func FormalizeBasePath(path string) string

+ func FromHex(s string) []byte

+ func HasHexPrefix(str string) bool

+ func Hash256NoError(in ...[]byte) []byte

+ func Hash256s(in ...[]byte) ([]byte, error)

+ func HashEquals(h1, h2 *Hash) bool

+ func HashLess(a, b Hash) bool

+ func HashObject(o interface{}) ([]byte, error)

+ func HashPair(a []byte, b []byte) []byte

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

+ func HashSliceEquals(h1, h2 []byte) bool

+ func HashsEquals(hs1, hs2 []Hash) bool

+ func HeaderIndexHash(posBuffer [13]byte, index byte) []byte

+ func Hex2Bytes(str string) []byte

+ func Hex2BytesFixed(str string, flen int) []byte

+ func HexToPrivKey(h string) (cipher.ECCPrivateKey, error)

+ func HomeDir() string

+ func InitNodeIDMap(nodeids []NodeID)

+ func InitShareObject(sopath string) *plugin.Plugin

+ func IntToBytes(n int) []byte

+ func IsHex(str string) bool

+ func IsHexAddress(s string) bool

+ func IsHexCharacter(c byte) bool

+ func IsNilHash(bs []byte) bool

+ func IsNodeIDIn(nidhs []Hash, nid NodeID) bool

+ func KeyCount() map[string]int

+ func LeftPadBytes(slice []byte, l int) []byte

+ func MerkleHash(hashList [][]byte, toBeProof int, proofs *MerkleProofs) (root []byte, err error)

+ func MerkleHashComplete(hashList [][]byte, toBeProof int, proofs *MerkleProofs) ([]byte, error)

+ func PackNodeIdsToBytes(nodeIds []NodeID) []byte

+ func ParseBytesToNodeIdBytes(s []byte) ([][]byte, error)

+ func PointerSliceLess(slice interface{}, i, j int) (less bool, needCompare bool)

+ func PrintBytesSlice(bss [][]byte, length int) string

+ func PrivateToPublicSlice(priv []byte) ([]byte, error)

+ func RandomBytes(length int) []byte

+ func RegisterNoCheckAddress(addrs ...Address)

+ func RegisterReservedAddress(addrs ...Address)

+ func RegisterSystemContract(noGas bool, addrs ...Address)

+ func ReverseBytes(bs []byte) []byte

+ func RightPadBytes(slice []byte, l int) []byte

+ func SignHash(hash []byte) (pub, sig []byte, err error)

+ func SignMsg(msg interface{}) (pub, sig []byte, err error)

+ func SplitBytes(bs []byte, size int) ([][]byte, error)

+ func SystemHash256(in ...[]byte) []byte

+ func ToHeaderPosHashBuffer(id ChainID, height Height) [13]byte

+ func ValuesMerkleTreeHash(values interface{}, toBeProof int, proofs *MerkleProofs) (rootHash []byte, err error)

+ func VerifyHash(hash, pub, sig []byte) bool

+ func VerifyMsg(v interface{}, pub, sig []byte) bool

+ func Watch(tp int)

+ func WatchDelta(ovfl bool)

+ func WatchHeight(id ChainID, height Height)

+ type AbstractService struct

+ CloseFunc func() error

+ InitFunc func() error

+ StartFunc func() error

+ func (s *AbstractService) Close() error

+ func (s *AbstractService) Init() error

+ func (s *AbstractService) SetChanger(changer ServiceStateChanger)

+ func (s *AbstractService) Start() error

+ func (s AbstractService) Copy() AbstractService

+ type AccountSharding struct

+ func (as *AccountSharding) String() string

+ func (as AccountSharding) AllIDs() []ChainID

+ func (as AccountSharding) GetMaskBits() uint

+ func (as AccountSharding) LocalID() ChainID

+ func (as AccountSharding) Number() int

+ func (as AccountSharding) ParentID() ChainID

+ func (as AccountSharding) Pos(id ChainID) int

+ func (as AccountSharding) ShardTo(v interface{}) ChainID

+ type AccountShards struct

+ func NewAccountShards(parent ChainStruct, chains []ChainID) AccountShards

+ func (s AccountShards) GetMaskBits() uint

+ type Address [AddressLength]byte

+ func AddressFromPubSlice(pub []byte) (Address, error)

+ func BigToAddress(b *big.Int) Address

+ func BytesToAddress(b []byte) Address

+ func BytesToAddressP(b []byte) *Address

+ func CreateAddress(b Address, nonce uint64) Address

+ func HexToAddress(s string) Address

+ func StringsToAddresses(strings []string) []Address

+ func (a *Address) Generate() error

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

+ func (a *Address) UnmarshalText(input []byte) error

+ func (a Address) Big() *big.Int

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

+ func (a Address) Clone() Address

+ func (a Address) Hash() Hash

+ func (a Address) Hex() string

+ func (a Address) IsNoGas() bool

+ func (a Address) IsReserved() bool

+ func (a Address) IsSystemContract() bool

+ func (a Address) MarshalText() ([]byte, error)

+ func (a Address) NoCheck() bool

+ func (a Address) String() string

+ type AddressShard struct

+ Index BitIndex

+ Value Bits

+ func (s *AddressShard) IsIn(addr Address) bool

+ func (s *AddressShard) IsValid() bool

+ type Addresser interface

+ Address func() Address

+ type BitIndex int

+ func (p BitIndex) BitPos() uint

+ func (p BitIndex) BytePos() int

+ func (p BitIndex) Mask(b byte) byte

+ type Bits []byte

+ func (bs Bits) Bit(index BitIndex) bool

+ func (bs Bits) Bits(length int) []bool

+ func (bs Bits) Byte(index int) (v byte, exist bool)

+ type BlockNum uint32

+ func (bn BlockNum) Bytes() []byte

+ func (bn BlockNum) IsLastOfEpoch() bool

+ func (bn BlockNum) IsNil() bool

+ func (bn BlockNum) String() string

+ type BootNode struct

+ BasicPort uint16

+ ConsensusPort0 uint16

+ ConsensusPort1 uint16

+ DataPort uint16

+ IP string

+ NodeID NodeID

+ type ChainAttr string

+ const AttrNoGas

+ const AttrPoC

+ const AttrReward

+ func (a ChainAttr) IsValid() bool

+ type ChainAttrs []ChainAttr

+ func (a *ChainAttrs) Add(attrs ...ChainAttr) error

+ func (a *ChainAttrs) AddByName(names ...string) error

+ func (a ChainAttrs) Clone() ChainAttrs

+ func (a ChainAttrs) Contains(attr ChainAttr) bool

+ func (a ChainAttrs) FromMap(m map[ChainAttr]struct{}) ChainAttrs

+ func (a ChainAttrs) Len() int

+ func (a ChainAttrs) Less(i, j int) bool

+ func (a ChainAttrs) Swap(i, j int)

+ func (a ChainAttrs) ToMap() map[ChainAttr]struct{}

+ func (a ChainAttrs) ToStringSlice() []string

+ type ChainID uint32

+ func BytesToChainID(bs []byte) ChainID

+ func (id ChainID) Bytes() []byte

+ func (id ChainID) Formalize() []byte

+ func (id ChainID) HashValue() ([]byte, error)

+ func (id ChainID) IsMain() bool

+ func (id ChainID) IsNil() bool

+ func (id ChainID) IsReserved() bool

+ func (id ChainID) IsSub() bool

+ func (id ChainID) IsUserDefined() bool

+ func (id ChainID) String() string

+ type ChainIDs []ChainID

+ func (ids ChainIDs) Clone() ChainIDs

+ func (ids ChainIDs) Len() int

+ func (ids ChainIDs) Less(i, j int) bool

+ func (ids ChainIDs) Swap(i, j int)

+ type ChainInfos struct

+ AdminPubs [][]byte

+ Attributes ChainAttrs

+ BootNodes []Dataserver

+ ChainVersion string

+ Datas NodeIDs

+ Election ElectionType

+ GenesisCommIds NodeIDs

+ GenesisDatas NodeIDs

+ HaveSecondCoin bool

+ SecondCoinId CoinID

+ SecondCoinName string

+ Syncblock bool

+ func (c *ChainInfos) AddBootNode(bootNode Dataserver) bool

+ func (c *ChainInfos) AddDataNode(node NodeID) bool

+ func (c *ChainInfos) AddrIsAdmin(addr Address) bool

+ func (c *ChainInfos) Clone() *ChainInfos

+ func (c *ChainInfos) GetDataNodes() []NodeID

+ func (c *ChainInfos) HasAttribute(attr ChainAttr) bool

+ func (c *ChainInfos) HasDataNode(nid NodeID) bool

+ func (c *ChainInfos) Index(nid NodeID) int

+ func (c *ChainInfos) IsGenesisDataNode(nid NodeID) bool

+ func (c *ChainInfos) IsMainChain() bool

+ func (c *ChainInfos) IsPocChain() bool

+ func (c *ChainInfos) IsRewardChain() bool

+ func (c *ChainInfos) Key() []byte

+ func (c *ChainInfos) PubIsAdmin(pub []byte) bool

+ func (c *ChainInfos) RemoveBootNode(node NodeID) bool

+ func (c *ChainInfos) RemoveDataNode(node NodeID) bool

+ func (c *ChainInfos) ReportTo() ChainID

+ func (c *ChainInfos) Sort()

+ func (c *ChainInfos) String() string

+ type ChainInfosShouldBe struct

+ AdminPubs [][]byte

+ Attributes ChainAttrs

+ BootNodes []BootNode

+ DataNodes DataNodes

+ Election ElectionType

+ Extra string

+ GenesisCommIds NodeIDs

+ LocalCurrencyID CoinID

+ LocalCurrencyName string

+ ReportTo ChainID

+ type ChainMode byte

+ const Branch

+ const Root

+ const Shard

+ const UnknownMode

+ func (m ChainMode) String() string

+ type ChainStruct struct

+ ID ChainID

+ Mode ChainMode

+ ParentID ChainID

+ func NewChainStruct(id, parentId ChainID) (cs *ChainStruct, err error)

+ func (s ChainStruct) String() string

+ func (s ChainStruct) Validate() error

+ type Cipherer interface

+ Priv func() []byte

+ Pub func() []byte

+ type CoinID uint16

+ func (c CoinID) IsSovereign() bool

+ type CommID int

+ func (i CommID) String() string

+ type DataNode struct

+ IsGenesis bool

+ NodeID NodeID

+ RpcAddress string

+ type DataNodes []DataNode

+ func (ds DataNodes) Len() int

+ func (ds DataNodes) Less(i, j int) bool

+ func (ds DataNodes) Swap(i, j int)

+ type Dataserver struct

+ BasicPort uint16

+ ChainID uint32

+ ConsensusPort0 uint16

+ ConsensusPort1 uint16

+ DataPort0 uint16

+ DataPort1 uint16

+ DataRpcPort uint16

+ IP string

+ NodeIDString string

+ func (d *Dataserver) Clone() *Dataserver

+ func (d *Dataserver) GetRpcAddr() string

+ func (d *Dataserver) HashValue() ([]byte, error)

+ func (d Dataserver) Compare(o Dataserver) int

+ func (d Dataserver) GetNodeID() (*NodeID, error)

+ func (d Dataserver) String() string

+ func (d Dataserver) Validation() error

+ type DvppError struct

+ Embedded error

+ Message string

+ func NewDvppError(msg string, embeded error) DvppError

+ func (e DvppError) Error() string

+ type DvppFormatError struct

+ func NewFormatError(format string, values ...interface{}) DvppFormatError

+ func (e DvppFormatError) Error() string

+ type ElectionType byte

+ func StringToElectionType(name string) (ElectionType, bool)

+ func (t ElectionType) Exclusiveness() bool

+ func (t ElectionType) IsManaged() bool

+ func (t ElectionType) IsValid() bool

+ func (t ElectionType) IsVrf() bool

+ func (t ElectionType) Name() string

+ func (t ElectionType) RewardNeeded() bool

+ func (t ElectionType) String() string

+ type Endpoint struct

+ Address string

+ NetType string

+ func (ep Endpoint) IsNil() bool

+ func (ep Endpoint) Network() string

+ func (ep Endpoint) String() string

+ type EpochNum uint64

+ func (en EpochNum) Bytes() []byte

+ func (en EpochNum) IsNil() bool

+ func (en EpochNum) String() string

+ type EraNum uint64

+ func (e *EraNum) String() string

+ func (e *EraNum) Value() EraNum

+ func (e EraNum) Bytes() []byte

+ func (e EraNum) Equals(era *EraNum) bool

+ func (e EraNum) IsNil() bool

+ type GasPool uint64

+ func (gp *GasPool) AddGas(amount uint64) *GasPool

+ func (gp *GasPool) Gas() uint64

+ func (gp *GasPool) String() string

+ func (gp *GasPool) SubGas(amount uint64) error

+ type Hash [HashLength]byte

+ func BigToHash(b *big.Int) Hash

+ func BytesToHash(b []byte) Hash

+ func BytesToHashP(b []byte) *Hash

+ func CopyHashs(hs []Hash) []Hash

+ func EncodeHash(v interface{}) Hash

+ func Hash256(v ...[]byte) Hash

+ func Hash256WithError(v ...[]byte) (Hash, error)

+ func Hash256p(v ...[]byte) *Hash

+ func HexToHash(s string) Hash

+ func NewHash(b []byte) *Hash

+ func (h *Hash) Clone() *Hash

+ func (h *Hash) Equals(v *Hash) bool

+ func (h *Hash) PrintString() string

+ func (h *Hash) SetBytes(b []byte)

+ func (h *Hash) Slice() []byte

+ func (h *Hash) SliceEqual(val []byte) bool

+ func (h *Hash) UnmarshalText(input []byte) error

+ func (h Hash) Big() *big.Int

+ func (h Hash) Bytes() []byte

+ func (h Hash) Generate(rand *mrand.Rand, size int) reflect.Value

+ func (h Hash) HashValue() ([]byte, error)

+ func (h Hash) Hex() string

+ func (h Hash) IsEmpty() bool

+ func (h Hash) IsNil() bool

+ func (h Hash) MarshalText() ([]byte, error)

+ func (h Hash) String() string

+ func (h Hash) TerminalString() string

+ type Hasher interface

+ HashValue func() ([]byte, error)

+ type Height uint64

+ func BytesToHeight(bs []byte) Height

+ func ToHeight(epoch EpochNum, bn BlockNum) Height

+ func (h Height) BlockNum() BlockNum

+ func (h Height) Bytes() []byte

+ func (h Height) Compare(o Height) int

+ func (h Height) EpochNum() EpochNum

+ func (h Height) EraNum() EraNum

+ func (h Height) HashValue() ([]byte, error)

+ func (h Height) IsLastOfEpoch() bool

+ func (h Height) IsNil() bool

+ func (h Height) Split() (epochNum EpochNum, blockNum BlockNum)

+ func (h Height) String() string

+ type Identifier interface

+ Address func() Address

+ AddressP func() *Address

+ type LastBlockMap struct

+ M map[ChainID]Height

+ func (m *LastBlockMap) CAS(key ChainID, value Height) bool

+ func (m *LastBlockMap) CopyMap() map[ChainID]Height

+ func (m *LastBlockMap) Get(key ChainID) (Height, bool)

+ func (m *LastBlockMap) Set(key ChainID, value Height)

+ type LruMap struct

+ Map *lru.Cache

+ func NewLruMap(size int) *LruMap

+ func (m *LruMap) Add(key interface{}, value interface{}) bool

+ func (m *LruMap) Clear()

+ func (m *LruMap) Contains(key interface{}) bool

+ func (m *LruMap) Get(key interface{}) interface{}

+ func (m *LruMap) Remove(key interface{})

+ type MerkleProofs struct

+ Hashs []Hash

+ Paths *big.Int

+ func NewMerkleProofs() *MerkleProofs

+ func (p *MerkleProofs) Append(h Hash, order bool)

+ func (p *MerkleProofs) Clone() *MerkleProofs

+ func (p *MerkleProofs) Deserialization(r io.Reader) (shouldBeNil bool, err error)

+ func (p *MerkleProofs) Get(index int) (h Hash, order bool, err error)

+ func (p *MerkleProofs) Key() (key uint64, ok bool)

+ func (p *MerkleProofs) Len() int

+ func (p *MerkleProofs) Order(i int) bool

+ func (p *MerkleProofs) Proof(toBeProof Hash) ([]byte, error)

+ func (p *MerkleProofs) Serialization(w io.Writer) error

+ func (p MerkleProofs) String() string

+ type NetInfo struct

+ NodeID *NodeID

+ func NewNetInfo(id *NodeID, basicAddr, consensusAddr1 string, consensusAddr2 string, ...) NetInfo

+ func (n NetInfo) AddAddr(ntype NetType, addr *Endpoint)

+ func (n NetInfo) GetAddr(ntype NetType) *Endpoint

+ type NetType byte

+ const BasicNet

+ const BranchDataNet

+ const ConsensusNet1

+ const ConsensusNet2

+ const RootDataNet

+ func ChooseConNetByEpoch(num EpochNum) NetType

+ func (n NetType) String() string

+ type NodeID [NodeIDBytes]byte

+ func BytesToNodeID(b []byte) NodeID

+ func GenerateNodeID() *NodeID

+ func ParseBytesToNodeIds(s []byte) ([]NodeID, error)

+ func ParseNodeID(nodeString string) (*NodeID, error)

+ func ParseNodeIDBytes(nodeBytes []byte) (*NodeID, error)

+ func PubToNodeID(pub []byte) (NodeID, error)

+ func StringsToNodeIDs(strings []string) ([]NodeID, error)

+ func (nid *NodeID) Bytes() []byte

+ func (nid *NodeID) Clone() *NodeID

+ func (nid *NodeID) Compare(to *NodeID) int

+ func (nid *NodeID) Generate() error

+ func (nid *NodeID) HashValue() ([]byte, error)

+ func (nid *NodeID) SetBytes(b []byte)

+ func (nid *NodeID) UnmarshalText(input []byte) error

+ func (nid NodeID) Hash() Hash

+ func (nid NodeID) MarshalText() ([]byte, error)

+ func (nid NodeID) New() *NodeID

+ func (nid NodeID) String() string

+ type NodeIDSet struct

+ func NewNodeIDSet(ids ...*NodeID) *NodeIDSet

+ func (ns *NodeIDSet) Delete(id *NodeID)

+ func (ns *NodeIDSet) Get(i int) (*NodeID, bool)

+ func (ns *NodeIDSet) GetIndex(id *NodeID) (int, bool)

+ func (ns *NodeIDSet) GetNodeIDs(chainid ChainID) NodeIDs

+ func (ns *NodeIDSet) Len() int

+ func (ns *NodeIDSet) Less(i, j int) bool

+ func (ns *NodeIDSet) Put(id *NodeID) bool

+ func (ns *NodeIDSet) Swap(i, j int)

+ type NodeIDs []NodeID

+ func ByteSlicesToNodeIDs(bss [][]byte) (NodeIDs, error)

+ func IdentifiersToNodeIDs(nis []NodeIdentifier) NodeIDs

+ func (ns *NodeIDs) AppendByHex(nidHex string) error

+ func (ns NodeIDs) Clone() NodeIDs

+ func (ns NodeIDs) Contains(nid NodeID) bool

+ func (ns NodeIDs) Equals(os NodeIDs) bool

+ func (ns NodeIDs) IsIn(nid NodeID) bool

+ func (ns NodeIDs) Len() int

+ func (ns NodeIDs) Less(i, j int) bool

+ func (ns NodeIDs) Remove(os NodeIDs) NodeIDs

+ func (ns NodeIDs) Swap(i, j int)

+ func (ns NodeIDs) ToBytesSlice() [][]byte

+ func (ns NodeIDs) ToMap() map[NodeID]struct{}

+ func (ns NodeIDs) Union(os NodeIDs) NodeIDs

+ type NodeIdentifier interface

+ NodeID func() NodeID

+ NodeIDP func() *NodeID

+ type NodeType byte

+ const Consensus

+ const Data

+ const Memo

+ const NoneNodeType

+ func (n NodeType) String() string

+ type RoutinePool struct

+ func NewRoutinePool(name string, routineSize int, queueSize int, workFunc WorkerFunc, ...) *RoutinePool

+ func (p *RoutinePool) PostHigher(v interface{})

+ func (p *RoutinePool) PostLower(v interface{})

+ func (p *RoutinePool) Start()

+ func (p *RoutinePool) Stop()

+ type Seed [SeedLength]byte

+ func BytesToSeed(b []byte) Seed

+ func (s *Seed) Byte() []byte

+ func (s *Seed) Clone() *Seed

+ func (s *Seed) Equals(v interface{}) bool

+ func (s *Seed) Generate() error

+ func (s *Seed) IsZero() bool

+ func (s *Seed) SetBytes(b []byte) *Seed

+ func (s *Seed) String() string

+ type Service interface

+ Close func() error

+ Init func() error

+ Start func() error

+ String func() string

+ type ServiceStateChanger interface

+ Closer func() error

+ Initializer func() error

+ Starter func() error

+ type ServiceStatus byte

+ const SSCreated

+ const SSInitialized

+ const SSStarted

+ const SSStopped

+ func (ss *ServiceStatus) CheckInit() error

+ func (ss *ServiceStatus) CheckStart() error

+ func (ss *ServiceStatus) CheckStop() error

+ type ShardInfo interface

+ AllIDs func() []ChainID

+ GetMaskBits func() uint

+ LocalID func() ChainID

+ Pos func(id ChainID) int

+ ShardTo func(interface{}) ChainID

+ func NewShardInfo(parent ChainStruct, currentChain ChainID, shards []ChainID) ShardInfo

+ type WorkerFunc func(workerName string, event interface{})