Documentation ¶
Index ¶
- type QueueProtocolAPI
- func (_m *QueueProtocolAPI) AddBlacklist(req *types.BlackPeer) (*types.Reply, error)
- func (_m *QueueProtocolAPI) AddPushSubscribe(param *types.PushSubscribeReq) (*types.ReplySubscribePush, error)
- func (_m *QueueProtocolAPI) Close()
- func (_m *QueueProtocolAPI) ClosePeer(in *types.SetPeer) (*types.Reply, error)
- func (_m *QueueProtocolAPI) CloseQueue() (*types.Reply, error)
- func (_m *QueueProtocolAPI) DelBlacklist(req *types.BlackPeer) (*types.Reply, error)
- func (_m *QueueProtocolAPI) DialPeer(in *types.SetPeer) (*types.Reply, error)
- func (_m *QueueProtocolAPI) ExecWallet(param *types.ChainExecutor) (types.Message, error)
- func (_m *QueueProtocolAPI) ExecWalletFunc(driver string, funcname string, param types.Message) (types.Message, error)
- func (_m *QueueProtocolAPI) GetAddrOverview(param *types.ReqAddr) (*types.AddrOverview, error)
- func (_m *QueueProtocolAPI) GetBlockByHashes(param *types.ReqHashes) (*types.BlockDetails, error)
- func (_m *QueueProtocolAPI) GetBlockBySeq(param *types.Int64) (*types.BlockSeq, error)
- func (_m *QueueProtocolAPI) GetBlockHash(param *types.ReqInt) (*types.ReplyHash, error)
- func (_m *QueueProtocolAPI) GetBlockOverview(param *types.ReqHash) (*types.BlockOverview, error)
- func (_m *QueueProtocolAPI) GetBlockSequences(param *types.ReqBlocks) (*types.BlockSequences, error)
- func (_m *QueueProtocolAPI) GetBlocks(param *types.ReqBlocks) (*types.BlockDetails, error)
- func (_m *QueueProtocolAPI) GetConfig() *types.ChainConfig
- func (_m *QueueProtocolAPI) GetHeaders(param *types.ReqBlocks) (*types.Headers, error)
- func (_m *QueueProtocolAPI) GetHighestBlockNum(param *types.ReqNil) (*types.ReplyBlockHeight, error)
- func (_m *QueueProtocolAPI) GetLastBlockMainSequence() (*types.Int64, error)
- func (_m *QueueProtocolAPI) GetLastBlockSequence() (*types.Int64, error)
- func (_m *QueueProtocolAPI) GetLastHeader() (*types.Header, error)
- func (_m *QueueProtocolAPI) GetLastMempool() (*types.ReplyTxList, error)
- func (_m *QueueProtocolAPI) GetMainSequenceByHash(param *types.ReqHash) (*types.Int64, error)
- func (_m *QueueProtocolAPI) GetMempool(req *types.ReqGetMempool) (*types.ReplyTxList, error)
- func (_m *QueueProtocolAPI) GetNetInfo(param *types.P2PGetNetInfoReq) (*types.NodeNetInfo, error)
- func (_m *QueueProtocolAPI) GetParaTxByHeight(param *types.ReqParaTxByHeight) (*types.ParaTxDetails, error)
- func (_m *QueueProtocolAPI) GetParaTxByTitle(param *types.ReqParaTxByTitle) (*types.ParaTxDetails, error)
- func (_m *QueueProtocolAPI) GetProperFee(req *types.ReqProperFee) (*types.ReplyProperFee, error)
- func (_m *QueueProtocolAPI) GetPushSeqLastNum(param *types.ReqString) (*types.Int64, error)
- func (_m *QueueProtocolAPI) GetSequenceByHash(param *types.ReqHash) (*types.Int64, error)
- func (_m *QueueProtocolAPI) GetTransactionByAddr(param *types.ReqAddr) (*types.ReplyTxInfos, error)
- func (_m *QueueProtocolAPI) GetTransactionByHash(param *types.ReqHashes) (*types.TransactionDetails, error)
- func (_m *QueueProtocolAPI) GetTxList(param *types.TxHashList) (*types.ReplyTxList, error)
- func (_m *QueueProtocolAPI) GetTxListByAddr(param *types.ReqAddrs) (*types.TransactionDetails, error)
- func (_m *QueueProtocolAPI) IsNtpClockSync() (*types.Reply, error)
- func (_m *QueueProtocolAPI) IsSync() (*types.Reply, error)
- func (_m *QueueProtocolAPI) ListPushes() (*types.PushSubscribes, error)
- func (_m *QueueProtocolAPI) LoadParaTxByTitle(param *types.ReqHeightByTitle) (*types.ReplyHeightByTitle, error)
- func (_m *QueueProtocolAPI) LocalBegin(param *types.Int64) error
- func (_m *QueueProtocolAPI) LocalClose(param *types.Int64) error
- func (_m *QueueProtocolAPI) LocalCommit(param *types.Int64) error
- func (_m *QueueProtocolAPI) LocalGet(param *types.LocalDBGet) (*types.LocalReplyValue, error)
- func (_m *QueueProtocolAPI) LocalList(param *types.LocalDBList) (*types.LocalReplyValue, error)
- func (_m *QueueProtocolAPI) LocalNew(readOnly bool) (*types.Int64, error)
- func (_m *QueueProtocolAPI) LocalRollback(param *types.Int64) error
- func (_m *QueueProtocolAPI) LocalSet(param *types.LocalDBSet) error
- func (_m *QueueProtocolAPI) NetProtocols(_a0 *types.ReqNil) (*types.NetProtocolInfos, error)
- func (_m *QueueProtocolAPI) NewMessage(topic string, msgid int64, data interface{}) *queue.Message
- func (_m *QueueProtocolAPI) Notify(topic string, ty int64, data interface{}) (*queue.Message, error)
- func (_m *QueueProtocolAPI) PeerInfo(param *types.P2PGetPeerReq) (*types.PeerList, error)
- func (_m *QueueProtocolAPI) Query(driver string, funcname string, param types.Message) (types.Message, error)
- func (_m *QueueProtocolAPI) QueryChain(param *types.ChainExecutor) (types.Message, error)
- func (_m *QueueProtocolAPI) QueryConsensus(param *types.ChainExecutor) (types.Message, error)
- func (_m *QueueProtocolAPI) QueryConsensusFunc(driver string, funcname string, param types.Message) (types.Message, error)
- func (_m *QueueProtocolAPI) QueryTx(param *types.ReqHash) (*types.TransactionDetail, error)
- func (_m *QueueProtocolAPI) RemoveTxsByHashList(hashList *types.TxHashList) error
- func (_m *QueueProtocolAPI) SendDelayTx(param *types.DelayTx, waitReply bool) (*types.Reply, error)
- func (_m *QueueProtocolAPI) SendTx(param *types.Transaction) (*types.Reply, error)
- func (_m *QueueProtocolAPI) ShowBlacklist(req *types.ReqNil) (*types.Blacklist, error)
- func (_m *QueueProtocolAPI) StoreCommit(param *types.ReqHash) (*types.ReplyHash, error)
- func (_m *QueueProtocolAPI) StoreDel(param *types.StoreDel) (*types.ReplyHash, error)
- func (_m *QueueProtocolAPI) StoreGet(_a0 *types.StoreGet) (*types.StoreReplyValue, error)
- func (_m *QueueProtocolAPI) StoreGetTotalCoins(_a0 *types.IterateRangeByStateHash) (*types.ReplyGetTotalCoins, error)
- func (_m *QueueProtocolAPI) StoreList(param *types.StoreList) (*types.StoreListReply, error)
- func (_m *QueueProtocolAPI) StoreMemSet(param *types.StoreSetWithSync) (*types.ReplyHash, error)
- func (_m *QueueProtocolAPI) StoreRollback(param *types.ReqHash) (*types.ReplyHash, error)
- func (_m *QueueProtocolAPI) StoreSet(param *types.StoreSetWithSync) (*types.ReplyHash, error)
- func (_m *QueueProtocolAPI) Version() (*types.VersionInfo, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type QueueProtocolAPI ¶
QueueProtocolAPI is an autogenerated mock type for the QueueProtocolAPI type
func (*QueueProtocolAPI) AddBlacklist ¶
AddBlacklist provides a mock function with given fields: req
func (*QueueProtocolAPI) AddPushSubscribe ¶
func (_m *QueueProtocolAPI) AddPushSubscribe(param *types.PushSubscribeReq) (*types.ReplySubscribePush, error)
AddPushSubscribe provides a mock function with given fields: param
func (*QueueProtocolAPI) Close ¶
func (_m *QueueProtocolAPI) Close()
Close provides a mock function with given fields:
func (*QueueProtocolAPI) CloseQueue ¶
func (_m *QueueProtocolAPI) CloseQueue() (*types.Reply, error)
CloseQueue provides a mock function with given fields:
func (*QueueProtocolAPI) DelBlacklist ¶
DelBlacklist provides a mock function with given fields: req
func (*QueueProtocolAPI) ExecWallet ¶
func (_m *QueueProtocolAPI) ExecWallet(param *types.ChainExecutor) (types.Message, error)
ExecWallet provides a mock function with given fields: param
func (*QueueProtocolAPI) ExecWalletFunc ¶
func (_m *QueueProtocolAPI) ExecWalletFunc(driver string, funcname string, param types.Message) (types.Message, error)
ExecWalletFunc provides a mock function with given fields: driver, funcname, param
func (*QueueProtocolAPI) GetAddrOverview ¶
func (_m *QueueProtocolAPI) GetAddrOverview(param *types.ReqAddr) (*types.AddrOverview, error)
GetAddrOverview provides a mock function with given fields: param
func (*QueueProtocolAPI) GetBlockByHashes ¶
func (_m *QueueProtocolAPI) GetBlockByHashes(param *types.ReqHashes) (*types.BlockDetails, error)
GetBlockByHashes provides a mock function with given fields: param
func (*QueueProtocolAPI) GetBlockBySeq ¶
GetBlockBySeq provides a mock function with given fields: param
func (*QueueProtocolAPI) GetBlockHash ¶
GetBlockHash provides a mock function with given fields: param
func (*QueueProtocolAPI) GetBlockOverview ¶
func (_m *QueueProtocolAPI) GetBlockOverview(param *types.ReqHash) (*types.BlockOverview, error)
GetBlockOverview provides a mock function with given fields: param
func (*QueueProtocolAPI) GetBlockSequences ¶
func (_m *QueueProtocolAPI) GetBlockSequences(param *types.ReqBlocks) (*types.BlockSequences, error)
GetBlockSequences provides a mock function with given fields: param
func (*QueueProtocolAPI) GetBlocks ¶
func (_m *QueueProtocolAPI) GetBlocks(param *types.ReqBlocks) (*types.BlockDetails, error)
GetBlocks provides a mock function with given fields: param
func (*QueueProtocolAPI) GetConfig ¶
func (_m *QueueProtocolAPI) GetConfig() *types.ChainConfig
GetConfig provides a mock function with given fields:
func (*QueueProtocolAPI) GetHeaders ¶
GetHeaders provides a mock function with given fields: param
func (*QueueProtocolAPI) GetHighestBlockNum ¶
func (_m *QueueProtocolAPI) GetHighestBlockNum(param *types.ReqNil) (*types.ReplyBlockHeight, error)
GetHighestBlockNum provides a mock function with given fields: param
func (*QueueProtocolAPI) GetLastBlockMainSequence ¶
func (_m *QueueProtocolAPI) GetLastBlockMainSequence() (*types.Int64, error)
GetLastBlockMainSequence provides a mock function with given fields:
func (*QueueProtocolAPI) GetLastBlockSequence ¶
func (_m *QueueProtocolAPI) GetLastBlockSequence() (*types.Int64, error)
GetLastBlockSequence provides a mock function with given fields:
func (*QueueProtocolAPI) GetLastHeader ¶
func (_m *QueueProtocolAPI) GetLastHeader() (*types.Header, error)
GetLastHeader provides a mock function with given fields:
func (*QueueProtocolAPI) GetLastMempool ¶
func (_m *QueueProtocolAPI) GetLastMempool() (*types.ReplyTxList, error)
GetLastMempool provides a mock function with given fields:
func (*QueueProtocolAPI) GetMainSequenceByHash ¶
GetMainSequenceByHash provides a mock function with given fields: param
func (*QueueProtocolAPI) GetMempool ¶
func (_m *QueueProtocolAPI) GetMempool(req *types.ReqGetMempool) (*types.ReplyTxList, error)
GetMempool provides a mock function with given fields: req
func (*QueueProtocolAPI) GetNetInfo ¶
func (_m *QueueProtocolAPI) GetNetInfo(param *types.P2PGetNetInfoReq) (*types.NodeNetInfo, error)
GetNetInfo provides a mock function with given fields: param
func (*QueueProtocolAPI) GetParaTxByHeight ¶
func (_m *QueueProtocolAPI) GetParaTxByHeight(param *types.ReqParaTxByHeight) (*types.ParaTxDetails, error)
GetParaTxByHeight provides a mock function with given fields: param
func (*QueueProtocolAPI) GetParaTxByTitle ¶
func (_m *QueueProtocolAPI) GetParaTxByTitle(param *types.ReqParaTxByTitle) (*types.ParaTxDetails, error)
GetParaTxByTitle provides a mock function with given fields: param
func (*QueueProtocolAPI) GetProperFee ¶
func (_m *QueueProtocolAPI) GetProperFee(req *types.ReqProperFee) (*types.ReplyProperFee, error)
GetProperFee provides a mock function with given fields: req
func (*QueueProtocolAPI) GetPushSeqLastNum ¶
GetPushSeqLastNum provides a mock function with given fields: param
func (*QueueProtocolAPI) GetSequenceByHash ¶
GetSequenceByHash provides a mock function with given fields: param
func (*QueueProtocolAPI) GetTransactionByAddr ¶
func (_m *QueueProtocolAPI) GetTransactionByAddr(param *types.ReqAddr) (*types.ReplyTxInfos, error)
GetTransactionByAddr provides a mock function with given fields: param
func (*QueueProtocolAPI) GetTransactionByHash ¶
func (_m *QueueProtocolAPI) GetTransactionByHash(param *types.ReqHashes) (*types.TransactionDetails, error)
GetTransactionByHash provides a mock function with given fields: param
func (*QueueProtocolAPI) GetTxList ¶
func (_m *QueueProtocolAPI) GetTxList(param *types.TxHashList) (*types.ReplyTxList, error)
GetTxList provides a mock function with given fields: param
func (*QueueProtocolAPI) GetTxListByAddr ¶
func (_m *QueueProtocolAPI) GetTxListByAddr(param *types.ReqAddrs) (*types.TransactionDetails, error)
GetTxListByAddr provides a mock function with given fields: param
func (*QueueProtocolAPI) IsNtpClockSync ¶
func (_m *QueueProtocolAPI) IsNtpClockSync() (*types.Reply, error)
IsNtpClockSync provides a mock function with given fields:
func (*QueueProtocolAPI) IsSync ¶
func (_m *QueueProtocolAPI) IsSync() (*types.Reply, error)
IsSync provides a mock function with given fields:
func (*QueueProtocolAPI) ListPushes ¶
func (_m *QueueProtocolAPI) ListPushes() (*types.PushSubscribes, error)
ListPushes provides a mock function with given fields:
func (*QueueProtocolAPI) LoadParaTxByTitle ¶
func (_m *QueueProtocolAPI) LoadParaTxByTitle(param *types.ReqHeightByTitle) (*types.ReplyHeightByTitle, error)
LoadParaTxByTitle provides a mock function with given fields: param
func (*QueueProtocolAPI) LocalBegin ¶
func (_m *QueueProtocolAPI) LocalBegin(param *types.Int64) error
LocalBegin provides a mock function with given fields: param
func (*QueueProtocolAPI) LocalClose ¶
func (_m *QueueProtocolAPI) LocalClose(param *types.Int64) error
LocalClose provides a mock function with given fields: param
func (*QueueProtocolAPI) LocalCommit ¶
func (_m *QueueProtocolAPI) LocalCommit(param *types.Int64) error
LocalCommit provides a mock function with given fields: param
func (*QueueProtocolAPI) LocalGet ¶
func (_m *QueueProtocolAPI) LocalGet(param *types.LocalDBGet) (*types.LocalReplyValue, error)
LocalGet provides a mock function with given fields: param
func (*QueueProtocolAPI) LocalList ¶
func (_m *QueueProtocolAPI) LocalList(param *types.LocalDBList) (*types.LocalReplyValue, error)
LocalList provides a mock function with given fields: param
func (*QueueProtocolAPI) LocalNew ¶
func (_m *QueueProtocolAPI) LocalNew(readOnly bool) (*types.Int64, error)
LocalNew provides a mock function with given fields: readOnly
func (*QueueProtocolAPI) LocalRollback ¶
func (_m *QueueProtocolAPI) LocalRollback(param *types.Int64) error
LocalRollback provides a mock function with given fields: param
func (*QueueProtocolAPI) LocalSet ¶
func (_m *QueueProtocolAPI) LocalSet(param *types.LocalDBSet) error
LocalSet provides a mock function with given fields: param
func (*QueueProtocolAPI) NetProtocols ¶
func (_m *QueueProtocolAPI) NetProtocols(_a0 *types.ReqNil) (*types.NetProtocolInfos, error)
NetProtocols provides a mock function with given fields: _a0
func (*QueueProtocolAPI) NewMessage ¶
func (_m *QueueProtocolAPI) NewMessage(topic string, msgid int64, data interface{}) *queue.Message
NewMessage provides a mock function with given fields: topic, msgid, data
func (*QueueProtocolAPI) Notify ¶
func (_m *QueueProtocolAPI) Notify(topic string, ty int64, data interface{}) (*queue.Message, error)
Notify provides a mock function with given fields: topic, ty, data
func (*QueueProtocolAPI) PeerInfo ¶
func (_m *QueueProtocolAPI) PeerInfo(param *types.P2PGetPeerReq) (*types.PeerList, error)
PeerInfo provides a mock function with given fields: param
func (*QueueProtocolAPI) Query ¶
func (_m *QueueProtocolAPI) Query(driver string, funcname string, param types.Message) (types.Message, error)
Query provides a mock function with given fields: driver, funcname, param
func (*QueueProtocolAPI) QueryChain ¶
func (_m *QueueProtocolAPI) QueryChain(param *types.ChainExecutor) (types.Message, error)
QueryChain provides a mock function with given fields: param
func (*QueueProtocolAPI) QueryConsensus ¶
func (_m *QueueProtocolAPI) QueryConsensus(param *types.ChainExecutor) (types.Message, error)
QueryConsensus provides a mock function with given fields: param
func (*QueueProtocolAPI) QueryConsensusFunc ¶
func (_m *QueueProtocolAPI) QueryConsensusFunc(driver string, funcname string, param types.Message) (types.Message, error)
QueryConsensusFunc provides a mock function with given fields: driver, funcname, param
func (*QueueProtocolAPI) QueryTx ¶
func (_m *QueueProtocolAPI) QueryTx(param *types.ReqHash) (*types.TransactionDetail, error)
QueryTx provides a mock function with given fields: param
func (*QueueProtocolAPI) RemoveTxsByHashList ¶
func (_m *QueueProtocolAPI) RemoveTxsByHashList(hashList *types.TxHashList) error
RemoveTxsByHashList provides a mock function with given fields: hashList
func (*QueueProtocolAPI) SendDelayTx ¶
SendDelayTx provides a mock function with given fields: param, waitReply
func (*QueueProtocolAPI) SendTx ¶
func (_m *QueueProtocolAPI) SendTx(param *types.Transaction) (*types.Reply, error)
SendTx provides a mock function with given fields: param
func (*QueueProtocolAPI) ShowBlacklist ¶
ShowBlacklist provides a mock function with given fields: req
func (*QueueProtocolAPI) StoreCommit ¶
StoreCommit provides a mock function with given fields: param
func (*QueueProtocolAPI) StoreGet ¶
func (_m *QueueProtocolAPI) StoreGet(_a0 *types.StoreGet) (*types.StoreReplyValue, error)
StoreGet provides a mock function with given fields: _a0
func (*QueueProtocolAPI) StoreGetTotalCoins ¶
func (_m *QueueProtocolAPI) StoreGetTotalCoins(_a0 *types.IterateRangeByStateHash) (*types.ReplyGetTotalCoins, error)
StoreGetTotalCoins provides a mock function with given fields: _a0
func (*QueueProtocolAPI) StoreList ¶
func (_m *QueueProtocolAPI) StoreList(param *types.StoreList) (*types.StoreListReply, error)
StoreList provides a mock function with given fields: param
func (*QueueProtocolAPI) StoreMemSet ¶
func (_m *QueueProtocolAPI) StoreMemSet(param *types.StoreSetWithSync) (*types.ReplyHash, error)
StoreMemSet provides a mock function with given fields: param
func (*QueueProtocolAPI) StoreRollback ¶
StoreRollback provides a mock function with given fields: param
func (*QueueProtocolAPI) StoreSet ¶
func (_m *QueueProtocolAPI) StoreSet(param *types.StoreSetWithSync) (*types.ReplyHash, error)
StoreSet provides a mock function with given fields: param
func (*QueueProtocolAPI) Version ¶
func (_m *QueueProtocolAPI) Version() (*types.VersionInfo, error)
Version provides a mock function with given fields: