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 CListMempool struct + func NewCListMempool(config *cfg.MempoolConfig, proxyAppConn proxy.AppConnMempool, height int64, ...) *CListMempool + func (mem *CListMempool) CheckTx(ctx context.Context, tx types.Tx, cb func(*abci.Response), ...) error + func (mem *CListMempool) EnableTxsAvailable() + func (mem *CListMempool) Flush() + func (mem *CListMempool) FlushAppConn() error + func (mem *CListMempool) Lock() + func (mem *CListMempool) ReapMaxBytesMaxGas(maxBytes, maxGas int64) types.Txs + func (mem *CListMempool) ReapMaxTxs(max int) types.Txs + func (mem *CListMempool) RemoveTxByKey(txKey [mempool.TxKeySize]byte, removeFromCache bool) + func (mem *CListMempool) SetLogger(l log.Logger) + func (mem *CListMempool) Size() int + func (mem *CListMempool) SizeBytes() int64 + func (mem *CListMempool) TxsAvailable() <-chan struct{} + func (mem *CListMempool) TxsFront() *clist.CElement + func (mem *CListMempool) TxsWaitChan() <-chan struct{} + func (mem *CListMempool) Unlock() + func (mem *CListMempool) Update(height int64, txs types.Txs, deliverTxResponses []*abci.ResponseDeliverTx, ...) error + type CListMempoolOption func(*CListMempool) + func WithMetrics(metrics *mempool.Metrics) CListMempoolOption + func WithPostCheck(f mempool.PostCheckFunc) CListMempoolOption + func WithPreCheck(f mempool.PreCheckFunc) CListMempoolOption + 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()
Go to main page