core

package

Go to main page

Versions in this module

v1

v1.0.8

Aug 21, 2018

Changes in this version

+ var DynastyConf *corepb.Dynasty

+ var DynastyTrie *trie.Trie

+ var GenesisDynastyTrie *trie.Trie

+ var GenesisRealTimestamp int64

+ var InitialDynastyKeepTime int64

+ func InitDynastyFromConf(chain *BlockChain, BlockIntervalInSecond, DynastyIntervalInSecond int64)

+ func LoadDynastyConf(filePath string, genesis *corepb.Genesis)

v1.0.7

Jul 17, 2018

Changes in this version

+ const LocalNvmGasLimitWithoutTimeoutAtHeight

+ const MainNetNvmGasLimitWithoutTimeoutAtHeight

+ const TestNetNvmGasLimitWithoutTimeoutAtHeight

+ var NvmGasLimitWithoutTimeoutAtHeight = TestNetNvmGasLimitWithoutTimeoutAtHeight

v1.0.6

Jun 25, 2018

v1.0.5

Jun 19, 2018

Changes in this version

+ const DefaultV8JSLibVersion

+ const LocalNewNvmExeTimeoutConsumeGasHeight

+ const LocalTransferFromContractFailureEventRecordableHeight

+ const LocalV8JSLibVersionControlHeight

+ const MainNetNewNvmExeTimeoutConsumeGasHeight

+ const MainNetTransferFromContractFailureEventRecordableHeight

+ const MainNetV8JSLibVersionControlHeight

+ const TestNetNewNvmExeTimeoutConsumeGasHeight

+ const TestNetTransferFromContractFailureEventRecordableHeight

+ const TestNetV8JSLibVersionControlHeight

+ var ErrInvalidJSLibVersion = errors.New("invalid js lib version")

+ var ErrUnexpected = errors.New("Unexpected sys error")

+ var LocalV8JSLibVersionHeightSlice = heightOfVersionSlice

+ var MainCompatArr = []string

+ var MainNetV8JSLibVersionHeightSlice = heightOfVersionSlice

+ var NewNvmExeTimeoutConsumeGasHeight = TestNetNewNvmExeTimeoutConsumeGasHeight

+ var TestCompatArr = []string

+ var TestNetV8JSLibVersionHeightSlice = heightOfVersionSlice

+ var TransferFromContractFailureEventRecordableHeight = TestNetTransferFromContractFailureEventRecordableHeight

+ var V8JSLibVersionControlHeight = TestNetV8JSLibVersionControlHeight

+ var V8JSLibVersionHeightSlice = TestNetV8JSLibVersionHeightSlice

+ var V8JSLibs = map[string][]string

+ func FindLastNearestLibVersion(deployVersion, libname string) string

+ func GetMaxV8JSLibVersionAtHeight(blockHeight uint64) string

+ func IsCompatibleStack(chainID uint32, hash byteutils.Hash) bool

type Block

+ func MockBlock(header *BlockHeader, height uint64) *Block

+ func (block *Block) RandomProof() string

type BlockChain

+ func (bc *BlockChain) IsActiveSyncing() bool

type WorldState

+ GetBlock func(txHash byteutils.Hash) ([]byte, error)

+ GetBlockHashByHeight func(height uint64) ([]byte, error)

v1.0.4

Jun 14, 2018

v1.0.3

May 22, 2018

Changes in this version

+ const LocalNvmMemoryLimitWithoutInjectHeight

+ const LocalWsResetRecordDependencyHeight

+ const MainNetAcceptFuncAvailableHeight

+ const MainNetDateAvailableHeight

+ const MainNetNvmMemoryLimitWithoutInjectHeight

+ const MainNetRandomAvailableHeight

+ const MainNetRecordCallContractResultHeight

+ const MainNetTransferFromContractEventRecordableHeight

+ const MainNetWsResetRecordDependencyHeight

+ const TestNetAcceptFuncAvailableHeight

+ const TestNetDateAvailableHeight

+ const TestNetNvmMemoryLimitWithoutInjectHeight

+ const TestNetRandomAvailableHeight

+ const TestNetRecordCallContractResultHeight

+ const TestNetTransferFromContractEventRecordableHeight

+ const TestNetWsResetRecordDependencyHeight

+ var NvmMemoryLimitWithoutInjectHeight = TestNetNvmMemoryLimitWithoutInjectHeight

+ var WsResetRecordDependencyHeight = TestNetWsResetRecordDependencyHeight

type Transaction

+ func (tx *Transaction) JSONString() string

+ func (tx *Transaction) StringWithoutData() string

v1.0.2

May 8, 2018

Changes in this version

+ const ContractAcceptFunc

