Versions in this module Expand all Collapse all v0 v0.1.0 Dec 10, 2018 Changes in this version + const MempoolChannel + type IFilter interface + CheckTx func(agtypes.Tx) (bool, error) + type Mempool struct + func NewMempool(logger *zap.Logger, config *viper.Viper) *Mempool + func (mem *Mempool) CheckTx(tx agtypes.Tx) (err error) + func (mem *Mempool) Flush() + func (mem *Mempool) Lock() + func (mem *Mempool) Reap(maxTxs int) []agtypes.Tx + func (mem *Mempool) RegisterFilter(filter IFilter) + func (mem *Mempool) Size() int + func (mem *Mempool) TxsFrontWait() *clist.CElement + func (mem *Mempool) Unlock() + func (mem *Mempool) Update(height def.INT, txs []agtypes.Tx) + type MempoolReactor struct + Mempool *Mempool + func NewMempoolReactor(logger *zap.Logger, config *viper.Viper, mempool *Mempool) *MempoolReactor + func (memR *MempoolReactor) AddPeer(peer *p2p.Peer) + func (memR *MempoolReactor) BroadcastTx(tx agtypes.Tx) 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) SetEventSwitch(evsw agtypes.EventSwitch) + type Peer interface + Get func(string) interface{} + IsRunning func() bool + SendBytes func(byte, []byte) bool + type PeerState interface + GetHeight func() def.INT
Go to main page