Versions in this module Expand all Collapse all v0 v0.0.2 May 13, 2020 v0.0.1 May 13, 2020 Changes in this version + const DoneCacheSize + const MempoolChannel + var ErrTxInCache = errors.New("Tx already exists in cache") + func RegisterMempoolMessages(cdc *amino.Codec) + type DoneTxs struct + type DoneTxsCache struct + func GetDoneTxsCache() *DoneTxsCache + func (cache *DoneTxsCache) Exists(logger log.Logger, tx types.Tx) bool + func (cache *DoneTxsCache) PushTxs(logger log.Logger, height int64, txs types.Txs) + func (cache *DoneTxsCache) Reset() + type Mempool struct + func NewMempool(config *cfg.MempoolConfig, proxyAppConn proxy.AppConnMempool, height int64) *Mempool + func (mem *Mempool) CheckTx(tx types.Tx, cb func(*abci.Response)) (err error) + func (mem *Mempool) CloseWAL() bool + func (mem *Mempool) EnableTxsAvailable() + func (mem *Mempool) Flush() + func (mem *Mempool) FlushAppConn() error + func (mem *Mempool) GiTxCache(tx cmn.HexBytes, a interface{}) + func (mem *Mempool) GiTxSearch(tx string) (*abci.ResponseCheckTx, error) + func (mem *Mempool) InitWAL() + func (mem *Mempool) Lock() + func (mem *Mempool) Reap(maxTxs int) types.Txs + func (mem *Mempool) SetLogger(l log.Logger) + func (mem *Mempool) Size() int + func (mem *Mempool) TxsAvailable() <-chan int64 + func (mem *Mempool) TxsFront() *clist.CElement + func (mem *Mempool) TxsWaitChan() <-chan struct{} + func (mem *Mempool) Unlock() + func (mem *Mempool) Update(height int64, txs types.Txs) error + type MempoolMessage interface + func DecodeMessage(bz []byte) (msg MempoolMessage, err error) + type MempoolReactor struct + Mempool *Mempool + func NewMempoolReactor(config *cfg.MempoolConfig, mempool *Mempool) *MempoolReactor + func (memR *MempoolReactor) AddPeer(peer p2p.Peer) + func (memR *MempoolReactor) BroadcastTx(tx types.Tx, cb func(*abci.Response)) error + func (memR *MempoolReactor) GetChannels() []*p2p.ChannelDescriptor + func (memR *MempoolReactor) Receive(chID byte, src p2p.Peer, msgBytes []byte) + func (memR *MempoolReactor) RemovePeer(peer p2p.Peer, reason interface{}) + func (memR *MempoolReactor) SetLogger(l log.Logger) + type PeerState interface + GetHeight func() int64 + type TxMessage struct + Tx types.Tx + func (m *TxMessage) String() string
Go to main page