Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

core

package

Go to main page

Versions in this module

v0

v0.5.3

Jun 14, 2019

v0.5.2

Jun 6, 2019

v0.5.1

May 25, 2019

v0.5.0

May 23, 2019

Changes in this version

+ const ChainDataTypeBlockH

+ const ChainDataTypeBlockN

+ const ChainDataTypeLatestH

+ const ChainDataTypeLatestN

+ const EventReqDhtGetMaxRetry

+ const EventReqDhtGetTimeout

+ const KeyChainID

+ const KeyLastBlock

+ const KeyPrefixBlockHash2Num

+ const KeyPrefixBlockNum2Hash

+ const KeyPrefixBody

+ const KeyPrefixHeader

+ const KeyPrefixStateTrie

+ const KeyPrefixTx

+ const OutputTxsDhtGetMaxRetry

+ const OutputTxsDhtGetTimeout

+ const TooFarBlocks

+ const TooFarTx

+ var EmptyRootHash = DeriveHash(Transactions{})

+ var ErrBlockBodyTxsMismatch = errors.New("block body txs mismatch")

+ var ErrBlockChainID = errors.New("block chainID mismatch")

+ var ErrBlockChainIDMismatch = errors.New("core.chain: chainID mismatch")

+ var ErrBlockChainNoStorage = errors.New("core.chain: must provide block chain storage")

+ var ErrBlockParentMismatch = errors.New("core.chain: block parent mismatch")

+ var ErrBlockParentMissing = errors.New("core.chain: block parent missing")

+ var ErrBlockSignatureMismatch = errors.New("core.chain: block signature mismatch")

+ var ErrBlockStateTrieMismatch = errors.New("core.chain: trie root hash mismatch")

+ var ErrBlockTooFarForChain = errors.New("block too far for chain head")

+ var ErrCoinbaseKeyNotFound = errors.New("coinbase not found in keystore")

+ var ErrInvalidProtoToTransaction = errors.New("failed to parse ProtoBuf msg to Transaction")

+ var ErrNoCoinbase = errors.New("coinbase not provided")

+ var ErrNoCoinbasePwdFile = errors.New("coinbase keystore password file not provided")

+ var ErrNoSignature = errors.New("no signature with tx")

+ var ErrNoSigner = errors.New("no signer found")

+ var ErrSignatureMismatch = errors.New("signature mismatch")

+ var ErrTxChainID = errors.New("transaction chainID mismatch")

+ var ErrTxFromMismatch = errors.New("tx sender mismatch")

+ func DeriveHash(list DerivableList) common.Hash

+ func GetStateDB(storage persistent.Storage) state.Database

+ type Block struct

+ func CopyBlock(b *Block) *Block

+ func NewBlock(header *BlockHeader, txs []*Transaction) *Block

+ func ParseBlock(enc []byte) (*Block, error)

+ func (b *Block) ChainID() uint32

+ func (b *Block) ConsensusRoot() common.Hash

+ func (b *Block) Extra() []byte

+ func (b *Block) GetAccount(address common.Address) state.Account

+ func (b *Block) Hash() common.Hash

+ func (b *Block) Number() uint64

+ func (b *Block) ParentHash() common.Hash

+ func (b *Block) ReceiptsRoot() common.Hash

+ func (b *Block) Sign(signer crypto.Signer) error

+ func (b *Block) Signers() (map[common.Address]crypto.Signature, error)

+ func (b *Block) StateRoot() common.Hash

+ func (b *Block) Time() uint64

+ func (b *Block) ToBytes() ([]byte, error)

+ func (b *Block) TxsRoot() common.Hash

+ func (b *Block) ValidatorAddr() []common.Address

+ func (b *Block) VerifyBody() error

+ func (b *Block) Write(putter persistent.Putter) error

+ type BlockChain struct

+ func NewBlockChain(chainID ChainID, storage persistent.Storage, engine consensus.Engine) (*BlockChain, error)

+ func NewBlockChainWithCore(core *Core) (*BlockChain, error)

+ func (bc *BlockChain) AddBlock(b *Block) error

+ func (bc *BlockChain) BuildNextBlock(parent *Block, t uint64, txs Transactions) (*Block, error)

+ func (bc *BlockChain) ChainID() ChainID

+ func (bc *BlockChain) CurrentBlockHeight() uint64

+ func (bc *BlockChain) GetBlockByHash(hash common.Hash) *Block

+ func (bc *BlockChain) GetBlockByNumber(number uint64) *Block

+ func (bc *BlockChain) GetBlockNum2Hash(number uint64) *common.Hash

+ func (bc *BlockChain) GetTxByHash(hash common.Hash) *Transaction

+ func (bc *BlockChain) GetValidators() []string

+ func (bc *BlockChain) LastBlock() *Block

+ func (bc *BlockChain) Reset() error

+ func (bc *BlockChain) State() (state.AccountTrie, error)

+ func (bc *BlockChain) StateAt(root common.Hash) (state.AccountTrie, error)

+ func (bc *BlockChain) Stop()

+ type BlockHeader struct

+ ChainID uint32

+ ConsensusRoot common.Hash