+ const DefaultAcceptFuncAvailableHeight

+ const DefaultDateAvailableHeight

+ const DefaultRandomAvailableHeight

+ const DefaultRecordCallContractResultHeight

+ const DefaultTransferFromContractEventRecordableHeight

+ const LocalAcceptFuncAvailableHeight

+ const LocalDateAvailableHeight

+ const LocalRandomAvailableHeight

+ const LocalRecordCallContractResultHeight

+ const LocalTransferFromContractEventRecordableHeight

+ const MainNetID

+ const SignNetID

+ const TopicTransferFromContract

+ var AcceptFuncAvailableHeight = DefaultAcceptFuncAvailableHeight

+ var DateAvailableHeight = DefaultDateAvailableHeight

+ var ErrBlockNotFound = errors.New("block not found in blockchain cache nor chain")

+ var ErrInvalidBlockRandom = errors.New("invalid block random")

+ var ErrUnsupportedKeyword = errors.New("transaction data has unsupported keyword")

+ var ErrVRFProofFailed = errors.New("VRF proof failed")

+ var MaxResultLength = 256

+ var RandomAvailableHeight = DefaultRandomAvailableHeight

+ var RecordCallContractResultHeight = DefaultRecordCallContractResultHeight

+ var TransferFromContractEventRecordableHeight = DefaultTransferFromContractEventRecordableHeight

+ func SetCompatibilityOptions(chainID uint32)

type AccountManager

+ GenerateRandomSeed func(*Address, []byte, []byte) ([]byte, []byte, error)

type AddressType

+ const UndefinedAddressType

type Block

+ func (block *Block) DateAvailable() bool

+ func (block *Block) HasRandomSeed() bool

+ func (block *Block) RandomAvailable() bool

+ func (block *Block) RandomSeed() string

+ func (block *Block) SetRandomSeed(vrfseed, vrfproof []byte)

type BlockChain

+ func (bc *BlockChain) GetContract(addr *Address) (state.Account, error)

+ func (bc *BlockChain) GetInputForVRFSigner(parentHash byteutils.Hash, height uint64) (ancestorHash, parentSeed []byte, err error)

type Consensus

+ NumberOfBlocksInDynasty func() uint64

+ type TransactionEventV2 struct

+ Error string

+ ExecuteResult string

+ GasUsed string

+ Hash string

+ Status int8

v1.0.1

Apr 16, 2018

Changes in this version

+ const TopicDropTransaction

+ var ErrTxDataBinPayLoadOutOfMaxLength = errors.New("data's payload is out of max data length in a binary tx")

+ var MaxDataBinPayloadLength = 64

+ func CheckGenesisTransaction(tx *Transaction) bool

type Consensus

+ CheckDoubleMint func(*Block) bool

type NVM

+ CheckV8Run func() error

v1.0.0

Mar 29, 2018

Changes in this version

+ const AddressBase58Length

+ const AddressDataEnd

+ const AddressPaddingIndex

+ const AddressPaddingLength

+ const AddressTypeIndex

+ const AddressTypeLength

+ const ChunkSize

+ const LIB

+ const MessageTypeBlockDownloadResponse

+ const MessageTypeParentBlockDownloadRequest

+ const NebulasFaith

+ const NoSender

+ const Padding

+ const PublicKeyDataLength

+ const SourceTypeJavaScript

+ const SourceTypeTypeScript

+ const TopicCallSmartContract

+ const TopicDeploySmartContract

+ const TopicLibBlock

+ const TopicNewTailBlock

+ const TopicPendingTransaction

+ const TopicRevertBlock

+ const TopicSendTransaction

+ const TopicTransactionExecutionResult

+ const TxExecutionFailed

+ const TxExecutionPendding

+ const TxExecutionSuccess

+ const TxHashByteLength

+ var DefaultLimitsOfTotalMemorySize uint64 = 40 * 1000 * 1000

+ var DefaultPayloadGas = util.NewUint128FromInt(1)

+ var ErrBelowGasPrice = errors.New("below the gas price")

+ var ErrCannotFindBlockAtGivenHeight = errors.New("cannot find a block at given height which is less than tail block's height")

+ var ErrCannotLoadGenesisBlock = errors.New("cannot load genesis block from storage")

+ var ErrCannotLoadGenesisConf = errors.New("cannot load genesis conf")

+ var ErrCannotLoadLIBBlock = errors.New("cannot load tail block from storage")

+ var ErrCannotLoadTailBlock = errors.New("cannot load latest irreversible block from storage")

+ var ErrCannotRevertLIB = errors.New("cannot revert latest irreversible block")

+ var ErrCloneAccountState = errors.New("Failed to clone account state")

