GetMempool get transactions from mempool
(req *types.ReqGetMempool)
| 299 | |
| 300 | // GetMempool get transactions from mempool |
| 301 | func (q *QueueProtocol) GetMempool(req *types.ReqGetMempool) (*types.ReplyTxList, error) { |
| 302 | msg, err := q.send(mempoolKey, types.EventGetMempool, req) |
| 303 | if err != nil { |
| 304 | log.Error("GetMempool", "Error", err.Error()) |
| 305 | return nil, err |
| 306 | } |
| 307 | if reply, ok := msg.GetData().(*types.ReplyTxList); ok { |
| 308 | return reply, nil |
| 309 | } |
| 310 | return nil, types.ErrTypeAsset |
| 311 | } |
| 312 | |
| 313 | // PeerInfo query peer list |
| 314 | func (q *QueueProtocol) PeerInfo(req *types.P2PGetPeerReq) (*types.PeerList, error) { |