+ Extra []byte

+ Number uint64

+ ParentHash common.Hash

+ ReceiptsRoot common.Hash

+ StateRoot common.Hash

+ Time uint64

+ TxsRoot common.Hash

+ func CopyHeader(header *BlockHeader) *BlockHeader

+ func (bh *BlockHeader) Hash() ([]byte, error)

+ func (bh *BlockHeader) ToBytes() ([]byte, error)

+ type BlockPool struct

+ func NewBlockPool(core *Core) (*BlockPool, error)

+ func (bp *BlockPool) AddSealRequest(h, t uint64, txs Transactions)

+ func (bp *BlockPool) GetBlockByHash(hash common.Hash) *Block

+ func (bp *BlockPool) GetBlockByNumber(number uint64) *Block

+ func (bp *BlockPool) GetBlockNum2Hash(number uint64) *common.Hash

+ func (bp *BlockPool) Start()

+ func (bp *BlockPool) Stop()

+ type ChainID uint32

+ const MainNetID

+ const TestNetID

+ type ChainReader interface

+ GetBlockByHash func(hash common.Hash) *Block

+ GetBlockByNumber func(number uint64) *Block

+ GetBlockNum2Hash func(number uint64) *common.Hash

+ GetTxByHash func(hash common.Hash) *Transaction

+ type Core struct

+ func NewCore(node INode, conf *config.Config) (*Core, error)

+ func NewCoreWithGenesis(node INode, conf *config.Config, genesis *Genesis) (*Core, error)

+ func (c *Core) AddressFromPublicKey(publicKey []byte) ([]byte, error)

+ func (c *Core) Chain() *BlockChain

+ func (c *Core) FakeP2pRecv(msg *p2p.Message)

+ func (c *Core) GetChainData(kind string, key []byte) []byte

+ func (c *Core) GetMinerSigner() (crypto.Signer, error)

+ func (c *Core) GetPrivateKeyOfDefaultAccount() ([]byte, error)

+ func (c *Core) GetRemoteBlockByHash(hash common.Hash) (*Block, error)

+ func (c *Core) GetRemoteBlockByNumber(n uint64) (*Block, error)

+ func (c *Core) GetRemoteLatestHash() (*common.Hash, error)

+ func (c *Core) GetRemoteLatestNumber() (uint64, error)

+ func (c *Core) GetSigner() crypto.Signer

+ func (c *Core) IsSyncing() bool

+ func (c *Core) MinerAddr() *address.Address

+ func (c *Core) Start() error

+ func (c *Core) Stop() error

+ func (c *Core) TriggerSync()

+ func (c *Core) TxBroadcast(tx *Transaction) error

+ type DerivableList interface

+ GetEncoded func(index int) []byte

+ Len func() int

+ type Genesis struct

+ ChainID ChainID

+ Consensus struct{ ... }

+ Extra string

+ Hash string

+ InitYeeDist []InitYeeDist

+ Time int64

+ func LoadGenesis(id ChainID) (*Genesis, error)

+ func NewGenesis(chainID ChainID, initDist map[string]*big.Int, validators []string) (*Genesis, error)

+ func (g *Genesis) Commit(stateDB state.Database, putter persistent.Putter) (*Block, error)

+ type INode interface

+ AccountManager func() *accounts.AccountManager

+ Core func() *Core

+ NodeID func() string

+ P2pService func() p2p.Service

+ type InitYeeDist struct

+ Address string

+ Value string

+ type Receipt struct

+ type Receipts []*Receipt

+ func (rs Receipts) GetEncoded(index int) []byte

+ func (rs Receipts) Len() int

+ type Transaction struct

+ func NewTransaction(chainID uint32, nonce uint64, recipient *common.Address, amount *big.Int) *Transaction

+ func NewTransactionFromProto(msg proto.Message) (*Transaction, error)

+ func (t *Transaction) Amount() *big.Int

+ func (t *Transaction) ChainID() uint32

+ func (t *Transaction) Decode(enc []byte) error

+ func (t *Transaction) Encode() ([]byte, error)

+ func (t *Transaction) From() *common.Address

+ func (t *Transaction) FromProto(msg proto.Message) error

+ func (t *Transaction) Hash() *common.Hash

+ func (t *Transaction) Nonce() uint64

+ func (t *Transaction) Recipient() *common.Address

+ func (t *Transaction) Sign(signer crypto.Signer) error

+ func (t *Transaction) String() string

+ func (t *Transaction) To() *common.Address

+ func (t *Transaction) ToProto() (*corepb.Transaction, error)

+ func (t *Transaction) VerifySig() error

+ type TransactionPool struct

+ func NewTransactionPool(core *Core) (*TransactionPool, error)

+ func (tp *TransactionPool) Start()

+ func (tp *TransactionPool) Stop()

+ func (tp *TransactionPool) TxBroadcast(tx *Transaction) error

+ type Transactions []*Transaction

+ func (txs Transactions) GetEncoded(index int) []byte

+ func (txs Transactions) Len() int

+ func (txs Transactions) String() string

+ func (txs Transactions) Write(putter persistent.Putter) error