+ var ErrCloneEventsState = errors.New("Failed to clone events state")

+ var ErrCloneTxsState = errors.New("Failed to clone txs state")

+ var ErrCloneWorldState = errors.New("Failed to clone world state")

+ var ErrContractCheckFailed = errors.New("contract check failed")

+ var ErrContractDeployFailed = errors.New("contract deploy failed")

+ var ErrContractTransactionAddressNotEqual = errors.New("contract transaction from-address not equal to to-address")

+ var ErrDoubleBlockMinted = errors.New("double block minted")

+ var ErrDoubleSealBlock = errors.New("cannot seal a block twice")

+ var ErrExecutionFailed = errors.New("execution failed")

+ var ErrGasCntOverflow = errors.New("the count of gas used is overflow")

+ var ErrGasFeeOverflow = errors.New("the fee of gas used is overflow")

+ var ErrGasLimitLessOrEqualToZero = errors.New("gas limit less or equal to 0")

+ var ErrGenesisConfNotMatch = errors.New("Failed to load genesis from storage, different with genesis conf")

+ var ErrGenesisNotEqualChainIDInDB = errors.New("Failed to check. genesis chainID not equal in db")

+ var ErrGenesisNotEqualDynastyInDB = errors.New("Failed to check. genesis dynasty not equal in db")

+ var ErrGenesisNotEqualDynastyLenInDB = errors.New("Failed to check. genesis dynasty length not equal in db")

+ var ErrGenesisNotEqualTokenInDB = errors.New("Failed to check. genesis TokenDistribution not equal in db")

+ var ErrGenesisNotEqualTokenLenInDB = errors.New("Failed to check. genesis TokenDistribution length not equal in db")

+ var ErrInvalidAddressChecksum = errors.New("address: invalid address checksum")

+ var ErrInvalidAddressFormat = errors.New("address: invalid address format")

+ var ErrInvalidAddressType = errors.New("address: invalid address type")

+ var ErrInvalidArgument = errors.New("invalid argument(s)")

+ var ErrInvalidBlockCannotFindParentInLocal = errors.New("invalid block received, download its parent from others")

+ var ErrInvalidBlockCannotFindParentInLocalAndTryDownload = errors.New("invalid block received, download its parent from others")

+ var ErrInvalidBlockCannotFindParentInLocalAndTrySync = errors.New("invalid block received, sync its parent from others")

+ var ErrInvalidBlockConsensusRoot = errors.New("invalid block consensus root hash")

+ var ErrInvalidBlockEventsRoot = errors.New("invalid block events root hash")

+ var ErrInvalidBlockOnCanonicalChain = errors.New("invalid block, it's not on canonical chain")

+ var ErrInvalidCallFunction = errors.New("invalid function of call payload")

+ var ErrInvalidCandidatePayloadAction = errors.New("invalid transaction candidate payload action")

+ var ErrInvalidConfigChainID = errors.New("invalid chainID, genesis chainID not equal to chainID in config")

+ var ErrInvalidDagBlock = errors.New("block's dag is incorrect")

+ var ErrInvalidDelegatePayloadAction = errors.New("invalid transaction vote payload action")

+ var ErrInvalidDelegateToNonCandidate = errors.New("cannot delegate to non-candidate")

+ var ErrInvalidDeploySource = errors.New("invalid source of deploy payload")

+ var ErrInvalidDeploySourceType = errors.New("invalid source type of deploy payload")

+ var ErrInvalidGasLimit = errors.New("invalid gas limit, should be in (0, 5*10^10]")

+ var ErrInvalidGasPrice = errors.New("invalid gas price, should be in (0, 10^12]")

+ var ErrInvalidProtoToBlock = errors.New("protobuf message cannot be converted into Block")

+ var ErrInvalidProtoToBlockHeader = errors.New("protobuf message cannot be converted into BlockHeader")

+ var ErrInvalidProtoToTransaction = errors.New("protobuf message cannot be converted into Transaction")

+ var ErrInvalidTransactionData = errors.New("invalid data in tx from Proto")

+ var ErrInvalidTransactionResultEvent = errors.New(...)

+ var ErrInvalidTransactionSigner = errors.New("invalid transaction signer")

+ var ErrInvalidTransfer = errors.New("transfer error: overflow or insufficient balance")

+ var ErrInvalidUnDelegateFromNonDelegatee = errors.New("cannot un-delegate from non-delegatee")

+ var ErrLinkToWrongParentBlock = errors.New("link the block to a block who is not its parent")

+ var ErrMissingParentBlock = errors.New("cannot find the block's parent block in storage")

+ var ErrNilArgument = errors.New("argument(s) is nil")

