dag

package
v1.0.1 Latest Latest
Warning

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

 Go to latest Published: Aug 1, 2019 License: GPL-3.0, GPL-3.0 Imports: 36 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

	//validate             validator.Validator
	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, light bool) (*Dag, error)

func NewDag4GenesisInit 

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

func NewDagForTest 

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

func (*Dag) ActiveMediatorsCount 

func (d *Dag) ActiveMediatorsCount() int

author Albert·Gou

func (*Dag) AfterChainMaintenanceEvent 

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

func (*Dag) AfterSysContractStateChangeEvent 

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

func (*Dag) ChainThreshold 

func (d *Dag) ChainThreshold() int

author Albert·Gou

func (*Dag) ClearUtxo 

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

func (*Dag) Close 

func (d *Dag) Close()

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)

func (*Dag) CreateUnit 

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

func (*Dag) CurrentHeader 

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

func (*Dag) CurrentUnit 

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

返回稳定单元

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)

func (*Dag) GenVoteMediatorTx 

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

func (*Dag) GenerateUnit 

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

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)

func (*Dag) GetAddrByOutPoint 

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

func (*Dag) GetAddrOutpoints 

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

func (*Dag) GetAddrTransactions 

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

func (*Dag) GetAddrUtxos 

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

func (*Dag) GetAllContractTpl 

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

func (*Dag) GetAllContracts 

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

func (*Dag) GetAllLeafNodes 

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

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

func (*Dag) GetAllUtxos 

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

GetAllUtxos is return all utxo.

func (*Dag) GetAssetReference added in v1.0.1 

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

func (*Dag) GetAssetTxHistory 

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

func (*Dag) GetChainParameters 

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

func (*Dag) GetChaincodes 

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

func (*Dag) GetCommon 

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

dag's common geter

func (*Dag) GetCommonByPrefix 

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

GetCommonByPrefix return the prefix's all key && value.

func (*Dag) GetContract 

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

Get Contract Api

func (*Dag) GetContractDeploy 

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

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.ElectionInf, error)

func (*Dag) GetContractState 

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

get contract state

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)

func (*Dag) GetContractTpl 

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

func (*Dag) GetContractTplCode 

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

func (*Dag) GetContractsByTpl 

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

func (*Dag) GetCurrentMemUnit 

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

func (*Dag) GetCurrentUnit 

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

func (*Dag) GetCurrentUnitIndex 

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

func (*Dag) GetDataVersion 

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

func (*Dag) GetDynGlobalProp 

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

func (*Dag) GetFileInfo 

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

GetFileInfo

func (*Dag) GetGenesisUnit 

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

func (*Dag) GetGlobalProp 

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

func (*Dag) GetHeaderByHash 

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

func (*Dag) GetHeaderByNumber 

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

func (*Dag) GetImmutableChainParameters 

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

func (*Dag) GetIrreversibleUnitNum 

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

func (*Dag) GetLightChainHeight 

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

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)

func (*Dag) GetMainCurrentUnit 

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

func (*Dag) GetMediator 

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

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) GetMinFee 

func (d *Dag) GetMinFee() (*modules.AmountAsset, error)

func (*Dag) GetNewestUnitTimestamp 

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

func (*Dag) GetPartitionChains 

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

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) GetStxoEntry added in v1.0.1 

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

func (*Dag) GetTransaction 

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

GetTransactionByHash is return the tx by tx's hash 

func (d *Dag) GetTransactionByHash(hash common.Hash) (*modules.Transaction, common.Hash, error) {
	tx, uhash, _, _, err := d.unstableUnitRep.GetTransaction(hash)
	if err != nil {
		return nil, uhash, errors.New("get transaction by hash is failed,none the transaction.")
	}
	return tx, uhash, nil
}

func (*Dag) GetTransactionOnly 

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

func (*Dag) GetTrieSyncProgress 

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

func (*Dag) GetTxByReqId 

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

func (*Dag) GetTxFee 

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

func (*Dag) GetTxFromAddress 

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

func (*Dag) GetTxHashByReqId 

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

GetTxHashByReqId

func (*Dag) GetTxOutput added in v1.0.1 

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

Include UTXO and STXO

func (*Dag) GetTxRequesterAddress 

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

func (*Dag) GetTxSearchEntry 

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

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)

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 UnitNumber

func (*Dag) GetUnitTransactions 

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

GetUnitTransactions is return unit's body, all transactions of unit.

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

func (*Dag) GetUtxoEntry 

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

func (*Dag) GetUtxoView 

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

func (*Dag) GetUtxosOutViewbyTx 

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

