Versions in this module Expand all Collapse all v0 v0.34.24 Sep 22, 2023 Changes in this version + type PeerState interface + GetHeight func() int64 + type Reactor struct + func NewReactor(config *cfg.MempoolConfig, mempool *TxMempool) *Reactor + func (memR *Reactor) AddPeer(peer p2p.Peer) + func (memR *Reactor) GetChannels() []*p2p.ChannelDescriptor + func (memR *Reactor) InitPeer(peer p2p.Peer) p2p.Peer + func (memR *Reactor) OnStart() error + func (memR *Reactor) Receive(chID byte, peer p2p.Peer, msgBytes []byte) + func (memR *Reactor) ReceiveEnvelope(e p2p.Envelope) + func (memR *Reactor) RemovePeer(peer p2p.Peer, reason interface{}) + func (memR *Reactor) SetLogger(l log.Logger) + type TxMempool struct + func NewTxMempool(logger log.Logger, cfg *config.MempoolConfig, ...) *TxMempool + func (txmp *TxMempool) CheckTx(tx types.Tx, cb func(*abci.Response), txInfo mempool.TxInfo) error + func (txmp *TxMempool) EnableTxsAvailable() + func (txmp *TxMempool) Flush() + func (txmp *TxMempool) FlushAppConn() error + func (txmp *TxMempool) Lock() + func (txmp *TxMempool) ReapMaxBytesMaxGas(maxBytes, maxGas int64) types.Txs + func (txmp *TxMempool) ReapMaxTxs(max int) types.Txs + func (txmp *TxMempool) RemoveTxByKey(txKey types.TxKey) error + func (txmp *TxMempool) Size() int + func (txmp *TxMempool) SizeBytes() int64 + func (txmp *TxMempool) TxsAvailable() <-chan struct{} + func (txmp *TxMempool) TxsFront() *clist.CElement + func (txmp *TxMempool) TxsWaitChan() <-chan struct{} + func (txmp *TxMempool) Unlock() + func (txmp *TxMempool) Update(blockHeight int64, blockTxs types.Txs, ...) error + type TxMempoolOption func(*TxMempool) + func WithMetrics(metrics *mempool.Metrics) TxMempoolOption + func WithPostCheck(f mempool.PostCheckFunc) TxMempoolOption + func WithPreCheck(f mempool.PreCheckFunc) TxMempoolOption + type TxsMessage struct + Txs []types.Tx + func (m *TxsMessage) String() string + type WrappedTx struct + func (w *WrappedTx) GasWanted() int64 + func (w *WrappedTx) HasPeer(id uint16) bool + func (w *WrappedTx) Priority() int64 + func (w *WrappedTx) Sender() string + func (w *WrappedTx) SetGasWanted(gas int64) + func (w *WrappedTx) SetPeer(id uint16) + func (w *WrappedTx) SetPriority(p int64) + func (w *WrappedTx) SetSender(sender string) + func (w *WrappedTx) Size() int64
Go to main page