+ var ErrNoTimeToPackTransactions = errors.New("no time left to pack transactions in a block")

+ var ErrNotBlockInCanonicalChain = errors.New("cannot find the block in canonical chain")

+ var ErrNotFoundTransactionResultEvent = errors.New("transaction result event is not found ")

+ var ErrOutOfGasLimit = errors.New("out of gas limit")

+ var ErrTxDataPayLoadOutOfMaxLength = errors.New("data's payload is out of max data length")

+ var ErrTxExecutionFailed = errors.New("transaction execution failed")

+ var ErrZeroGasLimit = errors.New("gas limit should be greater than zero")

+ var ErrZeroGasPrice = errors.New("gas price should be greater than zero")

+ var GasCountPerByte = util.NewUint128FromInt(1)

+ var GenesisCoinbase = NewAddressFromPublicKey(make([]byte, PublicKeyDataLength))

+ var GenesisHash = make([]byte, BlockHashLength)

+ var GenesisTimestamp = int64(0)

+ var MaxDataPayLoadLength = 128 * 1024

+ var MaxEventErrLength = 256

+ var MinGasCountPerTransaction = util.NewUint128FromInt(20000)

+ var ParallelNum = 1

+ var PublicFuncNameChecker = regexp.MustCompile("^[a-zA-Z$][A-Za-z0-9_$]*$")

+ var TransactionGasPrice = util.NewUint128FromInt(1000000)

+ var TransactionMaxGas = util.NewUint128FromString("50000000000")

+ var TransactionMaxGasPrice = util.NewUint128FromString("1000000000000")

+ var VerifyExecutionTimeout = 0

+ func AcceptTransaction(tx *Transaction, ws WorldState) (bool, error)

+ func CheckContract(addr *Address, ws WorldState) (state.Account, error)

+ func CheckContractArgs(args string) error

+ func CheckGenesisConfByDB(pGenesisDB *corepb.Genesis, pGenesis *corepb.Genesis) error

+ func CheckTransaction(tx *Transaction, ws WorldState) (bool, error)

+ func DumpGenesis(chain *BlockChain) (*corepb.Genesis, error)

+ func HashPbBlock(pbBlock *corepb.Block) (byteutils.Hash, error)

+ func LoadGenesisConf(filePath string) (*corepb.Genesis, error)

+ func VerifyExecution(tx *Transaction, block *Block, ws WorldState) (bool, error)

+ type AccountManager interface

+ Accounts func() []*Address

+ Import func([]byte, []byte) (*Address, error)

+ Load func([]byte, []byte) (*Address, error)

+ Lock func(*Address) error

+ NewAccount func([]byte) (*Address, error)

+ Remove func(*Address, []byte) error

+ SignBlock func(*Address, *Block) error

+ SignHash func(*Address, byteutils.Hash, keystore.Algorithm) ([]byte, error)

+ SignTransaction func(*Address, *Transaction) error

+ SignTransactionWithPassphrase func(*Address, *Transaction, []byte) error

+ Unlock func(*Address, []byte, time.Duration) error

+ Update func(*Address, []byte, []byte) error

type Address

+ func NewContractAddressFromData(from ContractTxFrom, nonce ContractTxNonce) (*Address, error)

+ func RecoverSignerFromSignature(alg keystore.Algorithm, plainText []byte, cipherText []byte) (*Address, error)

+ func (a *Address) String() string

+ func (a *Address) Type() AddressType

+ type AddressType byte

+ const AccountAddress

+ const ContractAddress

+ type BinaryPayload struct

+ Data []byte

+ func LoadBinaryPayload(bytes []byte) (*BinaryPayload, error)

+ func NewBinaryPayload(data []byte) *BinaryPayload

+ func (payload *BinaryPayload) BaseGasCount() *util.Uint128

+ func (payload *BinaryPayload) Execute(limitedGas *util.Uint128, tx *Transaction, block *Block, ws WorldState) (*util.Uint128, string, error)

+ func (payload *BinaryPayload) ToBytes() ([]byte, error)

type Block

+ func LoadBlockFromStorage(hash byteutils.Hash, chain *BlockChain) (*Block, error)

+ func (block *Block) Alg() keystore.Algorithm

+ func (block *Block) Begin() error

+ func (block *Block) ChainID() uint32

+ func (block *Block) CheckContract(addr *Address) (state.Account, error)

+ func (block *Block) Commit()

+ func (block *Block) ConsensusRoot() *consensuspb.ConsensusRoot

+ func (block *Block) Dynasty() ([]byteutils.Hash, error)

+ func (block *Block) EventsRoot() byteutils.Hash

+ func (block *Block) ExecuteTransaction(tx *Transaction, ws WorldState) (bool, error)