func (*Dag) GetUtxosOutViewbyUnit 

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

func (*Dag) HasHeader 

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

need add: assetId modules.AssetId, onMain bool

func (*Dag) HasUnit 

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

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, unit *modules.Unit) error

func (*Dag) InsertDag 

func (d *Dag) InsertDag(units modules.Units, txpool txspool.ITxPool) (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)

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

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

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)

func (*Dag) IsUtxoSpent added in v1.0.1 

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

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

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

func (*Dag) MediatorVotedResults 

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

func (*Dag) ParentsIsConfirmByHash 

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

confirm unit's parent

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 (dag *Dag) QueryProofOfExistenceByReference(ref []byte) ([]*modules.ProofOfExistence, error)

func (*Dag) RefreshAddrTxIndex 

func (d *Dag) RefreshAddrTxIndex() error

func (*Dag) RefreshSysParameters 

func (d *Dag) RefreshSysParameters()

func (*Dag) SaveChaincode 

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

func (*Dag) SaveCommon 

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

func (*Dag) SaveUnit 

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

TODO 待优化, 目前只用来存创世unit

func (*Dag) SaveUtxoView 

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

func (*Dag) SetUnitGroupSign 

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

func (*Dag) StoreDataVersion 

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

func (*Dag) SubscribeActiveMediatorsUpdatedEvent 

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

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) UnitIsConfirmedByHash 

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

confirm unit

func (*Dag) VerifyUnitGroupSign 

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

type IDag 

type IDag interface {
	Close()

	//common geter
	GetCommon(key []byte) ([]byte, error)
	GetCommonByPrefix(prefix []byte) map[string][]byte
	SaveCommon(key, val []byte) error

	IsEmpty() bool
	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) (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.ElectionInf, 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)
	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)

	//WalletTokens(addr common.Address) (map[string]*modules.AccountToken, error)
	//WalletBalance(address common.Address, assetid []byte, uniqueid []byte, chainid uint64) (uint64, 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

	//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
	GetChaincodes(contractId common.Address) (*list.CCInfo, error)
	GetPartitionChains() ([]*modules.PartitionChain, error)
	GetMainChain() (*modules.MainChain, error)

	RefreshAddrTxIndex() error
	GetMinFee() (*modules.AmountAsset, error)

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

	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

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

	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)
}

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) 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) 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) 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) 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) GetChainParameters 

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

GetChainParameters mocks base method

func (*MockIDag) GetChaincodes 

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

GetChaincodes mocks base method

func (*MockIDag) GetCommon 

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

GetCommon mocks base method

func (*MockIDag) GetCommonByPrefix 

func (m *MockIDag) GetCommonByPrefix(prefix []byte) 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) GetContractJury 

func (m *MockIDag) GetContractJury(contractId []byte) ([]modules.ElectionInf, 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) 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) 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) 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) GetMinFee 

func (m *MockIDag) GetMinFee() (*modules.AmountAsset, error)

GetMinFee 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) 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) 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) 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) (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) IsActiveMediator 

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

IsActiveMediator 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) 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) RefreshAddrTxIndex 

func (m *MockIDag) RefreshAddrTxIndex() error

RefreshAddrTxIndex 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

func (*MockIDag) UnitIsConfirmedByHash 

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

UnitIsConfirmedByHash mocks base method

type MockIDagMockRecorder 

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

MockIDagMockRecorder is the mock recorder for MockIDag

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) 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) 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) 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) GetChainParameters 

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

GetChainParameters indicates an expected call of GetChainParameters

func (*MockIDagMockRecorder) GetChaincodes 

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

GetChaincodes indicates an expected call of GetChaincodes

func (*MockIDagMockRecorder) GetCommon 

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

GetCommon indicates an expected call of GetCommon

func (*MockIDagMockRecorder) GetCommonByPrefix 

func (mr *MockIDagMockRecorder) GetCommonByPrefix(prefix 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) 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) 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) 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) 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) GetMinFee 

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

GetMinFee indicates an expected call of GetMinFee

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) 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) 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) 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 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) IsActiveMediator 

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

IsActiveMediator indicates an expected call of IsActiveMediator

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) 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) RefreshAddrTxIndex 

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

RefreshAddrTxIndex indicates an expected call of RefreshAddrTxIndex

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

func (*MockIDagMockRecorder) UnitIsConfirmedByHash 

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

UnitIsConfirmedByHash indicates an expected call of UnitIsConfirmedByHash

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
Package txspool is a generated GoMock package.
 Package txspool is a generated GoMock package.

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.