dag

package
v1.0.3 Latest Latest
Warning

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

 Go to latest Published: Oct 14, 2019 License: GPL-3.0, GPL-3.0 Imports: 37 Imported by: 0

README 

+------------------------------------------------------------------------------------------+
|                                                                                          |
|                                           Dag                                            |
|                                                                                          |
+--+-------------+-------------------+------------------------+---------------------+------+
   |             |                   |                        |                     |
   |             |                   |                        |                     |
   |             |                   |                        |                     |
   |             |                   |                        |                     |
+--v---+     +---v--+     +----------v---------+   +----------v--------+   +--------v------+
|      |     |      |     |                    +--->  UtxoRepository   |   |   Validator   |
|      +----->      +----->   UnitRepository   |   +-------------------+   +--------------++
|      |     |      |     |                    +---------------------------+              |
|      |     |      |     +------+----------+--------------+   |           |              |
|      |     |      |            |          |              |   |           |              |
|      |     |      |            |          |              |   |           |              |
|      |     |      |       +----v-----+  +-v-------+  +---v---v--+  +-----v----+         |
|TxPool|     |MemDag|       |  dagdb   |  |  idxdb  |  |  utxodb  |  |  statedb <---------+
|      |     |      |       +------+---+  +----+----+  +----+-----+  +-----+----+
|      |     |      |              |           |            |              |
|      |     |      |              |           |            |              |
|      |     |      |              |           |            |              |
|      |     |      |              |     +-----v------------v------+       |
|      |     |      |              |     |                         |       |
|      |     |      |              +---> |     ptndb.Database      | <-----+
|      |     |      |                    |                         |
+------+     +------+                    +-------------------------+

TxPool交易池

MemDag内存暂存单元

LevelDB存储

Documentation

Overview

Package dag is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Dag 

type Dag struct {
	Cache palletcache.ICache
	Db    ptndb.Database

	ChainHeadFeed *event.Feed

	Mutex           sync.RWMutex
	Memdag          memunit.IMemDag                     // memory unit
	PartitionMemDag map[modules.AssetId]memunit.IMemDag //其他分区的MemDag
	// contains filtered or unexported fields
}

func NewDag 

func NewDag(db ptndb.Database, cache palletcache.ICache, light bool) (*Dag, error)

newDag, with db , light to build a new dag firstly to check db migration, is updated ptn database.

func NewDag4GenesisInit 

func NewDag4GenesisInit(db ptndb.Database) (*Dag, error)

to build a new dag when init genesis

func NewDagForTest 

func NewDagForTest(db ptndb.Database) (*Dag, error)

to build a dag for test

func (*Dag) ActiveMediatorsCount 

func (d *Dag) ActiveMediatorsCount() int

author Albert·Gou

func (*Dag) AfterChainMaintenanceEvent 

func (dag *Dag) AfterChainMaintenanceEvent(arg *modules.ChainMaintenanceEvent)

after chain maintenance to set stable threshold

func (*Dag) AfterSysContractStateChangeEvent 

func (dag *Dag) AfterSysContractStateChangeEvent(arg *modules.SysContractStateChangeEvent)

to refresh partition memdag

func (*Dag) ChainThreshold 

func (d *Dag) ChainThreshold() int

author Albert·Gou

func (*Dag) CheckHeaderCorrect added in v1.0.3 

func (d *Dag) CheckHeaderCorrect(number int) error

func (*Dag) CheckUnitsCorrect added in v1.0.3 

func (d *Dag) CheckUnitsCorrect(assetId string, number int) error

func (*Dag) ClearUtxo 

func (dag *Dag) ClearUtxo(addr common.Address) error

clear all utxo by address

func (*Dag) Close 

func (d *Dag) Close()

close a dag

func (*Dag) CreateGenericTransaction 

func (dag *Dag) CreateGenericTransaction(from, to common.Address, daoAmount, daoFee uint64, certID *big.Int,
	msg *modules.Message, txPool txspool.ITxPool) (*modules.Transaction, uint64, error)

func (*Dag) CreateTokenTransaction 

func (dag *Dag) CreateTokenTransaction(from, to, toToken common.Address, daoAmount, daoFee uint64,
	daoAmountToken uint64,
	assetToken string, msg *modules.Message, txPool txspool.ITxPool) (*modules.Transaction, uint64, error)

to build a transfer transactions by the token, from to fee

func (*Dag) CreateUnit 

func (d *Dag) CreateUnit(mAddr common.Address, txpool txspool.ITxPool, t time.Time) (*modules.Unit, error)

createUnit, create a unit when mediator being produced

func (*Dag) CurrentHeader 

func (d *Dag) CurrentHeader(token modules.AssetId) *modules.Header

return latest header by assetId

func (*Dag) CurrentUnit 

func (d *Dag) CurrentUnit(token modules.AssetId) *modules.Unit

return stable unit in dag

func (*Dag) FastSyncCommitHead 

func (d *Dag) FastSyncCommitHead(hash common.Hash) error

FastSyncCommitHead sets the current head block to the one defined by the hash irrelevant what the chain contents were prior.

func (*Dag) GenTransferPtnTx 

func (dag *Dag) GenTransferPtnTx(from, to common.Address, daoAmount uint64, text *string,
	txPool txspool.ITxPool) (*modules.Transaction, uint64, error)

构建一个转ptn的转账交易

func (*Dag) GenVoteMediatorTx 

func (dag *Dag) GenVoteMediatorTx(voter common.Address, mediators map[string]bool,
	txPool txspool.ITxPool) (*modules.Transaction, uint64, error)

to build a vote mediator transaction

func (*Dag) GenerateUnit 

func (dag *Dag) GenerateUnit(when time.Time, producer common.Address, groupPubKey []byte, ks *keystore.KeyStore,
	txpool txspool.ITxPool) (*modules.Unit, error)

GenerateUnit, generate unit @author Albert·Gou

func (*Dag) GetAccountVotedMediators 

func (d *Dag) GetAccountVotedMediators(addr common.Address) map[string]bool

func (*Dag) GetActiveJuries 

func (d *Dag) GetActiveJuries() []common.Address

func (*Dag) GetActiveMediator 

func (d *Dag) GetActiveMediator(add common.Address) *core.Mediator

author Albert·Gou

func (*Dag) GetActiveMediatorAddr 

func (d *Dag) GetActiveMediatorAddr(index int) common.Address

author Albert·Gou

func (*Dag) GetActiveMediatorInitPubs 

func (d *Dag) GetActiveMediatorInitPubs() []kyber.Point

author Albert·Gou

func (*Dag) GetActiveMediatorNode 

func (d *Dag) GetActiveMediatorNode(index int) *discover.Node

author Albert·Gou

func (*Dag) GetActiveMediatorNodes 

func (d *Dag) GetActiveMediatorNodes() map[string]*discover.Node

author Albert·Gou

func (*Dag) GetActiveMediators 

func (d *Dag) GetActiveMediators() []common.Address

author Albert·Gou

func (*Dag) GetAddr1TokenUtxos 

func (d *Dag) GetAddr1TokenUtxos(addr common.Address, asset *modules.Asset) (
	map[modules.OutPoint]*modules.Utxo, error)

get the token balance by address and asset

func (*Dag) GetAddrByOutPoint 

func (d *Dag) GetAddrByOutPoint(outPoint *modules.OutPoint) (common.Address, error)

return address by outpoint

func (*Dag) GetAddrOutpoints 

func (d *Dag) GetAddrOutpoints(addr common.Address) ([]modules.OutPoint, error)

return all outpoint by address

func (*Dag) GetAddrStableUtxos added in v1.0.3 

func (d *Dag) GetAddrStableUtxos(addr common.Address) (map[modules.OutPoint]*modules.Utxo, error)

func (*Dag) GetAddrTransactions 

func (d *Dag) GetAddrTransactions(addr common.Address) ([]*modules.TransactionWithUnitInfo, error)

return all transaction with unit info by address

func (*Dag) GetAddrUtxos 

func (d *Dag) GetAddrUtxos(addr common.Address) (map[modules.OutPoint]*modules.Utxo, error)

get all utxos in dag by address

func (*Dag) GetAllContractTpl 

func (d *Dag) GetAllContractTpl() ([]*modules.ContractTemplate, error)

return all contract templates

func (*Dag) GetAllContracts 

func (d *Dag) GetAllContracts() ([]*modules.Contract, error)

return all contract from dag

func (*Dag) GetAllLeafNodes 

func (d *Dag) GetAllLeafNodes() ([]*modules.Header, error)

All leaf nodes for dag downloader. 根据资产Id返回所有链的header。

func (*Dag) GetAllUtxos 

func (d *Dag) GetAllUtxos() (map[modules.OutPoint]*modules.Utxo, error)

return all utxo in dag

func (*Dag) GetAssetReference added in v1.0.1 

func (d *Dag) GetAssetReference(asset []byte) ([]*modules.ProofOfExistence, error)

return proof of existence by asset

func (*Dag) GetAssetTxHistory 

func (d *Dag) GetAssetTxHistory(asset *modules.Asset) ([]*modules.TransactionWithUnitInfo, error)

return all transaction with unit info by asset

func (*Dag) GetBlacklistAddress added in v1.0.3 

func (d *Dag) GetBlacklistAddress() ([]common.Address, *modules.StateVersion, error)

func (*Dag) GetChainParameters 

func (dag *Dag) GetChainParameters() *core.ChainParameters

func (*Dag) GetChaincode added in v1.0.3 

func (d *Dag) GetChaincode(contractId common.Address) (*list.CCInfo, error)

get chain codes by contract id

func (*Dag) GetCommon 

func (d *Dag) GetCommon(key []byte, stableDb bool) ([]byte, error)

dag's common geter, return the key's value

func (*Dag) GetCommonByPrefix 

func (d *Dag) GetCommonByPrefix(prefix []byte, stableDb bool) map[string][]byte

return the prefix's all key && value.

func (*Dag) GetContract 

func (d *Dag) GetContract(id []byte) (*modules.Contract, error)

get contract by contract id

func (*Dag) GetContractDeploy 

func (d *Dag) GetContractDeploy(tempId, contractId []byte, name string) (*modules.ContractDeployPayload, error)

get contract deploy by tempId, contractId, and name

func (*Dag) GetContractDevelopers added in v1.0.1 

func (d *Dag) GetContractDevelopers() ([]common.Address, error)

func (*Dag) GetContractJury 

func (d *Dag) GetContractJury(contractId []byte) (*modules.ElectionNode, error)

return electionInfo by contractId

func (*Dag) GetContractState 

func (d *Dag) GetContractState(id []byte, field string) ([]byte, *modules.StateVersion, error)

get contract state return codes, state version by contractId and field

func (*Dag) GetContractStatesById 

func (d *Dag) GetContractStatesById(id []byte) (map[string]*modules.ContractStateValue, error)

get contract all state

func (*Dag) GetContractStatesByPrefix 

func (d *Dag) GetContractStatesByPrefix(id []byte, prefix string) (map[string]*modules.ContractStateValue, error)

return contract state value by contractId, prefix

func (*Dag) GetContractTpl 

func (d *Dag) GetContractTpl(tplId []byte) (*modules.ContractTemplate, error)

return contract template by tlpId

func (*Dag) GetContractTplCode 

func (d *Dag) GetContractTplCode(tplId []byte) ([]byte, error)

return the tplid's tlp code

func (*Dag) GetContractsByTpl 

func (d *Dag) GetContractsByTpl(tplId []byte) ([]*modules.Contract, error)

return all contract by tplId from dag

func (*Dag) GetCurrentMemUnit 

func (d *Dag) GetCurrentMemUnit(assetId modules.AssetId, index uint64) *modules.Unit

return latest unit in the memdag of assetid

func (*Dag) GetCurrentUnit 

func (d *Dag) GetCurrentUnit(assetId modules.AssetId) *modules.Unit