+ func (block *Block) FetchEvents(txHash byteutils.Hash) ([]*state.Event, error)

+ func (block *Block) FetchExecutionResultEvent(txHash byteutils.Hash) (*state.Event, error)

+ func (block *Block) GetAccount(address byteutils.Hash) (state.Account, error)

+ func (block *Block) GetTransaction(hash byteutils.Hash) (*Transaction, error)

+ func (block *Block) ReturnTransactions()

+ func (block *Block) RollBack()

+ func (block *Block) SetSignature(alg keystore.Algorithm, sign byteutils.Hash)

+ func (block *Block) Sign(signature keystore.Signature) error

+ func (block *Block) Signature() byteutils.Hash

+ func (block *Block) Storage() storage.Storage

+ func (block *Block) Timestamp() int64

+ func (block *Block) Transactions() Transactions

+ func (block *Block) VerifyExecution() error

+ func (block *Block) VerifyIntegrity(chainID uint32, consensus Consensus) error

+ func (block *Block) WorldState() state.WorldState

type BlockChain

+ func (bc *BlockChain) CheckGenesisConfig(neb Neblet) error

+ func (bc *BlockChain) EventEmitter() *EventEmitter

+ func (bc *BlockChain) GasPrice() *util.Uint128

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

+ func (bc *BlockChain) GetBlockOnCanonicalChainByHash(blockHash byteutils.Hash) *Block

+ func (bc *BlockChain) GetBlockOnCanonicalChainByHeight(height uint64) *Block

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

+ func (bc *BlockChain) LoadGenesisFromStorage() (*Block, error)

+ func (bc *BlockChain) LoadLIBFromStorage() (*Block, error)

+ func (bc *BlockChain) LoadTailFromStorage() (*Block, error)

+ func (bc *BlockChain) SetLIB(lib *Block)

+ func (bc *BlockChain) SetSyncService(syncService SyncService)

+ func (bc *BlockChain) Setup(neb Neblet) error

+ func (bc *BlockChain) SimulateTransactionExecution(tx *Transaction) (*SimulateResult, error)

+ func (bc *BlockChain) Start()

+ func (bc *BlockChain) StartActiveSync() bool

+ func (bc *BlockChain) Stop()

+ func (bc *BlockChain) StoreBlockToStorage(block *Block) error

+ func (bc *BlockChain) StoreLIBHashToStorage(block *Block) error

+ func (bc *BlockChain) StoreTailHashToStorage(block *Block) error

+ type CallPayload struct

+ Args string

+ Function string

+ func LoadCallPayload(bytes []byte) (*CallPayload, error)

+ func NewCallPayload(function, args string) (*CallPayload, error)

+ func (payload *CallPayload) BaseGasCount() *util.Uint128

+ func (payload *CallPayload) Execute(limitedGas *util.Uint128, tx *Transaction, block *Block, ws WorldState) (*util.Uint128, string, error)

+ func (payload *CallPayload) ToBytes() ([]byte, error)

type Consensus

+ CheckTimeout func(*Block) bool

+ DisableMining func() error

+ Enable func() bool

+ EnableMining func(string) error

+ ForkChoice func() error

+ GenesisConsensusState func(*BlockChain, *corepb.Genesis) (state.ConsensusState, error)

+ NewState func(*consensuspb.ConsensusRoot, storage.Storage, bool) (state.ConsensusState, error)

+ Pending func() bool

+ ResumeMining func()

+ Setup func(Neblet) error

+ Start func()

+ Stop func()

+ SuspendMining func()

+ UpdateLIB func()

+ type ContractTxFrom []byte

+ type ContractTxNonce []byte

+ type DeployPayload struct

+ Args string

+ Source string

+ SourceType string

+ func LoadDeployPayload(bytes []byte) (*DeployPayload, error)

+ func NewDeployPayload(source, sourceType, args string) (*DeployPayload, error)

+ func (payload *DeployPayload) BaseGasCount() *util.Uint128

+ func (payload *DeployPayload) Execute(limitedGas *util.Uint128, tx *Transaction, block *Block, ws WorldState) (*util.Uint128, string, error)

+ func (payload *DeployPayload) ToBytes() ([]byte, error)

+ type EventEmitter struct

+ func NewEventEmitter(size int) *EventEmitter

+ func (emitter *EventEmitter) Deregister(subscribers ...*EventSubscriber)

+ func (emitter *EventEmitter) Register(subscribers ...*EventSubscriber)

+ func (emitter *EventEmitter) Start()

+ func (emitter *EventEmitter) Stop()

+ func (emitter *EventEmitter) Trigger(e *state.Event)

+ type EventSubscriber struct

+ func NewEventSubscriber(size int, topics []string) *EventSubscriber

+ func (s *EventSubscriber) EventChan() chan *state.Event

+ type NVM interface

+ CreateEngine func(block *Block, tx *Transaction, contract state.Account, ws WorldState) (SmartContractEngine, error)

+ type Neblet interface

+ AccountManager func() AccountManager

+ BlockChain func() *BlockChain

+ Config func() *nebletpb.Config

+ Consensus func() Consensus

+ EventEmitter func() *EventEmitter

+ Genesis func() *corepb.Genesis

+ IsActiveSyncing func() bool

+ NetService func() net.Service

+ Nvm func() NVM

+ SetGenesis func(*corepb.Genesis)

+ StartPprof func(string) error

+ Storage func() storage.Storage

+ type SimulateResult struct

+ Err error

+ GasUsed *util.Uint128

+ Msg string

+ type SmartContractEngine interface

+ Call func(source, sourceType, function, args string) (string, error)

+ DeployAndInit func(source, sourceType, args string) (string, error)

+ Dispose func()

+ ExecutionInstructions func() uint64

+ SetExecutionLimits func(uint64, uint64) error

+ type SyncService interface

+ IsActiveSyncing func() bool

+ Start func()

+ StartActiveSync func() bool

+ Stop func()

+ StopActiveSync func()

+ WaitingForFinish func()

type Transaction

+ func GetTransaction(hash byteutils.Hash, ws WorldState) (*Transaction, error)

+ func (tx *Transaction) ChainID() uint32

+ func (tx *Transaction) Data() []byte

+ func (tx *Transaction) GasCountOfTxBase() (*util.Uint128, error)

+ func (tx *Transaction) GasLimit() *util.Uint128

+ func (tx *Transaction) GasPrice() *util.Uint128

+ func (tx *Transaction) GenerateContractAddress() (*Address, error)

+ func (tx *Transaction) LoadPayload() (TxPayload, error)

+ func (tx *Transaction) Timestamp() int64

+ func (tx *Transaction) To() *Address

+ func (tx *Transaction) Type() string

+ func (tx *Transaction) Value() *util.Uint128

+ func (tx *Transaction) VerifyIntegrity(chainID uint32) error

+ type TransactionEvent struct

+ Error string

+ GasUsed string

+ Hash string

+ Status int8

type TransactionPool

+ func (pool *TransactionPool) Del(tx *Transaction)

+ func (pool *TransactionPool) GetTransaction(hash byteutils.Hash) *Transaction

+ func (pool *TransactionPool) PopWithBlacklist(fromBlacklist *sync.Map, toBlacklist *sync.Map) *Transaction

+ func (pool *TransactionPool) SetGasConfig(gasPrice, gasLimit *util.Uint128) error

+ type TxPayload interface

+ BaseGasCount func() *util.Uint128

+ Execute func(limitedGas *util.Uint128, tx *Transaction, block *Block, ws WorldState) (*util.Uint128, string, error)

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

+ type WorldState interface

+ CreateContractAccount func(owner byteutils.Hash, birthPlace byteutils.Hash) (state.Account, error)

+ Dynasty func() ([]byteutils.Hash, error)

+ DynastyRoot func() byteutils.Hash

+ FetchEvents func(byteutils.Hash) ([]*state.Event, error)

+ GetContractAccount func(addr byteutils.Hash) (state.Account, error)

+ GetOrCreateUserAccount func(addr byteutils.Hash) (state.Account, error)

+ GetTx func(txHash byteutils.Hash) ([]byte, error)

+ PutTx func(txHash byteutils.Hash, txBytes []byte) error

+ RecordEvent func(txHash byteutils.Hash, event *state.Event)

+ RecordGas func(from string, gas *util.Uint128) error

+ Reset func() error

v0

v0.3.0

Nov 7, 2017

Changes in this version

+ const Tail

+ const TxPayloadBinaryType

+ const TxPayloadCallType

+ const TxPayloadDeployType

+ const TxPayloadVoteType

+ var ErrDuplicatedBlock = errors.New("duplicated block")

+ var ErrDuplicatedTransaction = errors.New("duplicated transaction")

+ var ErrInvalidChainID = errors.New("invalid transaction chainID")

+ var ErrInvalidContractAddress = errors.New("invalid contract address")

+ var ErrInvalidTxPayloadType = errors.New("invalid transaction data payload type")

+ var ErrLargeTransactionNonce = errors.New("cannot accept a transaction with too bigger nonce")

+ var ErrSmallTransactionNonce = errors.New("cannot accept a transaction with smaller nonce")

+ func CheckGenesisBlock(block *Block) bool

+ func NewCallSCPayload(function, args string) ([]byte, error)

+ func NewDeploySCPayload(source, args string) ([]byte, error)

type Account

+ ContractLocalStorage *trie.BatchTrie

+ ContractOwner *Address

+ ContractTransactionHash Hash

+ UserBalance *util.Uint128

+ UserGlobalStorage *trie.BatchTrie

+ UserNonce uint64

+ func NewAccount(storage storage.Storage) *Account

+ func (acc *Account) AddBalance(value *util.Uint128)

+ func (acc *Account) IncreNonce()

+ func (acc *Account) SetContractOwner(address *Address)

+ func (acc *Account) SetContractTransactionHash(code []byte)

+ func (acc *Account) SubBalance(value *util.Uint128)

type Address

+ func NewContractAddressFromHash(s []byte) (*Address, error)

type Block

+ func (block *Block) Coinbase() *Address

+ func (block *Block) Execute() error

+ func (block *Block) FindOrCreateAccount(address *Address) (account *Account, created bool)

+ func (block *Block) GlobalContractStorage(contract *Address) *trie.BatchTrie

+ func (block *Block) LocalContractStorage(contract *Address) *trie.BatchTrie

type BlockChain

+ func (bc *BlockChain) GetTransaction(hash Hash) *Transaction

+ func (bc *BlockChain) Storage() storage.Storage

type Transaction

+ func (tx *Transaction) TargetContractAddress() *Address

v0.2.0

Oct 17, 2017

Changes in this version

+ const MessageTypeNewBlock

+ const MessageTypeNewTx

+ var ErrDuplicateBlock = errors.New("duplicate err")

+ var ErrInvalidBlockTxsRoot = errors.New("invalid block txs root hash")

+ type Account struct

+ Balance *util.Uint128

+ Nonce uint64

+ func (acc *Account) FromProto(msg proto.Message) error

+ func (acc *Account) ToProto() (proto.Message, error)

type Address

+ func AddressParse(s string) (*Address, error)

+ func AddressParseFromBytes(s []byte) (*Address, error)

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

+ func (a *Address) Equals(b Address) bool

type Block

+ func (block *Block) CollectTransactions(n int)

+ func (block *Block) FindAccount(address *Address) *Account

+ func (block *Block) FromProto(msg proto.Message) error

+ func (block *Block) GetBalance(address Hash) *util.Uint128

+ func (block *Block) GetNonce(address Hash) uint64

+ func (block *Block) ToProto() (proto.Message, error)

+ func (block *Block) TxsRoot() Hash

type BlockChain

+ func (bc *BlockChain) FetchDescendantInCanonicalChain(n int, block *Block) ([]*Block, error)

+ func (bc *BlockChain) FindCommonAncestorWithTail(block *Block) (*Block, error)

+ func (bc *BlockChain) TransactionPool() *TransactionPool

type BlockHeader

+ func (b *BlockHeader) FromProto(msg proto.Message) error

+ func (b *BlockHeader) ToProto() (proto.Message, error)

type BlockPool

+ func (pool *BlockPool) Push(block *Block) error

+ func (pool *BlockPool) PushAndBroadcast(block *Block) error

+ func (pool *BlockPool) PushAndRelay(block *Block) error

type Transaction

+ func (tx *Transaction) DataLen() int

+ func (tx *Transaction) From() []byte

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

+ func (tx *Transaction) Nonce() uint64

+ func (tx *Transaction) String() string

+ func (tx *Transaction) ToProto() (proto.Message, error)

type TransactionPool

+ func (pool *TransactionPool) Empty() bool

+ func (pool *TransactionPool) Pop() *Transaction

+ func (pool *TransactionPool) Push(tx *Transaction) error

+ func (pool *TransactionPool) PushAndBroadcast(tx *Transaction) error

+ func (pool *TransactionPool) PushAndRelay(tx *Transaction) error

+ func (pool *TransactionPool) RegisterInNetwork(nm net.Manager)

+ func (pool *TransactionPool) Start()

+ func (pool *TransactionPool) Stop()

v0.1.0

Sep 27, 2017

Changes in this version

+ const AddressChecksumLength

+ const AddressDataLength

+ const AddressLength

+ const BlockHashLength

+ const BlockReward

+ const EagleNebula

+ const TestNetID

+ var ErrFromAddressLocked = errors.New("from address locked")

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

+ var ErrInvalidAddress = errors.New("address: invalid address")

+ var ErrInvalidAddressDataLength = errors.New("address: invalid address data length")

+ var ErrInvalidBlockHash = errors.New("invalid block hash")

+ var ErrInvalidBlockStateRoot = errors.New("invalid block state root hash")

