QueueProtocolAPI 消息通道交互API接口定义
| 11 | |
| 12 | // QueueProtocolAPI 消息通道交互API接口定义 |
| 13 | type QueueProtocolAPI interface { |
| 14 | Version() (*types.VersionInfo, error) |
| 15 | Close() |
| 16 | NewMessage(topic string, msgid int64, data interface{}) *queue.Message |
| 17 | Notify(topic string, ty int64, data interface{}) (*queue.Message, error) |
| 18 | // +++++++++++++++ mempool interfaces begin |
| 19 | // 同步发送交易信息到指定模块，获取应答消息 types.EventTx |
| 20 | SendTx(param *types.Transaction) (*types.Reply, error) |
| 21 | // types.EventGetAddrTxs |
| 22 | GetTxListByAddr(param *types.ReqAddrs) (*types.TransactionDetails, error) |
| 23 | // types.EventTxList |
| 24 | GetTxList(param *types.TxHashList) (*types.ReplyTxList, error) |
| 25 | // types.EventGetMempool |
| 26 | GetMempool(req *types.ReqGetMempool) (*types.ReplyTxList, error) |
| 27 | // types.EventGetLastMempool |
| 28 | GetLastMempool() (*types.ReplyTxList, error) |
| 29 | // types.EventGetProperFee |
| 30 | GetProperFee(req *types.ReqProperFee) (*types.ReplyProperFee, error) |
| 31 | //types.EventDelTxList |
| 32 | RemoveTxsByHashList(hashList *types.TxHashList) error |
| 33 | // +++++++++++++++ execs interfaces begin |
| 34 | // types.EventBlockChainQuery |
| 35 | Query(driver, funcname string, param types.Message) (types.Message, error) |
| 36 | QueryConsensus(param *types.ChainExecutor) (types.Message, error) |
| 37 | QueryConsensusFunc(driver string, funcname string, param types.Message) (types.Message, error) |
| 38 | QueryChain(param *types.ChainExecutor) (types.Message, error) |
| 39 | ExecWalletFunc(driver string, funcname string, param types.Message) (types.Message, error) |
| 40 | ExecWallet(param *types.ChainExecutor) (types.Message, error) |
| 41 | // --------------- execs interfaces end |
| 42 | |
| 43 | // +++++++++++++++ p2p interfaces begin |
| 44 | // types.EventPeerInfo |
| 45 | PeerInfo(param *types.P2PGetPeerReq) (*types.PeerList, error) |
| 46 | // types.EventGetNetInfo |
| 47 | GetNetInfo(param *types.P2PGetNetInfoReq) (*types.NodeNetInfo, error) |
| 48 | //type.EventNetProtocols |
| 49 | NetProtocols(*types.ReqNil) (*types.NetProtocolInfos, error) |
| 50 | // --------------- p2p interfaces end |
| 51 | // +++++++++++++++ wallet interfaces begin |
| 52 | // types.EventLocalGet |
| 53 | LocalGet(param *types.LocalDBGet) (*types.LocalReplyValue, error) |
| 54 | // types.EventLocalNew |
| 55 | LocalNew(readOnly bool) (*types.Int64, error) |
| 56 | // types.EventLocalClose |
| 57 | LocalClose(param *types.Int64) error |
| 58 | // types.EventLocalBeign |
| 59 | LocalBegin(param *types.Int64) error |
| 60 | // types.EventLocalCommit |
| 61 | LocalCommit(param *types.Int64) error |
| 62 | // types.EventLocalRollback |
| 63 | LocalRollback(param *types.Int64) error |
| 64 | // types.EventLocalSet |
| 65 | LocalSet(param *types.LocalDBSet) error |
| 66 | // types.EventLocalList |
| 67 | LocalList(param *types.LocalDBList) (*types.LocalReplyValue, error) |
| 68 | // types.EventGetBlocks |
| 69 | GetBlocks(param *types.ReqBlocks) (*types.BlockDetails, error) |
| 70 | // types.EventQueryTx |
no outgoing calls
no test coverage detected