return higher unit in memdag

func (*Dag) GetCurrentUnitIndex 

func (d *Dag) GetCurrentUnitIndex(token modules.AssetId) (*modules.ChainIndex, error)

return the chain index by assetId

func (*Dag) GetDataVersion 

func (d *Dag) GetDataVersion() (*modules.DataVersion, error)

return a data version from dag

func (*Dag) GetDynGlobalProp 

func (d *Dag) GetDynGlobalProp() *modules.DynamicGlobalProperty

func (*Dag) GetFileInfo 

func (d *Dag) GetFileInfo(filehash []byte) ([]*modules.FileInfo, error)

return a file info by the filehash

func (*Dag) GetGenesisUnit 

func (d *Dag) GetGenesisUnit() (*modules.Unit, error)

return genesis unit of ptn chain

func (*Dag) GetGlobalProp 

func (d *Dag) GetGlobalProp() *modules.GlobalProperty

func (*Dag) GetHeaderByHash 

func (d *Dag) GetHeaderByHash(hash common.Hash) (*modules.Header, error)

return the header by hash in dag

func (*Dag) GetHeaderByNumber 

func (d *Dag) GetHeaderByNumber(number *modules.ChainIndex) (*modules.Header, error)

return the header by chain index in dag

func (*Dag) GetImmutableChainParameters 

func (dag *Dag) GetImmutableChainParameters() *core.ImmutableChainParameters

func (*Dag) GetIrreversibleUnitNum 

func (d *Dag) GetIrreversibleUnitNum(id modules.AssetId) uint64

func (*Dag) GetJurorByAddrHash added in v1.0.3 

func (d *Dag) GetJurorByAddrHash(hash common.Hash) (*modules.JurorDeposit, error)

func (*Dag) GetLightChainHeight 

func (d *Dag) GetLightChainHeight(assetId modules.AssetId) uint64

return a light chain's height by the assetId

func (*Dag) GetLightHeaderByHash 

func (d *Dag) GetLightHeaderByHash(headerHash common.Hash) (*modules.Header, error)

Light Palletone Subprotocal

func (*Dag) GetMainChain 

func (bc *Dag) GetMainChain() (*modules.MainChain, error)

return main chain from dag

func (*Dag) GetMainCurrentUnit 

func (d *Dag) GetMainCurrentUnit() *modules.Unit

return last main chain unit in memdag

func (*Dag) GetMediator 

func (d *Dag) GetMediator(add common.Address) *core.Mediator

func (*Dag) GetMediatorCount added in v1.0.2 

func (dag *Dag) GetMediatorCount() int

func (*Dag) GetMediatorInfo 

func (d *Dag) GetMediatorInfo(address common.Address) *modules.MediatorInfo

func (*Dag) GetMediatorSchl 

func (d *Dag) GetMediatorSchl() *modules.MediatorSchedule

func (*Dag) GetMediators 

func (dag *Dag) GetMediators() map[common.Address]bool

func (*Dag) GetNewestUnitTimestamp 

func (dag *Dag) GetNewestUnitTimestamp(token modules.AssetId) (int64, error)

func (*Dag) GetPartitionChains 

func (bc *Dag) GetPartitionChains() ([]*modules.PartitionChain, error)

return all partition chain from dag

func (*Dag) GetPrecedingMediatorNodes 

func (d *Dag) GetPrecedingMediatorNodes() map[string]*discover.Node

func (*Dag) GetPtnBalance 

func (d *Dag) GetPtnBalance(addr common.Address) uint64

func (*Dag) GetScheduledMediator 

func (dag *Dag) GetScheduledMediator(slotNum uint32) common.Address

func (*Dag) GetSlotAtTime 

func (dag *Dag) GetSlotAtTime(when time.Time) uint32

func (*Dag) GetSlotTime 

func (dag *Dag) GetSlotTime(slotNum uint32) time.Time

func (*Dag) GetStableChainIndex added in v1.0.3 

func (d *Dag) GetStableChainIndex(token modules.AssetId) *modules.ChainIndex

func (*Dag) GetStxoEntry added in v1.0.1 

func (d *Dag) GetStxoEntry(outpoint *modules.OutPoint) (*modules.Stxo, error)

get the stxoEntry by outpoint

func (*Dag) GetTransaction 

func (d *Dag) GetTransaction(hash common.Hash) (*modules.TransactionWithUnitInfo, error)

return the transaction with unit packed by hash

func (*Dag) GetTransactionOnly 

func (d *Dag) GetTransactionOnly(hash common.Hash) (*modules.Transaction, error)

return the transaction by hash

func (*Dag) GetTrieSyncProgress 

func (d *Dag) GetTrieSyncProgress() (uint64, error)

get trie sync progress

func (*Dag) GetTxByReqId 

func (d *Dag) GetTxByReqId(reqid common.Hash) (*modules.TransactionWithUnitInfo, error)

return the transaction with unit info by reqid

func (*Dag) GetTxFee 

func (d *Dag) GetTxFee(pay *modules.Transaction) (*modules.AmountAsset, error)

return the transaction's fee ,

func (*Dag) GetTxFromAddress 

func (d *Dag) GetTxFromAddress(tx *modules.Transaction) ([]common.Address, error)

return all address by the transaction

func (*Dag) GetTxHashByReqId 

func (d *Dag) GetTxHashByReqId(reqid common.Hash) (common.Hash, error)

return a transaction hash by the reqId

func (*Dag) GetTxOutput added in v1.0.1 

func (d *Dag) GetTxOutput(outpoint *modules.OutPoint) (*modules.Utxo, error)

get the txoutput by outpoint include UTXO and STXO

func (*Dag) GetTxRequesterAddress 

func (d *Dag) GetTxRequesterAddress(tx *modules.Transaction) (common.Address, error)

return requester's address from the transaction

func (*Dag) GetTxSearchEntry 

func (d *Dag) GetTxSearchEntry(hash common.Hash) (*modules.TxLookupEntry, error)

retunr the txLookEntry by transaction hash

func (*Dag) GetUnitByHash 

func (dag *Dag) GetUnitByHash(hash common.Hash) (*modules.Unit, error)

func (*Dag) GetUnitByNumber 

func (d *Dag) GetUnitByNumber(number *modules.ChainIndex) (*modules.Unit, error)

return the unit by chain index

func (*Dag) GetUnitHash added in v1.0.2 

func (d *Dag) GetUnitHash(number *modules.ChainIndex) (common.Hash, error)

func (*Dag) GetUnitHashesFromHash 

func (d *Dag) GetUnitHashesFromHash(hash common.Hash, max uint64) []common.Hash

GetBlockHashesFromHash retrieves a number of block hashes starting at a given hash, fetching towards the genesis block.

func (*Dag) GetUnitNumber 

func (d *Dag) GetUnitNumber(hash common.Hash) (*modules.ChainIndex, error)

get unit chain index by hash

func (*Dag) GetUnitTransactions 

func (d *Dag) GetUnitTransactions(hash common.Hash) (modules.Transactions, error)

return unit's body , all transactions of unit by hash

func (*Dag) GetUnitTxsHash 

func (d *Dag) GetUnitTxsHash(hash common.Hash) ([]common.Hash, error)

GetUnitTxsHash is return the unit's txs hash list.

func (*Dag) GetUnstableUnits 

func (d *Dag) GetUnstableUnits() []*modules.Unit

return all unstable units in memdag

func (*Dag) GetUtxoEntry 

func (d *Dag) GetUtxoEntry(outpoint *modules.OutPoint) (*modules.Utxo, error)

get the utxoEntry by outpoint

func (*Dag) GetUtxoView 

func (d *Dag) GetUtxoView(tx *modules.Transaction) (*txspool.UtxoViewpoint, error)

get the tx's utxoView

func (*Dag) GetUtxosOutViewbyTx 

func (d *Dag) GetUtxosOutViewbyTx(tx *modules.Transaction) *txspool.UtxoViewpoint

get the tx's utxoViewpoint

func (*Dag) GetUtxosOutViewbyUnit 

func (d *Dag) GetUtxosOutViewbyUnit(unit *modules.Unit) *txspool.UtxoViewpoint

get the unit's utxoViewPoint

func (*Dag) GetVotingForMediator added in v1.0.3 

func (d *Dag) GetVotingForMediator(addStr string) (map[string]uint64, error)

func (*Dag) HasHeader 

func (d *Dag) HasHeader(hash common.Hash, number uint64) bool

return has header exist in dag or not by hash

func (*Dag) HasUnit 

func (d *Dag) HasUnit(hash common.Hash) bool

return the unit exist in dag is true or false

func (*Dag) HeadUnitHash 

func (dag *Dag) HeadUnitHash() common.Hash

func (*Dag) HeadUnitNum 

func (dag *Dag) HeadUnitNum() uint64

func (*Dag) HeadUnitTime 

func (dag *Dag) HeadUnitTime() int64

func (*Dag) InitPropertyDB 

func (dag *Dag) InitPropertyDB(genesis *core.Genesis, unit *modules.Unit) error

func (*Dag) InitStateDB 

func (dag *Dag) InitStateDB(genesis *core.Genesis, head *modules.Header) error

func (*Dag) InsertDag 

func (d *Dag) InsertDag(units modules.Units, txpool txspool.ITxPool, is_stable bool) (int, error)

InsertDag attempts to insert the given batch of blocks in to the canonical chain or, otherwise, create a fork. If an error is returned it will return the index number of the failing block as well an error describing what went wrong. After insertion is done, all accumulated events will be fired. reference : Eth InsertChain

func (*Dag) InsertHeaderDag 

func (d *Dag) InsertHeaderDag(headers []*modules.Header) (int, error)

InsertHeaderDag attempts to insert the given header chain in to the local chain, possibly creating a reorg. If an error is returned, it will return the index number of the failing header as well an error describing what went wrong.

The verify parameter can be used to fine tune whether nonce verification should be done or not. The reason behind the optional check is because some of the header retrieval mechanisms already need to verify nonces, as well as because nonces can be verified sparsely, not needing to check each.

func (*Dag) InsertLightHeader 

func (d *Dag) InsertLightHeader(headers []*modules.Header) (int, error)

insert headers into a light

func (*Dag) IsActiveJury 

func (d *Dag) IsActiveJury(addr common.Address) bool

func (*Dag) IsActiveMediator 

func (d *Dag) IsActiveMediator(add common.Address) bool

func (*Dag) IsConsecutiveMediator 

func (dag *Dag) IsConsecutiveMediator(nextMediator common.Address) bool

判断该mediator是下一个产块mediator

func (*Dag) IsContractDeveloper added in v1.0.1 

func (d *Dag) IsContractDeveloper(addr common.Address) bool

func (*Dag) IsEmpty 

func (d *Dag) IsEmpty() bool

func (*Dag) IsHeaderExist 

func (d *Dag) IsHeaderExist(hash common.Hash) bool

return has header exist in dag or not by hash

func (*Dag) IsIrreversibleUnit 

func (d *Dag) IsIrreversibleUnit(hash common.Hash) bool

func (*Dag) IsMediator 

func (dag *Dag) IsMediator(address common.Address) bool

func (*Dag) IsPrecedingMediator 

func (d *Dag) IsPrecedingMediator(add common.Address) bool

func (*Dag) IsSynced 

func (dag *Dag) IsSynced() bool

func (*Dag) IsTransactionExist 

func (d *Dag) IsTransactionExist(hash common.Hash) (bool, error)

return the transaction exist in dag is true or false

func (*Dag) IsUtxoSpent added in v1.0.1 

func (d *Dag) IsUtxoSpent(outpoint *modules.OutPoint) (bool, error)

return the true or false , is utxo is spent.

func (*Dag) JuryCount 

func (d *Dag) JuryCount() uint

func (*Dag) LastMaintenanceTime 

func (dag *Dag) LastMaintenanceTime() int64

func (*Dag) LookupMediatorInfo 

func (dag *Dag) LookupMediatorInfo() []*modules.MediatorInfo

func (*Dag) MediatorParticipationRate 

func (dag *Dag) MediatorParticipationRate() uint32

计算最近128个生产slots的mediator参与度，不包括当前unit Calculate the percent of unit production slots that were missed in the past 128 units, not including the current unit.

func (*Dag) MediatorVotedResults 

func (d *Dag) MediatorVotedResults() (map[string]uint64, error)

return all mediators voted results

func (*Dag) ParentsIsConfirmByHash 

func (d *Dag) ParentsIsConfirmByHash(hash common.Hash) bool

return the unit's parent confirmed is true or false

func (*Dag) PostChainEvents 

func (bc *Dag) PostChainEvents(events []interface{})

PostChainEvents iterates over the events generated by a chain insertion and posts them into the event feed. TODO: Should not expose PostChainEvents. The chain events should be posted in WriteBlock.

func (*Dag) PrecedingMediatorsCount 

func (d *Dag) PrecedingMediatorsCount() int

func (*Dag) PrecedingThreshold 

func (d *Dag) PrecedingThreshold() int

func (*Dag) QueryDbByKey 

func (d *Dag) QueryDbByKey(key []byte) ([]byte, error)

func (*Dag) QueryDbByPrefix 

func (d *Dag) QueryDbByPrefix(prefix []byte) ([]*modules.DbRow, error)

func (*Dag) QueryProofOfExistenceByReference 

func (d *Dag) QueryProofOfExistenceByReference(ref []byte) ([]*modules.ProofOfExistence, error)

return proof of existence

func (*Dag) RebuildAddrTxIndex added in v1.0.3 

func (d *Dag) RebuildAddrTxIndex() error

func (*Dag) RefreshAddrTxIndex 

func (d *Dag) RefreshAddrTxIndex() error

refresh all address transaction's index

func (*Dag) RefreshSysParameters 

func (d *Dag) RefreshSysParameters()

refresh system parameters

func (*Dag) RetrieveChaincodes added in v1.0.3 

func (d *Dag) RetrieveChaincodes() ([]*list.CCInfo, error)

func (*Dag) SaveChaincode 

func (d *Dag) SaveChaincode(contractId common.Address, cc *list.CCInfo) error

save chain code by contract id

func (*Dag) SaveCommon 

func (d *Dag) SaveCommon(key, val []byte) error

save the key, value

func (*Dag) SaveUnit 

func (d *Dag) SaveUnit(unit *modules.Unit, txpool txspool.ITxPool, isGenesis bool) error

save unit, 目前只用来存创世unit

func (*Dag) SaveUtxoView 

func (dag *Dag) SaveUtxoView(view map[modules.OutPoint]*modules.Utxo) error

save all utxo of a view

func (*Dag) SetUnitGroupSign 

func (d *Dag) SetUnitGroupSign(unitHash common.Hash, groupSign []byte, txpool txspool.ITxPool) error

set the unit's group sign ,and set to be stable unit by hash

func (*Dag) StoreDataVersion 

func (d *Dag) StoreDataVersion(dv *modules.DataVersion) error

store a data version in dag

func (*Dag) SubscribeActiveMediatorsUpdatedEvent 

func (d *Dag) SubscribeActiveMediatorsUpdatedEvent(ch chan<- modules.ActiveMediatorsUpdatedEvent) event.Subscription

subscribe active mediators updated event

func (*Dag) SubscribeChainEvent 

func (bc *Dag) SubscribeChainEvent(ch chan<- modules.ChainEvent) event.Subscription

SubscribeChainEvent registers a subscription of ChainEvent.

func (*Dag) SubscribeChainHeadEvent 

func (bc *Dag) SubscribeChainHeadEvent(ch chan<- modules.ChainHeadEvent) event.Subscription

SubscribeChainHeadEvent registers a subscription of ChainHeadEvent.

func (*Dag) SubscribeLogsEvent 

func (bc *Dag) SubscribeLogsEvent(ch chan<- []*types.Log) event.Subscription

SubscribeLogsEvent registers a subscription of []*types.Log.

func (*Dag) SubscribeRemovedLogsEvent 

func (bc *Dag) SubscribeRemovedLogsEvent(ch chan<- modules.RemovedLogsEvent) event.Subscription

SPV SubscribeRemovedLogsEvent registers a subscription of RemovedLogsEvent.

func (*Dag) SubscribeToGroupSignEvent 

func (d *Dag) SubscribeToGroupSignEvent(ch chan<- modules.ToGroupSignEvent) event.Subscription

func (*Dag) UnitIrreversibleTime 

func (d *Dag) UnitIrreversibleTime() time.Duration

func (*Dag) VerifyUnitGroupSign 

func (d *Dag) VerifyUnitGroupSign(unitHash common.Hash, groupSign []byte) error

type IDag 

type IDag interface {
	Close()

	GetCommon(key []byte, stableDb bool) ([]byte, error)
	GetCommonByPrefix(prefix []byte, stableDb bool) map[string][]byte
	SaveCommon(key, val []byte) error

	IsEmpty() bool
	GetStableChainIndex(token modules.AssetId) *modules.ChainIndex
	CurrentUnit(token modules.AssetId) *modules.Unit
	GetCurrentUnit(assetId modules.AssetId) *modules.Unit
	GetMainCurrentUnit() *modules.Unit
	GetCurrentMemUnit(assetId modules.AssetId, index uint64) *modules.Unit
	InsertDag(units modules.Units, txpool txspool.ITxPool, is_stable bool) (int, error)
	GetUnitByHash(hash common.Hash) (*modules.Unit, error)
	HasHeader(common.Hash, uint64) bool
	GetHeaderByNumber(number *modules.ChainIndex) (*modules.Header, error)
	GetHeaderByHash(common.Hash) (*modules.Header, error)
	GetUnstableUnits() []*modules.Unit

	CurrentHeader(token modules.AssetId) *modules.Header
	GetUnitTransactions(hash common.Hash) (modules.Transactions, error)
	GetUnitTxsHash(hash common.Hash) ([]common.Hash, error)
	GetTransaction(hash common.Hash) (*modules.TransactionWithUnitInfo, error)
	GetTransactionOnly(hash common.Hash) (*modules.Transaction, error)
	IsTransactionExist(hash common.Hash) (bool, error)
	GetTxSearchEntry(hash common.Hash) (*modules.TxLookupEntry, error)
	GetTxRequesterAddress(tx *modules.Transaction) (common.Address, error)

	// InsertHeaderDag inserts a batch of headers into the local chain.
	InsertHeaderDag([]*modules.Header) (int, error)
	HasUnit(hash common.Hash) bool
	//UnitIsConfirmedByHash(hash common.Hash) bool
	ParentsIsConfirmByHash(hash common.Hash) bool
	IsHeaderExist(hash common.Hash) bool
	SaveUnit(unit *modules.Unit, txpool txspool.ITxPool, isGenesis bool) error
	CreateUnit(mAddr common.Address, txpool txspool.ITxPool, t time.Time) (*modules.Unit, error)

	FastSyncCommitHead(common.Hash) error
	GetGenesisUnit() (*modules.Unit, error)

	GetContractState(contractid []byte, field string) ([]byte, *modules.StateVersion, error)
	GetContractStatesById(id []byte) (map[string]*modules.ContractStateValue, error)
	GetContractStatesByPrefix(id []byte, prefix string) (map[string]*modules.ContractStateValue, error)
	GetContractJury(contractId []byte) (*modules.ElectionNode, error)
	GetUnitNumber(hash common.Hash) (*modules.ChainIndex, error)

	GetUtxoView(tx *modules.Transaction) (*txspool.UtxoViewpoint, error)
	IsUtxoSpent(outpoint *modules.OutPoint) (bool, error)
	SubscribeChainHeadEvent(ch chan<- modules.ChainHeadEvent) event.Subscription
	SubscribeChainEvent(ch chan<- modules.ChainEvent) event.Subscription
	PostChainEvents(events []interface{})

	GetTrieSyncProgress() (uint64, error)
	GetUtxoEntry(outpoint *modules.OutPoint) (*modules.Utxo, error)
	GetStxoEntry(outpoint *modules.OutPoint) (*modules.Stxo, error)
	//Include Utxo and Stxo
	GetTxOutput(outpoint *modules.OutPoint) (*modules.Utxo, error)
	GetAddrOutpoints(addr common.Address) ([]modules.OutPoint, error)
	GetAddrUtxos(addr common.Address) (map[modules.OutPoint]*modules.Utxo, error)
	GetAddrStableUtxos(addr common.Address) (map[modules.OutPoint]*modules.Utxo, error)
	GetAddr1TokenUtxos(addr common.Address, asset *modules.Asset) (map[modules.OutPoint]*modules.Utxo, error)
	GetAllUtxos() (map[modules.OutPoint]*modules.Utxo, error)
	GetAddrTransactions(addr common.Address) ([]*modules.TransactionWithUnitInfo, error)
	GetAssetTxHistory(asset *modules.Asset) ([]*modules.TransactionWithUnitInfo, error)

	GetContractTpl(tplId []byte) (*modules.ContractTemplate, error)
	GetContractTplCode(tplId []byte) ([]byte, error)
	GetAllContractTpl() ([]*modules.ContractTemplate, error)

	GetContract(id []byte) (*modules.Contract, error)
	GetAllContracts() ([]*modules.Contract, error)
	GetContractsByTpl(tplId []byte) ([]*modules.Contract, error)
	GetUnitByNumber(number *modules.ChainIndex) (*modules.Unit, error)
	GetUnitHashesFromHash(hash common.Hash, max uint64) []common.Hash
	GetUnitHash(number *modules.ChainIndex) (common.Hash, error)

	//Mediator
	GetActiveMediator(add common.Address) *core.Mediator
	GetActiveMediatorNode(index int) *discover.Node
	GetActiveMediatorNodes() map[string]*discover.Node

	GetAddrByOutPoint(outPoint *modules.OutPoint) (common.Address, error)
	GetTxFee(pay *modules.Transaction) (*modules.AmountAsset, error)
	SetUnitGroupSign(unitHash common.Hash, groupSign []byte, txpool txspool.ITxPool) error
	SubscribeToGroupSignEvent(ch chan<- modules.ToGroupSignEvent) event.Subscription

	IsSynced() bool
	SubscribeActiveMediatorsUpdatedEvent(ch chan<- modules.ActiveMediatorsUpdatedEvent) event.Subscription
	GetPrecedingMediatorNodes() map[string]*discover.Node
	UnitIrreversibleTime() time.Duration
	GenTransferPtnTx(from, to common.Address, daoAmount uint64, text *string,
		txPool txspool.ITxPool) (*modules.Transaction, uint64, error)

	QueryDbByKey(key []byte) ([]byte, error)
	QueryDbByPrefix(prefix []byte) ([]*modules.DbRow, error)

	// SaveReqIdByTx
	GetTxHashByReqId(reqid common.Hash) (common.Hash, error)
	GetTxByReqId(reqid common.Hash) (*modules.TransactionWithUnitInfo, error)

	GetTxFromAddress(tx *modules.Transaction) ([]common.Address, error)

	GetFileInfo(filehash []byte) ([]*modules.FileInfo, error)

	GetLightHeaderByHash(headerHash common.Hash) (*modules.Header, error)
	GetLightChainHeight(assetId modules.AssetId) uint64
	InsertLightHeader(headers []*modules.Header) (int, error)
	GetAllLeafNodes() ([]*modules.Header, error)
	ClearUtxo(addr common.Address) error
	SaveUtxoView(view map[modules.OutPoint]*modules.Utxo) error

	HeadUnitTime() int64
	HeadUnitNum() uint64
	HeadUnitHash() common.Hash
	GetIrreversibleUnitNum(id modules.AssetId) uint64

	SaveChaincode(contractId common.Address, cc *list.CCInfo) error
	GetChaincode(contractId common.Address) (*list.CCInfo, error)
	RetrieveChaincodes() ([]*list.CCInfo, error)
	GetPartitionChains() ([]*modules.PartitionChain, error)
	GetMainChain() (*modules.MainChain, error)

	RefreshAddrTxIndex() error

	GenVoteMediatorTx(voter common.Address, mediators map[string]bool,
		txPool txspool.ITxPool) (*modules.Transaction, uint64, error)
	GetDynGlobalProp() *modules.DynamicGlobalProperty
	GetGlobalProp() *modules.GlobalProperty
	GetMediatorCount() int

	IsMediator(address common.Address) bool
	GetMediators() map[common.Address]bool
	GetActiveMediators() []common.Address
	GetAccountVotedMediators(addr common.Address) map[string]bool
	GetMediatorInfo(address common.Address) *modules.MediatorInfo

	GetVotingForMediator(addStr string) (map[string]uint64, error)
	MediatorVotedResults() (map[string]uint64, error)
	LookupMediatorInfo() []*modules.MediatorInfo
	IsActiveMediator(add common.Address) bool
	GetMediator(add common.Address) *core.Mediator

	GetNewestUnitTimestamp(token modules.AssetId) (int64, error)
	GetScheduledMediator(slotNum uint32) common.Address
	GetSlotAtTime(when time.Time) uint32
	GetChainParameters() *core.ChainParameters
	GetImmutableChainParameters() *core.ImmutableChainParameters

	GetDataVersion() (*modules.DataVersion, error)
	StoreDataVersion(dv *modules.DataVersion) error
	QueryProofOfExistenceByReference(ref []byte) ([]*modules.ProofOfExistence, error)
	GetAssetReference(asset []byte) ([]*modules.ProofOfExistence, error)

	IsActiveJury(addr common.Address) bool
	JuryCount() uint
	GetContractDevelopers() ([]common.Address, error)
	IsContractDeveloper(addr common.Address) bool
	GetActiveJuries() []common.Address
	CreateGenericTransaction(from, to common.Address, daoAmount, daoFee uint64, certID *big.Int,
		msg *modules.Message, txPool txspool.ITxPool) (*modules.Transaction, uint64, error)
	CreateTokenTransaction(from, to, toToken common.Address, daoAmount, daoFee, daoAmountToken uint64, assetToken string,
		msg *modules.Message, txPool txspool.ITxPool) (*modules.Transaction, uint64, error)
	ChainThreshold() int
	CheckHeaderCorrect(number int) error
	CheckUnitsCorrect(assetId string, number int) error
	GetBlacklistAddress() ([]common.Address, *modules.StateVersion, error)
	RebuildAddrTxIndex() error
	GetJurorByAddrHash(hash common.Hash) (*modules.JurorDeposit, error)
}

type MockIDag 

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

MockIDag is a mock of IDag interface

func NewMockIDag 

func NewMockIDag(ctrl *gomock.Controller) *MockIDag

NewMockIDag creates a new mock instance

func (*MockIDag) ChainThreshold added in v1.0.3 

func (m *MockIDag) ChainThreshold() int

ChainThreshold mocks base method

func (*MockIDag) CheckHeaderCorrect added in v1.0.3 

func (m *MockIDag) CheckHeaderCorrect(number int) error

CheckHeaderCorrect mocks base method

func (*MockIDag) CheckUnitsCorrect added in v1.0.3 

func (m *MockIDag) CheckUnitsCorrect(assetId string, number int) error

CheckUnitsCorrect mocks base method

func (*MockIDag) ClearUtxo 

func (m *MockIDag) ClearUtxo(addr common.Address) error

ClearUtxo mocks base method

func (*MockIDag) Close 

func (m *MockIDag) Close()

Close mocks base method

func (*MockIDag) CreateGenericTransaction added in v1.0.3 

func (m *MockIDag) CreateGenericTransaction(from, to common.Address, daoAmount, daoFee uint64, certID *big.Int, msg *modules.Message, txPool txspool.ITxPool) (*modules.Transaction, uint64, error)

CreateGenericTransaction mocks base method

func (*MockIDag) CreateTokenTransaction added in v1.0.3 

func (m *MockIDag) CreateTokenTransaction(from, to, toToken common.Address, daoAmount, daoFee, daoAmountToken uint64, assetToken string, msg *modules.Message, txPool txspool.ITxPool) (*modules.Transaction, uint64, error)

CreateTokenTransaction mocks base method

func (*MockIDag) CreateUnit 

func (m *MockIDag) CreateUnit(mAddr common.Address, txpool txspool.ITxPool, t time.Time) (*modules.Unit, error)

CreateUnit mocks base method

func (*MockIDag) CurrentHeader 

func (m *MockIDag) CurrentHeader(token modules.AssetId) *modules.Header

CurrentHeader mocks base method

func (*MockIDag) CurrentUnit 

func (m *MockIDag) CurrentUnit(token modules.AssetId) *modules.Unit

CurrentUnit mocks base method

func (*MockIDag) EXPECT 

func (m *MockIDag) EXPECT() *MockIDagMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockIDag) FastSyncCommitHead 

func (m *MockIDag) FastSyncCommitHead(arg0 common.Hash) error

FastSyncCommitHead mocks base method

func (*MockIDag) GenTransferPtnTx 

func (m *MockIDag) GenTransferPtnTx(from, to common.Address, daoAmount uint64, text *string, txPool txspool.ITxPool) (*modules.Transaction, uint64, error)

GenTransferPtnTx mocks base method

func (*MockIDag) GenVoteMediatorTx 

func (m *MockIDag) GenVoteMediatorTx(voter common.Address, mediators map[string]bool, txPool txspool.ITxPool) (*modules.Transaction, uint64, error)

GenVoteMediatorTx mocks base method

func (*MockIDag) GetAccountVotedMediators 

func (m *MockIDag) GetAccountVotedMediators(addr common.Address) map[string]bool

GetAccountVotedMediators mocks base method

func (*MockIDag) GetActiveJuries added in v1.0.3 

func (m *MockIDag) GetActiveJuries() []common.Address

GetActiveJuries mocks base method

func (*MockIDag) GetActiveMediator 

func (m *MockIDag) GetActiveMediator(add common.Address) *core.Mediator

GetActiveMediator mocks base method

func (*MockIDag) GetActiveMediatorNode 

func (m *MockIDag) GetActiveMediatorNode(index int) *discover.Node

GetActiveMediatorNode mocks base method

func (*MockIDag) GetActiveMediatorNodes 

func (m *MockIDag) GetActiveMediatorNodes() map[string]*discover.Node

GetActiveMediatorNodes mocks base method

func (*MockIDag) GetActiveMediators 

func (m *MockIDag) GetActiveMediators() []common.Address

GetActiveMediators mocks base method

func (*MockIDag) GetAddr1TokenUtxos 

func (m *MockIDag) GetAddr1TokenUtxos(addr common.Address, asset *modules.Asset) (map[modules.OutPoint]*modules.Utxo, error)

GetAddr1TokenUtxos mocks base method

func (*MockIDag) GetAddrByOutPoint 

func (m *MockIDag) GetAddrByOutPoint(outPoint *modules.OutPoint) (common.Address, error)

GetAddrByOutPoint mocks base method

func (*MockIDag) GetAddrOutpoints 

func (m *MockIDag) GetAddrOutpoints(addr common.Address) ([]modules.OutPoint, error)

GetAddrOutpoints mocks base method

func (*MockIDag) GetAddrStableUtxos added in v1.0.3 

func (m *MockIDag) GetAddrStableUtxos(addr common.Address) (map[modules.OutPoint]*modules.Utxo, error)

GetAddrStableUtxos mocks base method

func (*MockIDag) GetAddrTransactions 

func (m *MockIDag) GetAddrTransactions(addr common.Address) ([]*modules.TransactionWithUnitInfo, error)

GetAddrTransactions mocks base method

func (*MockIDag) GetAddrUtxos 

func (m *MockIDag) GetAddrUtxos(addr common.Address) (map[modules.OutPoint]*modules.Utxo, error)

GetAddrUtxos mocks base method

func (*MockIDag) GetAllContractTpl 

func (m *MockIDag) GetAllContractTpl() ([]*modules.ContractTemplate, error)

GetAllContractTpl mocks base method

func (*MockIDag) GetAllContracts 

func (m *MockIDag) GetAllContracts() ([]*modules.Contract, error)

GetAllContracts mocks base method

func (*MockIDag) GetAllLeafNodes 

func (m *MockIDag) GetAllLeafNodes() ([]*modules.Header, error)

GetAllLeafNodes mocks base method

func (*MockIDag) GetAllUtxos 

func (m *MockIDag) GetAllUtxos() (map[modules.OutPoint]*modules.Utxo, error)

GetAllUtxos mocks base method

func (*MockIDag) GetAssetReference added in v1.0.1 

func (m *MockIDag) GetAssetReference(asset []byte) ([]*modules.ProofOfExistence, error)

GetAssetReference mocks base method

func (*MockIDag) GetAssetTxHistory 

func (m *MockIDag) GetAssetTxHistory(asset *modules.Asset) ([]*modules.TransactionWithUnitInfo, error)

GetAssetTxHistory mocks base method

func (*MockIDag) GetBlacklistAddress added in v1.0.3 

func (m *MockIDag) GetBlacklistAddress() ([]common.Address, *modules.StateVersion, error)

GetBlacklistAddress mocks base method

func (*MockIDag) GetChainParameters 

func (m *MockIDag) GetChainParameters() *core.ChainParameters

GetChainParameters mocks base method

func (*MockIDag) GetChaincode added in v1.0.3 

func (m *MockIDag) GetChaincode(contractId common.Address) (*list.CCInfo, error)

GetChaincode mocks base method

func (*MockIDag) GetCommon 

func (m *MockIDag) GetCommon(key []byte, stableDb bool) ([]byte, error)

GetCommon mocks base method

func (*MockIDag) GetCommonByPrefix 

func (m *MockIDag) GetCommonByPrefix(prefix []byte, stableDb bool) map[string][]byte

GetCommonByPrefix mocks base method

func (*MockIDag) GetContract 

func (m *MockIDag) GetContract(id []byte) (*modules.Contract, error)

GetContract mocks base method

func (*MockIDag) GetContractDevelopers added in v1.0.3 

func (m *MockIDag) GetContractDevelopers() ([]common.Address, error)

GetContractDevelopers mocks base method

func (*MockIDag) GetContractJury 

func (m *MockIDag) GetContractJury(contractId []byte) (*modules.ElectionNode, error)

GetContractJury mocks base method

func (*MockIDag) GetContractState 

func (m *MockIDag) GetContractState(contractid []byte, field string) ([]byte, *modules.StateVersion, error)

GetContractState mocks base method

func (*MockIDag) GetContractStatesById 

func (m *MockIDag) GetContractStatesById(id []byte) (map[string]*modules.ContractStateValue, error)

GetContractStatesById mocks base method

func (*MockIDag) GetContractStatesByPrefix 

func (m *MockIDag) GetContractStatesByPrefix(id []byte, prefix string) (map[string]*modules.ContractStateValue, error)

GetContractStatesByPrefix mocks base method

func (*MockIDag) GetContractTpl 

func (m *MockIDag) GetContractTpl(tplId []byte) (*modules.ContractTemplate, error)

GetContractTpl mocks base method

func (*MockIDag) GetContractTplCode 

func (m *MockIDag) GetContractTplCode(tplId []byte) ([]byte, error)

GetContractTplCode mocks base method

func (*MockIDag) GetContractsByTpl 

func (m *MockIDag) GetContractsByTpl(tplId []byte) ([]*modules.Contract, error)

GetContractsByTpl mocks base method

func (*MockIDag) GetCurrentMemUnit 

func (m *MockIDag) GetCurrentMemUnit(assetId modules.AssetId, index uint64) *modules.Unit

GetCurrentMemUnit mocks base method

func (*MockIDag) GetCurrentUnit 

func (m *MockIDag) GetCurrentUnit(assetId modules.AssetId) *modules.Unit

GetCurrentUnit mocks base method

func (*MockIDag) GetDataVersion 

func (m *MockIDag) GetDataVersion() (*modules.DataVersion, error)

GetDataVersion mocks base method

func (*MockIDag) GetDynGlobalProp 

func (m *MockIDag) GetDynGlobalProp() *modules.DynamicGlobalProperty

GetDynGlobalProp mocks base method

func (*MockIDag) GetFileInfo 

func (m *MockIDag) GetFileInfo(filehash []byte) ([]*modules.FileInfo, error)

GetFileInfo mocks base method

func (*MockIDag) GetGenesisUnit 

func (m *MockIDag) GetGenesisUnit() (*modules.Unit, error)

GetGenesisUnit mocks base method

func (*MockIDag) GetGlobalProp added in v1.0.2 

func (m *MockIDag) GetGlobalProp() *modules.GlobalProperty

GetGlobalProp mocks base method

func (*MockIDag) GetHeaderByHash 

func (m *MockIDag) GetHeaderByHash(arg0 common.Hash) (*modules.Header, error)

GetHeaderByHash mocks base method

func (*MockIDag) GetHeaderByNumber 

func (m *MockIDag) GetHeaderByNumber(number *modules.ChainIndex) (*modules.Header, error)

GetHeaderByNumber mocks base method

func (*MockIDag) GetImmutableChainParameters 

func (m *MockIDag) GetImmutableChainParameters() *core.ImmutableChainParameters

GetImmutableChainParameters mocks base method

func (*MockIDag) GetIrreversibleUnitNum 

func (m *MockIDag) GetIrreversibleUnitNum(id modules.AssetId) uint64

GetIrreversibleUnitNum mocks base method

func (*MockIDag) GetJurorByAddrHash added in v1.0.3 

func (m *MockIDag) GetJurorByAddrHash(hash common.Hash) (*modules.JurorDeposit, error)

GetJurorByAddrHash mocks base method

func (*MockIDag) GetLightChainHeight 

func (m *MockIDag) GetLightChainHeight(assetId modules.AssetId) uint64

GetLightChainHeight mocks base method

func (*MockIDag) GetLightHeaderByHash 

func (m *MockIDag) GetLightHeaderByHash(headerHash common.Hash) (*modules.Header, error)

GetLightHeaderByHash mocks base method

func (*MockIDag) GetMainChain 

func (m *MockIDag) GetMainChain() (*modules.MainChain, error)

GetMainChain mocks base method

func (*MockIDag) GetMainCurrentUnit 

func (m *MockIDag) GetMainCurrentUnit() *modules.Unit

GetMainCurrentUnit mocks base method

func (*MockIDag) GetMediator added in v1.0.2 

func (m *MockIDag) GetMediator(add common.Address) *core.Mediator

GetMediator mocks base method

func (*MockIDag) GetMediatorCount added in v1.0.2 

func (m *MockIDag) GetMediatorCount() int

GetMediatorCount mocks base method

func (*MockIDag) GetMediatorInfo 

func (m *MockIDag) GetMediatorInfo(address common.Address) *modules.MediatorInfo

GetMediatorInfo mocks base method

func (*MockIDag) GetMediators 

func (m *MockIDag) GetMediators() map[common.Address]bool

GetMediators mocks base method

func (*MockIDag) GetNewestUnitTimestamp 

func (m *MockIDag) GetNewestUnitTimestamp(token modules.AssetId) (int64, error)

GetNewestUnitTimestamp mocks base method

func (*MockIDag) GetPartitionChains 

func (m *MockIDag) GetPartitionChains() ([]*modules.PartitionChain, error)

GetPartitionChains mocks base method

func (*MockIDag) GetPrecedingMediatorNodes 

func (m *MockIDag) GetPrecedingMediatorNodes() map[string]*discover.Node

GetPrecedingMediatorNodes mocks base method

func (*MockIDag) GetScheduledMediator 

func (m *MockIDag) GetScheduledMediator(slotNum uint32) common.Address

GetScheduledMediator mocks base method

func (*MockIDag) GetSlotAtTime 

func (m *MockIDag) GetSlotAtTime(when time.Time) uint32

GetSlotAtTime mocks base method

func (*MockIDag) GetStableChainIndex added in v1.0.3 

func (m *MockIDag) GetStableChainIndex(token modules.AssetId) *modules.ChainIndex

GetStableChainIndex mocks base method

func (*MockIDag) GetStxoEntry added in v1.0.1 

func (m *MockIDag) GetStxoEntry(outpoint *modules.OutPoint) (*modules.Stxo, error)

GetStxoEntry mocks base method

func (*MockIDag) GetTransaction 

func (m *MockIDag) GetTransaction(hash common.Hash) (*modules.TransactionWithUnitInfo, error)

GetTransaction mocks base method

func (*MockIDag) GetTransactionOnly 

func (m *MockIDag) GetTransactionOnly(hash common.Hash) (*modules.Transaction, error)

GetTransactionOnly mocks base method

func (*MockIDag) GetTrieSyncProgress 

func (m *MockIDag) GetTrieSyncProgress() (uint64, error)

GetTrieSyncProgress mocks base method

func (*MockIDag) GetTxByReqId 

func (m *MockIDag) GetTxByReqId(reqid common.Hash) (*modules.TransactionWithUnitInfo, error)

GetTxByReqId mocks base method

func (*MockIDag) GetTxFee 

func (m *MockIDag) GetTxFee(pay *modules.Transaction) (*modules.AmountAsset, error)

GetTxFee mocks base method

func (*MockIDag) GetTxFromAddress 

func (m *MockIDag) GetTxFromAddress(tx *modules.Transaction) ([]common.Address, error)

GetTxFromAddress mocks base method

func (*MockIDag) GetTxHashByReqId 

func (m *MockIDag) GetTxHashByReqId(reqid common.Hash) (common.Hash, error)

GetTxHashByReqId mocks base method

func (*MockIDag) GetTxOutput added in v1.0.1 

func (m *MockIDag) GetTxOutput(outpoint *modules.OutPoint) (*modules.Utxo, error)

GetTxOutput mocks base method

func (*MockIDag) GetTxRequesterAddress 

func (m *MockIDag) GetTxRequesterAddress(tx *modules.Transaction) (common.Address, error)

GetTxRequesterAddress mocks base method

func (*MockIDag) GetTxSearchEntry 

func (m *MockIDag) GetTxSearchEntry(hash common.Hash) (*modules.TxLookupEntry, error)

GetTxSearchEntry mocks base method

func (*MockIDag) GetUnitByHash 

func (m *MockIDag) GetUnitByHash(hash common.Hash) (*modules.Unit, error)

GetUnitByHash mocks base method

func (*MockIDag) GetUnitByNumber 

func (m *MockIDag) GetUnitByNumber(number *modules.ChainIndex) (*modules.Unit, error)

GetUnitByNumber mocks base method

func (*MockIDag) GetUnitHash added in v1.0.2 

func (m *MockIDag) GetUnitHash(number *modules.ChainIndex) (common.Hash, error)

GetUnitHash mocks base method

func (*MockIDag) GetUnitHashesFromHash 

func (m *MockIDag) GetUnitHashesFromHash(hash common.Hash, max uint64) []common.Hash

GetUnitHashesFromHash mocks base method

func (*MockIDag) GetUnitNumber 

func (m *MockIDag) GetUnitNumber(hash common.Hash) (*modules.ChainIndex, error)

GetUnitNumber mocks base method

func (*MockIDag) GetUnitTransactions 

func (m *MockIDag) GetUnitTransactions(hash common.Hash) (modules.Transactions, error)

GetUnitTransactions mocks base method

func (*MockIDag) GetUnitTxsHash 

func (m *MockIDag) GetUnitTxsHash(hash common.Hash) ([]common.Hash, error)

GetUnitTxsHash mocks base method

func (*MockIDag) GetUnstableUnits 

func (m *MockIDag) GetUnstableUnits() []*modules.Unit

GetUnstableUnits mocks base method

func (*MockIDag) GetUtxoEntry 

func (m *MockIDag) GetUtxoEntry(outpoint *modules.OutPoint) (*modules.Utxo, error)

GetUtxoEntry mocks base method

func (*MockIDag) GetUtxoView 

func (m *MockIDag) GetUtxoView(tx *modules.Transaction) (*txspool.UtxoViewpoint, error)

GetUtxoView mocks base method

func (*MockIDag) GetVotingForMediator added in v1.0.3 

func (m *MockIDag) GetVotingForMediator(addStr string) (map[string]uint64, error)

GetVotingForMediator mocks base method

func (*MockIDag) HasHeader 

func (m *MockIDag) HasHeader(arg0 common.Hash, arg1 uint64) bool

HasHeader mocks base method

func (*MockIDag) HasUnit 

func (m *MockIDag) HasUnit(hash common.Hash) bool

HasUnit mocks base method

func (*MockIDag) HeadUnitHash 

func (m *MockIDag) HeadUnitHash() common.Hash

HeadUnitHash mocks base method

func (*MockIDag) HeadUnitNum 

func (m *MockIDag) HeadUnitNum() uint64

HeadUnitNum mocks base method

func (*MockIDag) HeadUnitTime 

func (m *MockIDag) HeadUnitTime() int64

HeadUnitTime mocks base method

func (*MockIDag) InsertDag 

func (m *MockIDag) InsertDag(units modules.Units, txpool txspool.ITxPool, is_stable bool) (int, error)

InsertDag mocks base method

func (*MockIDag) InsertHeaderDag 

func (m *MockIDag) InsertHeaderDag(arg0 []*modules.Header) (int, error)

InsertHeaderDag mocks base method

func (*MockIDag) InsertLightHeader 

func (m *MockIDag) InsertLightHeader(headers []*modules.Header) (int, error)

InsertLightHeader mocks base method

func (*MockIDag) IsActiveJury added in v1.0.3 

func (m *MockIDag) IsActiveJury(addr common.Address) bool

IsActiveJury mocks base method

func (*MockIDag) IsActiveMediator 

func (m *MockIDag) IsActiveMediator(add common.Address) bool

IsActiveMediator mocks base method

func (*MockIDag) IsContractDeveloper added in v1.0.3 

func (m *MockIDag) IsContractDeveloper(addr common.Address) bool

IsContractDeveloper mocks base method

func (*MockIDag) IsEmpty 

func (m *MockIDag) IsEmpty() bool

IsEmpty mocks base method

func (*MockIDag) IsHeaderExist 

func (m *MockIDag) IsHeaderExist(hash common.Hash) bool

IsHeaderExist mocks base method

func (*MockIDag) IsMediator 

func (m *MockIDag) IsMediator(address common.Address) bool

IsMediator mocks base method

func (*MockIDag) IsSynced 

func (m *MockIDag) IsSynced() bool

IsSynced mocks base method

func (*MockIDag) IsTransactionExist 

func (m *MockIDag) IsTransactionExist(hash common.Hash) (bool, error)

IsTransactionExist mocks base method

func (*MockIDag) IsUtxoSpent added in v1.0.1 

func (m *MockIDag) IsUtxoSpent(outpoint *modules.OutPoint) (bool, error)

IsUtxoSpent mocks base method

func (*MockIDag) JuryCount added in v1.0.3 

func (m *MockIDag) JuryCount() uint

JuryCount mocks base method

func (*MockIDag) LookupMediatorInfo 

func (m *MockIDag) LookupMediatorInfo() []*modules.MediatorInfo

LookupMediatorInfo mocks base method

func (*MockIDag) MediatorVotedResults 

func (m *MockIDag) MediatorVotedResults() (map[string]uint64, error)

MediatorVotedResults mocks base method

func (*MockIDag) ParentsIsConfirmByHash 

func (m *MockIDag) ParentsIsConfirmByHash(hash common.Hash) bool

ParentsIsConfirmByHash mocks base method

func (*MockIDag) PostChainEvents 

func (m *MockIDag) PostChainEvents(events []interface{})

PostChainEvents mocks base method

func (*MockIDag) QueryDbByKey 

func (m *MockIDag) QueryDbByKey(key []byte) ([]byte, error)

QueryDbByKey mocks base method

func (*MockIDag) QueryDbByPrefix 

func (m *MockIDag) QueryDbByPrefix(prefix []byte) ([]*modules.DbRow, error)

QueryDbByPrefix mocks base method

func (*MockIDag) QueryProofOfExistenceByReference 

func (m *MockIDag) QueryProofOfExistenceByReference(ref []byte) ([]*modules.ProofOfExistence, error)

QueryProofOfExistenceByReference mocks base method

func (*MockIDag) RebuildAddrTxIndex added in v1.0.3 

func (m *MockIDag) RebuildAddrTxIndex() error

RebuildAddrTxIndex mocks base method

func (*MockIDag) RefreshAddrTxIndex 

func (m *MockIDag) RefreshAddrTxIndex() error

RefreshAddrTxIndex mocks base method

func (*MockIDag) RetrieveChaincodes added in v1.0.3 

func (m *MockIDag) RetrieveChaincodes() ([]*list.CCInfo, error)

RetrieveChaincodes mocks base method

func (*MockIDag) SaveChaincode 

func (m *MockIDag) SaveChaincode(contractId common.Address, cc *list.CCInfo) error

SaveChaincode mocks base method

func (*MockIDag) SaveCommon 

func (m *MockIDag) SaveCommon(key, val []byte) error

SaveCommon mocks base method

func (*MockIDag) SaveUnit 

func (m *MockIDag) SaveUnit(unit *modules.Unit, txpool txspool.ITxPool, isGenesis bool) error

SaveUnit mocks base method

func (*MockIDag) SaveUtxoView 

func (m *MockIDag) SaveUtxoView(view map[modules.OutPoint]*modules.Utxo) error

SaveUtxoView mocks base method

func (*MockIDag) SetUnitGroupSign 

func (m *MockIDag) SetUnitGroupSign(unitHash common.Hash, groupSign []byte, txpool txspool.ITxPool) error

SetUnitGroupSign mocks base method

func (*MockIDag) StoreDataVersion 

func (m *MockIDag) StoreDataVersion(dv *modules.DataVersion) error

StoreDataVersion mocks base method

func (*MockIDag) SubscribeActiveMediatorsUpdatedEvent 

func (m *MockIDag) SubscribeActiveMediatorsUpdatedEvent(ch chan<- modules.ActiveMediatorsUpdatedEvent) event.Subscription

SubscribeActiveMediatorsUpdatedEvent mocks base method

func (*MockIDag) SubscribeChainEvent 

func (m *MockIDag) SubscribeChainEvent(ch chan<- modules.ChainEvent) event.Subscription

SubscribeChainEvent mocks base method

func (*MockIDag) SubscribeChainHeadEvent 

func (m *MockIDag) SubscribeChainHeadEvent(ch chan<- modules.ChainHeadEvent) event.Subscription

SubscribeChainHeadEvent mocks base method

func (*MockIDag) SubscribeToGroupSignEvent 

func (m *MockIDag) SubscribeToGroupSignEvent(ch chan<- modules.ToGroupSignEvent) event.Subscription

SubscribeToGroupSignEvent mocks base method

func (*MockIDag) UnitIrreversibleTime 

func (m *MockIDag) UnitIrreversibleTime() time.Duration

UnitIrreversibleTime mocks base method

type MockIDagMockRecorder 

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

MockIDagMockRecorder is the mock recorder for MockIDag

func (*MockIDagMockRecorder) ChainThreshold added in v1.0.3 

func (mr *MockIDagMockRecorder) ChainThreshold() *gomock.Call

ChainThreshold indicates an expected call of ChainThreshold

func (*MockIDagMockRecorder) CheckHeaderCorrect added in v1.0.3 

func (mr *MockIDagMockRecorder) CheckHeaderCorrect(number interface{}) *gomock.Call

CheckHeaderCorrect indicates an expected call of CheckHeaderCorrect

func (*MockIDagMockRecorder) CheckUnitsCorrect added in v1.0.3 

func (mr *MockIDagMockRecorder) CheckUnitsCorrect(assetId, number interface{}) *gomock.Call

CheckUnitsCorrect indicates an expected call of CheckUnitsCorrect

func (*MockIDagMockRecorder) ClearUtxo 

func (mr *MockIDagMockRecorder) ClearUtxo(addr interface{}) *gomock.Call

ClearUtxo indicates an expected call of ClearUtxo

func (*MockIDagMockRecorder) Close 

func (mr *MockIDagMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close

func (*MockIDagMockRecorder) CreateGenericTransaction added in v1.0.3 

func (mr *MockIDagMockRecorder) CreateGenericTransaction(from, to, daoAmount, daoFee, certID, msg, txPool interface{}) *gomock.Call

CreateGenericTransaction indicates an expected call of CreateGenericTransaction

func (*MockIDagMockRecorder) CreateTokenTransaction added in v1.0.3 

func (mr *MockIDagMockRecorder) CreateTokenTransaction(from, to, toToken, daoAmount, daoFee, daoAmountToken, assetToken, msg, txPool interface{}) *gomock.Call

CreateTokenTransaction indicates an expected call of CreateTokenTransaction

func (*MockIDagMockRecorder) CreateUnit 

func (mr *MockIDagMockRecorder) CreateUnit(mAddr, txpool, t interface{}) *gomock.Call

CreateUnit indicates an expected call of CreateUnit

func (*MockIDagMockRecorder) CurrentHeader 

func (mr *MockIDagMockRecorder) CurrentHeader(token interface{}) *gomock.Call

CurrentHeader indicates an expected call of CurrentHeader

func (*MockIDagMockRecorder) CurrentUnit 

func (mr *MockIDagMockRecorder) CurrentUnit(token interface{}) *gomock.Call

CurrentUnit indicates an expected call of CurrentUnit

func (*MockIDagMockRecorder) FastSyncCommitHead 

func (mr *MockIDagMockRecorder) FastSyncCommitHead(arg0 interface{}) *gomock.Call

FastSyncCommitHead indicates an expected call of FastSyncCommitHead

func (*MockIDagMockRecorder) GenTransferPtnTx 

func (mr *MockIDagMockRecorder) GenTransferPtnTx(from, to, daoAmount, text, txPool interface{}) *gomock.Call

GenTransferPtnTx indicates an expected call of GenTransferPtnTx

func (*MockIDagMockRecorder) GenVoteMediatorTx 

func (mr *MockIDagMockRecorder) GenVoteMediatorTx(voter, mediators, txPool interface{}) *gomock.Call

GenVoteMediatorTx indicates an expected call of GenVoteMediatorTx

func (*MockIDagMockRecorder) GetAccountVotedMediators 

func (mr *MockIDagMockRecorder) GetAccountVotedMediators(addr interface{}) *gomock.Call

GetAccountVotedMediators indicates an expected call of GetAccountVotedMediators

func (*MockIDagMockRecorder) GetActiveJuries added in v1.0.3 

func (mr *MockIDagMockRecorder) GetActiveJuries() *gomock.Call

GetActiveJuries indicates an expected call of GetActiveJuries

func (*MockIDagMockRecorder) GetActiveMediator 

func (mr *MockIDagMockRecorder) GetActiveMediator(add interface{}) *gomock.Call

GetActiveMediator indicates an expected call of GetActiveMediator

func (*MockIDagMockRecorder) GetActiveMediatorNode 

func (mr *MockIDagMockRecorder) GetActiveMediatorNode(index interface{}) *gomock.Call

GetActiveMediatorNode indicates an expected call of GetActiveMediatorNode

func (*MockIDagMockRecorder) GetActiveMediatorNodes 

func (mr *MockIDagMockRecorder) GetActiveMediatorNodes() *gomock.Call

GetActiveMediatorNodes indicates an expected call of GetActiveMediatorNodes

func (*MockIDagMockRecorder) GetActiveMediators 

func (mr *MockIDagMockRecorder) GetActiveMediators() *gomock.Call

GetActiveMediators indicates an expected call of GetActiveMediators

func (*MockIDagMockRecorder) GetAddr1TokenUtxos 

func (mr *MockIDagMockRecorder) GetAddr1TokenUtxos(addr, asset interface{}) *gomock.Call

GetAddr1TokenUtxos indicates an expected call of GetAddr1TokenUtxos

func (*MockIDagMockRecorder) GetAddrByOutPoint 

func (mr *MockIDagMockRecorder) GetAddrByOutPoint(outPoint interface{}) *gomock.Call

GetAddrByOutPoint indicates an expected call of GetAddrByOutPoint

func (*MockIDagMockRecorder) GetAddrOutpoints 

func (mr *MockIDagMockRecorder) GetAddrOutpoints(addr interface{}) *gomock.Call

GetAddrOutpoints indicates an expected call of GetAddrOutpoints

func (*MockIDagMockRecorder) GetAddrStableUtxos added in v1.0.3 

func (mr *MockIDagMockRecorder) GetAddrStableUtxos(addr interface{}) *gomock.Call

GetAddrStableUtxos indicates an expected call of GetAddrStableUtxos

func (*MockIDagMockRecorder) GetAddrTransactions 

func (mr *MockIDagMockRecorder) GetAddrTransactions(addr interface{}) *gomock.Call

GetAddrTransactions indicates an expected call of GetAddrTransactions

func (*MockIDagMockRecorder) GetAddrUtxos 

func (mr *MockIDagMockRecorder) GetAddrUtxos(addr interface{}) *gomock.Call

GetAddrUtxos indicates an expected call of GetAddrUtxos

func (*MockIDagMockRecorder) GetAllContractTpl 

func (mr *MockIDagMockRecorder) GetAllContractTpl() *gomock.Call

GetAllContractTpl indicates an expected call of GetAllContractTpl

func (*MockIDagMockRecorder) GetAllContracts 

func (mr *MockIDagMockRecorder) GetAllContracts() *gomock.Call

GetAllContracts indicates an expected call of GetAllContracts

func (*MockIDagMockRecorder) GetAllLeafNodes 

func (mr *MockIDagMockRecorder) GetAllLeafNodes() *gomock.Call

GetAllLeafNodes indicates an expected call of GetAllLeafNodes

func (*MockIDagMockRecorder) GetAllUtxos 

func (mr *MockIDagMockRecorder) GetAllUtxos() *gomock.Call

GetAllUtxos indicates an expected call of GetAllUtxos

func (*MockIDagMockRecorder) GetAssetReference added in v1.0.1 

func (mr *MockIDagMockRecorder) GetAssetReference(asset interface{}) *gomock.Call

GetAssetReference indicates an expected call of GetAssetReference

func (*MockIDagMockRecorder) GetAssetTxHistory 

func (mr *MockIDagMockRecorder) GetAssetTxHistory(asset interface{}) *gomock.Call

GetAssetTxHistory indicates an expected call of GetAssetTxHistory

func (*MockIDagMockRecorder) GetBlacklistAddress added in v1.0.3 

func (mr *MockIDagMockRecorder) GetBlacklistAddress() *gomock.Call

GetBlacklistAddress indicates an expected call of GetBlacklistAddress

func (*MockIDagMockRecorder) GetChainParameters 

func (mr *MockIDagMockRecorder) GetChainParameters() *gomock.Call

GetChainParameters indicates an expected call of GetChainParameters

func (*MockIDagMockRecorder) GetChaincode added in v1.0.3 

func (mr *MockIDagMockRecorder) GetChaincode(contractId interface{}) *gomock.Call

GetChaincode indicates an expected call of GetChaincode

func (*MockIDagMockRecorder) GetCommon 

func (mr *MockIDagMockRecorder) GetCommon(key, stableDb interface{}) *gomock.Call

GetCommon indicates an expected call of GetCommon

func (*MockIDagMockRecorder) GetCommonByPrefix 

func (mr *MockIDagMockRecorder) GetCommonByPrefix(prefix, stableDb interface{}) *gomock.Call

GetCommonByPrefix indicates an expected call of GetCommonByPrefix

func (*MockIDagMockRecorder) GetContract 

func (mr *MockIDagMockRecorder) GetContract(id interface{}) *gomock.Call

GetContract indicates an expected call of GetContract

func (*MockIDagMockRecorder) GetContractDevelopers added in v1.0.3 

func (mr *MockIDagMockRecorder) GetContractDevelopers() *gomock.Call

GetContractDevelopers indicates an expected call of GetContractDevelopers

func (*MockIDagMockRecorder) GetContractJury 

func (mr *MockIDagMockRecorder) GetContractJury(contractId interface{}) *gomock.Call

GetContractJury indicates an expected call of GetContractJury

func (*MockIDagMockRecorder) GetContractState 

func (mr *MockIDagMockRecorder) GetContractState(contractid, field interface{}) *gomock.Call

GetContractState indicates an expected call of GetContractState

func (*MockIDagMockRecorder) GetContractStatesById 

func (mr *MockIDagMockRecorder) GetContractStatesById(id interface{}) *gomock.Call

GetContractStatesById indicates an expected call of GetContractStatesById

func (*MockIDagMockRecorder) GetContractStatesByPrefix 

func (mr *MockIDagMockRecorder) GetContractStatesByPrefix(id, prefix interface{}) *gomock.Call

GetContractStatesByPrefix indicates an expected call of GetContractStatesByPrefix

func (*MockIDagMockRecorder) GetContractTpl 

func (mr *MockIDagMockRecorder) GetContractTpl(tplId interface{}) *gomock.Call

GetContractTpl indicates an expected call of GetContractTpl

func (*MockIDagMockRecorder) GetContractTplCode 

func (mr *MockIDagMockRecorder) GetContractTplCode(tplId interface{}) *gomock.Call

GetContractTplCode indicates an expected call of GetContractTplCode

func (*MockIDagMockRecorder) GetContractsByTpl 

func (mr *MockIDagMockRecorder) GetContractsByTpl(tplId interface{}) *gomock.Call

GetContractsByTpl indicates an expected call of GetContractsByTpl

func (*MockIDagMockRecorder) GetCurrentMemUnit 

func (mr *MockIDagMockRecorder) GetCurrentMemUnit(assetId, index interface{}) *gomock.Call

GetCurrentMemUnit indicates an expected call of GetCurrentMemUnit

func (*MockIDagMockRecorder) GetCurrentUnit 

func (mr *MockIDagMockRecorder) GetCurrentUnit(assetId interface{}) *gomock.Call

GetCurrentUnit indicates an expected call of GetCurrentUnit

func (*MockIDagMockRecorder) GetDataVersion 

func (mr *MockIDagMockRecorder) GetDataVersion() *gomock.Call

GetDataVersion indicates an expected call of GetDataVersion

func (*MockIDagMockRecorder) GetDynGlobalProp 

func (mr *MockIDagMockRecorder) GetDynGlobalProp() *gomock.Call

GetDynGlobalProp indicates an expected call of GetDynGlobalProp

func (*MockIDagMockRecorder) GetFileInfo 

func (mr *MockIDagMockRecorder) GetFileInfo(filehash interface{}) *gomock.Call

GetFileInfo indicates an expected call of GetFileInfo

func (*MockIDagMockRecorder) GetGenesisUnit 

func (mr *MockIDagMockRecorder) GetGenesisUnit() *gomock.Call

GetGenesisUnit indicates an expected call of GetGenesisUnit

func (*MockIDagMockRecorder) GetGlobalProp added in v1.0.2 

func (mr *MockIDagMockRecorder) GetGlobalProp() *gomock.Call

GetGlobalProp indicates an expected call of GetGlobalProp

func (*MockIDagMockRecorder) GetHeaderByHash 

func (mr *MockIDagMockRecorder) GetHeaderByHash(arg0 interface{}) *gomock.Call

GetHeaderByHash indicates an expected call of GetHeaderByHash

func (*MockIDagMockRecorder) GetHeaderByNumber 

func (mr *MockIDagMockRecorder) GetHeaderByNumber(number interface{}) *gomock.Call

GetHeaderByNumber indicates an expected call of GetHeaderByNumber

func (*MockIDagMockRecorder) GetImmutableChainParameters 

func (mr *MockIDagMockRecorder) GetImmutableChainParameters() *gomock.Call

GetImmutableChainParameters indicates an expected call of GetImmutableChainParameters

func (*MockIDagMockRecorder) GetIrreversibleUnitNum 

func (mr *MockIDagMockRecorder) GetIrreversibleUnitNum(id interface{}) *gomock.Call

GetIrreversibleUnitNum indicates an expected call of GetIrreversibleUnitNum

func (*MockIDagMockRecorder) GetJurorByAddrHash added in v1.0.3 

func (mr *MockIDagMockRecorder) GetJurorByAddrHash(hash interface{}) *gomock.Call

GetJurorByAddrHash indicates an expected call of GetJurorByAddrHash

func (*MockIDagMockRecorder) GetLightChainHeight 

func (mr *MockIDagMockRecorder) GetLightChainHeight(assetId interface{}) *gomock.Call

GetLightChainHeight indicates an expected call of GetLightChainHeight

func (*MockIDagMockRecorder) GetLightHeaderByHash 

func (mr *MockIDagMockRecorder) GetLightHeaderByHash(headerHash interface{}) *gomock.Call

GetLightHeaderByHash indicates an expected call of GetLightHeaderByHash

func (*MockIDagMockRecorder) GetMainChain 

func (mr *MockIDagMockRecorder) GetMainChain() *gomock.Call

GetMainChain indicates an expected call of GetMainChain

func (*MockIDagMockRecorder) GetMainCurrentUnit 

func (mr *MockIDagMockRecorder) GetMainCurrentUnit() *gomock.Call

GetMainCurrentUnit indicates an expected call of GetMainCurrentUnit

func (*MockIDagMockRecorder) GetMediator added in v1.0.2 

func (mr *MockIDagMockRecorder) GetMediator(add interface{}) *gomock.Call

GetMediator indicates an expected call of GetMediator

func (*MockIDagMockRecorder) GetMediatorCount added in v1.0.2 

func (mr *MockIDagMockRecorder) GetMediatorCount() *gomock.Call

GetMediatorCount indicates an expected call of GetMediatorCount

func (*MockIDagMockRecorder) GetMediatorInfo 

func (mr *MockIDagMockRecorder) GetMediatorInfo(address interface{}) *gomock.Call

GetMediatorInfo indicates an expected call of GetMediatorInfo

func (*MockIDagMockRecorder) GetMediators 

func (mr *MockIDagMockRecorder) GetMediators() *gomock.Call

GetMediators indicates an expected call of GetMediators

func (*MockIDagMockRecorder) GetNewestUnitTimestamp 

func (mr *MockIDagMockRecorder) GetNewestUnitTimestamp(token interface{}) *gomock.Call

GetNewestUnitTimestamp indicates an expected call of GetNewestUnitTimestamp

func (*MockIDagMockRecorder) GetPartitionChains 

func (mr *MockIDagMockRecorder) GetPartitionChains() *gomock.Call

GetPartitionChains indicates an expected call of GetPartitionChains

func (*MockIDagMockRecorder) GetPrecedingMediatorNodes 

func (mr *MockIDagMockRecorder) GetPrecedingMediatorNodes() *gomock.Call

GetPrecedingMediatorNodes indicates an expected call of GetPrecedingMediatorNodes

func (*MockIDagMockRecorder) GetScheduledMediator 

func (mr *MockIDagMockRecorder) GetScheduledMediator(slotNum interface{}) *gomock.Call

GetScheduledMediator indicates an expected call of GetScheduledMediator

func (*MockIDagMockRecorder) GetSlotAtTime 

func (mr *MockIDagMockRecorder) GetSlotAtTime(when interface{}) *gomock.Call

GetSlotAtTime indicates an expected call of GetSlotAtTime

func (*MockIDagMockRecorder) GetStableChainIndex added in v1.0.3 

func (mr *MockIDagMockRecorder) GetStableChainIndex(token interface{}) *gomock.Call

GetStableChainIndex indicates an expected call of GetStableChainIndex

func (*MockIDagMockRecorder) GetStxoEntry added in v1.0.1 

func (mr *MockIDagMockRecorder) GetStxoEntry(outpoint interface{}) *gomock.Call

GetStxoEntry indicates an expected call of GetStxoEntry

func (*MockIDagMockRecorder) GetTransaction 

func (mr *MockIDagMockRecorder) GetTransaction(hash interface{}) *gomock.Call

GetTransaction indicates an expected call of GetTransaction

func (*MockIDagMockRecorder) GetTransactionOnly 

func (mr *MockIDagMockRecorder) GetTransactionOnly(hash interface{}) *gomock.Call

GetTransactionOnly indicates an expected call of GetTransactionOnly

func (*MockIDagMockRecorder) GetTrieSyncProgress 

func (mr *MockIDagMockRecorder) GetTrieSyncProgress() *gomock.Call

GetTrieSyncProgress indicates an expected call of GetTrieSyncProgress

func (*MockIDagMockRecorder) GetTxByReqId 

func (mr *MockIDagMockRecorder) GetTxByReqId(reqid interface{}) *gomock.Call

GetTxByReqId indicates an expected call of GetTxByReqId

func (*MockIDagMockRecorder) GetTxFee 

func (mr *MockIDagMockRecorder) GetTxFee(pay interface{}) *gomock.Call

GetTxFee indicates an expected call of GetTxFee

func (*MockIDagMockRecorder) GetTxFromAddress 

func (mr *MockIDagMockRecorder) GetTxFromAddress(tx interface{}) *gomock.Call

GetTxFromAddress indicates an expected call of GetTxFromAddress

func (*MockIDagMockRecorder) GetTxHashByReqId 

func (mr *MockIDagMockRecorder) GetTxHashByReqId(reqid interface{}) *gomock.Call

GetTxHashByReqId indicates an expected call of GetTxHashByReqId

func (*MockIDagMockRecorder) GetTxOutput added in v1.0.1 

func (mr *MockIDagMockRecorder) GetTxOutput(outpoint interface{}) *gomock.Call

GetTxOutput indicates an expected call of GetTxOutput

func (*MockIDagMockRecorder) GetTxRequesterAddress 

func (mr *MockIDagMockRecorder) GetTxRequesterAddress(tx interface{}) *gomock.Call

GetTxRequesterAddress indicates an expected call of GetTxRequesterAddress

func (*MockIDagMockRecorder) GetTxSearchEntry 

func (mr *MockIDagMockRecorder) GetTxSearchEntry(hash interface{}) *gomock.Call

GetTxSearchEntry indicates an expected call of GetTxSearchEntry

func (*MockIDagMockRecorder) GetUnitByHash 

func (mr *MockIDagMockRecorder) GetUnitByHash(hash interface{}) *gomock.Call

GetUnitByHash indicates an expected call of GetUnitByHash

func (*MockIDagMockRecorder) GetUnitByNumber 

func (mr *MockIDagMockRecorder) GetUnitByNumber(number interface{}) *gomock.Call

GetUnitByNumber indicates an expected call of GetUnitByNumber

func (*MockIDagMockRecorder) GetUnitHash added in v1.0.2 

func (mr *MockIDagMockRecorder) GetUnitHash(number interface{}) *gomock.Call

GetUnitHash indicates an expected call of GetUnitHash

func (*MockIDagMockRecorder) GetUnitHashesFromHash 

func (mr *MockIDagMockRecorder) GetUnitHashesFromHash(hash, max interface{}) *gomock.Call

GetUnitHashesFromHash indicates an expected call of GetUnitHashesFromHash

func (*MockIDagMockRecorder) GetUnitNumber 

func (mr *MockIDagMockRecorder) GetUnitNumber(hash interface{}) *gomock.Call

GetUnitNumber indicates an expected call of GetUnitNumber

func (*MockIDagMockRecorder) GetUnitTransactions 

func (mr *MockIDagMockRecorder) GetUnitTransactions(hash interface{}) *gomock.Call

GetUnitTransactions indicates an expected call of GetUnitTransactions

func (*MockIDagMockRecorder) GetUnitTxsHash 

func (mr *MockIDagMockRecorder) GetUnitTxsHash(hash interface{}) *gomock.Call

GetUnitTxsHash indicates an expected call of GetUnitTxsHash

func (*MockIDagMockRecorder) GetUnstableUnits 

func (mr *MockIDagMockRecorder) GetUnstableUnits() *gomock.Call

GetUnstableUnits indicates an expected call of GetUnstableUnits

func (*MockIDagMockRecorder) GetUtxoEntry 

func (mr *MockIDagMockRecorder) GetUtxoEntry(outpoint interface{}) *gomock.Call

GetUtxoEntry indicates an expected call of GetUtxoEntry

func (*MockIDagMockRecorder) GetUtxoView 

func (mr *MockIDagMockRecorder) GetUtxoView(tx interface{}) *gomock.Call

GetUtxoView indicates an expected call of GetUtxoView

func (*MockIDagMockRecorder) GetVotingForMediator added in v1.0.3 

func (mr *MockIDagMockRecorder) GetVotingForMediator(addStr interface{}) *gomock.Call

GetVotingForMediator indicates an expected call of GetVotingForMediator

func (*MockIDagMockRecorder) HasHeader 

func (mr *MockIDagMockRecorder) HasHeader(arg0, arg1 interface{}) *gomock.Call

HasHeader indicates an expected call of HasHeader

func (*MockIDagMockRecorder) HasUnit 

func (mr *MockIDagMockRecorder) HasUnit(hash interface{}) *gomock.Call

HasUnit indicates an expected call of HasUnit

func (*MockIDagMockRecorder) HeadUnitHash 

func (mr *MockIDagMockRecorder) HeadUnitHash() *gomock.Call

HeadUnitHash indicates an expected call of HeadUnitHash

func (*MockIDagMockRecorder) HeadUnitNum 

func (mr *MockIDagMockRecorder) HeadUnitNum() *gomock.Call

HeadUnitNum indicates an expected call of HeadUnitNum

func (*MockIDagMockRecorder) HeadUnitTime 

func (mr *MockIDagMockRecorder) HeadUnitTime() *gomock.Call

HeadUnitTime indicates an expected call of HeadUnitTime

func (*MockIDagMockRecorder) InsertDag 

func (mr *MockIDagMockRecorder) InsertDag(units, txpool, is_stable interface{}) *gomock.Call

InsertDag indicates an expected call of InsertDag

func (*MockIDagMockRecorder) InsertHeaderDag 

func (mr *MockIDagMockRecorder) InsertHeaderDag(arg0 interface{}) *gomock.Call

InsertHeaderDag indicates an expected call of InsertHeaderDag

func (*MockIDagMockRecorder) InsertLightHeader 

func (mr *MockIDagMockRecorder) InsertLightHeader(headers interface{}) *gomock.Call

InsertLightHeader indicates an expected call of InsertLightHeader

func (*MockIDagMockRecorder) IsActiveJury added in v1.0.3 

func (mr *MockIDagMockRecorder) IsActiveJury(addr interface{}) *gomock.Call

IsActiveJury indicates an expected call of IsActiveJury

func (*MockIDagMockRecorder) IsActiveMediator 

func (mr *MockIDagMockRecorder) IsActiveMediator(add interface{}) *gomock.Call

IsActiveMediator indicates an expected call of IsActiveMediator

func (*MockIDagMockRecorder) IsContractDeveloper added in v1.0.3 

func (mr *MockIDagMockRecorder) IsContractDeveloper(addr interface{}) *gomock.Call

IsContractDeveloper indicates an expected call of IsContractDeveloper

func (*MockIDagMockRecorder) IsEmpty 

func (mr *MockIDagMockRecorder) IsEmpty() *gomock.Call

IsEmpty indicates an expected call of IsEmpty

func (*MockIDagMockRecorder) IsHeaderExist 

func (mr *MockIDagMockRecorder) IsHeaderExist(hash interface{}) *gomock.Call

IsHeaderExist indicates an expected call of IsHeaderExist

func (*MockIDagMockRecorder) IsMediator 

func (mr *MockIDagMockRecorder) IsMediator(address interface{}) *gomock.Call

IsMediator indicates an expected call of IsMediator

func (*MockIDagMockRecorder) IsSynced 

func (mr *MockIDagMockRecorder) IsSynced() *gomock.Call

IsSynced indicates an expected call of IsSynced

func (*MockIDagMockRecorder) IsTransactionExist 

func (mr *MockIDagMockRecorder) IsTransactionExist(hash interface{}) *gomock.Call

IsTransactionExist indicates an expected call of IsTransactionExist

func (*MockIDagMockRecorder) IsUtxoSpent added in v1.0.1 

func (mr *MockIDagMockRecorder) IsUtxoSpent(outpoint interface{}) *gomock.Call

IsUtxoSpent indicates an expected call of IsUtxoSpent

func (*MockIDagMockRecorder) JuryCount added in v1.0.3 

func (mr *MockIDagMockRecorder) JuryCount() *gomock.Call

JuryCount indicates an expected call of JuryCount

func (*MockIDagMockRecorder) LookupMediatorInfo 

func (mr *MockIDagMockRecorder) LookupMediatorInfo() *gomock.Call

LookupMediatorInfo indicates an expected call of LookupMediatorInfo

func (*MockIDagMockRecorder) MediatorVotedResults 

func (mr *MockIDagMockRecorder) MediatorVotedResults() *gomock.Call

MediatorVotedResults indicates an expected call of MediatorVotedResults

func (*MockIDagMockRecorder) ParentsIsConfirmByHash 

func (mr *MockIDagMockRecorder) ParentsIsConfirmByHash(hash interface{}) *gomock.Call

ParentsIsConfirmByHash indicates an expected call of ParentsIsConfirmByHash

func (*MockIDagMockRecorder) PostChainEvents 

func (mr *MockIDagMockRecorder) PostChainEvents(events interface{}) *gomock.Call

PostChainEvents indicates an expected call of PostChainEvents

func (*MockIDagMockRecorder) QueryDbByKey 

func (mr *MockIDagMockRecorder) QueryDbByKey(key interface{}) *gomock.Call

QueryDbByKey indicates an expected call of QueryDbByKey

func (*MockIDagMockRecorder) QueryDbByPrefix 

func (mr *MockIDagMockRecorder) QueryDbByPrefix(prefix interface{}) *gomock.Call

QueryDbByPrefix indicates an expected call of QueryDbByPrefix

func (*MockIDagMockRecorder) QueryProofOfExistenceByReference 

func (mr *MockIDagMockRecorder) QueryProofOfExistenceByReference(ref interface{}) *gomock.Call

QueryProofOfExistenceByReference indicates an expected call of QueryProofOfExistenceByReference

func (*MockIDagMockRecorder) RebuildAddrTxIndex added in v1.0.3 

func (mr *MockIDagMockRecorder) RebuildAddrTxIndex() *gomock.Call

RebuildAddrTxIndex indicates an expected call of RebuildAddrTxIndex

func (*MockIDagMockRecorder) RefreshAddrTxIndex 

func (mr *MockIDagMockRecorder) RefreshAddrTxIndex() *gomock.Call

RefreshAddrTxIndex indicates an expected call of RefreshAddrTxIndex

func (*MockIDagMockRecorder) RetrieveChaincodes added in v1.0.3 

func (mr *MockIDagMockRecorder) RetrieveChaincodes() *gomock.Call

RetrieveChaincodes indicates an expected call of RetrieveChaincodes

func (*MockIDagMockRecorder) SaveChaincode 

func (mr *MockIDagMockRecorder) SaveChaincode(contractId, cc interface{}) *gomock.Call

SaveChaincode indicates an expected call of SaveChaincode

func (*MockIDagMockRecorder) SaveCommon 

func (mr *MockIDagMockRecorder) SaveCommon(key, val interface{}) *gomock.Call

SaveCommon indicates an expected call of SaveCommon

func (*MockIDagMockRecorder) SaveUnit 

func (mr *MockIDagMockRecorder) SaveUnit(unit, txpool, isGenesis interface{}) *gomock.Call

SaveUnit indicates an expected call of SaveUnit

func (*MockIDagMockRecorder) SaveUtxoView 

func (mr *MockIDagMockRecorder) SaveUtxoView(view interface{}) *gomock.Call

SaveUtxoView indicates an expected call of SaveUtxoView

func (*MockIDagMockRecorder) SetUnitGroupSign 

func (mr *MockIDagMockRecorder) SetUnitGroupSign(unitHash, groupSign, txpool interface{}) *gomock.Call

SetUnitGroupSign indicates an expected call of SetUnitGroupSign

func (*MockIDagMockRecorder) StoreDataVersion 

func (mr *MockIDagMockRecorder) StoreDataVersion(dv interface{}) *gomock.Call

StoreDataVersion indicates an expected call of StoreDataVersion

func (*MockIDagMockRecorder) SubscribeActiveMediatorsUpdatedEvent 

func (mr *MockIDagMockRecorder) SubscribeActiveMediatorsUpdatedEvent(ch interface{}) *gomock.Call

SubscribeActiveMediatorsUpdatedEvent indicates an expected call of SubscribeActiveMediatorsUpdatedEvent

func (*MockIDagMockRecorder) SubscribeChainEvent 

func (mr *MockIDagMockRecorder) SubscribeChainEvent(ch interface{}) *gomock.Call

SubscribeChainEvent indicates an expected call of SubscribeChainEvent

func (*MockIDagMockRecorder) SubscribeChainHeadEvent 

func (mr *MockIDagMockRecorder) SubscribeChainHeadEvent(ch interface{}) *gomock.Call

SubscribeChainHeadEvent indicates an expected call of SubscribeChainHeadEvent

func (*MockIDagMockRecorder) SubscribeToGroupSignEvent 

func (mr *MockIDagMockRecorder) SubscribeToGroupSignEvent(ch interface{}) *gomock.Call

SubscribeToGroupSignEvent indicates an expected call of SubscribeToGroupSignEvent

func (*MockIDagMockRecorder) UnitIrreversibleTime 

func (mr *MockIDagMockRecorder) UnitIrreversibleTime() *gomock.Call

UnitIrreversibleTime indicates an expected call of UnitIrreversibleTime

type Txo4Greedy 

type Txo4Greedy struct {
	modules.OutPoint
	Amount uint64
}

func (*Txo4Greedy) GetAmount 

func (txo *Txo4Greedy) GetAmount() uint64

Source Files

View all Source files

Directories

Path Synopsis
* @author PalletOne core developers <dev@pallet.one> * @date 2018
 * @author PalletOne core developers <dev@pallet.one> * @date 2018
* * This file is part of go-palletone.
 * * This file is part of go-palletone.
* @author PalletOne core developers <dev@pallet.one> * @date 2018 unit package, unit structure and storage api This file is part of go-palletone.
 * @author PalletOne core developers <dev@pallet.one> * @date 2018 unit package, unit structure and storage api This file is part of go-palletone.
cache
redis

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.