+ var ErrInvalidSignature = errors.New("invalid transaction signature")

+ var ErrInvalidTransactionHash = errors.New("invalid transaction hash")

+ type Address struct

+ func NewAddress(s []byte) (*Address, error)

+ func NewAddressFromPublicKey(s []byte) (*Address, error)

+ func Parse(s string) (*Address, error)

+ func ParseFromBytes(s []byte) (*Address, error)

+ func (a *Address) ToHex() string

+ type Block struct

+ func NewBlock(coinbase *Address, parentHash Hash, nonce uint64, stateTrie *trie.Trie, ...) *Block

+ func NewGenesisBlock(stateTrie *trie.Trie) *Block

+ func (block *Block) AddTransactions(txs ...*Transaction) *Block

+ func (block *Block) Deserialize(blob []byte) error

+ func (block *Block) Hash() Hash

+ func (block *Block) Height() uint64

+ func (block *Block) LinkParentBlock(parentBlock *Block) bool

+ func (block *Block) Nonce() uint64

+ func (block *Block) ParentBlock() *Block

+ func (block *Block) ParentHash() Hash

+ func (block *Block) Seal()

+ func (block *Block) Sealed() bool

+ func (block *Block) Serialize() ([]byte, error)

+ func (block *Block) SetNonce(nonce uint64)

+ func (block *Block) SetTimestamp(timestamp time.Time)

+ func (block *Block) StateRoot() Hash

+ func (block *Block) String() string

+ func (block *Block) Verify(bc *BlockChain) error

+ func (block *Block) VerifyHash(bc *BlockChain) error

+ func (block *Block) VerifyStateRoot() error

+ type BlockChain struct

+ func NewBlockChain(chainID int) *BlockChain

+ func (bc *BlockChain) BlockPool() *BlockPool

+ func (bc *BlockChain) ChainID() int

+ func (bc *BlockChain) ConsensusHandler() Consensus

+ func (bc *BlockChain) DetachedTailBlocks() []*Block

+ func (bc *BlockChain) Dump() string

+ func (bc *BlockChain) GetBlock(hash Hash) *Block

+ func (bc *BlockChain) NewBlock(coinbase *Address) *Block

+ func (bc *BlockChain) NewBlockFromParent(coinbase *Address, parentBlock *Block) *Block

+ func (bc *BlockChain) PutVerifiedNewBlocks(allBlocks, tailBlocks []*Block)

+ func (bc *BlockChain) SetConsensusHandler(handler Consensus)

+ func (bc *BlockChain) SetTailBlock(block *Block)

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

+ type BlockHeader struct

+ func (b *BlockHeader) Deserialize(blob []byte) error

+ func (b *BlockHeader) Serialize() ([]byte, error)

+ type BlockPool struct

+ func NewBlockPool() *BlockPool

+ func (pool *BlockPool) AddLocalBlock(block *Block)

+ func (pool *BlockPool) ReceivedBlockCh() chan *Block

+ func (pool *BlockPool) RegisterInNetwork(nm net.Manager)

+ func (pool *BlockPool) Start()

+ func (pool *BlockPool) Stop()

+ type Consensus interface

+ VerifyBlock func(*Block) error

+ type Hash []byte

+ func HashBlock(block *Block) Hash

+ func HashBlockStateRoot(block *Block) Hash

+ func HashTransaction(tx *Transaction) Hash

+ func (h Hash) Equals(b Hash) bool

+ func (h Hash) Hex() HexHash

+ func (h Hash) String() string

+ type HexHash string

+ func (hh HexHash) Hash() Hash

+ type Transaction struct

+ func NewTransaction(from, to Address, value uint64, nonce uint64, data []byte) *Transaction

+ func (tx *Transaction) Deserialize(blob []byte) error

+ func (tx *Transaction) Execute(stateTrie *trie.Trie) error

+ func (tx *Transaction) Hash() Hash

+ func (tx *Transaction) Serialize() ([]byte, error)

+ func (tx *Transaction) Sign() error

+ func (tx *Transaction) Verify() error

+ func (tx *Transaction) VerifySign() (bool, error)

+ type TransactionPool struct

+ func NewTransactionPool() *TransactionPool

+ func (txPool *TransactionPool) Put(tx *Transaction)

+ type Transactions []*Transaction

+ func (txs *Transactions) Deserialize(blob []byte) error

+ func (txs *Transactions) Serialize() ([]byte, error)

Incompatible versions in this module

v2.1.0+incompatible

Aug 7, 2019

v2.0.2+incompatible

Jun 20, 2019

v2.0.1+incompatible

May 5, 2019

v2.0.0+incompatible

Apr 15, 2019

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL