Versions in this module Expand all Collapse all v0 v0.8.14 Sep 15, 2021 Changes in this version + func GetChannelShims(config *cfg.MempoolConfig) map[p2p.ChannelID]*p2p.ChannelDescriptorShim + type PeerManager interface + GetHeight func(types.NodeID) int64 + type Reactor struct + func NewReactor(logger log.Logger, config *cfg.MempoolConfig, peerMgr PeerManager, ...) *Reactor + func (r *Reactor) OnStart() error + func (r *Reactor) OnStop() + type TxMempool struct + func NewTxMempool(logger log.Logger, cfg *config.MempoolConfig, ...) *TxMempool + func (txmp *TxMempool) CheckTx(ctx context.Context, tx types.Tx, cb func(*abci.Response), ...) error + func (txmp *TxMempool) EnableTxsAvailable() + func (txmp *TxMempool) Flush() + func (txmp *TxMempool) FlushAppConn() error + func (txmp *TxMempool) Lock() + func (txmp *TxMempool) NextGossipTx() *WrappedTx + func (txmp *TxMempool) ReapMaxBytesMaxGas(maxBytes, maxGas int64) types.Txs + func (txmp *TxMempool) ReapMaxTxs(max int) types.Txs + func (txmp *TxMempool) Size() int + func (txmp *TxMempool) SizeBytes() int64 + func (txmp *TxMempool) TxsAvailable() <-chan struct{} + func (txmp *TxMempool) Unlock() + func (txmp *TxMempool) Update(blockHeight int64, blockTxs types.Txs, ...) error + func (txmp *TxMempool) WaitForNextTx() <-chan struct{} + type TxMempoolOption func(*TxMempool) + func WithMetrics(metrics *mempool.Metrics) TxMempoolOption + func WithPostCheck(f mempool.PostCheckFunc) TxMempoolOption + func WithPreCheck(f mempool.PreCheckFunc) TxMempoolOption + type TxPriorityQueue struct + func NewTxPriorityQueue() *TxPriorityQueue + func (pq *TxPriorityQueue) GetEvictableTxs(priority, txSize, totalSize, cap int64) []*WrappedTx + func (pq *TxPriorityQueue) Len() int + func (pq *TxPriorityQueue) Less(i, j int) bool + func (pq *TxPriorityQueue) NumTxs() int + func (pq *TxPriorityQueue) Pop() interface{} + func (pq *TxPriorityQueue) PopTx() *WrappedTx + func (pq *TxPriorityQueue) Push(x interface{}) + func (pq *TxPriorityQueue) PushTx(tx *WrappedTx) + func (pq *TxPriorityQueue) RemoveTx(tx *WrappedTx) + func (pq *TxPriorityQueue) Swap(i, j int) + type TxStore struct + func NewTxStore() *TxStore + func (txs *TxStore) GetAllTxs() []*WrappedTx + func (txs *TxStore) GetOrSetPeerByTxHash(hash [mempool.TxKeySize]byte, peerID uint16) (*WrappedTx, bool) + func (txs *TxStore) GetTxByHash(hash [mempool.TxKeySize]byte) *WrappedTx + func (txs *TxStore) GetTxBySender(sender string) *WrappedTx + func (txs *TxStore) IsTxRemoved(hash [mempool.TxKeySize]byte) bool + func (txs *TxStore) RemoveTx(wtx *WrappedTx) + func (txs *TxStore) SetTx(wtx *WrappedTx) + func (txs *TxStore) Size() int + func (txs *TxStore) TxHasPeer(hash [mempool.TxKeySize]byte, peerID uint16) bool + type WrappedTx struct + func (wtx *WrappedTx) Size() int + type WrappedTxList struct + func NewWrappedTxList(less func(*WrappedTx, *WrappedTx) bool) *WrappedTxList + func (wtl *WrappedTxList) Insert(wtx *WrappedTx) + func (wtl *WrappedTxList) Remove(wtx *WrappedTx) + func (wtl *WrappedTxList) Reset() + func (wtl *WrappedTxList) Size() int